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

!100 修改海量数据库mysql BulkCopyAsync兼容性问题

Browse Source 
Merge pull request !100 from 陈剑辉/master
This commit is contained in:
阿妮亚
2025-10-28 09:38:48 +00:00
committed by Gitee
parent a0e52cf1e5 fa7b38119d
commit b981f88fa0
1 changed files with 15 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Src/Asp.NetCore2/SqlSugar/Realization/PostgreSQL/SqlBuilder/PostgreSQLFastBuilder.cs
View File

@@ -39,7 +39,9 @@ namespace SqlSugar
lsColNames.Add($"\"{dt.Columns[i].ColumnName}\""); lsColNames.Add($"\"{dt.Columns[i].ColumnName}\"");
} }
string copyString = $"COPY {dt.TableName} ( {string.Join(",", lsColNames)} ) FROM STDIN (FORMAT BINARY)"; string copyString = $"COPY {dt.TableName} ( {string.Join(",", lsColNames)} ) FROM STDIN (FORMAT BINARY)";
if (this.Context?.CurrentConnectionConfig?.MoreSettings?.DatabaseModel == DbType.OpenGauss) var innertemp = this.Context.CurrentConnectionConfig?.MoreSettings?.InnerTemp as DbType?;
if (this.Context?.CurrentConnectionConfig?.MoreSettings?.DatabaseModel == DbType.OpenGauss ||
(this.Context?.CurrentConnectionConfig?.MoreSettings?.DatabaseModel == DbType.Vastbase && innertemp == DbType.MySql))
{ {
copyString = copyString.Replace("(FORMAT BINARY)", "(FORMAT 'BINARY')"); copyString = copyString.Replace("(FORMAT BINARY)", "(FORMAT 'BINARY')");
} }