public static class SqlDBConnect
{
//public static ConnectionConfig db1Config;
public static ISqlSugarClient GetConnect(string tenantId)
{
if (!SqlSugarManager.Db.IsAnyConnection(tenantId))
{
throw new Exception("该连接不存在");
}
return SqlSugarManager.Db.GetConnection(tenantId);
}
}
public static class SqlSugarManager
{
private static readonly Lazy<SqlSugarScope> _dbLazy = new Lazy<SqlSugarScope>(InitializeDb);
public static SqlSugarScope Db => _dbLazy.Value;
private static SqlSugarScope InitializeDb()
{
List<ConnectionConfig> configList = new List<ConnectionConfig>
{
new ConnectionConfig
{
DbType = DbType.MySql,
ConnectionString =
"server=;uid=;pwd=;database=;allowuservariables=true",
IsAutoCloseConnection = true,
ConfigId = "test_mysql_aliyun", // 默认库标识
},
};
//var config =
return new SqlSugarScope(
configList,
db =>
{
// 配置 AOP 日志
db.Aop.OnLogExecuting = (sql, parameters) =>
{
string parametersJson = JsonSerializer.Serialize(parameters);
Console.WriteLine($"SQL: {sql}\nParameters: {parametersJson}");
};
}
);
}
}
个人自存sqlSugar封装类(支持多库)
发布于 24 天前 54 次阅读
Comments NOTHING