当前位置：
  1. 首页
  2. 市民
  3. 正文

最近, 做的一个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

希望能帮助到您！

 

上一篇 2022年21岁是哪年出生的，67年属羊人53岁财运
下一篇 asp.net core中使用cookie身份验证

相关文章