tk/FreeSql
1
0
Fork 0
mirror of https://github.com/nsnail/FreeSql.git synced 2025-04-22 18:52:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of https://github.com/2881099/FreeSql

Browse Source
This commit is contained in:
2881099 2023-06-28 17:47:13 +08:00
commit bd71dfd80b
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs
View File

@ -169,9 +169,9 @@ public static partial class QuestDbGlobalExtensions
{
var client = QuestDbContainer.GetService<IHttpClientFactory>().CreateClient();
var boundary = "---------------" + DateTime.Now.Ticks.ToString("x");
var name = typeof(T).Name;
var list = new List<Hashtable>();
var insert = that as QuestDbInsert<T>;
var name = insert.InternalTable.DbName; //获取表名
insert.InternalOrm.DbFirst.GetTableByName(name).Columns.ForEach(d =>
{
if (d.DbTypeText == "TIMESTAMP")
@ -213,7 +213,7 @@ public static partial class QuestDbGlobalExtensions
await client.PostAsync($"{RestAPIExtension.BaseUrl}/imp?name={name}", httpContent);
var readAsStringAsync = await httpResponseMessage.Content.ReadAsStringAsync();
var splitByLine = SplitByLine(readAsStringAsync);
Console.WriteLine(readAsStringAsync);
//Console.WriteLine(readAsStringAsync);
foreach (var s in splitByLine)
{
if (s.Contains("Rows"))
@ -250,7 +250,7 @@ public static partial class QuestDbGlobalExtensions
/// <returns></returns>
public static int ExecuteBulkCopy<T>(this IInsert<T> insert) where T : class
{
return ExecuteBulkCopyAsync(insert).GetAwaiter().GetResult();
return ExecuteBulkCopyAsync(insert).ConfigureAwait(false).GetAwaiter().GetResult();
}
}