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

来源:https://www.cnblogs.com/lmp138/archive/2019/11/30/11962095.html

最近, 做的一個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文件中,添加表:

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

12)生成項目

13)運行

 

 

 

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

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

 

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

希望能幫助到您!

 


您的分享是我們最大的動力!

更多相關文章
  • 本系列將和大家分享下ASP.NET Core Web 應用程式的一些基礎知識,本章主要簡單介紹下在ASP.NET Core中如何使用AutoMapper進行實體映射。 ...
  • 作為開發人員,您始終需要處理應用程式配置數據。常見的示例是INI 文件,XML文件, .NET配置文件(也稱為“ .config”),Windows註冊表和命令行(argv)參數。配置文件的優點是它們載入速度快,不占用大量空間且易於編輯。Nini是一個功能強大的 .NET配置庫,旨在幫助快速構建高度... ...
  • 探究 C 中的 char 、 string(一) [TOC] 1. System.Char 字元 char 是 System.Char 的別名。 System.Char 占兩個位元組,16個二進位位。 System.Char 用來表示、存儲一個 Unicode 字元。 System.Char 的表示範 ...
  • 今天介紹一個開源的C# WPF開源控制項庫,非常漂亮,重點是開源哦 WPF做桌面開發是很有優勢的,除了微軟自帶的控制項外,還有很多第三方的控制項庫,比如收費的Dev Express For WPF、Telerik For WPF等,及Github上開源免費的控制項庫如MaterialDesignInXAML ...
  • Mark Zhou寫了很不錯的一系列介紹C# 7的文章,雖然是2年多年前發佈的,不過對於不熟悉C# 7特性的同學來說,仍然有很高的閱讀價值。 原文:https://blogs.msdn.microsoft.com/mazhou/2017/05/26/c-7-series-part-1-value-t ...
  • 配置 在 Startup.ConfigureServices 方法中,創建具有 AddAuthentication 和 AddCookie 方法的身份驗證中間件服務: AuthenticationScheme 傳遞到 AddAuthentication 設置應用程式的預設身份驗證方案。 如果有多個 ...
  • abp攔截器基本定義 攔截器介面定義: 預設抽象類定義: abp的攔截器實現是基於Autofac.Extras.DynamicProxy,這個包依賴兩個組件:Autofac、Castle.Core(實質上是調用內部組件DynamicProxy實現動態代理)。關於此組件的資料參考 ".NET 通過 A ...
  • 面向對象開發有三大特性(特點 / 特征) : 封裝, 繼承, 多態。我們今天主要討論封裝和繼承,多態會在下篇中討論。 一、封裝: 所謂封裝,也就是把客觀事物封裝成抽象的類,並且類可以把自己的數據和方法只讓可信的類或者對象操作,對不可信的進行信息隱藏。封裝是面向對象的特征之一,是對象和類概念的主要特性 ...
一周排行
  • 在園子裡面有很多關於各種技術細節的研究文章,都是比較牛逼的框架研究;但是一直沒有看到關於怎麼樣提高開發效率的文章,大多提高開發效率的文章都是關於自動化等方面的輔助工具類型的,而不是開發中的一些小技巧;今天從編碼規範、編碼技巧、開發思想、設計模式等各方面的經驗來分享如何提高開發效率。 ...
  • 前言 隨著近些年微服務的流行,有越來越多的開發者和團隊所採納和使用,它的確提供了很多的優勢也解決了很多的問題,但是我們也知道也並不是銀彈,提供優勢的同時它也給我們的開發人員和團隊也帶來了很多的挑戰。 為了迎接或者採用這些新技術,開發團隊需要更加註重一些流程或工具的使用,這樣才能更好的適應這些新技術所 ...
  • 本文是本系列的完結篇。本系列前面的文章: 邏輯式編程語言極簡實現(使用C#) - 1. 邏輯式編程語言介紹 邏輯式編程語言極簡實現(使用C#) - 2. 一道邏輯題:誰是凶手 邏輯式編程語言極簡實現(使用C#) - 3. 運行原理 下午,吃飽飯的老明和小皮,各拿著一杯剛買的咖啡回到會議室,開始了邏輯 ...
  • 微服務之間的通信之gRPC 介紹 gRPC是一種與語言無關的高性能遠程過程調用 (RPC) 框架,gRPC是Google發佈的基於HTTP 2.0傳輸層協議承載的高性能開源軟體框架,提供了支持多種編程語言的、對網路設備進行配置和納管的方法。由於是開源框架,通信的雙方可以進行二次開發,所以客戶端和服務 ...
  • 一、TLS 線程本地存儲(Thread Local Storage),字面意思就是專屬某個線程的存儲空間。變數大體上分為全局變數和局部變數,一個進程中的所有線程共用地址空間,這個地址空間被劃分為幾個固有的區域,比如堆棧區,全局變數區等,全局變數存儲在全局變數區,虛擬地址固定;局部變數存儲在堆棧區,虛... ...
  • private:私有成員,在類的內部才可以訪問。 protected:保護成員,該類內部和繼承類中可以訪問。 public:公共成員,完全公開,沒有訪問限制。 internal:當前程式集內可以訪問。 ...
  • 前言 上一篇【.Net Core微服務入門全紀錄(六)——EventBus-事件匯流排】中使用CAP完成了一個簡單的Eventbus,實現了服務之間的解耦和非同步調用,並且做到數據的最終一致性。這一篇將使用IdentityServer4來搭建一個鑒權中心,來完成授權認證相關的功能。 IdentitySe ...
  • using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System. ...
  • 從今天起,我將製作一個電影推薦項目,在此寫下博客,記錄每天的成果。 其實,從我發佈 C# 爬取貓眼電影數據 這篇博客後, 我就已經開始製作電影推薦項目了,今天寫下這篇博客,也是因為項目進度已經完成50%了,我就想在這一階段停一下,回顧之前學到的知識。 一、主要為手機端 考慮到項目要有實用性,我選擇了 ...
  • 一、實現Runnable介面 public class RunnableDemo implements Runnable { public void run() { try { Thread.sleep(100); } catch (InterruptedException e) { e.print ...