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

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

最近, 做的一個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; }
    }

}

View Code

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()
        {

        }
    }
}

View Code

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);
            }
        }
    }
}

View Code

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

9）MainWindow.xaml文件中，添加表：

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<統計表>();
            }
        }

View Code

12）生成項目

13）運行

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

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

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

希望能幫助到您！

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

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