SqlSugar/Src/Asp.NetCore2/AccessTest/Demo/DemoH_Tenant.cs

using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;

namespace OrmTest
{
    public class DemoH_Tenant
    {
        public static void Init()
        {
            Console.WriteLine("");
            Console.WriteLine("#### DemoH_Tenant Start ####");
            new C1Service().Test();
            Console.WriteLine("#### DemoH_Tenant End ####");
        }
        public class C1Service : Repository<C1Table>
        {
            public void Test()
            {
                db.BeginTran();
                base.GetList(); //调用内部仓储方法
                base.ChangeRepository<Repository<C2Table>>().GetList();//调用外部仓储
                db.CommitTran();
            }
        }
        public class Repository<T> : SimpleClient<T> where T : class, new()
        {
            //单例实同db同上下文共享
            public static SqlSugarScope db = new SqlSugarScope(new List<ConnectionConfig> {
                                                        new ConnectionConfig()
                                                    {
                                                        ConfigId="1",
                                                        DbType = SqlSugar.DbType.Access,
                                                        IsAutoCloseConnection = true,
                                                        ConnectionString = Config.ConnectionString
                                                    },
                                                        new ConnectionConfig()
                                                    {
                                                        ConfigId="2",
                                                        DbType = SqlSugar.DbType.Access,
                                                        IsAutoCloseConnection = true,
                                                        ConnectionString = Config.ConnectionString2
                                                    }
                    });
            public Repository(ISqlSugarClient context = null) : base(context)//注意这里要有默认值等于null
            {
                if (context == null)
                {
                    var configId = typeof(T).GetCustomAttribute<TenantAttribute>().configId;
                    Context = db.GetConnection(configId);
                    Context.CodeFirst.InitTables<T>();
                }
            }

            /// <summary>
            /// 扩展方法，自带方法不能满足的时候可以添加新方法
            /// </summary>
            /// <returns></returns>
            public List<T> CommQuery(string sql)
            {
                //base.Context.Queryable<T>().ToList();可以拿到SqlSugarClient 做复杂操作
                return base.Context.Queryable<T>().Where(sql).ToList();
            }

        }

        [TenantAttribute("1")]
        public class C1Table
        {
            public string Id { get; set; }
        }
        [TenantAttribute("2")]
        public class C2Table
        {
            public string Id { get; set; }
        }
    }
}