分享Db4o的便捷封裝類源碼

導言

大家好，話說真是好久好久沒寫文章了，哈哈。

最近在寫網站，個人對傳統數據庫天然抵觸，感覺非常繁冗，即便是Entity Framework也過於龐雜了，Db4o這種輕量級且讀寫、配置都極其方便的新型數據庫非常適合我。

不過我發現Db4o這么多年發展下來，竟然仍舊沒多少中文資料可尋，很奇怪為什么這么優秀的數據庫國內使用率極低呢？於是我就想嘗試自己來寫一些心得什么的，為Db4o在國內的傳播盡微薄之力吧。

此次分享的是自己寫的工具類代碼，封裝了Db4o的一種基本使用方式，高度優化了調用體驗，下面直接介紹用法，源代碼在文章末尾貼出。

初始化

如果是桌面應用的話，那就在程序開始時直接初始化即可：

        /// <summary>
        /// Db4o服務器管理器
        /// </summary>
        public static Db4oServerManager Db4oServerManager=new Db4oServerManager("db.db4o");

如果是網站，建議在Global.asax里作為網站核心類的靜態屬性，並在網站啟動時初始化：

    public class MvcApplication : System.Web.HttpApplication
    {
        /// <summary>
        /// Db4o服務器管理器
        /// </summary>
        public static Db4oServerManager Db4oServerManager;

        protected void Application_Start()
        {
            AreaRegistration.RegisterAllAreas();
            FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
            RouteConfig.RegisterRoutes(RouteTable.Routes);
            BundleConfig.RegisterBundles(BundleTable.Bundles);

            Db4oServerManager = new Db4oServerManager(Server.MapPath(System.Configuration.ConfigurationManager.ConnectionStrings["db4o"].ConnectionString));
        }

        public override void Dispose()
        {
            Db4oServerManager.Dispose();
            base.Dispose();
        }
    }

然后記得在Web.config里配置數據庫存放路徑：

    <connectionStrings>
        <add name="db4o" connectionString="/App_Data/db.db4o"/>
    </connectionStrings>

調用方法

注：下文以網站項目為例

建議采用Lambda表達式方法調用：

                    //無返回值調用方法
                    MvcApplication.Db4oServerManager.Access(q =>
                    {
                        //查找相同ID的對象，以進行更新，否則直接存儲將存儲為新對象
                        var u = q.Query<ApplicationUser>(t => t.Id == user.Id).First();
                        u.用戶信息.名稱 = model.DisplayName;
                        //必須明確存儲子對象才能得到正確更新，因為默認貌似沒有開啟級聯更新（新建對象存儲時會默認自動存儲子對象，但更新對象時不會自動更新子對象）
                        q.Store(u.用戶信息);
                    });

                    //有返回值調用方法
                    return MvcApplication.Db4oServerManager.AccessAndReturn(q => q.Query<WebSite.Models.ApplicationUser>(t => t.UserName == User.Identity.GetUserName()).First().用戶信息.名稱)

下面是傳統一些的調用方式：

            using (var dbsa = MvcApplication.Db4oServerManager.CreatAccessor())
            {
                var finduser = dbsa.Query<TUser>(q => q.Id == user.Id).FirstOrDefault();
                dbsa.Delete(finduser);
            }

源代碼

    /// <summary>
    /// Db4o服務器訪問器。注意，對數據進行修改后必須釋放此對象才能真正的將更改提交到服務器。建議配合using(var dbsa=new Db4oServerAccessor(...)){...}語句使用
    /// </summary>
    // ReSharper disable once InconsistentNaming
    public class Db4oServerAccessor : IDisposable
    {
        // ReSharper disable once InconsistentNaming
        private IObjectContainer DBContainer { get; set; }

        /// <summary>
        /// 構造函數
        /// </summary>
        /// <param name="serverManager">Db4o服務器管理器</param>
        public Db4oServerAccessor(Db4oServerManager serverManager)
        {
            DBContainer = serverManager.OpenClient();
        }

        public void Store(object o)
        {
            DBContainer.Store(o);
        }

        public IDb4oLinqQuery<T> Query<T>(Predicate<T> p)
        {
            return from T q in DBContainer where p(q) select q;
        }

        public IDb4oLinqQuery<T> QueryAll<T>()
        {
            return from T q in DBContainer select q;
        }

        public int Count<T>(IDb4oLinqQuery<T> collection)
        {
            return collection.Count();
        }

        public int CountAll<T>()
        {
            return QueryAll<T>().Count();
        }

        public int Count<T>(Predicate<T> p)
        {
            return Query(p).Count();
        }

        public int CountAllByExt<T>()
        {
            foreach (var storedClass in DBContainer.Ext().StoredClasses())
            {
                if (storedClass.GetName() == typeof(T).FullName) return storedClass.InstanceCount();
            }
            return 0;
        }

        public void Delete(object o)
        {
            DBContainer.Delete(o);
        }

        public void Delete<T>(Predicate<T> p)
        {
            foreach (var f in Query<T>(p))
            {
                Delete(f);
            }
        }

        #region IDisposable 成員

        public void Dispose()
        {
            DBContainer.Dispose();
        }

        #endregion
    }

    /// <summary>
    /// Db4o服務器管理器
    /// </summary>
    // ReSharper disable once InconsistentNaming
    public class Db4oServerManager : IDisposable
    {
        private IObjectServer _db4OServer;
        private readonly string _dbFilePath;

        /// <summary>
        /// 構造函數
        /// </summary>
        /// <param name="dbFilePath">數據庫文件路徑，通常使用Server.MapPath("/xxxx/xx.xx")函數獲取到。</param>
        public Db4oServerManager(string dbFilePath)
        {
            _dbFilePath = dbFilePath;
            OpenServer();
        }

        private void OpenServer()
        {
            IServerConfiguration serverConfig = Db4oClientServer.NewServerConfiguration();
            _db4OServer = Db4oClientServer.OpenServer(serverConfig, _dbFilePath, 0);
        }

        /// <summary>
        /// 開啟一個客戶端實例
        /// </summary>
        /// <returns>客戶端實例</returns>
        public IObjectContainer OpenClient()
        {
        Begin:
            try
            {
                return _db4OServer.OpenClient();
            }
            catch
            {
                OpenServer();
                goto Begin;
            }
        }

        /// <summary>
        /// 創建一個服務器訪問器對象。注意，對數據進行修改后必須釋放此對象才能真正的將更改提交到服務器。
        /// </summary>
        /// <returns>一個服務器訪問器對象</returns>
        public Db4oServerAccessor CreatAccessor()
        {
            return new Db4oServerAccessor(this);
        }

        /// <summary>
        /// 創建並訪問一個服務器訪問器對象。
        /// </summary>
        /// <param name="action">對服務器訪問器對象的操作行為</param>
        public void Access(Action<Db4oServerAccessor> action)
        {
            using (var dba = CreatAccessor())
            {
                action(dba);
            }
        }

        /// <summary>
        /// 創建並訪問一個服務器訪問器對象，繼而獲得返回值。
        /// </summary>
        /// <param name="action">對服務器訪問器對象的操作行為</param>
        /// <typeparam name="T">返回值類型</typeparam>
        public T AccessAndReturn<T>(Func<Db4oServerAccessor,T> action)
        {
            T v = default(T);
            using (var dba = CreatAccessor())
            {
                v= action(dba);
                //System.Diagnostics.Debug.WriteLine(v.ToString());
            }
            return v;
        }

        #region IDisposable 成員

        public void Dispose()
        {
            _db4OServer.Dispose();
        }

        #endregion
    }

結語

最后容我再鄭重向大家強力推薦一下Db4o，真心的，桌面、網站、移動無往不利，你值得擁有。