惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

B
Blog
D
Docker
J
Java Code Geeks
腾讯CDC
Blog — PlanetScale
Blog — PlanetScale
G
Google Developers Blog
M
MIT News - Artificial intelligence
L
LangChain Blog
T
The Blog of Author Tim Ferriss
P
Proofpoint News Feed
MyScale Blog
MyScale Blog
博客园 - Franky
GbyAI
GbyAI
Hugging Face - Blog
Hugging Face - Blog
aimingoo的专栏
aimingoo的专栏
Last Week in AI
Last Week in AI
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻
博客园 - 聂微东
N
Netflix TechBlog - Medium
B
Blog RSS Feed
Y
Y Combinator Blog
阮一峰的网络日志
阮一峰的网络日志
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
Google DeepMind News
Google DeepMind News

博客园 - Hey,Coder!

微信小程序 web方案实现调音器功能 systemctl slice配置docker最大占用cpu 内存 pipenv环境变量配置 .net8验证码 数据库差异对比工具 docker部署prometheus grafana pgexporter Alertmanager ubuntu24 换源 ssh配置 ubuntu24 Harbor部署 ubuntu24 kvm部署 cockpit web管理界面 .net api代理 Ubuntu 24.04 DMAR IOMMU 报错修复 uniapp iOS App 上架 vs文件软链接 Docker 网络别名 .net8通用中间件处理公共返回值结构 .net环境下OpenTelemetry Body 读取注意事项 jaeger界面显示异常 .net opentelemetry collector jaeger c# opentelemetry 自定义export c# opentelemetry 自定义export c# 生成对象的初始化代码 Elasticsearch ILM 与 Data Stream 概念及实例说明文档 portainer httphelper封装 Ocelot + Consul + SignalR 粘性会话 正交软件架构 docker postgresql17 主从复制 rabbitmq总结与c#示例 docker rabbitmq quartz dashboard
c# 动态切换sqlsugar连接字符串
Hey,Coder! · 2026-03-06 · via 博客园 - Hey,Coder!
 public class BLLDBService
 {
     private static ConcurrentDictionary<string, ISqlSugarClient> DBList = new();

     private readonly ISqlSugarClient sqlSugar;

     private readonly IServiceProvider serviceProvider;
     public BLLDBService(ISqlSugarClient sqlSugar, IServiceProvider serviceProvider)
     {
         this.sqlSugar = sqlSugar;
         this.serviceProvider = serviceProvider;
     }



     private ISqlSugarClient GetDBClient(string dbNo)
     {

         if (!DBList.ContainsKey(dbNo))
         {
             throw new Exception("DBCannotCreate");
         }

            return DBList[dbNo];
     }

     public static void InjectDB(string dbNo, SqlSugar.DbType dbType, string connectionStr)
     {
         DBList.AddOrUpdate(dbNo, f =>
               new SqlSugarScope(new ConnectionConfig()
            {
                DbType = dbType,
                ConnectionString = connectionStr,
                IsAutoCloseConnection = true,
                AopEvents = new AopEvents
                {
                    OnLogExecuting = (log, para) =>
                    {
                        //Console.WriteLine(log);
                    }
                }
            })
         , (f, client) =>
               new SqlSugarScope(new ConnectionConfig()
            {
                DbType = dbType,
                ConnectionString = connectionStr,
                IsAutoCloseConnection = true,
                AopEvents = new AopEvents
                {
                    OnLogExecuting = (log, para) =>
                    {
                        //Console.WriteLine(log);
                    }
                }
            })
        );
     }

     public static void DetectAndInjectDB(string dbNo, SqlSugar.DbType dbType, string connectionStr)
     {
         if (!DBList.ContainsKey(dbNo))
         {
             InjectDB( dbNo, dbType,  connectionStr);
             return;
         }

         var oldData = DBList[dbNo];

         if (oldData?.CurrentConnectionConfig == null)
         {
             InjectDB(dbNo, dbType, connectionStr);
             return;
         }

         if (oldData.CurrentConnectionConfig.ConnectionString != connectionStr||
             oldData.CurrentConnectionConfig.DbType != dbType)
         {
             InjectDB(dbNo, dbType, connectionStr);
             return;
         }
     }
 }