CSFramework.EF应用 - ASP.NETCore/WebApi使用IDatabase动态代理创建多个数据库实例

    /// <summary>
    /// 授权系统数据库接口
    /// </summary>
    public interface ILicenseDatabase : CSFramework.EF.IDatabase
    {
        //
    }

    /// <summary>
    /// CSFramework开发框架系统数据库接口
    /// </summary>
    public interface ISystemDatabase : CSFramework.EF.IDatabase
    {
        //
    }

//注入授权系统数据库
builder.Services.AddDatabase((config) =>
{
    var key = "Database:CSFramework_LicenseV3";
    var dbOption = builder.Configuration.GetSection(key).Get<DatabaseOptions>(); //appsettings.json
    config.UseDatabase<ILicenseDatabase>(dbOption, optionsBuilder: (op) =>
    {
        //这个可以设置参数
    });
});

//注入开发框架系统数据库
builder.Services.AddDatabase((config) =>
{
    var key = "Database:CSFrameworkV6_System";
    var dbOption = builder.Configuration.GetSection(key).Get<DatabaseOptions>(); //appsettings.json
    config.UseDatabase<ISystemDatabase>(dbOption, optionsBuilder: (op) =>
    {
        //这个可以设置参数
    });
});

        /// <summary>
        /// 注入CSFramework.EF DatabaseBuilder构件
        /// </summary>
        /// <param name="services">服务集合</param>
        /// <param name="builder">配置项</param>
        /// <returns></returns>
        public static IServiceCollection AddDatabase(this IServiceCollection services, Action<IDatabaseBuilder> builder = null)
        {
            services.AddOptions<DatabaseOptions>();
            services.AddLogging();

            DatabaseBuilder container = new DatabaseBuilder(services);
            builder?.Invoke(container);

            services.AddSingleton(container);
            services.AddSingleton<IDatabaseBuilder>(container);

            return services;
        }

 /// <summary>
 /// 用于构建和配置CSFramework.EF.IDatabase数据库实例
 /// </summary>
 internal class DatabaseBuilder : IDatabaseBuilder
 {
     private readonly IServiceCollection _services;

     public DatabaseBuilder(IServiceCollection services)
     {
         _services = services;
     }

     /// <summary>
     /// 使用数据库
     /// </summary>
     /// <typeparam name="TDatabase">IDatabase派生接口</typeparam>
     /// <param name="dbOption">数据库配置</param>
     /// <param name="optionsBuilder">自定义配置</param>
     /// <returns></returns>
     public IDatabaseBuilder UseDatabase<TDatabase>(DatabaseOptions dbOption, Action<DatabaseOptions> optionsBuilder)
          where TDatabase : class, IDatabase
     {
         var optionName = typeof(TDatabase).FullName;//接口全名：CSFramework.LicenseServerV3.ILicenseDatabase
         _services.AddOptions<DatabaseOptions>(optionName);

         if (optionsBuilder != null)
         {
             _services.Configure(optionName, optionsBuilder);
         }

         _services.AddScoped(serviceProvider =>
         {
             var parameter = new DatabaseConfig
             {
                 ConnectionString = dbOption.ConnectionString,
                 DatabaseType = dbOption.DatabaseType,
                 Schema = dbOption.Schema,
                 EntityTypes = DatabaseEngine.GetEntityTypes(),
                 AllTypes = DatabaseEngine.GetTypes(),
                 CommandTimeout = 30,
                 TableSuffix = "",
             };

             IDatabase db = DatabaseFactory.GetDatabase(parameter);

             if (typeof(TDatabase) == typeof(IDatabase))
                 return (TDatabase)db;
             else
                 return db.CreateProxy<TDatabase>(); //动态代理创建数据库实例
         });

         return this;
     }
 }

    /// <summary>
    /// 数据库连接参数配置（加载appsettings.json）
    /// </summary>
    internal class DatabaseOptions
    {  /// <summary>
       /// 连接字符串
       /// </summary>
        public string ConnectionString { get; set; }

        /// <summary>
        /// 数据库类型
        /// </summary>
        public DatabaseType DatabaseType { get; set; }

        /// <summary>
        /// 数据库连接类型。参考值：Database/Service/SID
        /// </summary>
        public string ServiceOrSID { get; set; }

        /// <summary>
        /// 架构，服务名（oracle)
        /// </summary>
        public string Schema { get; set; }

    }

[ApiController]
[Route("api/[controller]/[action]")]
[OpenApiTag("API控制器")]
public class LicenseController : ControllerBase
{
    private ILicenseClient _business;
    private IServiceProvider _service;

    public LicenseController(ILicenseClient business,IServiceProvider service)
    {
        _business = business;
        _service = service;

        Console.WriteLine("》》》测试数据库动态代理...");

        var db1 = _service.GetService<ILicenseDatabase>();
        var db2 = _service.GetService<ISystemDatabase>();

        //测试授权系统数据库
        var user = db1.GetQueryable<sys_AdminUser>().FirstOrDefault();
        Console.WriteLine("》》》扩展接口：" + typeof(ILicenseDatabase));
        Console.WriteLine(db1.ConnectionString);
        Console.WriteLine("用户名："+user.AccountName);
        Console.WriteLine();

        //测试开发框架数据库
        var menu = db2.GetQueryable<tb_MyMenu>().FirstOrDefault();
        Console.WriteLine("》》》扩展接口：" + typeof(ISystemDatabase));
        Console.WriteLine(db2.ConnectionString);
        Console.WriteLine("菜单名：" + menu.MenuName);

    }
}