lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-04-05 17:37:58 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update Ob Oracle

Browse Source
This commit is contained in:
sunkaixuan 2024-05-18 15:39:44 +08:00
parent 0b2bdab2da
commit 798f760bae
1 changed files with 16 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
Src/Asp.NetCore2/SqlSugar.OceanBaseForOracle/OceanBase/Insertable/OceanBaseForOracleInsertable.cs
View File

@ -36,9 +36,9 @@ namespace SqlSugar.OceanBaseForOracle
}
else
{
sql = sql + " RETURNING ID INTO :newId01 ";
// sql = sql + " RETURNING ID INTO :newId01 ";
}
InsertBuilder.Parameters.Add(new SugarParameter(":newId01", 0,true));
//InsertBuilder.Parameters.Add(new SugarParameter(":newId01", 0,true));
}
RestoreMapping();
var isDisableMasterSlaveSeparation = this.Context.Ado.IsDisableMasterSlaveSeparation;
@ -50,7 +50,8 @@ namespace SqlSugar.OceanBaseForOracle
AutoEnd(oldIsAuto);
if (isIdEntityEnable())
{
return this.InsertBuilder.Parameters.FirstOrDefault(it => it.ParameterName == ":newId01")?.Value?.ObjToInt()??0;
var name = this.EntityInfo.Columns.First(it => it.IsIdentity).DbColumnName;
return this.Context.Ado.GetInt(" SELECT MAX("+this.InsertBuilder.Builder.GetTranslationColumnName(name) +") FROM "+this.InsertBuilder.GetTableNameString);
}
return result;
}
@ -74,9 +75,9 @@ namespace SqlSugar.OceanBaseForOracle
}
else
{
sql = sql + " RETURNING ID INTO :newId01 ";
//sql = sql + " RETURNING ID INTO :newId01 ";
}
InsertBuilder.Parameters.Add(new SugarParameter(":newId01", Convert.ToInt64(0), true));
//InsertBuilder.Parameters.Add(new SugarParameter(":newId01", Convert.ToInt64(0), true));
}
RestoreMapping();
var isDisableMasterSlaveSeparation = this.Context.Ado.IsDisableMasterSlaveSeparation;
@ -88,7 +89,8 @@ namespace SqlSugar.OceanBaseForOracle
AutoEnd(oldIsAuto);
if (isIdEntityEnable())
{
return this.InsertBuilder.Parameters.FirstOrDefault(it => it.ParameterName == ":newId01")?.Value?.ObjToLong() ?? 0;
var name = this.EntityInfo.Columns.First(it => it.IsIdentity).DbColumnName;
return this.Context.Ado.GetInt(" SELECT MAX(" + this.InsertBuilder.Builder.GetTranslationColumnName(name) + ") FROM " + this.InsertBuilder.GetTableNameString);
}
return result;
}
@ -108,9 +110,9 @@ namespace SqlSugar.OceanBaseForOracle
}
else
{
sql = sql + " RETURNING ID INTO :newId01 ";
//sql = sql + " RETURNING ID INTO :newId01 ";
}
InsertBuilder.Parameters.Add(new SugarParameter(":newId01", 0, true));
//InsertBuilder.Parameters.Add(new SugarParameter(":newId01", 0, true));
}
RestoreMapping();
var isDisableMasterSlaveSeparation = this.Context.Ado.IsDisableMasterSlaveSeparation;
@ -122,7 +124,8 @@ namespace SqlSugar.OceanBaseForOracle
AutoEnd(oldIsAuto);
if (isIdEntityEnable())
{
return this.InsertBuilder.Parameters.FirstOrDefault(it => it.ParameterName == ":newId01")?.Value?.ObjToInt() ?? 0;
var name = this.EntityInfo.Columns.First(it => it.IsIdentity).DbColumnName;
return await this.Context.Ado.GetIntAsync(" SELECT MAX(" + this.InsertBuilder.Builder.GetTranslationColumnName(name) + ") FROM " + this.InsertBuilder.GetTableNameString);
}
return result;
}
@ -142,9 +145,9 @@ namespace SqlSugar.OceanBaseForOracle
}
else
{
sql = sql + " RETURNING ID INTO :newId01 ";
//sql = sql + " RETURNING ID INTO :newId01 ";
}
InsertBuilder.Parameters.Add(new SugarParameter(":newId01", Convert.ToInt64(0), true));
//InsertBuilder.Parameters.Add(new SugarParameter(":newId01", Convert.ToInt64(0), true));
}
RestoreMapping();
var isDisableMasterSlaveSeparation = this.Context.Ado.IsDisableMasterSlaveSeparation;
@ -156,7 +159,8 @@ namespace SqlSugar.OceanBaseForOracle
AutoEnd(oldIsAuto);
if (isIdEntityEnable())
{
return this.InsertBuilder.Parameters.FirstOrDefault(it => it.ParameterName == ":newId01")?.Value?.ObjToLong() ?? 0;
var name = this.EntityInfo.Columns.First(it => it.IsIdentity).DbColumnName;
return this.Context.Ado.GetInt(" SELECT MAX(" + this.InsertBuilder.Builder.GetTranslationColumnName(name) + ") FROM " + this.InsertBuilder.GetTableNameString);
}
return result;
}