Skip to content
Permalink
Browse files

修正拼写错误的内部方法名

  • Loading branch information
28810 28810
28810 authored and 28810 committed Jan 5, 2020
1 parent d67e964 commit 54ceb537d9dd80d10fa8c4b4b94c594da7d229ec
@@ -6,9 +6,9 @@
</PropertyGroup>

<ItemGroup>
<PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="2.1.3" />
<PackageReference Include="Pomelo.EntityFrameworkCore.MySql" Version="2.1.0" />
<PackageReference Include="sqlSugarCore" Version="4.9.9.3" />
<PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="3.1.0" />
<PackageReference Include="Pomelo.EntityFrameworkCore.MySql" Version="3.1.0" />
<PackageReference Include="sqlSugarCore" Version="5.0.0.11" />
</ItemGroup>

<ItemGroup>
@@ -17,7 +17,7 @@ async public virtual Task<int> SaveChangesAsync()
return SaveChangesSuccess();
}

static Dictionary<Type, Dictionary<string, Func<object, object[], Task<int>>>> _dicExecCommandDbContextBetchAsync = new Dictionary<Type, Dictionary<string, Func<object, object[], Task<int>>>>();
static Dictionary<Type, Dictionary<string, Func<object, object[], Task<int>>>> _dicExecCommandDbContextBatchAsync = new Dictionary<Type, Dictionary<string, Func<object, object[], Task<int>>>>();
async internal Task ExecCommandAsync()
{
if (isExecCommanding) return;
@@ -27,9 +27,9 @@ async internal Task ExecCommandAsync()
ExecCommandInfo oldinfo = null;
var states = new List<object>();

Func<string, Task<int>> dbContextBetch = methodName =>
Func<string, Task<int>> dbContextBatch = methodName =>
{
if (_dicExecCommandDbContextBetchAsync.TryGetValue(oldinfo.stateType, out var trydic) == false)
if (_dicExecCommandDbContextBatchAsync.TryGetValue(oldinfo.stateType, out var trydic) == false)
trydic = new Dictionary<string, Func<object, object[], Task<int>>>();
if (trydic.TryGetValue(methodName, out var tryfunc) == false)
{
@@ -53,19 +53,19 @@ async internal Task ExecCommandAsync()
};
Func<Task> funcDelete = async () =>
{
_affrows += await dbContextBetch("DbContextBetchRemoveAsync");
_affrows += await dbContextBatch("DbContextBatchRemoveAsync");
states.Clear();
};
Func<Task> funcInsert = async () =>
{
_affrows += await dbContextBetch("DbContextBetchAddAsync");
_affrows += await dbContextBatch("DbContextBatchAddAsync");
states.Clear();
};
Func<bool, Task> funcUpdate = async (isLiveUpdate) =>
{
var affrows = 0;
if (isLiveUpdate) affrows = await dbContextBetch("DbContextBetchUpdateNowAsync");
else affrows = await dbContextBetch("DbContextBetchUpdateAsync");
if (isLiveUpdate) affrows = await dbContextBatch("DbContextBatchUpdateNowAsync");
else affrows = await dbContextBatch("DbContextBatchUpdateAsync");
if (affrows == -999)
{ //最后一个元素已被删除
states.RemoveAt(states.Count - 1);
@@ -30,7 +30,7 @@ public virtual int SaveChanges()
return SaveChangesSuccess();
}

static Dictionary<Type, Dictionary<string, Func<object, object[], int>>> _dicExecCommandDbContextBetch = new Dictionary<Type, Dictionary<string, Func<object, object[], int>>>();
static Dictionary<Type, Dictionary<string, Func<object, object[], int>>> _dicExecCommandDbContextBatch = new Dictionary<Type, Dictionary<string, Func<object, object[], int>>>();
bool isExecCommanding = false;
internal void ExecCommand()
{
@@ -41,9 +41,9 @@ internal void ExecCommand()
ExecCommandInfo oldinfo = null;
var states = new List<object>();

Func<string, int> dbContextBetch = methodName =>
Func<string, int> dbContextBatch = methodName =>
{
if (_dicExecCommandDbContextBetch.TryGetValue(oldinfo.stateType, out var trydic) == false)
if (_dicExecCommandDbContextBatch.TryGetValue(oldinfo.stateType, out var trydic) == false)
trydic = new Dictionary<string, Func<object, object[], int>>();
if (trydic.TryGetValue(methodName, out var tryfunc) == false)
{
@@ -67,19 +67,19 @@ internal void ExecCommand()
};
Action funcDelete = () =>
{
_affrows += dbContextBetch("DbContextBetchRemove");
_affrows += dbContextBatch("DbContextBatchRemove");
states.Clear();
};
Action funcInsert = () =>
{
_affrows += dbContextBetch("DbContextBetchAdd");
_affrows += dbContextBatch("DbContextBatchAdd");
states.Clear();
};
Action<bool> funcUpdate = isLiveUpdate =>
{
var affrows = 0;
if (isLiveUpdate) affrows = dbContextBetch("DbContextBetchUpdateNow");
else affrows = dbContextBetch("DbContextBetchUpdate");
if (isLiveUpdate) affrows = dbContextBatch("DbContextBatchUpdateNow");
else affrows = dbContextBatch("DbContextBatchUpdate");
if (affrows == -999)
{ //最后一个元素已被删除
states.RemoveAt(states.Count - 1);
@@ -20,7 +20,7 @@ Task DbContextExecCommandAsync()
return _db.ExecCommandAsync();
}

async Task<int> DbContextBetchAddAsync(EntityState[] adds)
async Task<int> DbContextBatchAddAsync(EntityState[] adds)
{
if (adds.Any() == false) return 0;
var affrows = await this.OrmInsert(adds.Select(a => a.Value)).ExecuteAffrowsAsync();
@@ -303,9 +303,9 @@ async Task AddOrUpdateNavigateListAsync(TEntity item, bool isAdd, string propert
#endregion

#region UpdateAsync
Task<int> DbContextBetchUpdateAsync(EntityState[] ups) => DbContextBetchUpdatePrivAsync(ups, false);
Task<int> DbContextBetchUpdateNowAsync(EntityState[] ups) => DbContextBetchUpdatePrivAsync(ups, true);
async Task<int> DbContextBetchUpdatePrivAsync(EntityState[] ups, bool isLiveUpdate)
Task<int> DbContextBatchUpdateAsync(EntityState[] ups) => DbContextBatchUpdatePrivAsync(ups, false);
Task<int> DbContextBatchUpdateNowAsync(EntityState[] ups) => DbContextBatchUpdatePrivAsync(ups, true);
async Task<int> DbContextBatchUpdatePrivAsync(EntityState[] ups, bool isLiveUpdate)
{
if (ups.Any() == false) return 0;
var uplst1 = ups[ups.Length - 1];
@@ -392,7 +392,7 @@ async Task UpdateRangePrivAsync(IEnumerable<TEntity> data, bool isCheck)
#endregion

#region RemoveAsync
async Task<int> DbContextBetchRemoveAsync(EntityState[] dels)
async Task<int> DbContextBatchRemoveAsync(EntityState[] dels)
{
if (dels.Any() == false) return 0;
var affrows = await this.OrmDelete(dels.Select(a => a.Value)).ExecuteAffrowsAsync();
@@ -19,7 +19,7 @@ void DbContextExecCommand()
_db.ExecCommand();
}

int DbContextBetchAdd(EntityState[] adds)
int DbContextBatchAdd(EntityState[] adds)
{
if (adds.Any() == false) return 0;
var affrows = this.OrmInsert(adds.Select(a => a.Value)).ExecuteAffrows();
@@ -338,9 +338,9 @@ object GetItemValue(TEntity item, PropertyInfo prop)
#endregion

#region Update
int DbContextBetchUpdate(EntityState[] ups) => DbContextBetchUpdatePriv(ups, false);
int DbContextBetchUpdateNow(EntityState[] ups) => DbContextBetchUpdatePriv(ups, true);
int DbContextBetchUpdatePriv(EntityState[] ups, bool isLiveUpdate)
int DbContextBatchUpdate(EntityState[] ups) => DbContextBatchUpdatePriv(ups, false);
int DbContextBatchUpdateNow(EntityState[] ups) => DbContextBatchUpdatePriv(ups, true);
int DbContextBatchUpdatePriv(EntityState[] ups, bool isLiveUpdate)
{
if (ups.Any() == false) return 0;
var uplst1 = ups[ups.Length - 1];
@@ -433,7 +433,7 @@ void UpdateRangePriv(IEnumerable<TEntity> data, bool isCheck)
#endregion

#region Remove
int DbContextBetchRemove(EntityState[] dels)
int DbContextBatchRemove(EntityState[] dels)
{
if (dels.Any() == false) return 0;
var affrows = this.OrmDelete(dels.Select(a => a.Value)).ExecuteAffrows();

Some generated files are not rendered by default. Learn more.

@@ -103,19 +103,19 @@ public void ExecuteAffrows()
//items = Enumerable.Range(0, 9989).Select(a => new Topic { Title = "newtitle" + a, CreateTime = DateTime.Now }).ToList();
//Assert.Equal(9989, g.sqlserver.Insert<Topic>(items).ExecuteAffrows());

//var bttype = new TestBetchInsertType { title = "testbttitle1" };
//var bttype = new TestBatchInsertType { title = "testbttitle1" };
//bttype.id = (int)g.sqlserver.Insert(bttype).ExecuteIdentity();
//Assert.True(bttype.id > 0);
//var bttopic = Enumerable.Range(0, 10000).Select(a => new TestBetchInsertTopic { TypeId = bttype.id, Text = $"testtopic{a}" }).ToArray();
//Assert.Equal(bttopic.Length, g.sqlserver.Insert<TestBetchInsertTopic>(bttopic).ExecuteAffrows());
//var bttopic = Enumerable.Range(0, 10000).Select(a => new TestBatchInsertTopic { TypeId = bttype.id, Text = $"testtopic{a}" }).ToArray();
//Assert.Equal(bttopic.Length, g.sqlserver.Insert<TestBatchInsertTopic>(bttopic).ExecuteAffrows());

//g.sqlserver.Transaction(() =>
//{
// bttype = new TestBetchInsertType { title = "transaction_testbttitle2" };
// bttype = new TestBatchInsertType { title = "transaction_testbttitle2" };
// bttype.id = (int)g.sqlserver.Insert(bttype).ExecuteIdentity();
// Assert.True(bttype.id > 0);
// bttopic = Enumerable.Range(0, 10000).Select(a => new TestBetchInsertTopic { TypeId = bttype.id, Text = $"transaction_testtopic{a}" }).ToArray();
// Assert.Equal(bttopic.Length, g.sqlserver.Insert<TestBetchInsertTopic>(bttopic).ExecuteAffrows());
// bttopic = Enumerable.Range(0, 10000).Select(a => new TestBatchInsertTopic { TypeId = bttype.id, Text = $"transaction_testtopic{a}" }).ToArray();
// Assert.Equal(bttopic.Length, g.sqlserver.Insert<TestBatchInsertTopic>(bttopic).ExecuteAffrows());
//});

g.sqlserver.Transaction(() =>
@@ -127,12 +127,12 @@ public void ExecuteAffrows()
Assert.Equal(detail.Length, g.sqlserver.Insert<AdjustPriceDetail>(detail).NoneParameter().ExecuteAffrows());
});
}
class TestBetchInsertType {
class TestBatchInsertType {
[Column(IsIdentity = true)]
public int id { get; set; }
public string title { get; set; }
}
class TestBetchInsertTopic
class TestBatchInsertTopic
{
public Guid id { get; set; }
public int TypeId { get; set; }

0 comments on commit 54ceb53

Please sign in to comment.
You can’t perform that action at this time.