This commit is contained in:
sunkaixuna 2021-08-07 03:14:08 +08:00
parent c5c45ee2f9
commit 5b96f433ca
4 changed files with 19 additions and 19 deletions

View File

@ -309,16 +309,16 @@ namespace SqlSugar
}; };
return this; return this;
} }
public MySqlBlueCopy<T> UseMySql() public MySqlBlukCopy<T> UseMySql()
{ {
return new MySqlBlueCopy<T>(this.Context, this.SqlBuilder, InsertObjs); return new MySqlBlukCopy<T>(this.Context, this.SqlBuilder, InsertObjs);
} }
public SqlServerBlueCopy UseSqlServer() public SqlServerBlukCopy UseSqlServer()
{ {
PreToSql(); PreToSql();
var currentType = this.Context.CurrentConnectionConfig.DbType; var currentType = this.Context.CurrentConnectionConfig.DbType;
Check.Exception(currentType != DbType.SqlServer, "UseSqlServer no support " + currentType); Check.Exception(currentType != DbType.SqlServer, "UseSqlServer no support " + currentType);
SqlServerBlueCopy result = new SqlServerBlueCopy(); SqlServerBlukCopy result = new SqlServerBlukCopy();
result.DbColumnInfoList =this.InsertBuilder.DbColumnInfoList.GroupBy(it => it.TableId).ToList(); result.DbColumnInfoList =this.InsertBuilder.DbColumnInfoList.GroupBy(it => it.TableId).ToList();
result.InsertBuilder = this.InsertBuilder; result.InsertBuilder = this.InsertBuilder;
result.Builder = this.SqlBuilder; result.Builder = this.SqlBuilder;

View File

@ -42,8 +42,8 @@ namespace SqlSugar
IInsertable<T> RemoveDataCache(); IInsertable<T> RemoveDataCache();
IInsertable<T> RemoveDataCache(string likeString); IInsertable<T> RemoveDataCache(string likeString);
KeyValuePair<string, List<SugarParameter>> ToSql(); KeyValuePair<string, List<SugarParameter>> ToSql();
SqlServerBlueCopy UseSqlServer(); SqlServerBlukCopy UseSqlServer();
MySqlBlueCopy<T> UseMySql(); MySqlBlukCopy<T> UseMySql();
void AddQueue(); void AddQueue();
} }

View File

@ -9,29 +9,29 @@ using System.Text;
using System.Threading.Tasks; using System.Threading.Tasks;
namespace SqlSugar namespace SqlSugar
{ {
public class MySqlBlueCopy<T> public class MySqlBlukCopy<T>
{ {
internal SqlSugarProvider Context { get; set; } internal SqlSugarProvider Context { get; set; }
internal ISqlBuilder Builder { get; set; } internal ISqlBuilder Builder { get; set; }
internal T[] Entitys { get; set; } internal T[] Entitys { get; set; }
internal string Chara { get; set; } internal string Chara { get; set; }
private MySqlBlueCopy() private MySqlBlukCopy()
{ {
} }
public MySqlBlueCopy(SqlSugarProvider context, ISqlBuilder builder, T []entitys) public MySqlBlukCopy(SqlSugarProvider context, ISqlBuilder builder, T []entitys)
{ {
this.Context = context; this.Context = context;
this.Builder = builder; this.Builder = builder;
this.Entitys = entitys; this.Entitys = entitys;
} }
public bool ExecuteBlueCopy(string characterSet) public bool ExecuteBlukCopy(string characterSet)
{ {
this.Chara = characterSet; this.Chara = characterSet;
return ExecuteBlueCopy(); return ExecuteBlukCopy();
} }
public bool ExecuteBlueCopy() public bool ExecuteBlukCopy()
{ {
var IsBulkLoad = false; var IsBulkLoad = false;
if (Entitys == null || Entitys.Length <= 0) if (Entitys == null || Entitys.Length <= 0)
@ -111,15 +111,15 @@ namespace SqlSugar
return IsBulkLoad; ; return IsBulkLoad; ;
} }
public Task<bool> ExecuteBlueCopyAsync() public Task<bool> ExecuteBlukCopyAsync()
{ {
return Task.FromResult(ExecuteBlueCopy()); return Task.FromResult(ExecuteBlukCopy());
} }
public Task<bool> ExecuteBlueCopyAsync(string characterSet) public Task<bool> ExecuteBlukCopyAsync(string characterSet)
{ {
this.Chara = characterSet; this.Chara = characterSet;
return Task.FromResult(ExecuteBlueCopy()); return Task.FromResult(ExecuteBlukCopy());
} }
#region Helper #region Helper

View File

@ -8,7 +8,7 @@ using System.Threading.Tasks;
namespace SqlSugar namespace SqlSugar
{ {
public class SqlServerBlueCopy public class SqlServerBlukCopy
{ {
internal List<IGrouping<int, DbColumnInfo>> DbColumnInfoList { get; set; } internal List<IGrouping<int, DbColumnInfo>> DbColumnInfoList { get; set; }
internal SqlSugarProvider Context { get; set; } internal SqlSugarProvider Context { get; set; }
@ -16,7 +16,7 @@ namespace SqlSugar
internal InsertBuilder InsertBuilder { get; set; } internal InsertBuilder InsertBuilder { get; set; }
internal object[] Inserts { get; set; } internal object[] Inserts { get; set; }
public int ExecuteBlueCopy() public int ExecuteBlukCopy()
{ {
if (DbColumnInfoList == null || DbColumnInfoList.Count == 0) return 0; if (DbColumnInfoList == null || DbColumnInfoList.Count == 0) return 0;
@ -40,7 +40,7 @@ namespace SqlSugar
return DbColumnInfoList.Count; return DbColumnInfoList.Count;
} }
public async Task<int> ExecuteBlueCopyAsync() public async Task<int> ExecuteBlukCopyAsync()
{ {
if (DbColumnInfoList == null || DbColumnInfoList.Count == 0) return 0; if (DbColumnInfoList == null || DbColumnInfoList.Count == 0) return 0;