欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2022-05-31 22:05:51
最近, 做的一个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文件的内容。这段代码是经过我的修改,支持中文。在此复制代码: 

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到项目中,生成操作:内容;复制到输出目录:如果较新则复制。

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

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)运行

 

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

 

14) 如果要修改统计表的内容,只需修改该类即可。sqlite-net 会自动迁移,给数据库增加相关的列。

15)增删改查请参考:上面的sqlitehelper类中的函数即可。

 

本文章涉及的源代码下载 : https://files.cnblogs.com/files/lmp138/sqlite4.7z

希望能帮助到您!