当前位置： 首页 > news >正文

C# 实现轻量化数据库SQLite在工业中上的应用

news 来源：原创 2025/5/23 5:11:37

1、安装：

安装SQLite可视化工具，SQLiteStudio.下载地址：SQLite

新建.NET FromWork项目，在NUGet包中安装System.Data.SQLite包。或者直接在引用中添加System.Data.SQLite.dll配置文件。

2、连接数据库

public const string ConfigPath = "D:\\FuyaoGroup\\SQLite_Test\\Config.db";//数据库成员变量public SQLiteConnection DBcn_Config;      //DB连接对象public SQLiteDataAdapter DBadp_Config;    //作为DataSet与数据库之间的桥梁，用于填充数据(Fill方法)和将修改更新回数据库(Update方法)。public DataSet DBds_Config;               //BD数据临时储存public SQLiteCommand DBSqlCmd_Config;     //表格操作public void ConnectDataBase(){try{DBcn_Config = new SQLiteConnection($"Data Source={ConfigPath};Persist Security Info=False");if (DBcn_Config.State == ConnectionState.Closed) DBcn_Config.Open();         // 打开数据库                             string SqlstrConfig = "select * from Sys_Config Order by id DESC";           // 定义查询规则，从下往上         DBadp_Config = new SQLiteDataAdapter(SqlstrConfig, DBcn_Config);             // 创建数据适配器               DBds_Config = new DataSet();                                                 // 创建数据集               DBadp_Config.Fill(DBds_Config, "Sys_Config");                                // 将数据源中选中的记录填充到数据集 Fig_DBOpen = true;TB_DBState.Text = "数据库连接成功！";}catch(Exception ex) {MessageBox.Show(ex.Message);              TB_DBState.Text = "数据库连接失败！";Fig_DBOpen = false;}}

2、加载数据库中所有表，并在listBox中显示

  public void loadRecipe(){string sql = "SELECT name FROM sqlite_master WHERE type='table' ORDER BY name";SQLiteCommand cmd = new SQLiteCommand(sql, DBcn_Recipe);using (SQLiteDataReader dr = cmd.ExecuteReader()){listBox1.Items.Clear();while (dr.Read()){if (dr["name"].ToString() != "sqlite_sequence"){listBox1.Items.Add(dr["name"].ToString());}                 }}}

3、读取数据库中某表

 public void ReadRecipe(string Recipe_Table){if (Fig_DBOpen){try{ //初始化查询变量string SqlstrRecipe = $"select * from {Recipe_Table} Order by id DESC";DBadp_Recipe = new SQLiteDataAdapter(SqlstrRecipe, DBcn_Recipe);DBds_Recipe = new DataSet();DBadp_Recipe.Fill(DBds_Recipe, Recipe_Table);//读取数据TB_Name.Text = Convert.ToString(DBds_Recipe.Tables[Recipe_Table].Rows[0]["name"] as object);TB_Age.Text = Convert.ToString(DBds_Recipe.Tables[Recipe_Table].Rows[0]["age"] as object);TB_Height.Text = Convert.ToString(DBds_Recipe.Tables[Recipe_Table].Rows[0]["height"] as object);TB_Weight.Text = Convert.ToString(DBds_Recipe.Tables[Recipe_Table].Rows[0]["weight"] as object);}catch(Exception ex){MessageBox.Show(ex.Message);}             }else{MessageBox.Show("读取失败，请检查数据库连接");}}

4、新建表，并向表中填充数据

public void WriteRecipe(string Recipe_Table){          if (Fig_DBOpen){try{string createTableSql = $@"CREATE TABLE IF NOT EXISTS {Recipe_Table} (id INTEGER PRIMARY KEY AUTOINCREMENT,name TEXT NOT NULL,age TEXT,height TEXT ,weight TEXT )";using (SQLiteCommand cmd = new SQLiteCommand(createTableSql, DBcn_Recipe)){cmd.ExecuteNonQuery();}string SqlstrRecipe = $"select * from {Recipe_Table} Order by id DESC";DBadp_Recipe = new SQLiteDataAdapter(SqlstrRecipe, DBcn_Recipe);DBds_Recipe = new DataSet();DBadp_Recipe.Fill(DBds_Recipe, Recipe_Table);SQLiteCommandBuilder DBCmdBd_SysConfig = new SQLiteCommandBuilder(DBadp_Recipe);      //使用SQLiteCommandBuilder简化操作            DataRow DataRow_Sys = DBds_Recipe.Tables[Recipe_Table].NewRow();                      //在DataSet新增一行//写入数据DataRow_Sys["name"] = TB_Name.Text;DataRow_Sys["age"] = TB_Age.Text;DataRow_Sys["height"] = TB_Height.Text;DataRow_Sys["weight"] = TB_Weight.Text;//新建的Row添加到DataSetDBds_Recipe.Tables[Recipe_Table].Rows.Add(DataRow_Sys);//更新DataSet数据缓存到真实数据表中DBadp_Recipe.InsertCommand = DBCmdBd_SysConfig.GetInsertCommand();DBadp_Recipe.Update(DBds_Recipe, Recipe_Table);loadRecipe();}catch(Exception ex){MessageBox.Show(ex.Message);}            }else{MessageBox.Show("写入失败，请检查数据库连接");}}

5、删除某表

 public void dropTabRecipe(string Recipe_Table){try{string dropTableSql = $"DROP TABLE IF EXISTS {Recipe_Table};";using (SQLiteCommand cmd = new SQLiteCommand(dropTableSql, DBcn_Recipe)){cmd.ExecuteNonQuery();MessageBox.Show($"表{Recipe_Table}已成功删除。");loadRecipe();}}catch (Exception ex){ MessageBox.Show($"删除表时发生错误: {ex.Message}");}}

完整代码
 

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Data.SQLite;namespace SQLite_Test
{public partial class Form1 : Form{public Form1(){InitializeComponent();}private void Form1_Load(object sender, EventArgs e){ConnectDataBase(); //打开数据库ReadConfig();      //加载系统信息loadRecipe();      //加载产品至listBox中}#region 变量//数据库路径public const string ConfigPath = "D:\\FuyaoGroup\\SQLite_Test\\Config.db";public const string RecipePath = "D:\\FuyaoGroup\\SQLite_Test\\Recipe.db";public const string ResultPath = "D:\\FuyaoGroup\\SQLite_Test\\Sys_Result.db";//数据库成员变量public SQLiteConnection DBcn_Config;      //DB连接对象public SQLiteDataAdapter DBadp_Config;    //作为DataSet与数据库之间的桥梁，用于填充数据(Fill方法)和将修改更新回数据库(Update方法)。public DataSet DBds_Config;               //BD数据临时储存public SQLiteCommand DBSqlCmd_Config;     //表格操作public SQLiteConnection DBcn_Recipe;   public SQLiteDataAdapter DBadp_Recipe; public DataSet DBds_Recipe;            public SQLiteCommand DBSqlCmd_Recipe;  public SQLiteConnection DBcn_Result;   public SQLiteDataAdapter DBadp_Result; public DataSet DBds_Result;            public SQLiteCommand DBSqlCmd_Result;  //系统相关变量public bool   Fig_DBOpen=false;#endregion//连接数据库public void ConnectDataBase(){try{DBcn_Config = new SQLiteConnection($"Data Source={ConfigPath};Persist Security Info=False");if (DBcn_Config.State == ConnectionState.Closed) DBcn_Config.Open();         // 打开数据库                             string SqlstrConfig = "select * from Sys_Config Order by id DESC";           // 定义查询规则，从下往上         DBadp_Config = new SQLiteDataAdapter(SqlstrConfig, DBcn_Config);             // 创建数据适配器               DBds_Config = new DataSet();                                                 // 创建数据集               DBadp_Config.Fill(DBds_Config, "Sys_Config");                                // 将数据源中选中的记录填充到数据集 DBcn_Recipe= new SQLiteConnection($"Data Source={RecipePath};Persist Security Info=False");if (DBcn_Recipe.State == ConnectionState.Closed) DBcn_Recipe.Open();DBcn_Result = new SQLiteConnection($"Data Source={ResultPath};Persist Security Info=False");if (DBcn_Result.State == ConnectionState.Closed) DBcn_Result.Open();string SqlstrResult = "select * from Prods_Result Order by id DESC";DBadp_Result = new SQLiteDataAdapter(SqlstrResult, DBcn_Result);DBds_Result = new DataSet();DBadp_Result.Fill(DBds_Result, "Prods_Result");Fig_DBOpen = true;TB_DBState.Text = "数据库连接成功！";}catch(Exception ex) {MessageBox.Show(ex.Message);              TB_DBState.Text = "数据库连接失败！";Fig_DBOpen = false;}}//*********COnfig***********////读公共配置public void ReadConfig(){if (Fig_DBOpen){//重新执行查询（防止数据库已经被改动）DBadp_Config.SelectCommand.CommandText = "select * from Sys_Config Order by id DESC";DBds_Config.Clear();DBadp_Config.Fill(DBds_Config, "Sys_Config");//读取数据TB_Shool.Text = Convert.ToString(DBds_Config.Tables["Sys_Config"].Rows[0]["shool"] as object);TB_Grade.Text = Convert.ToString(DBds_Config.Tables["Sys_Config"].Rows[0]["grade"] as object);TB_Class.Text = Convert.ToString(DBds_Config.Tables["Sys_Config"].Rows[0]["class"] as object);TB_Teacher.Text = Convert.ToString(DBds_Config.Tables["Sys_Config"].Rows[0]["teacher"] as object);}else {MessageBox.Show("读取失败，请检查数据库连接");}}//写公共配置public void WriteConfig(){if (Fig_DBOpen){//使用SQLiteCommandBuilder对操作进行简化，实现增删改操作SQLiteCommandBuilder DBCmdBd_SysConfig = new SQLiteCommandBuilder(DBadp_Config);//在DataSet新增一行DataRow DataRow_Sys = DBds_Config.Tables["Sys_Config"].NewRow();//写入数据DataRow_Sys["shool"] = TB_Shool.Text;DataRow_Sys["grade"]  = TB_Grade.Text;DataRow_Sys["class"] = TB_Class.Text;DataRow_Sys["teacher"] = TB_Teacher.Text;//新建的Row添加到DataSetDBds_Config.Tables["Sys_Config"].Rows.Add(DataRow_Sys);//更新DataSet数据缓存到真实数据表中DBadp_Config.InsertCommand = DBCmdBd_SysConfig.GetInsertCommand();DBadp_Config.Update(DBds_Config, "Sys_Config");ReadConfig();}else{MessageBox.Show("写入失败，请检查数据库连接");}}//********Recipe************//public void loadRecipe(){string sql = "SELECT name FROM sqlite_master WHERE type='table' ORDER BY name";SQLiteCommand cmd = new SQLiteCommand(sql, DBcn_Recipe);using (SQLiteDataReader dr = cmd.ExecuteReader()){listBox1.Items.Clear();while (dr.Read()){if (dr["name"].ToString() != "sqlite_sequence"){listBox1.Items.Add(dr["name"].ToString());}                 }}}public void ReadRecipe(string Recipe_Table){if (Fig_DBOpen){try{ //初始化查询变量string SqlstrRecipe = $"select * from {Recipe_Table} Order by id DESC";DBadp_Recipe = new SQLiteDataAdapter(SqlstrRecipe, DBcn_Recipe);DBds_Recipe = new DataSet();DBadp_Recipe.Fill(DBds_Recipe, Recipe_Table);//读取数据TB_Name.Text = Convert.ToString(DBds_Recipe.Tables[Recipe_Table].Rows[0]["name"] as object);TB_Age.Text = Convert.ToString(DBds_Recipe.Tables[Recipe_Table].Rows[0]["age"] as object);TB_Height.Text = Convert.ToString(DBds_Recipe.Tables[Recipe_Table].Rows[0]["height"] as object);TB_Weight.Text = Convert.ToString(DBds_Recipe.Tables[Recipe_Table].Rows[0]["weight"] as object);}catch(Exception ex){MessageBox.Show(ex.Message);}             }else{MessageBox.Show("读取失败，请检查数据库连接");}}public void WriteRecipe(string Recipe_Table){          if (Fig_DBOpen){try{string createTableSql = $@"CREATE TABLE IF NOT EXISTS {Recipe_Table} (id INTEGER PRIMARY KEY AUTOINCREMENT,name TEXT NOT NULL,age TEXT,height TEXT ,weight TEXT )";using (SQLiteCommand cmd = new SQLiteCommand(createTableSql, DBcn_Recipe)){cmd.ExecuteNonQuery();}string SqlstrRecipe = $"select * from {Recipe_Table} Order by id DESC";DBadp_Recipe = new SQLiteDataAdapter(SqlstrRecipe, DBcn_Recipe);DBds_Recipe = new DataSet();DBadp_Recipe.Fill(DBds_Recipe, Recipe_Table);SQLiteCommandBuilder DBCmdBd_SysConfig = new SQLiteCommandBuilder(DBadp_Recipe);      //使用SQLiteCommandBuilder简化操作            DataRow DataRow_Sys = DBds_Recipe.Tables[Recipe_Table].NewRow();                      //在DataSet新增一行//写入数据DataRow_Sys["name"] = TB_Name.Text;DataRow_Sys["age"] = TB_Age.Text;DataRow_Sys["height"] = TB_Height.Text;DataRow_Sys["weight"] = TB_Weight.Text;//新建的Row添加到DataSetDBds_Recipe.Tables[Recipe_Table].Rows.Add(DataRow_Sys);//更新DataSet数据缓存到真实数据表中DBadp_Recipe.InsertCommand = DBCmdBd_SysConfig.GetInsertCommand();DBadp_Recipe.Update(DBds_Recipe, Recipe_Table);loadRecipe();}catch(Exception ex){MessageBox.Show(ex.Message);}            }else{MessageBox.Show("写入失败，请检查数据库连接");}}public void dropTabRecipe(string Recipe_Table){try{string dropTableSql = $"DROP TABLE IF EXISTS {Recipe_Table};";using (SQLiteCommand cmd = new SQLiteCommand(dropTableSql, DBcn_Recipe)){cmd.ExecuteNonQuery();MessageBox.Show($"表{Recipe_Table}已成功删除。");loadRecipe();}}catch (Exception ex){ MessageBox.Show($"删除表时发生错误: {ex.Message}");}}#region 界面操作//Config更新private void BT_UpdataConfig_Click(object sender, EventArgs e){WriteConfig();}//Recipe加载private void BT_RecipeLode_Click(object sender, EventArgs e){if (textBox1.Text != ""){ReadRecipe(textBox1.Text);}else {MessageBox.Show("请选择产品");}}//Recipe保存private void button4_Click(object sender, EventArgs e){if (textBox1.Text != ""){WriteRecipe(textBox1.Text);}else{MessageBox.Show("请选择产品");}}//Recipe删除private void button3_Click(object sender, EventArgs e){if (textBox1.Text != ""){dropTabRecipe(textBox1.Text);}else{MessageBox.Show("请选择产品");}}//listBox选择事件private void listBox1_SelectedIndexChanged(object sender, EventArgs e){if (listBox1.SelectedItem != null){textBox1.Text = listBox1.SelectedItem.ToString();}}#endregion}
}

完整代码工程：

项目链接

相关文章：

  • JVM——内存模型
  • [Git] 认识 Git 的三大区域 文件的修改和提交
  • github cli主要用途，优势，和git的区别
  • 2025淘宝最新DSR评分计算方式
  • WebSocket 从入门到进阶实战
  • 【计算机网络】网络层——IP协议
  • 生成树协议（STP）配置详解：避免网络环路的最佳实践
  • Ubuntu Desktop 24.04 常用软件安装步骤
  • 【C++20新特性】ranges::sort()使用方法，优势，注意点
  • Python与自动驾驶数据集处理：构建智能驾驶的基石
  • DRIVEVLM: 大视觉语言模型和自动驾驶的融合
  • java jdbc执行Oracle sql文件
  • Centos系统资源镜像配置
  • 批量处理合并拆分pdf功能 OCR 准确率高 免费开源
  • Intel oneMKL 入门
  • 手机打电话时由对方DTMF响应切换多级IVR语音菜单（完结）
  • 基于deepseek 以及豆包工具+nodejs 搭建A I自动化客服系统
  • 【brpc】安装与使用
  • MySQL初阶：JDBC
  • WPF读取json文件，用到combox控件
  • 网站备案 论坛/网络运营师
  • 建设官方网站的请示/网络营销专业学什么课程
  • 产品展示类网站/外贸网站推广费用
  • 网站怎么做才能被百度收录/百度推广电话客服
  • 做装修网站多少钱/友情链接站长平台
  • 确定B2B网站建设方案/湖南网站seo找行者seo