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

- 增加 IInsertOrUpdate 高性能方法 ExecuteMySqlBulkCopy；

Browse Source
This commit is contained in:
2881099
2023-03-25 15:45:24 +08:00
parent dc659417a4
commit be043e322f
5 changed files with 89 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
Providers/FreeSql.Provider.PostgreSQL/PostgreSQLExtensions.cs
View File

@ -71,8 +71,14 @@ public static partial class FreeSqlPostgreSQLGlobalExtensions
sb.Clear();
try
{
upsert._sourceSql = $"select * from {tempTableName}";
upsert._sourceSql = $"select __**__ from {tempTableName}";
var sql2 = upsert.ToSql();
if (string.IsNullOrWhiteSpace(sql2) == false)
{
var field = sql2.Substring(sql2.IndexOf("\"(") + 2);
field = field.Remove(field.IndexOf(upsert._sourceSql)).TrimEnd().TrimEnd(')');
sql2 = sql2.Replace(upsert._sourceSql, $"select {field} from {tempTableName}");
}
var sql3 = $"DROP TABLE {_commonUtils.QuoteSqlName(tempTableName)}";
return NativeTuple.Create(sql1, sql2, sql3, tempTableName, _table.Columns.Values.Select(a => a.Attribute.Name).ToArray());
}