C#对SQLite数据库的操作

功能

1. 对SQLite数据库进行连接
2. 对数据库中的数据进行增删改查并更新到DataGridView控件中

一、创建数据库连接

#region 变量private string dbUrl = null;//数据库文件的地址private SQLiteConnection connection;//数据库连接对象#endregion#region 数据库工具类相关的函数/****************************************************************************************************************** * name: public DBHelper(string DBName) * Function: 指定数据库文件的地址 * Parameters: DBName ：数据库的名称 * Returns : NULL * Author: 那些你很冒险的梦 * Check : * Date: 2021-3-21******************************************************************************************************************/public DBHelper(string DBName){dbUrl = Application.StartupPath + "\\" + DBName + ".db";}/****************************************************************************************************************** * name: public SQLiteConnection Connection * Function: 创建并返回数据的连接 * Parameters: DBName ：数据库的名称 * Returns : NULL * Note: * Author: 那些你很冒险的梦 * Check : * Date: 2021-3-21******************************************************************************************************************///创建连接public SQLiteConnection Connection{get{//判断数据库文件是否存在if (!File.Exists(dbUrl)){SQLiteConnection.CreateFile(dbUrl);}//判断连接是否存在if (connection == null){connection = new SQLiteConnection("Data Source=" + dbUrl + ";Version=3;");}return connection;}set{connection = value;}}/****************************************************************************************************************** * name: public void OpenConnection() * Function: 打开数据库 * Parameters: void * Returns : NULL * Author:那些你很冒险的梦 * Check : * Date: 2021-3-21******************************************************************************************************************/public void OpenConnection(){//如果连接关闭if (connection.State == System.Data.ConnectionState.Closed){connection.Open();}//如果连接损坏if (connection.State == System.Data.ConnectionState.Broken){connection.Close();connection.Open();}}/****************************************************************************************************************** * name: public void OpenConnection() * Function: 关闭数据库连接 * Parameters: void * Returns : NULL * Author: 那些你很冒险的梦 * Check : * Date: 2021-3-21******************************************************************************************************************/public void CloseConnection(){//判断连接是否打开或者损坏if (connection.State == System.Data.ConnectionState.Open || connection.State == System.Data.ConnectionState.Broken){connection.Close();}}

二、对数据库中的数据实现增删改查

#region 对数据库中数据的增上改查/****************************************************************************************************************** * name: public void getMessage(string sql,DataGridView dataGridView) * Function: 从数据库中获取信息并填充到DataGridView控件中 * Parameters: sql：订制SQL语句dataGridView：指定数据填充的控件的名称 * Returns : NULL * Author: 那些你很冒险的梦 * Check : * Date: 2021-3-21******************************************************************************************************************/public void getMessage(string sql, DataGridView dataGridView){DataSet ds = new DataSet();try{SQLiteDataAdapter adapter = new SQLiteDataAdapter(string.Format(@sql), Connection);OpenConnection();adapter.Fill(ds, "mark");dataGridView.DataSource = ds.Tables["mark"];}catch (Exception ex){MessageTip.ShowError("数据库操作错误");MessageBox.Show(ex.ToString());}finally{CloseConnection();}}/****************************************************************************************************************** * name: public void addMessage(string sql) * Function: 向数据库中插入数据 * Parameters: sql：订制SQL语句 * Returns : NULL * Author: 那些你很冒险的梦 * Check :* Date: 2021-3-21******************************************************************************************************************/public void addMessage(string sql1, string sql2,DataGridView dataGridView){try{string sql = string.Format(@sql1);//创建连接SQLiteCommand command = new SQLiteCommand(sql1, Connection);//打开连接OpenConnection();//执行SQL语句int result = command.ExecuteNonQuery();//判断是否更新成功if (result == 0){MessageTip.ShowWarning("插入数据失败");//MessageBox.Show("插入数据失败", "系统提示", MessageBoxButtons.OK, MessageBoxIcon.Information);}else{//重新向datagridview中填充数据//UserDev.userInstance.showUserList();getMessage(sql2, dataGridView);MessageTip.ShowOk("插入数据成功");//MessageBox.Show("插入数据成功", "系统提示", MessageBoxButtons.OK, MessageBoxIcon.Information);}}catch (Exception ex){MessageTip.ShowError("数据库操作错误");MessageBox.Show(ex.ToString());//MessageBox.Show("数据库操作错误", "系统提示", MessageBoxButtons.OK, MessageBoxIcon.Information);}finally{CloseConnection();}}/****************************************************************************************************************** * name: public void deleteMessage(string sql) * Function: 从数据库中删除数据 * Parameters: sql：订制SQL语句 * Returns : NULL * Author: 那些你很冒险的梦 * Check :* Date: 2021-3-21******************************************************************************************************************/public void deleteMessage(string sql1, string sql2, DataGridView dataGridView){try{string sql = string.Format(@sql1);SQLiteCommand command = new SQLiteCommand(sql, Connection);OpenConnection();int result = command.ExecuteNonQuery();if (result != 0){getMessage(sql2, dataGridView);MessageTip.ShowOk("删除成功");//MessageBox.Show("删除成功", "系统提示", MessageBoxButtons.OK, MessageBoxIcon.Information);}else{MessageTip.ShowWarning("删除失败");//MessageBox.Show("删除失败", "系统提示", MessageBoxButtons.OK, MessageBoxIcon.Information);}}catch (Exception ex){MessageTip.ShowError("数据库操作错误");MessageBox.Show(ex.ToString());//MessageBox.Show("数据库操作错误", "系统提示", MessageBoxButtons.OK, MessageBoxIcon.Information);}finally{CloseConnection();}}/****************************************************************************************************************** * name: public void updateMessage(string sql) * Function: 更新数据库中的数据 * Parameters: sql：订制SQL语句 * Returns : NULL * Author: 那些你很冒险的梦 * Check :* Date: 2021-3-21******************************************************************************************************************/public void updateMessage(string sql1, string sql2, DataGridView dataGridView){try{string sql = string.Format(@sql1);SQLiteCommand command = new SQLiteCommand(sql, Connection);OpenConnection();int result = command.ExecuteNonQuery();if (result == 0){MessageTip.ShowWarning("修改数据失败");}else{//重新向datagridview中填充数据 UserDev.userInstance.showUserList();getMessage(sql2, dataGridView);MessageTip.ShowOk("插入数据成功");}}catch (Exception ex){MessageTip.ShowError("数据库操作错误");MessageBox.Show(ex.ToString());}finally{CloseConnection();}}#endregion

欢迎一起讨论技术问题，求关注！