Skip to content

Commit df3f8fb

Browse files
committed
- 修复 QuestDB BulkCopy 自定义表名无效的问题;
1 parent c4b42de commit df3f8fb

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

Providers/FreeSql.Provider.QuestDb/Curd/QuestDbInsert.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ public QuestDbInsert(IFreeSql orm, CommonUtils commonUtils, CommonExpression com
3030
internal List<T1> InternalSource => _source;
3131
internal Dictionary<string, bool> InternalIgnore => _ignore;
3232
internal void InternalClearData() => ClearData();
33+
internal string InternalTableRuleInvoke() => TableRuleInvoke();
3334

3435
private int InternelExecuteAffrows()
3536
{

Providers/FreeSql.Provider.QuestDb/QuestDbGlobalExtensions.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,7 @@ public static async Task<int> ExecuteBulkCopyAsync<T>(this IInsert<T> that) wher
171171
var boundary = "---------------" + DateTime.Now.Ticks.ToString("x");
172172
var list = new List<Hashtable>();
173173
var insert = that as QuestDbInsert<T>;
174-
var name = insert.InternalTable.DbName; //获取表名
174+
var name = insert.InternalTableRuleInvoke(); //获取表名
175175
insert.InternalOrm.DbFirst.GetTableByName(name).Columns.ForEach(d =>
176176
{
177177
if (d.DbTypeText == "TIMESTAMP")

0 commit comments

Comments
 (0)