ArielCore.MixedDataBase 1.0.2

使用步骤：

1. 首先添加nuget包ArielCore.MixedDataBase
2. 在startup.cs或Program.cs或入口处添加如下

 services.AddCoreDbContext<MySqlSjDbContext>("server=localhost;port=3306;user id=root;password=123456;database=cztest;charset=utf8mb4;ConnectionReset=false;AllowUserVariables=true;default command timeout=600;", DataBaseType.MySql);

3. 添加文件MySqlSjDbContext.cs文件

  namespace API.Domain.DataAcces
  {
      /// <summary>
      /// DbContext
      /// </summary>
      public class MySqlSjDbContext : DbContext
      {
          /// <summary>
          /// 构造函数
          /// </summary>
          /// <param name="options"></param>
          public MySqlSjDbContext(DbContextOptions options) : base(options)
          {
              Database.EnsureCreated();
          }
          /// <summary>
          /// 用户
          /// </summary>
          public DbSet<UserEntity> Users { get; set; }
          /// <summary>
          /// OnModelCreating
          /// </summary>
          /// <param name="modelBuilder"></param>
          protected override void OnModelCreating(ModelBuilder modelBuilder)
          {
              base.OnModelCreating(modelBuilder);
              #region 注册领域模型与数据库的映射关系
              //modelBuilder.ApplyConfiguration(new UserSourceEntityTypeConfiguration());
              #endregion
          }
      }
  }

4. 添加文件UserEntity.cs

namespace API.Domain.Entities.UserAggregate
{
    /// <summary>
    /// 用户
    /// </summary>
    [Table("t_user")]
    public class UserEntity : CommonBaseEntity
    {
        /// <summary>
        /// 构造函数
        /// </summary>
        public UserEntity() { }
        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="loginName"></param>
        public UserEntity(string loginName)
        {
            LoginName = loginName;
            UserName = LoginName;
            CreatedTime = DateTime.Now;
            UpdatedTime = DateTime.Now;
            IsDeleted = false;
        }
        /// <summary>
        /// 用户名称
        /// </summary>
        [Required]
        [MaxLength(50)]
        public string UserName { get; set; }
        /// <summary>
        /// 登录名称
        /// </summary>
        [Required]
        [MaxLength(50)]
        public string LoginName { get; set; }
        /// <summary>
        /// 登录密码
        /// </summary>
        [Required]
        [MaxLength(150)]
        public string LoginPwd { get; set; }
        /// <summary>
        /// Email
        /// </summary>
        [MaxLength(50)]
        public string Email { get; set; }
        #region 关联属性，有需要类似下面添加
        /// <summary>
        /// 用户-部门
        /// </summary>
        [NotMapped]
        public virtual ICollection<UserDepartmentEntity> UserDepartments { get; set; }
        /// <summary>
        /// 部门id集合
        /// </summary>
        [NotMapped]
        public List<string> DepartmentIds { get; set; }
        /// <summary>
        /// 部门名称集合
        /// </summary>
        [NotMapped]
        public List<string> DepartmentNames { get; set; }
        #endregion
    }
}

5. 添加EntityBase.cs文件

namespace API.Domain.Entities
{
    /// <summary>
    /// 实体基类
    /// </summary>
    public class CommonBaseEntity : EntityBase<string>
    {
        /// <summary>
        /// 主键Id
        /// </summary>
        [MaxLength(50)]
        [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
        //[ExplicitKey]
        public override string Id { get; set; } = GetId();

        /// <summary>
        /// 创建时间
        /// </summary>
        public DateTime? CreatedTime { get; set; } = DateTime.Now;
        /// <summary>
        /// 创建人
        /// </summary>
        [MaxLength(50)]
        public string? CreatedBy { get; set; } = default!;
        /// <summary>
        /// 更新时间
        /// </summary>
        public DateTime? UpdatedTime { get; set; } = DateTime.Now;
        /// <summary>
        /// 更新人
        /// </summary>
        [MaxLength(50)]
        public string? UpdatedBy { get; set; } = default!;
        /// <summary>
        /// 是否删除标识0false 1true
        /// </summary>
        public bool IsDeleted { get; set; }
    }

    /// <summary>
    /// EntityBase
    /// </summary>
    /// <typeparam name="TPrimaryKey"></typeparam>
    public abstract class EntityBase<TPrimaryKey>
    {
        /// <summary>
        /// Id
        /// </summary>
        public virtual TPrimaryKey Id { get; set; }
    }
    #region 生成Id
    /// <summary>
    /// 生成Id
    /// </summary>
    /// <param name="size"></param>
    /// <returns></returns>
    private string GetId(string size = "32")
    {
        if (size?.Equals("16") ?? false)
        {
            long i = 1;
            foreach (byte b in Guid.NewGuid().ToByteArray())
            {
                i *= b + 1;
            }

            return string.Format("{0:x}", i - DateTime.Now.Ticks);
        }
        else if (size?.Equals("32") ?? false)
        {
            return Guid.NewGuid().ToString("N");
        }

        throw new NotSupportedException($"{size} 暂不支持！");
    }
    #endregion
}

6. 实际使用时候在Service服务中添加类似如下

public class TestService : ITestService
{
  private readonly IMySqlDbRepository<MySqlSjDbContext> _uoRepository;
  public TestService(IMySqlDbRepository<MySqlWebApiDbContext>)
  {
      _uoRepository = uoRepository;
  }
  public string AddUserInfo()
  {
      try
      {
          var transaction = _uoRepository.BeginTransaction();
          var userList = _uoRepository.Get<UserEntity>(a => a.LoginName == "aa").ToList();
          if (userList.Count == 0)
          {
              _uoRepository.Insert(new UserEntity());
              _uoRepository.Insert(new UserEntity());
              result = 1;
          }
          else
          {
              _uoRepository.Rollback();
              return "用户已存在！";
          }
          _uoRepository.Commit();
      }
      catch (Exception e)
      {
          _uoRepository.Rollback();
      }
      return "";
  }
}