DAL层连接多数据库跨服务器进行数据交互对接


DAL层连接多数据库跨服务器进行数据交互对接-开发框架文库

DAL(Data Access Layer)

DAL是数据访问层的英文缩写,即为数据访问层(Data Access Layer)。其功能主要是负责数据库的访问,简单地说就是实现对数据表的Select(查询)、Insert(插入)、Update(更新)、Delete(删除)等操作。

对于企业级大型软件系统,数据访问层承载更多的数据逻辑处理的工作,比如操作多个数据库,或者跨服务器进行数据交互,数据对接等。

CSFramework.DB组件

CSFramework.DB组件针对多个数据库操作,或者跨服务器数据交互与对接提供强大的技术支持,封装大量底层常用接口与方法,在实际应用中调用方法与接口就能实现。

本文针对DAL层连接多数据库,跨服务器进行数据操作方面提供客户实例,供大家参考。

DatabaseProvider

DatabaseProvider,既数据库提供者(DAL层应用)。DatabaseProvider的主要职责是初始化数据库连接,以及提供一组通用方法创建IDatabase实例。

C# 全选
    /// <summary>
    /// 数据库提供者(DAL层应用)
    /// </summary>
    public static class DatabaseProvider
    {
        //连接字符串列表 <key,connectionString>
        private static Dictionary<string, string> _ConnectionString = new Dictionary<string, string>();

        //活动数据库列表 <key,IDatabase>
        private static Dictionary<string, IDatabase> _ActivedDBs = new Dictionary<string, IDatabase>();

        //静态构造器
        static DatabaseProvider()
        {
            InitConnection(Globals.IsTestMode);
        }

        public static void InitConnection(bool isTest)
        {
            _ConnectionString.Clear();

                //系统数据库,需要建立数据库
                _ConnectionString["MiniSystem"] = "Server=121.79.28.39;Database=CSFramework_Mini;User ID=test;Password=123456.";

                //其他数据库
                _ConnectionString["GTDB8120"] = "Server=121.79.28.39;Database=GTDB8;User ID=test;Password=123456.";
                _ConnectionString["C_bei120"] = "Server=121.79.28.39;Database=C_bei;User ID=test;Password=123456.";
                _ConnectionString["gSales"] = "Server=121.79.28.39;Database=gSales;User ID=test;Password=123456.";
                _ConnectionString["C_bei110"] = "Server=121.79.28.39;Database=C_bei110;User ID=test;Password=qifan123456.";
          
        }

        /// <summary>
        /// 获取活动状态的数据库
        /// </summary>
        /// <param name="DBID">账套编号</param>
        /// <returns></returns>
        public static IDatabase GetDatabase(DBIDs DBID)
        {
            //使用缓存的IDatabase实例
            if (!_ActivedDBs.ContainsKey(DBID.ToString()))
            {
                IDatabase db = DatabaseFactory.CreateSqlDatabase(_ConnectionString[DBID.ToString()]);//OK
                _ActivedDBs.Add(DBID.ToString(), db);
            }

            return _ActivedDBs[DBID.ToString()];
        }
    }

DBIDs

DBID,Database ID的简称,数据库编号。DBIDs是个枚举类型,定义企业级系统需要连接的数据库编号。

参考:

C# 全选
    public enum DBIDs
    {
        /// <summary>
        /// MiniSystem作为系统库
        /// </summary>
        MiniSystem,

        /// <summary>
        /// 其他数据库、账套数据库
        /// </summary>
        GTDB8120,
        /// <summary>
        /// 其他数据库、账套数据库
        /// </summary>
        C_bei120,
        /// <summary>
        /// 其他数据库、账套数据库
        /// </summary>
        gSales,
        /// <summary>
        /// ERP数据库、其他数据库、账套数据库
        /// </summary>
        C_bei110
    }

DAL层创建多个IDatabase实例

C# 全选
 /// <summary>
        /// 同步数据方法
        /// </summary>
        /// <returns></returns>
        internal int SyncData()
        {
            //创建不同数据库的实例
            IDatabase db_MsSQL = DatabaseProvider.GetDatabase(DBIDs.GTDB8120);//MsSQL数据库
            IDatabase db_Oracle = DatabaseProvider.GetDatabase(DBIDs.C_bei110);//Oracle数据库
            IDatabase db_MySQL = DatabaseProvider.GetDatabase(DBIDs.GTDB8120);//MySQL数据库

            //获取不同数据库服务器的数据
            var d1 = db_MsSQL.GetTable("SELECT * FROM dt_Customer WHERE FlagSync=0");
            var d2 = db_Oracle.GetTable("SELECT * FROM DT_CUSTOMER WHERE FlagSync=0");//oracle
            var d3 = db_MySQL.GetTable("SELECT * FROM dt_Customer WHERE FlagSync=0");

            //
            //数据处理, 省略。。。
            //

            //操作MySQL数据库
            var cmd1 = db_MySQL.CreateCommand("");
            db_MySQL.ExecuteCommand(cmd1.Command);

            //操作Oracle数据库
            var cmd2 = db_Oracle.CreateCommand("");
            db_Oracle.ExecuteCommand(cmd2.Command);

            return 0;
        }

CSFramework.DB多数据库框架-开发框架文库

参考:CSFramework.DB组件

版权声明:本文为开发框架文库发布内容,转载请附上原文出处连接
C/S框架网
上一篇:2022年喜鹊科技年初八开工大吉
下一篇:DatabaseProvider类详解
评论列表

发表评论

评论内容
昵称:
关联文章

DAL连接数据库服务器进行数据交互对接
怎样将DAL提交数据默认为系统数据库
DAL数据访问提交单个表的数据
开发数据访问DAL - MiniFramework蝇量框架 - Winform框架
C/S开发框架教程:使用基础资料(数据字典)的DAL更新主从表(或表)数据
如何使用数据库IDatabase接口以及数据访问应用
C# Win服务定时作业实现集团之间的系统数据库数据同步
实例化Loginer和DAL对象,调用方法返回数据
C#.Net C/S结构开发框架中数据访问(DAL)的作用
Winform界面自适应快速开发框架(C#+Dev+三架构+数据库支持)
SqlServer配置链接服务器LINKSERVER:ODBC连接MySQL数据库
CSFramework C#代码生成器生成窗体界面UI,BLL,DAL,Model,WCF接口源代码
SQLServer服务器实例配置端口及SqlConnection连接字符串、安全组规则配置
DAL重写Update方法手工启动事务
部署Web服务器客户端的WebService连接状态监视技术参考
数据字典BLL不依赖WCF连接策略实现三架构的直连模式(ADO-Direct)
ADO Direct/WebService区域下载数据测试报告
C#数据访问主类.(SqlHelper)SQLDataAccess.cs
C/S开发框架DAL提交数据报错"外键值为空!"解决方案。
GoF设计模式:中介者模式(Mediator Pattern)—协调个对象之间的交互