lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2026-02-27 16:50:33 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Optimize the code

Browse Source
This commit is contained in:
sunkaixuan
2022-10-06 13:21:03 +08:00
parent a7ba34b66d
commit 162bb4c832
1 changed files with 55 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files

103
Src/Asp.NetCore2/SqlSugar/Realization/Oracle/SqlBuilder/OracleInsertBuilder.cs
View File

@@ -49,57 +49,64 @@ namespace SqlSugar
} }
else else
{ {
StringBuilder batchInsetrSql = new StringBuilder(); string result = Small(identities, groupList, columnsString);
batchInsetrSql.AppendLine("INSERT ALL");
foreach (var item in groupList)
{
batchInsetrSql.Append("INTO " + GetTableNameString + " ");
string insertColumns = "";
batchInsetrSql.Append("(");
batchInsetrSql.Append(columnsString);
if (identities.HasValue())
{
batchInsetrSql.Append("," + string.Join(",", identities.Select(it => Builder.GetTranslationColumnName(it.DbColumnName))));
}
batchInsetrSql.Append(") VALUES");
batchInsetrSql.Append("(");
insertColumns = string.Join(",", item.Select(it =>FormatValue(it.Value,it.PropertyName)));
batchInsetrSql.Append(insertColumns);
if (identities.HasValue())
{
batchInsetrSql.Append(",");
foreach (var idn in identities)
{
var seqvalue = this.OracleSeqInfoList[idn.OracleSequenceName];
this.OracleSeqInfoList[idn.OracleSequenceName] = this.OracleSeqInfoList[idn.OracleSequenceName] + 1;
if (identities.Last() == idn)
{
batchInsetrSql.Append(seqvalue );
}
else
{
batchInsetrSql.Append(seqvalue + ",");
}
}
}
batchInsetrSql.AppendLine(") ");
}
if (identities.HasValue())
{
batchInsetrSql.AppendLine("SELECT "+ (this.OracleSeqInfoList.First().Value-1) + " FROM DUAL");
}
else
{
batchInsetrSql.AppendLine("SELECT 1 FROM DUAL");
}
var result= batchInsetrSql.ToString();
return result; return result;
} }
} }
private string Small(List<EntityColumnInfo> identities, List<IGrouping<int, DbColumnInfo>> groupList, string columnsString)
{
StringBuilder batchInsetrSql = new StringBuilder();
batchInsetrSql.AppendLine("INSERT ALL");
foreach (var item in groupList)
{
batchInsetrSql.Append("INTO " + GetTableNameString + " ");
string insertColumns = "";
batchInsetrSql.Append("(");
batchInsetrSql.Append(columnsString);
if (identities.HasValue())
{
batchInsetrSql.Append("," + string.Join(",", identities.Select(it => Builder.GetTranslationColumnName(it.DbColumnName))));
}
batchInsetrSql.Append(") VALUES");
batchInsetrSql.Append("(");
insertColumns = string.Join(",", item.Select(it => FormatValue(it.Value, it.PropertyName)));
batchInsetrSql.Append(insertColumns);
if (identities.HasValue())
{
batchInsetrSql.Append(",");
foreach (var idn in identities)
{
var seqvalue = this.OracleSeqInfoList[idn.OracleSequenceName];
this.OracleSeqInfoList[idn.OracleSequenceName] = this.OracleSeqInfoList[idn.OracleSequenceName] + 1;
if (identities.Last() == idn)
{
batchInsetrSql.Append(seqvalue);
}
else
{
batchInsetrSql.Append(seqvalue + ",");
}
}
}
batchInsetrSql.AppendLine(") ");
}
if (identities.HasValue())
{
batchInsetrSql.AppendLine("SELECT " + (this.OracleSeqInfoList.First().Value - 1) + " FROM DUAL");
}
else
{
batchInsetrSql.AppendLine("SELECT 1 FROM DUAL");
}
var result = batchInsetrSql.ToString();
return result;
}
int i = 0; int i = 0;
public object FormatValue(object value,string name) public object FormatValue(object value,string name)
{ {