From e2280e2c47e154890b7a81c0e2923dab926185c9 Mon Sep 17 00:00:00 2001 From: d4ilys <963922242@qq.com> Date: Wed, 28 Jun 2023 10:56:56 +0800 Subject: [PATCH 1/2] =?UTF-8?q?-=20=E4=BF=AE=E5=A4=8DQuestDb=20BulkCopy?= =?UTF-8?q?=E5=9C=A8=E7=89=B9=E5=AE=9A=E6=83=85=E5=86=B5=E4=B8=8B=E6=97=A0?= =?UTF-8?q?=E6=B3=95=E8=A7=A3=E5=86=B3=E8=A1=A8=E5=90=8D=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs b/Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs index aed7de90..96407eee 100644 --- a/Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs +++ b/Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs @@ -171,7 +171,7 @@ public static partial class QuestDbGlobalExtensions { var client = QuestDbContainer.GetService().CreateClient(); var boundary = "---------------" + DateTime.Now.Ticks.ToString("x"); - var name = typeof(T).Name; + var name = insert.InternalTable.DbName; //获取表名 var list = new List(); var insert = that as QuestDbInsert; insert.InternalOrm.DbFirst.GetTableByName(name).Columns.ForEach(d => From d4bfe9eb5af35ad72fbcf3ddae69d9a3cd2ee40c Mon Sep 17 00:00:00 2001 From: d4ilys <963922242@qq.com> Date: Wed, 28 Jun 2023 11:19:44 +0800 Subject: [PATCH 2/2] =?UTF-8?q?-=20=E4=BF=AE=E5=A4=8DQuestDb=20BulkCopy?= =?UTF-8?q?=E5=9C=A8=E5=AE=9E=E4=BD=93=E7=B1=BB=E6=8C=87=E5=AE=9A=E5=88=AB?= =?UTF-8?q?=E5=90=8D=E6=83=85=E5=86=B5=E4=B8=8B=E6=97=A0=E6=B3=95=E8=A7=A3?= =?UTF-8?q?=E6=9E=90=E8=A1=A8=E5=90=8D=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs b/Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs index 96407eee..1f165879 100644 --- a/Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs +++ b/Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs @@ -171,9 +171,9 @@ public static partial class QuestDbGlobalExtensions { var client = QuestDbContainer.GetService().CreateClient(); var boundary = "---------------" + DateTime.Now.Ticks.ToString("x"); - var name = insert.InternalTable.DbName; //获取表名 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") @@ -215,7 +215,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")) @@ -252,7 +252,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(); } }