diff --git a/Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs b/Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs index 92483dd93..c31a1c49d 100644 --- a/Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs +++ b/Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs @@ -169,9 +169,9 @@ public static partial class QuestDbGlobalExtensions { var client = QuestDbContainer.GetService().CreateClient(); var boundary = "---------------" + DateTime.Now.Ticks.ToString("x"); - var name = typeof(T).Name; var list = new List(); var insert = that as QuestDbInsert; + 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 /// public static int ExecuteBulkCopy(this IInsert insert) where T : class { - return ExecuteBulkCopyAsync(insert).GetAwaiter().GetResult(); + return ExecuteBulkCopyAsync(insert).ConfigureAwait(false).GetAwaiter().GetResult(); } }