lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-08-20 00:44:19 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update达梦

Browse Source
This commit is contained in:
sunkaixuan 2025-08-02 13:25:35 +08:00
parent 967eaa2b08
commit 2ed4cea4aa
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
Src/Asp.NetCore2/SqlSugar/Realization/Dm/DbMaintenance/DmDbMaintenance.cs
View File

@ -3,6 +3,7 @@ using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.DirectoryServices.Protocols;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
@ -393,11 +394,19 @@ WHERE table_name = '" + tableName + "'");
object schemaName = string.Empty;
if (dbConnection.TryGetValue("schema", out schemaName) && !string.IsNullOrEmpty(schemaName?.ToString()))
{
var newConn = dbConnection.Remove("schema");
var newddb = new SqlSugarClient(new ConnectionConfig()
{
ConnectionString =
dbConnection.ToString(),
DbType=DbType.Dm,
IsAutoCloseConnection=true
});
// 检查 Schema 是否存在，不存在则创建
var schemaExists = db.Ado.GetInt($"SELECT COUNT(*) FROM SYSOBJECTS WHERE TYPE$ = 'SCH' AND Upper(NAME) = '{schemaName?.ToString()?.ToUpper()}'") > 0;
var schemaExists = newddb.Ado.GetInt($"SELECT COUNT(*) FROM SYSOBJECTS WHERE TYPE$ = 'SCH' AND Upper(NAME) = '{schemaName?.ToString()?.ToUpper()}'") > 0;
if (!schemaExists)
{
db.Ado.ExecuteCommand($"CREATE SCHEMA {schemaName}");
newddb.Ado.ExecuteCommand($"CREATE SCHEMA {schemaName}");
}
}
}