C簡單構架之EF進行讀寫分離+多資料庫(Mysql/SqlService)

最近因為項目需要，研究了下EF的讀寫分離，所以做了一個demo進行測試，下面是項目的結構

表現層view

主要提供Web、WebApi等表現層的解決方案

公共層public

主要提供項目公共類庫，數據緩存基礎方法等

實體層model

主要提供資料庫映射模型，還有就是DDD領域操作模型

數據層Db

主要封裝EF操作基礎類

數據服務層Service

主要提供資料庫操作服務、緩存操作服務

數據介面服務層inface

主要提供資料庫操作服務介面、緩存操作服務介面

1.首先是多資料庫的支持，目前就支持mysql/sqlservice，如果需要添加更多的資料庫支持，只需要再資料庫操作類型上面添加即可

///

public enum DbContextType : byte
{
SqlService = 1,
MySql = 2
}

View Code

分別對mysql/sqlservice的上下文操作進行封裝

///

[DbConfigurationType(typeof(MySqlEFConfiguration))]
public class MySqlContext : DbContext
{
public DbSet TestEntities { get; set; }
///

public MySqlContext : base("DefaultConnection") {
}
///

/// public MySqlContext(string connenction) : base(connenction) { }
///

/// protected override void OnModelCreating(DbModelBuilder modelBuilder)
{
}
}

View Code

///

public class SqlServiceContext : DbContext
{
///

public SqlServiceContext {
}
///

/// public SqlServiceContext(string connenction) : base(connenction) {
}
///

/// protected override void OnModelCreating(DbModelBuilder modelBuilder)
{
}
}

View Code

在view調用時候，進行ef上下文初始化只需要設置類型

///

public static class DBInitializer
{
public static DbContextType DbContextType { get; set; }
///

`
public static void Initialize(DbContextType ContextType)
{
string IsUsedWR = System.Configuration.ConfigurationManager.AppSettings["IsUsedWR"];
DbContextType = ContextType;
///獲得資料庫最後一個版本
// Database.SetInitializer(new MigrateDatabaseToLatestVersion);
if (ContextType == DbContextType.SqlService)
{
Database.SetInitializer(new MigrateDatabaseToLatestVersion);
if (IsUsedWR == "1") {
Database.SetInitializer(new MigrateDatabaseToLatestVersion);
}
else
{
Database.SetInitializer(null);
}
}
else
{
Database.SetInitializer(new MigrateDatabaseToLatestVersion);
if (IsUsedWR == "1")
{
Database.SetInitializer(new MigrateDatabaseToLatestVersion);
}
else
{
Database.SetInitializer(null);
}
//Database.SetInitializer(null);
// Database.SetInitializer(null);
}
// Database.SetInitializer(null);
///刪除原來資料庫 重新創建資料庫
//Database.SetInitializer(new DropCreateDatabaseIfModelChanges);
// Database.SetInitializer(new DropCreateDatabaseIfModelChanges);
}
}

View Code

public class MvcApplication : System.Web.HttpApplication
{
protected void Application_Start
{
AreaRegistration.RegisterAllAreas;
FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
RouteConfig.RegisterRoutes(RouteTable.Routes);
BundleConfig.RegisterBundles(BundleTable.Bundles);

//Autofac
//ContainerBuilder builder = new ContainerBuilder;
//builder.RegisterAssemblyTypes(Assembly.GetExecutingAssembly);
//IContainer container = builder.Build;
//DependencyResolver.SetResolver(new AutofacDependencyResolver(container));

//Autofac初始化過程
ContainerBuilder builder = new ContainerBuilder;
builder.RegisterControllers(System.Reflection.Assembly.GetExecutingAssembly);//註冊mvc容器的實現
var assemblys = BuildManager.GetReferencedAssemblies.Cast.ToList;
builder.RegisterAssemblyTypes(assemblys.ToArray).Where(t => t.Name.Contains("Service")).AsImplementedInterfaces;
var container = builder.Build;
DependencyResolver.SetResolver(new AutofacDependencyResolver(container));
//初始化資料庫
DBInitializer.Initialize(DbContextType.MySql);
}
}

View Code

通過上面多資料庫的支持已經完成，下面進行讀寫分離，分別進行繼承上述上下文操作

///

public class WriteSqlServiceContext : SqlServiceContext
{
public WriteSqlServiceContext : base("") { }
}
///

public class ReadSqlServiceContext : SqlServiceContext
{
public ReadSqlServiceContext : base("") { }
}

View Code

通過工廠類進行初始化

///

public static class Contextfactory
{
///

///
public static DbContext GetContext(DbOpertionType OpertionType)
{
DbContextType ContextType = DBInitializer.DbContextType;
if (ContextType == DbContextType.MySql)
{
if (OpertionType == DbOpertionType.Read)
return new ReadMySqlContext;
else
return new WriteMySqlContext;
}
else
{
if (OpertionType == DbOpertionType.Read)
return new ReadSqlServiceContext;
else
return new WriteSqlServiceContext;
}
}
///

///
/// ///
public static TEntity CallContext(DbOpertionType OpertionType) where TEntity: DbContext
{
var DbContext = GetContext(OpertionType);
return (TEntity)DbContext;
}
}

View Code

最後配置webcofig即可

View Code

最後進行測試

public class TestController : Controller
{
private ITestService _TestServiceDb { get; set; }

public TestController(ITestService TestServiceDb) {
_TestServiceDb = TestServiceDb;
}
// GET: Test
public ActionResult Index
{
var result = _TestServiceDb.AddEntity(new Test { ID=Guid.NewGuid, Age=11, CreateTime=DateTime.Now, Name="Test" });
var NewResult = _TestServiceDb.GetEntityByID(result.ID);
return View;
}
}

View Code

搞定，可能在代碼上有點累贅，但是總算是可行的。

如果有興趣的朋友可以留下郵箱，然後發全代碼一起研究，謝謝！

喜歡這篇文章嗎？立刻分享出去讓更多人知道吧！