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文件的内容。这段代码是经过我的修改，支持中文。在此复制代码: 

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

希望能帮助到您！