efcore 跨庫查詢,實現一個接口內查詢兩個不同數據庫里各自的表數據

  最近有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代碼

 

 

 

posted @ 2020-07-06 22:34  那一片藍海  閱讀(...)  評論(...編輯  收藏
色网站直播