Browse Source

Update Oracle Insertable(list)

pull/12/MERGE
sunkaixuan 4 years ago
parent
commit
cbeb4e247d
  1. 6
      Src/Asp.Net/OracleTest/Config.cs
  2. 55
      Src/Asp.Net/SqlSugar/Realization/Oracle/SqlBuilder/OracleInsertBuilder.cs

6
Src/Asp.Net/OracleTest/Config.cs

@ -8,8 +8,8 @@ namespace OrmTest
{
public class Config
{
public static string ConnectionString = "Data Source=localhost/orcl;User ID=system;Password=jhl856615011;";
public static string ConnectionString2 = "Data Source=localhost/orcl;User ID=system;Password=jhl856615011;";
public static string ConnectionString3= "Data Source=localhost/orcl;User ID=system;Password=jhl856615011;";
public static string ConnectionString = "Data Source=localhost/orcl;User ID=system;Password=jhl52771;";
public static string ConnectionString2 = "Data Source=localhost/orcl;User ID=system;Password=jhl52771;";
public static string ConnectionString3= "Data Source=localhost/orcl;User ID=system;Password=jhl52771;";
}
}

55
Src/Asp.Net/SqlSugar/Realization/Oracle/SqlBuilder/OracleInsertBuilder.cs

@ -49,42 +49,47 @@ namespace SqlSugar
else
{
StringBuilder batchInsetrSql = new StringBuilder();
int pageSize = 200;
int pageIndex = 1;
int totalRecord = groupList.Count;
int pageCount = (totalRecord + pageSize - 1) / pageSize;
batchInsetrSql.AppendLine("INSERT ALL");
foreach (var item in groupList)
{
batchInsetrSql.Append("INTO " + GetTableNameString + " ");
string insertColumns = "";
batchInsetrSql.Append("(");
batchInsetrSql.Append(columnsString);
if (identities.HasValue())
{
columnsString = columnsString.TrimEnd(',') + "," + string.Join(",", identities.Select(it => Builder.GetTranslationColumnName(it.DbColumnName)));
batchInsetrSql.Append("," + string.Join(",", identities.Select(it => Builder.GetTranslationColumnName(it.DbColumnName))));
}
while (pageCount >= pageIndex)
batchInsetrSql.Append(") VALUES");
batchInsetrSql.Append("(");
insertColumns = string.Join(",", item.Select(it =>FormatValue(it.Value)));
batchInsetrSql.Append(insertColumns);
if (identities.HasValue())
{
batchInsetrSql.AppendFormat(SqlTemplateBatch, GetTableNameString, columnsString);
int i = 0;
foreach (var columns in groupList.Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList())
batchInsetrSql.Append(",");
foreach (var idn in identities)
{
var isFirst = i == 0;
if (!isFirst)
var seqvalue = this.OracleSeqInfoList[idn.OracleSequenceName];
this.OracleSeqInfoList[idn.OracleSequenceName] = this.OracleSeqInfoList[idn.OracleSequenceName] + 1;
if (identities.Last() == idn)
{
batchInsetrSql.Append(SqlTemplateBatchUnion);
batchInsetrSql.Append(seqvalue + 1 );
}
var insertColumns = string.Join(",", columns.Select(it => string.Format(SqlTemplateBatchSelect, FormatValue(it.Value), Builder.GetTranslationColumnName(it.DbColumnName))));
if (identities.HasValue())
{
insertColumns = insertColumns.TrimEnd(',') + "," + string.Join(",", identities.Select(it =>
else
{
var seqValue = this.OracleSeqInfoList[it.OracleSequenceName];
this.OracleSeqInfoList[it.OracleSequenceName] = this.OracleSeqInfoList[it.OracleSequenceName] + 1;
return seqValue + 1+" AS "+it.DbColumnName;
}));
batchInsetrSql.Append(seqvalue + 1 + ",");
}
batchInsetrSql.Append("\r\n SELECT " + insertColumns + " FROM DUAL ");
++i;
}
pageIndex++;
batchInsetrSql.Append("\r\n;\r\n");
}
return "BEGIN\r\n"+ batchInsetrSql.ToString()+"\r\nEND;";
batchInsetrSql.AppendLine(") ");
}
batchInsetrSql.AppendLine("SELECT 1 FROM DUAL");
var result= batchInsetrSql.ToString();
return result;
}
}
public override object FormatValue(object value)

Loading…
Cancel
Save