lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-10-15 18:55:07 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Synchronization code

Browse Source
This commit is contained in:
sunkaixuan
2023-04-04 13:11:17 +08:00
parent 0b4be3e2f3
commit b8e798a08a
1 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
Src/Asp.Net/SqlSugar/Realization/MySql/DbMaintenance/MySqlDbMaintenance.cs
View File

@@ -375,7 +375,12 @@ namespace SqlSugar
});
if (!GetDataBaseList(newDb).Any(it => it.Equals(databaseName, StringComparison.CurrentCultureIgnoreCase)))
{
newDb.Ado.ExecuteCommand(string.Format(CreateDataBaseSql, databaseName, databaseDirectory));
var createSql = CreateDataBaseSql;
if (ContainsCharSet("utf8mb4"))
{
createSql = createSql.Replace("utf8 COLLATE utf8_general_ci", "utf8mb4");
}
newDb.Ado.ExecuteCommand(string.Format(createSql, databaseName, databaseDirectory));
}
return true;
}
@@ -405,7 +410,6 @@ namespace SqlSugar
}
sql = sql.Replace("$PrimaryKey", primaryKeyInfo);
this.Context.Ado.ExecuteCommand(sql);
SetCharSet(tableName, "utf8mb4");
return true;
}
public override bool AddRemark(EntityInfo entity)
@@ -593,12 +597,15 @@ namespace SqlSugar
#endregion
#region Helper
private void SetCharSet(string tableName, string charset)
private bool ContainsCharSet(string charset)
{
if (this.Context.CurrentConnectionConfig.ConnectionString.ObjToString().ToLower().Contains(charset))
{
var name = this.SqlBuilder.GetTranslationTableName(tableName);
this.Context.Ado.ExecuteCommand($"ALTER TABLE {name} CONVERT TO CHARACTER SET utf8mb4;");
return true;
}
else
{
return false;
}
}
#endregion