CRL快速開發框架4.4版發布,支持主從讀寫分離

經過一些調整和優化,4.3已經運行在生產環境,對於不久將會遇到的查詢性能,讀寫分離需求列上日程

讀寫分離需求

對於一個數據庫作了主從發布/訂閱,主庫為DB1,從庫為DB2

所有寫入通過DB1,所有查詢通過DB2,當然也可以通過DB1

CRL內部實現

在CRL內部調用,請求讀和請求寫的方法會標記為Read或Write,然后再通過標記實現不同的數據庫連接訪問對象

如以下代碼

/// <summary>
        /// 返回動態對象的查詢
        /// </summary>
        /// <param name="query"></param>
        /// <returns></returns>
        internal CallBackDataReader GetQueryDynamicReader(LambdaQueryBase query)
        {
            CheckTableCreated(query.__MainType);
            var sql = "";
            query.FillParames(this);
            sql = query.GetQuery();
            sql = _DBAdapter.SqlFormat(sql);
            System.Data.Common.DbDataReader reader;
            var compileSp = query.__CompileSp;
            var db = GetDBHelper(AccessType.Read); 16             if (!compileSp)
            {
                if (query.TakeNum > 0)
                {
                    db.AutoFormatWithNolock = false;
                }
                reader = db.ExecDataReader(sql);
            }
            else//生成儲過程
            {
                string sp = CompileSqlToSp(_DBAdapter.TemplateSp, sql);
                reader = db.RunDataReader(sp);
            }
            query.ExecuteTime = db.ExecuteTime;
            ClearParame();
            return new CallBackDataReader(reader, null, sql);
        }

GetDBHelper方法將此標記傳到數據訪問對象創建層

在程序啟動處,以Global為例

protected void Application_Start(object sender, EventArgs e)
        {
            CRL.SettingConfig.UseReadSeparation = true;//啟用主從讀寫分離
            //配置數據連接
            CRL.SettingConfig.GetDbAccess = (dbLocation) =>
            {
                var obj = dbLocation.TagData;
                if (dbLocation.ShardingDataBase != null)//按分庫判斷
                {
                    if (dbLocation.ShardingDataBase.Name == "db1")
                    {
                        return WebTest.Code.LocalSqlHelper.TestConnection;
                    }
                    else
                    {
                        return WebTest.Code.LocalSqlHelper.TestConnection2;
                    }
                }
                else
                {
                    //可按type區分數據庫
                    var type2 = dbLocation.ManageType;
                    if (type2 == typeof(Code.MongoDBTestManage))
                    {
                        return Code.LocalSqlHelper.MongoDB;
                    }
                    if(dbLocation.AccessType== CRL.AccessType.Read)//區分讀寫 28  { 29                         return Code.LocalSqlHelper.TestConnection2; 30  } 31                     return WebTest.Code.LocalSqlHelper.TestConnection;
                }
            };

        }

這樣就實現了在邏輯調用上實現了讀寫分離

實際調用

啟用主從讀寫分離

CRL.SettingConfig.UseReadSeparation = true;

更改數據

var item = Code.ProductDataManage.Instance.QueryItem(2);
item.ProductName = "更改主庫數據為" + DateTime.Now.Second;
Code.ProductDataManage.Instance.Update(item);

DB1數據被更改

查詢數據

 var item = Code.ProductDataManage.Instance.QueryItem(2);
            Response.Write("從庫數據2為" + item.ProductName);

查詢出DB2的數據

事務問題

由於主從復制可能存在延遲,在事務中可不想查到臟數據,或者數據在事務中被更改

因此,在事務內需要由主庫查詢

在CRL事務范圍內的查詢,都默認為主庫

 

此功能測試代碼見文檔/Page/ReadSeparation.aspx

最新源碼見文章底部簽名