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

Oracle support BulkCopyUpdate

Browse Source
This commit is contained in:
sunkaixuna
2021-11-25 20:14:37 +08:00
parent 50af500457
commit 1045212056
1 changed files with 13 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Oracle/SqlBuilder/OracleFastBuilder.cs
View File

@@ -17,23 +17,27 @@ namespace SqlSugar
this.entityInfo = entityInfo; this.entityInfo = entityInfo;
} }
public override string UpdateSql { get; set; } = "UPDATE (SELECT A.NAME ANAME,B.NAME BNAME FROM A,B WHERE A.ID=B.ID)SET ANAME = BNAME;"; public override string UpdateSql { get; set; } = "UPDATE (SELECT {4} FROM {2} TM,{3} TE WHERE {1})SET {0}";
public override async Task CreateTempAsync<T>(DataTable dt) public override async Task CreateTempAsync<T>(DataTable dt)
{ {
await Task.FromResult(0); //await Task.FromResult(0);
throw new Exception("Oracle no support BulkUpdate"); //throw new Exception("Oracle no support BulkUpdate");
//dt.TableName = "T" + SnowFlakeSingle.instance.getID().ToString().Substring(4,16); var columns = this.Context.EntityMaintenance.GetEntityInfo<T>().Columns.Where(it => it.IsPrimarykey).Select(it => it.DbColumnName).ToArray();
//var sql = this.Context.Queryable<T>().Where(it => false).Select("*").ToSql().Key; dt.TableName = "T" + SnowFlakeSingle.instance.getID().ToString().Substring(4, 10);
//await this.Context.Ado.ExecuteCommandAsync($"create global temporary table {dt.TableName} as {sql} "); var sql = this.Context.Queryable<T>().Where(it => false).Select("*").ToSql().Key;
await this.Context.Ado.ExecuteCommandAsync($"create global temporary table {dt.TableName} as {sql} ");
this.Context.DbMaintenance.AddPrimaryKeys(dt.TableName, columns);
//var xxx = this.Context.Queryable<T>().AS(dt.TableName).ToList(); //var xxx = this.Context.Queryable<T>().AS(dt.TableName).ToList();
} }
public override async Task<int> UpdateByTempAsync(string tableName, string tempName, string[] updateColumns, string[] whereColumns) public override async Task<int> UpdateByTempAsync(string tableName, string tempName, string[] updateColumns, string[] whereColumns)
{ {
var sqlBuilder = this.Context.Queryable<object>().SqlBuilder;
Check.ArgumentNullException(!updateColumns.Any(), "update columns count is 0"); Check.ArgumentNullException(!updateColumns.Any(), "update columns count is 0");
Check.ArgumentNullException(!whereColumns.Any(), "where columns count is 0"); Check.ArgumentNullException(!whereColumns.Any(), "where columns count is 0");
var sets = string.Join(",", updateColumns.Select(it => $"TM.{it}=TE.{it}")); var sets = string.Join(",", updateColumns.Select(it => $"TM{it}=TE{it}"));
var wheres = string.Join(",", whereColumns.Select(it => $"TM.{it}=TE.{it}")); var wheres = string.Join(",", whereColumns.Select(it => $"TM.{sqlBuilder.GetTranslationColumnName(it)}=TE.{sqlBuilder.GetTranslationColumnName(it)}"));
string sql = string.Format(UpdateSql, sets, tableName, tempName, wheres); var forms= string.Join(",", updateColumns.Select(it => $" TM.{sqlBuilder.GetTranslationColumnName(it)} TM{it},TE.{sqlBuilder.GetTranslationColumnName(it)} TE{it}")); ;
string sql = string.Format(UpdateSql, sets, wheres,tableName, tempName, forms);
return await this.Context.Ado.ExecuteCommandAsync(sql); return await this.Context.Ado.ExecuteCommandAsync(sql);
} }
private OracleBulkCopy GetBulkCopyInstance() private OracleBulkCopy GetBulkCopyInstance()