Sqlite-net 修改版 支持中文和CodeFirst技術

最近, 做的一個windows 桌面WPF程式， 需要資料庫支持，嘗試了 sql server 的開發版，使用EF , 效率太低，后來采用sqlite資料庫，中間踩坑無數，但最終完美的解決了這些問題，為了幫助廣大程式員更好的使用sqlite ，今分享所有相關代碼，

sqlite , 是一款免費的資料庫管理程式，可以嵌入到桌面應用程式、asp.net 網站應用程式中，對于不太復雜軟體來說，是個不錯的選擇，

sqlite-net , 是sqlite的擴展程式，支持codefirst，并自動遷移，筆者認為比EF好很多，也方便使用，但原版不支持中文（中文顯示亂碼），經本人修改后，已經支持中文了，

CodeFirst 技術，是一種無需事先創建資料庫，而是用C#代碼創建業務物件（類）的方式，創建資料庫，這種方式，減少了作業量，是理想的使用資料庫的方式，

要在WPF桌面軟體中添加sqlite , 遵循以下步驟：

1)  打開Visual Studio, 創建wpf 專案， 右鍵點擊專案的”參考“檔案夾，點：管理nuget程式包

2）點“瀏覽”，搜索：sqlite, 選擇第一項, 點安裝，安裝后生成專案，

3）搜索：sqlite-net, 選擇第一項，點安裝，當前版本是：sqlite-net.1.6.292; 專案中會增加兩個cs代碼檔案：SQLite.cs 和 SQLiteAsync.cs

4)  重點：用如下代碼替換 SQLite.cs檔案的內容，這段代碼是經過我的修改，支持中文，在此復制代碼: https://www.cnblogs.com/lmp138/articles/11962112.html

5）要應用sqlite-net, 首先，添加業務物件類，如下：統計表；注意：using SQLite;

using SQLite;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Sqlite4
{
    [Serializable]
    public class 統計表
    {
        [PrimaryKey, AutoIncrement]
        public long Id { get; set; }

        public string 表名稱 { get; set; }
        public string 說明 { get; set; }
        public int 記錄數 { get; set; }
        public int 序號 { get; set; }
        public DateTime 更新時間 { get; set; }
    }

}

6) 創建SQLiteHelper類

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using SQLite;

namespace Sqlite4
{
    /// <summary>
    /// 處理資料庫的操作，
    /// 需要 sqlite3.dll的配合，專案檔案應添加該檔案
    /// 本類，包含一個靜態的字典，儲存對資料庫檔案的連接，
    /// 建構式可以指定不同的資料庫檔案
    /// </summary>
    public class SQLiteHelper : IDisposable
    {
        /// <summary>
        /// 互斥鎖物件
        /// </summary>
        private static readonly object objForLock = new object();
        /// <summary>
        /// 連接字典: Key : 資料庫的檔案名，Value: 該檔案的資料庫連接
        /// </summary>
        private static readonly Dictionary<string, SQLiteConnection> ConnDic = new Dictionary<string, SQLiteConnection>();

        /// <summary>
        /// 連接
        /// </summary>
        private SQLiteConnection cnn = null;

        /// <summary>
        ///   打開資料庫連接，日期時間采用字串方式，
        /// </summary>
        /// <param name="dbPath">資料庫的檔案名</param>
        public SQLiteHelper(string dbPath)
        {
            if (ConnDic.ContainsKey(dbPath))
            {
                cnn = ConnDic[dbPath];
            }
            else
            {
                cnn = new SQLiteConnection(dbPath, false); // 資料庫中，日期使用DateTime型別，而不是 Ticks
                ConnDic.Add(dbPath, cnn);
            }
        }
        /// <summary>
        /// 關閉打開的檔案連接
        /// </summary>
        public void Close()
        {
            ConnDic.Remove(cnn.DatabasePath);  // 從字典里洗掉
            cnn.Close();  // 關閉連接
        }
        /// <summary>
        /// 創建所有的表到資料庫,表已存在不會重復創建
        /// 要增加表到資料庫, 參考:ClassLibraryEF空間下的 CodeFirstClass.css檔案
        /// </summary>
        public void CreateMyTables()
        {
            cnn.CreateTable<統計表>();
        
         }
 

        

        /// <summary>
        /// 洗掉一項
        /// </summary>
        /// <param name="obj"></param>
        /// <returns></returns>
        public int Delete(object obj)
        {
            lock (objForLock)
            {
                return cnn.Delete(obj);
            }
        }

        /// <summary>
        /// 洗掉一組
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="list"></param>
        /// <returns></returns>
        public int DeleteRange<T>(IEnumerable<T> list)
        {
            lock (objForLock)
            {
                int c = 0;
                cnn.RunInTransaction(() =>
                {
                    foreach (var item in list)
                    {
                        c += cnn.Delete(item);
                    }
                });

                return c;
            }
        }

        /// <summary>
        /// 洗掉表的所有內容
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <returns></returns>
        public int DeleteAll<T>()
        {
            lock (objForLock)
            {
                return cnn.DeleteAll<T>();
            }
        }

        /// <summary>
        /// 插入資料
        /// </summary>
        /// <param name="data"></param>
        /// <returns></returns>
        public int Insert(object data)
        {
            lock (objForLock)
            {
                return cnn.Insert(data);
            }
        }
        /// <summary>
        /// 插入資料
        /// </summary>
        /// <param name="objects"></param>
        /// <returns></returns>
        public int InsertAll(System.Collections.IEnumerable objects)
        {
            lock (objForLock)
            {
                return cnn.InsertAll(objects);
            }
        }

        /// <summary>
        /// 更新一項
        /// </summary>
        /// <param name="obj"></param>
        /// <returns></returns>
        public int Update(object obj)
        {
            lock (objForLock)
            {
                return cnn.Update(obj);
            }
        }

        public int UpdateAll(System.Collections.IEnumerable objects)
        {
            lock (objForLock)
            {
                return cnn.UpdateAll(objects);
            }
        }

        /// <summary>
        /// 執行SQL命令
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public int Execute(string sql)
        {
            lock (objForLock)
            {
                return cnn.Execute(sql);
            }
        }

        /// <summary>
        /// 備份
        /// </summary>
        /// <param name="destFileName"></param>
        public void Backup(string destFileName)
        {
            lock (objForLock)
            {
                File.Copy(cnn.DatabasePath, destFileName);
            }
        }

       

        /// <summary>
        /// 回傳所有記錄
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <returns></returns>
        public List<T> ToListAll<T>() where T : new()
        {
            lock (objForLock)
            {
                Type tp = typeof(T);
                string sql = $"select * from {tp.Name}";
                return cnn.Query<T>(sql);
            }
        }

        /// <summary>
        /// 查詢sql表示的記錄
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="sql"></param>
        /// <returns></returns>
        public List<T> ToListSql<T>(string sql) where T : new()
        {
            lock (objForLock)
            {
                return cnn.Query<T>(sql);
            }
        }

        /// <summary>
        /// 回傳sql描述的記錄
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="sql"></param>
        /// <returns></returns>
        public List<T> ToList<T>(string sql) where T : new()
        {
            lock (objForLock)
            {
                return cnn.Query<T>(sql);
            }
        }

        /// <summary>
        /// 查詢表的內容，使用SQL陳述句
        /// </summary>
        /// <param name="tableName"></param>
        /// <param name="sqlText"></param>
        /// <returns></returns>
        public IList<object> Query(string tableName, string sqlText)
        {
            lock (objForLock)
            {
                Type tp = GetTypeByTableName(tableName);
                if (tp == null)
                    return null;
                SQLite.TableMapping tm = cnn.GetMapping(tp);
                return cnn.Query(tm, sqlText);
            }
        }

        /// <summary>
        /// 獲取表
        /// </summary>
        /// <param name="tableName"></param>
        /// <returns></returns>
        public IList<object> ToListByTableName(string tableName)
        {
            lock (objForLock)
            {
                Type tp = GetTypeByTableName(tableName);
                if (tp == null)
                    return null;

                SQLite.TableMapping tm = cnn.GetMapping(tp);
                return cnn.Query(tm, $"select * from {tableName}");
            }
        }

        /// <summary>
        /// 根據表名稱，獲得型別
        /// </summary>
        /// <param name="tableName"></param>
        /// <returns></returns>
        public Type GetTypeByTableName(string tableName)
        {
            Assembly assembly = Assembly.Load("ClassLibraryEF");
            Type[] types = assembly.GetTypes();

            foreach (Type tp in types)
            {
                if (tp.Name == tableName)
                    return tp;
            }
            return null;
        }
 

        /// <summary>
        /// 獲取表的行數
        /// </summary>
        /// <param name="tableName"></param>
        /// <returns></returns>
        public int GetCountOfTable(string tableName)
        {
            lock (objForLock)
            {
                return cnn.CreateCommand($"select count(*) from {tableName}").ExecuteScalar<int>();
            }
        }

        /// <summary>
        /// Sqlite標準時間
        /// </summary>
        /// <param name="dt"></param>
        /// <returns></returns>
        public string SqliteDateTimeStr(DateTime dt)
        {
            return dt.ToString("yyyy-MM-ddTHH:mm:ss");
        }

        /// <summary>
        /// Sqlite標準時間字串，日期的最后一秒
        /// </summary>
        /// <param name="dt"></param>
        /// <returns></returns>
        public string SqliteDateTimeStr_EndDayTime(DateTime dt)
        {
            return dt.ToString("yyyy-MM-ddT23:59:59");
        }

        /// <summary>
        /// Sqlite標準時間字串，日期的開始0秒
        /// </summary>
        /// <param name="dt"></param>
        /// <returns></returns>
        public string SqliteDateTimeStr_BeginDayTime(DateTime dt)
        {
            return dt.ToString("yyyy-MM-ddT00:00:00");
        }

        /// <summary>
        /// 釋放時，無需釋放任何物件，因為采用靜態的Sqlite連接，
        /// 如果釋放靜態連接，之后的實體將重新創建連接，太頻繁
        /// </summary>
        public void Dispose()
        {

        }
    }
}

7）創建SqliteDb類

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Sqlite4
{
    /// <summary>
    /// sqlite 資料庫管理，
    /// </summary>
    class SqliteDb : SQLiteHelper
    {
        private static string path = "d:\\data1.db";  // 任意本地資料檔案名，如果不存在該檔案會自動創建

        public SqliteDb() : base(path)
        {


        }

        /// <summary>
        /// 獲取表的所有記錄
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <returns></returns>
        public static List<T> GetList<T>() where T : new()
        {
            using (SqliteDb db = new SqliteDb())
            {
                return db.ToListAll<T>();
            }
        }
        /// <summary>
        /// 表中獲取某個代碼的第一項記錄
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="code"></param>
        /// <returns></returns>
        public static T GetItem<T>(string code) where T : new()
        {
            using (SqliteDb db = new SqliteDb())
            {
                string tableName = typeof(T).Name;
                var sql = $"select * from {tableName} where 代碼 = '{code}'";
                var list = db.ToList<T>(sql);
                if (list.Count > 0)
                    return list[0];
                return default(T);
            }
        }
        /// <summary>
        /// 回傳指定代碼的所有記錄
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="code"></param>
        /// <returns></returns>
        public static List<T> GetItems<T>(string code) where T : new()
        {
            using (SqliteDb db = new SqliteDb())
            {
                string tableName = typeof(T).Name;
                var sql = $"select * from {tableName} where 代碼 = '{code}'";
                return db.ToList<T>(sql);
            }
        }
    }
}

8）添加：sqlite3.dll到專案檔案中，生成專案，則專案的Release檔案夾下，多了兩個檔案夾：x64 和x86; 分別存盤64位和32位的sqlite驅動程式；根據你程式的位數，添加需要的sqlite3.dll到專案中，生成操作：內容；復制到輸出目錄：如果較新則復制，

9）MainWindow.xaml檔案中，添加表：

  <DataGrid x:Name="dg1" />

10）主視窗中添加事件： Loaded="Window_Loaded"

11)添加事件處理程式：

        private void Window_Loaded(object sender, RoutedEventArgs e)
        {
            try
            {
            LoadDb();

            }
            catch(Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
        }
        /// <summary>
        /// 載入資料庫內容
        /// </summary>
        private void LoadDb()
        {
            using(SqliteDb db = new SqliteDb())
            {
                db.CreateMyTables();

                統計表 t = new 統計表()
                { 序號 = 1, 更新時間 = DateTime.Now, 表名稱 = "A表", 記錄數 = 100, 說明 = "測驗" };

                db.Insert(t);

                this.dg1.ItemsSource = db.ToListAll<統計表>();
            }
        }

12）生成專案

13）運行

14) 如果要修改統計表的內容，只需修改該類即可，sqlite-net 會自動遷移，給資料庫增加相關的列，

15）增刪改查請參考：上面的SQLiteHelper類中的函式即可，

本文章涉及的源代碼下載 : https://files.cnblogs.com/files/lmp138/Sqlite4.7z

希望能幫助到您！

標籤：Entity Framework

上一篇：ADO.NET ORM資料庫增刪改查封裝（工具一）

下一篇：EFCore的外鍵級聯洗掉導致的【可能會導致回圈或多重級聯路徑】