Update MySqlConnector

This commit is contained in:
sunkaixuna
2022-02-01 13:59:32 +08:00
parent 5c6c5b93aa
commit 92746e9950
3 changed files with 10 additions and 2 deletions

View File

@@ -23,6 +23,8 @@ namespace SqlSugar
return new OracleFastBuilder(this.entityInfo);
case DbType.PostgreSQL:
return new PostgreSQLFastBuilder(this.entityInfo);
case DbType.MySqlConnector:
return InstanceFactory.CreateInstance<IFastBuilder>("SqlSugar.MySqlConnector.MySqlFastBuilder");
case DbType.Dm:
break;
case DbType.Kdbndp:
@@ -56,7 +58,7 @@ namespace SqlSugar
}
dt.TableName = GetTableName();
var columns = entityInfo.Columns;
var isMySql = this.context.CurrentConnectionConfig.DbType == DbType.MySql;
var isMySql = this.context.CurrentConnectionConfig.DbType.IsIn(DbType.MySql, DbType.MySqlConnector);
foreach (var item in datas)
{
var dr = dt.NewRow();

View File

@@ -429,7 +429,9 @@ namespace SqlSugar
private bool UpdateObjectNotWhere()
{
return this.Context.CurrentConnectionConfig.DbType != DbType.MySql && this.Context.CurrentConnectionConfig.DbType != DbType.SqlServer;
return this.Context.CurrentConnectionConfig.DbType != DbType.MySql
&& this.Context.CurrentConnectionConfig.DbType!=DbType.MySqlConnector
&& this.Context.CurrentConnectionConfig.DbType != DbType.SqlServer;
}
private void AppendSets()

View File

@@ -635,6 +635,10 @@ namespace SqlSugar
type = DbType.Oracle;
else if (this.Context is PostgreSQLExpressionContext)
type = DbType.PostgreSQL;
else if (this.Context.GetType().Name.StartsWith("MySql"))
{
type = DbType.MySql;
}
return this.Context.SqlFuncServices.First(it => it.UniqueMethodName == name).MethodValue(model, type, this.Context);
}
else