1.跨品種查詢(xún) :比如 MYSQL和一個(gè)SQLSERVER進(jìn)行聯(lián)表查詢(xún) ,或者SQLITE和MYSQL進(jìn)行聯(lián)表查詢(xún)
延吉網(wǎng)站建設(shè)公司創(chuàng)新互聯(lián)建站,延吉網(wǎng)站設(shè)計(jì)制作,有大型網(wǎng)站制作公司豐富經(jīng)驗(yàn)。已為延吉1000+提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\外貿(mào)營(yíng)銷(xiāo)網(wǎng)站建設(shè)要多少錢(qián),請(qǐng)找那個(gè)售后服務(wù)好的延吉做網(wǎng)站的公司定做!
2.跨服務(wù)器查詢(xún) : A服務(wù)器和B服務(wù)器查詢(xún)
如果想同時(shí)支持1和2 相信很多人都沒(méi)有比較好的解決方案
我的設(shè)計(jì)是通過(guò)多庫(kù)架構(gòu)來(lái)實(shí)現(xiàn)多庫(kù)操作
什么是多庫(kù)架構(gòu)ORM,一個(gè)對(duì)象可以同時(shí)操作和管理多個(gè)數(shù)據(jù)庫(kù) 我們稱(chēng)為多庫(kù)架構(gòu)
一個(gè)對(duì)象只能操作一個(gè)數(shù)據(jù)庫(kù),所以EF Core不能稱(chēng)為多庫(kù)架構(gòu),只能稱(chēng)為支持多種數(shù)據(jù)庫(kù),如果要實(shí)現(xiàn)多庫(kù)
我們就需外部封裝,代碼如下
SqlSugar在2017最火的時(shí)候停更了一年半,最大的原因就是因?yàn)榈讓蛹軜?gòu)影響了SqlSugar的上限,歷史遺留問(wèn)題太多
需要大量重構(gòu),如果直接更新對(duì)現(xiàn)有用戶(hù)是不負(fù)責(zé)的,所以我選擇了一年半未更新,讓不是特別熱愛(ài)SqlSugar的用戶(hù)
先用其他框架,留下對(duì)于SqlSugar一直熱衷的用戶(hù),能支持和一起完善SqlSugar的用戶(hù),謝謝有一群這樣的用戶(hù)不離不棄
籌劃了一年半的時(shí)間終于在2020開(kāi)始進(jìn)行重構(gòu) 每隔一個(gè)月就重構(gòu)一部分 加點(diǎn)功能 , 直到今天終于重構(gòu)完成
代碼如下:
var db = new SqlSugarClient(new List() { new ConnectionConfig(){ConfigId="0",DbType=DbType.SqlServer,ConnectionString=..,IsAutoCloseConnection=true}, new ConnectionConfig(){ConfigId="1",DbType=DbType.MySql,ConnectionString=..,IsAutoCloseConnection=true } }); if(!db.IsAnyConnection(configId))//當(dāng)前上下文不存在則添加 db.AddConnection(new ConnectionConfig{ DbType = DbType.SqlServer,ConfigId = "1", IsAutoCloseConnection = true, ConnectionString = 。。 }); //開(kāi)啟事務(wù) try { //db我們稱(chēng)為主Db db.BeginTran(); //開(kāi)啟多庫(kù) (db.Ado.BeginTran是單庫(kù)事務(wù))事務(wù)支持單庫(kù)和多庫(kù) db.GetConnection("1").Insertable(new Order()//var childDb=db.GetConnection(1);我們稱(chēng)為子DB,子DB不具有租戶(hù)方法,具有單當(dāng)庫(kù)操作方法 { 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(); //提交事務(wù) db.CommitTran(); } catch(Exception ex) { //回滾事務(wù) db.Rollback(); }