lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-08-23 22:11:36 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update questdb

Browse Source
This commit is contained in:
sunkaixuan 2024-03-21 05:13:39 +08:00
parent ce3d941c28
commit 145753bdb1
1 changed files with 22 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
Src/Asp.NetCore2/SqlSugar.QuestDb.RestApi/QuestDbRestAPI.cs
View File

@ -14,14 +14,14 @@ using System.Web;
using System.Xml.Linq;
namespace SqlSugar
{
{
/// <summary>
/// QuestDb RestAPI
/// </summary>
public class QuestDbRestAPI
{
internal string url = string.Empty;
internal string authorization = string.Empty;
internal string url = string.Empty;
internal string authorization = string.Empty;
internal static Random random = new Random();
ISqlSugarClient db;
public QuestDbRestAPI(ISqlSugarClient db)
@ -41,7 +41,7 @@ namespace SqlSugar
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public async Task<string> ExecuteCommandAsync(string sql)
public async Task<string> ExecuteCommandAsync(string sql)
{
//HTTP GET 执行SQL
var result = string.Empty;
@ -58,10 +58,26 @@ namespace SqlSugar
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public string ExecuteCommand(string sql)
public string ExecuteCommand(string sql)
{
return ExecuteCommandAsync(sql).GetAwaiter().GetResult();
}
public async Task<string> InsertAsync<T>(T insertData) where T:class,new()
{
if (db.CurrentConnectionConfig.MoreSettings == null)
db.CurrentConnectionConfig.MoreSettings = new ConnMoreSettings();
db.CurrentConnectionConfig.MoreSettings.DisableNvarchar = true;
var sql= db.Insertable(insertData).ToSqlString();
return await ExecuteCommandAsync(sql);
}
public string Insert<T>(T insertData) where T : class, new()
{
return InsertAsync(insertData).GetAwaiter().GetResult();
}
/// <summary>
/// 批量快速插入异步
/// </summary>
@ -69,7 +85,7 @@ namespace SqlSugar
/// <param name="that"></param>
/// <param name="dateFormat">导入时，时间格式 默认:yyyy/M/d H:mm:ss</param>
/// <returns></returns>
public async Task<int> BulkCopyAsync<T>(List<T> insertList, string dateFormat = "yyyy/M/d H:mm:ss") where T : class
public async Task<int> BulkCopyAsync<T>(List<T> insertList, string dateFormat = "yyyy/M/d H:mm:ss") where T : class
{
if (string.IsNullOrWhiteSpace(url))