.NET 6 跨伺服器聯表查詢, MySql、Oracle、SqlServer等相互聯表

来源:https://www.cnblogs.com/sunkaixuan/archive/2022/10/08/16767798.html
-Advertisement-
Play Games

一、大家是否有這個需求 1.跨品種查詢 ：比如 MYSQL和一個SQLSERVER進行聯表查詢 ，或者SQLITE和MYSQL進行聯表查詢 2.跨伺服器查詢 ： A伺服器和B伺服器查詢 如果想同時支持1和2 相信很多人都沒有比較好的解決方案 我的設計是通過多庫架構來實現多庫操作 二、 多庫架構ORM ...


一、大家是否有這個需求

1.跨品種查詢 ：比如 MYSQL和一個SQLSERVER進行聯表查詢 ，或者SQLITE和MYSQL進行聯表查詢

2.跨伺服器查詢 ： A伺服器和B伺服器查詢

 如果想同時支持1和2 相信很多人都沒有比較好的解決方案

我的設計是通過多庫架構來實現多庫操作

 

二、 多庫架構ORM

什麼是多庫架構ORM，一個對象可以同時操作和管理多個資料庫 我們稱為多庫架構

EF Core

一個對象只能操作一個資料庫，所以EF Core不能稱為多庫架構，只能稱為支持多種資料庫，如果要實現多庫

我們就需外部封裝，代碼如下

 

SqlSugar

SqlSugar在2017最火的時候停更了一年半，最大的原因就是因為底層架構影響了SqlSugar的上限，歷史遺留問題太多

需要大量重構，如果直接更新對現有用戶是不負責的，所以我選擇了一年半未更新，讓不是特別熱愛SqlSugar的用戶

先用其他框架，留下對於SqlSugar一直熱衷的用戶，能支持和一起完善SqlSugar的用戶，謝謝有一群這樣的用戶不離不棄

籌划了一年半的時間終於在2020開始進行重構 每隔一個月就重構一部分 加點功能 ， 直到今天終於重構完成

 

代碼如下：

var db = new SqlSugarClient(new List<ConnectionConfig>()
{
 new ConnectionConfig(){ConfigId="0",DbType=DbType.SqlServer,ConnectionString=..,IsAutoCloseConnection=true},
 new ConnectionConfig(){ConfigId="1",DbType=DbType.MySql,ConnectionString=..,IsAutoCloseConnection=true  }
});

 if(!db.IsAnyConnection(configId))//當前上下文不存在則添加
    db.AddConnection(new ConnectionConfig{
                           DbType = DbType.SqlServer,ConfigId = "1", 
                IsAutoCloseConnection = true,
                ConnectionString = 。。 });
//開啟事務
try {
 //db我們稱為主Db 
 db.BeginTran(); //開啟多庫 （db.Ado.BeginTran是單庫事務）事務支持單庫和多庫
 
 db.GetConnection("1").Insertable(new Order()//var childDb=db.GetConnection(1);我們稱為子DB，子DB不具有租戶方法，具有單當庫操作方法
 {
   CreateTime = DateTime.Now,
   CustomId = 1,
   Name = "a",
   Price = 1
 }).ExecuteCommand();
 
 db.GetConnection("2").Insertable(new Order()
 {
   CreateTime = DateTime.Now,
   CustomId = 1,
   Name = "a",
   Price = 1
 }).ExecuteCommand();
 
 //提交事務 
 db.CommitTran();  
 
}
catch(Exception ex)
{
  //回滾事務
  db.Rollback();
}

多庫架構可以在底層做到相容，比如事務不需要引用外部DLL，比如我可以讓底層語法支持多庫，像EF CORE你能改他的

Include 語法嗎？改不了，我只能封裝他的語法，或者添加擴展方法。

 

三、跨伺服器跨庫聯表查詢

SqlSugar來實現跨伺服器聯表查詢

3.1 跨庫查詢之一對一

 [Tenant("db2")]//在類的特性設置當前類屬於哪個庫
  public class OrderItem
 {
            [SqlSugar.SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
            public int ItemId { get; set; }
            public int OrderId { get; set; }
            public decimal? Price { get; set; }
            [SqlSugar.SugarColumn(IsNullable = true)]
            public DateTime? CreateTime { get; set; }
            [Navigate(NavigateType.OneToOne,nameof(OrderId))] //設置關係 對應Order表主鍵
            public Order Order { get; set; }
 }



//通過ConfigId進行區分是哪個庫
var db = new SqlSugarClient(new List<ConnectionConfig>()
{
  new ConnectionConfig(){ConfigId="db1",DbType=DbType.Sqlite,ConnectionString="DataSource=/Db_OrderDb.sqlite",IsAutoCloseConnection=true},
  new ConnectionConfig(){ConfigId="db2",DbType=DbType.Sqlite,ConnectionString="DataSource=/Db_OrderItemDb.sqlite",IsAutoCloseConnection=true }
});

//通過實體類特性[Tenant("db2")]自動映射不同資料庫進行查詢
var list=db.QueryableWithAttr<OrderItem>()
.Includes(z => z.Order)
.ToList(); //1行代碼就搞定了2個庫聯表查詢

3.2 跨庫查詢之一對多

 [Tenant("db1")]//指定是db1  (OrderItem類設置為 db2)
  public class Order
  {
            [SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
            public int Id { get; set; }
            public string Name { get; set; }
            public decimal Price { get; set; }
            [SugarColumn(IsNullable = true)]
            public DateTime CreateTime { get; set; }
            [SugarColumn(IsNullable = true)]
            public int CustomId { get; set; }
            [Navigate(NavigateType.OneToMany, nameof(OrderItem.OrderId))]//
            public List<OrderItem> Items { get; set; }
  }

  var list = db.QueryableWithAttr<Order>()
                    .Includes(z => z.Items)//跨庫一對多
                    .ToList();

3.3 跨庫查詢之多對多　　

我們將3個表扔進3個不同的庫裡面

 var db = new SqlSugarClient(new List<ConnectionConfig>()
    {
        new ConnectionConfig(){ConfigId="A",DbType=DbType.Sqlite,ConnectionString="DataSource=/A_DB.sqlite",IsAutoCloseConnection=true},
        new ConnectionConfig(){ConfigId="B",DbType=DbType.Sqlite,ConnectionString="DataSource=/B_DB.sqlite",IsAutoCloseConnection=true  },
        new ConnectionConfig(){ConfigId="AB",DbType=DbType.Sqlite,ConnectionString="DataSource=/AB_DB.sqlite",IsAutoCloseConnection=true  }
  });p　

　實體

       [Tenant("A")]//指定為A庫
        public partial class OperatorInfo
        {
            /// <summary>
            /// 主鍵
            /// </summary>
            [SugarColumn(IsPrimaryKey = true)]
            public int id { get; set; }

            /// <summary>
            /// 姓名
            /// </summary>
            public string realname { get; set; }

            /// <summary>
            /// 多角色
            /// </summary>
            [Navigate(typeof(OptRole), nameof(OptRole.operId), nameof(OptRole.roleId))]//配置導航
            public List<Role> Roles { get; set; }
        }


        [Tenant("B")]//指定為B庫
        public partial class Role
        {
            /// <summary>
            /// 角色
            /// </summary>
            [SugarColumn(IsPrimaryKey = true )]
            public int id { get; set; }

            /// <summary>
            /// 角色名稱
            /// </summary>
            public string name { get; set; }
 
        }
 

        [Tenant("AB")]//指定為AB庫
        public partial class OptRole
        {
            /// <summary>
            /// 
            /// </summary>
            [SugarColumn(IsPrimaryKey = true)]
            public int id { get; set; }

            /// <summary>
            /// 
            /// </summary>
            public int operId { get; set; }

            /// <summary>
            /// 
            /// </summary>
            public int roleId { get; set; }


        }

//3個庫3個表進行多對多查詢
var x=db.QueryableWithAttr<OperatorInfo>()
.Includes(z => z.Roles).ToList();

3.4 多個表查詢我們可以這麼寫

//多個表聯表
var x=db.QueryableWithAttr<TB>()
.Includes(z => z.A1)
.Includes(z => z.A2)
.Includes(z => z.A3).ToList();

//多個表嵌套聯表
var x=db.QueryableWithAttr<TB>()
.Includes(z =>z.A1, z.Province,z=>z.City)//4個層級
.Includes(z => z.A2)
.Includes(z => z.A3).ToList();

3.5 手動指定多庫

上面都是通多特性實現的多庫查詢，我們也可以手動指定資料庫進行多庫查詢

 var list =db.GetConnection("db1").Queryable<OrderItem>()//Orderitem是db1
                .CrossQuery(typeof(Order), "db2")//Order是db2
                .Includes(z => z.Order)
                .ToList();

3.6是否有性能問題

不會SqlSugar跨庫導航和不跨庫導航是一套演算法，性能有保障，也就是單庫和多庫性能是一樣的

原理：一次獲取需要的數據，在記憶體分配置，數據多可進行拆分讀取

　

如今的成績

    企業認可以：

　 51job 搜索 簡曆數 僅次 EF 和 Dapper 超過國外的 　Nhibernate PetaPoco ， 占Dapper 40%簡曆數

    知名收費框架  JNPF 和 力軟 都有使用 SqlSugar

    培訓機構開始 講解SqlSugar

    用戶認可

   擁有強大的生態，3k以上的項目就有4個，基本都在500星以上，不算生態就擁有5個2000人群

　RuYiAdmin 、ZrAdminNetCore 、Admin.NET通用管理平臺(gitee 3k)   Yi框架(Ruoyi Vue)  CoreShop商城(gitee 3k)  Blog.Core(github 4k)

    YuebonCore  Furion(gitee8k) WebFirst  騰訊 APIJSON.NET   WaterCloud微服務         

   Viper  FamilyBucket    SmartSql  vboot-net   WMS倉庫管理系統  magic.net   

 

源碼地址：

SqlSugar一直在努力創新，喜歡的Github關註一下，文章推薦或轉發 

https://github.com/donet5/SqlSugar

　

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Java中如何實現兩個線程交替運行呢？
    前言 無聊的時候做了一個搜索文章的軟體，有沒有更加的方便快捷不知道，好玩就行了 環境使用 Python 3.8 Pycharm 模塊使用 import requests import tkinter as tk from tkinter import ttk import webbrowser 最終 ...
  • Python基礎語法：函數
    1 函數定義 1.1 函數概述 在程式設計中，函數的使用可以提升代碼的復用率和可維護性。 提升代碼的復用率： 程式設計中，一些代碼的功能是相同的，操作是一樣的，只不過針對的數據不一樣。此種情況下，可以將這種功能寫成一個函數模塊，要使用此功能時只需調用這個函數模塊就可以了。提升代碼的可維護性： 使用函 ...
  • 實踐GoF的設計模式：訪問者模式
    摘要：訪問者模式的目的是，解耦數據結構和演算法，使得系統能夠在不改變現有代碼結構的基礎上，為對象新增一種新的操作。 本文分享自華為雲社區《【Go實現】實踐GoF的23種設計模式：訪問者模式》，作者：元閏子 。 簡介 GoF 對訪問者模式（Visitor Pattern）的定義如下： Represent ...
  • SpringBoot實戰派讀書筆記---響應式編程
    1.什麼是WebFlux？ WebFlux不需要Servlet API，在完全非同步且無阻塞，並通過Reactor項目實現了Reactor Streams規範。 WebFlux可以在資源有限的情況下提高系統的吞吐量和伸縮性。 WebFlux除支持Restful Web服務外，還可以用於提供動態HTML ...
  • 離職了，要優雅地離開！
    作為軟體工程經理，我也會遇到人情世故的難題。最近一位團隊成員提出了離職申請，是因為個人的原因，而且很直接。 1、收到離職申請 我知道他會離職，我很少有措手不及的時候，所以我早就有預感，事實證明我的預感沒錯。幾周前，我就有一種感覺：“該來的遲早會來。”他們提出的問題、他們的疑慮以及他們有時會莫名離開辦 ...
  • 這8個技巧直接讓你的Python性能起飛
    1.使用map()進行函數映射 ✅ Exp1：將字元串數組中的小寫字母轉為大寫字母。 測試數組為 oldlist = ['life', 'is', 'short', 'i', 'choose', 'python']。 方法一 newlist = [] for word in oldlist: new ...
  • grpc+protobuf的一個demo示例
    1.需要保證電腦中安裝了protobuf安裝教程 2.如果出現報錯請看博客protobuf報錯問題解決 3.demo地址：demo 簡介： rpc微服務，grpc是一種開源的高性能RPC框架，能夠運行在任何環境中，最初由谷歌進行開發，它使用HTTP2作為傳輸協議。grpc讓客戶端可以像調用本地方法一 ...
  • 使用EF Core更新與修改生產資料庫
    使用EF Core的Code First，在設計階段，直接使用Database.EnsureCreated()和EnsureDeleted()可以快速刪除、更新最新的數據結構。由於沒有什麼數據，刪除的風險非常低。但是對於已經投入生產的資料庫，這個方法就絕對不可行了。 考慮以下場景： 項目已經上線，一 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類