最近有efcore跨庫查詢的需求,研究了下colder框架里文檔的分庫實現,發現並不能完全實現一個接口下的跨庫查詢請求,只能滿足一個業務層構造指定的唯一一個數據庫訪問接口。
先說下文檔是怎么實現的
DbAccessor實現使用多數據庫
默認框架會自動注入IDbAccessor作為數據庫訪問接口,在需要的時候注入即可,若系統需要操作多個數據庫,那么需要定義額外的接口繼承IDbAccessor然后配置注入進去即可訪問
-
先定義新的接口IMyDbAccessor
-
然后配置數據庫類型和連接字符串
-
使用IMyDbAccessor
這樣就可以在任何地方注入並使用IMyDbAccessor,更多數據庫同理配置即可
--上面的缺陷在於BaseBussiness 中只能構造一個IMyDbAccessor,也就是說只能注入和使用一個數據庫的數據訪問接口。
DbFactory.GetDbAccessor()實現 (推薦)
不需要像上面那樣事先依賴注入,再寫自己的IMyDbAccessor接口繼承IDbAccessor。
直接使用EFCore.Sharding中的DbFactory數據工廠
using EFCore.Sharding; using Microsoft.Extensions.Logging; namespace EFCore.Sharding { // // 摘要: // 數據庫工廠 public static class DbFactory { // // 摘要: // 根據配置文件獲取數據庫類型,並返回對應的工廠接口 // // 參數: // conString: // 完整數據庫鏈接字符串 // // dbType: // 數據庫類型 // // loggerFactory: // 日志工廠 public static IDbAccessor GetDbAccessor(string conString, DatabaseType dbType, ILoggerFactory loggerFactory = null); // // 摘要: // 獲取ShardingDbAccessor // // 參數: // absDbName: // 抽象數據庫 // // 返回結果: // ShardingDbAccessor public static IShardingDbAccessor GetShardingDbAccessor(string absDbName = "BaseDb"); } }
appsetting.json代碼