C#教程之SQLite使用笔记

当前位置:

首页 > Python基础教程 >

C#教程之SQLite使用笔记

前言

客户端存储信息的方法有好多种，在以往的项目中采用的是序列化记录到文件中的方式，即时通信项目中客户端的一些系统配置的保存也使用的这种方式，然而客户端保存聊天记录就不能使用这种方式（保存、读取、修改都需要进行序列化操作比较费时，不同会话聊天记录到不同文件中，将需要创建大量的文件），调研相关技术后，决定使用SQLite。

SQLite

我的认知如下：
SQLite是一款轻量级文件数据库，无需部署安装，特点是嵌入式与事务（原子性、一致性、隔离性和持久性）。使用时只需创建一个db文件（db文件即代表一个数据库），然后利用ADO.NET进行连接库、创建、插入、查询、修改表就可以了，非常的简单方便。

步骤

1.添加引用
右键项目引用选择管理Nuget程序包搜索SQLite,选择第一个进行安装

2.创建数据库文件

string dbPath = AppDomain.CurrentDomain.BaseDirectory + "local.db";
SQLiteConnection.CreateFile(dbPath);

注意需要添加引用：using System.Data.SQLite;
3.连接SQLite

SQLiteConnection conn = new SQLiteConnection();
SQLiteConnectionStringBuilder connstr = new SQLiteConnectionStringBuilder();
connstr.DataSource = datasource;
connstr.Password = "123456";//设置密码，SQLite ADO.NET实现了数据库密码保护
conn.ConnectionString = connstr.ToString();
conn.Open();

4.创建表

SQLiteCommand cmd = new SQLiteCommand();
string sql = "CREATE TABLE FirstTable(ID varchar(36),UserName varchar(30),PassWord varchar(30))";
cmd.CommandText = sql;
cmd.Connection = conn;
cmd.ExecuteNonQuery();

5.增删改查
增：

		SQLiteCommand cmd = new SQLiteCommand();
string sql = "INSERT INTO FirstTable VALUES('1','ading3','123')";
cmd.Connection = conn;
cmd.CommandText = sql; 
cmd.ExecuteNonQuery();
	

删：

			
string sql = "DELETE FROM FirstTable WHERE ID = @ID";
SQLiteParameter[] parms =
{
new SQLiteParameter("@ID",id)
};
command.CommandText = sql;
command.Parameters.AddRange(parameters);
int counts = command.ExecuteNonQuery();
			

改：

			
string sql= @"UPDATE FirstTable
SET UserName=@UserName,
PassWord=@PassWord 
WHERE UserName='admin'
";
SQLiteParameter[] parms1 =
{
new SQLiteParameter("@UserName","adminading"),
new SQLiteParameter("@PassWord","2622020")
};
command.CommandText = sql;
command.Parameters.AddRange(parameters);
int counts = command.ExecuteNonQuery();
			

查：

			
string query = "SELECT * FROM FirstTable"; 
DataTable dt = SQLiteHelper.ExecuteQuery(query, null);
List<Test> tlist = new List<Test>();
foreach (var item in dt1.Rows)
{
Test tt = new Test();
tt.ID=(item as DataRow)["ID"].ToString();
tt.UserName = (item as DataRow)["UserName"].ToString();
tt.PassWord = (item as DataRow)["PassWord"].ToString();

tlist.Add(tt);
}
public class Test
{
public string ID { get; set; }
public string UserName { get; set; }
public string PassWord { get; set; }
}
			

帮助类

			
/// <summary>
   /// SQLite帮助类
   /// 说明：使用SQLite很简单，只需要Nuget搜SQLite 使用第一个System.Data.SQLite安装即可
   /// 使用CreateDB方法 创建一个数据库文件 传入路径即可  （注意：一个数据库文件代表一个数据库）
   /// 使用前请先指定连接字符串 使用SetConnectionString()方法
   /// SQLite作为本地文件数据库 具有独立运行、无服务器、零配置、支持事务、低内存、原子性等特点
   /// </summary>
   public class SQLiteHelper
   {
       #region 属性
       /// <summary>
       /// 连接字符串
       /// </summary>
       private static string connectionString = string.Empty;
       #endregion 属性

       #region 设置连接字符串与创建数据库文件
       /// <summary>
       /// 根据数据源、密码、版本号设置连接字符串。
       /// </summary>
       /// <param name="datasource">数据源。</param>
       /// <param name="password">密码。</param>
       /// <param name="version">版本号（缺省为3）。</param>
       public static void SetConnectionString(string datasource, string password, int version = 3)
       {
           connectionString = string.Format("Data Source={0};Version={1};password={2}",
               datasource, version, password);
       }

       /// <summary>
       /// 创建一个数据库文件。如果存在同名数据库文件，则会覆盖。
       /// </summary>
       /// <param name="dbName">数据库文件名。为null或空串时不创建。</param>
       /// <param name="password">（可选）数据库密码，默认为空。</param>
       /// <exception cref="Exception"></exception>
       public static void CreateDB(string dbName)
       {
           if (!string.IsNullOrEmpty(dbName))
           {
               try
               {
                   CreateDirectory(dbName);
                   SQLiteConnection.CreateFile(dbName);
               }
               catch (Exception ex)
               {
                   string errormes = ex.Message;
                   errormes += "\r\n";
                   errormes += LogHelper.ToMessage(ex);
                   string path = string.Empty;
                   path += AppDomain.CurrentDomain.BaseDirectory;
                   path += @"Unlog\SQLiteError";
                   path += DateTime.Now.ToString("yyyyMMddHHmm");
                   path += ".txt";
                   LogHelper.Instance.WriteLog(path, errormes);
               }
           }
       }

       #region 辅助方法
       /// <summary>
       /// 创建父级路径
       /// </summary>
       /// <param name="infoPath"></param>
       private static void CreateDirectory(string infoPath)
       {
           DirectoryInfo directoryInfo = Directory.GetParent(infoPath);
           if (!directoryInfo.Exists)
           {
               directoryInfo.Create();
           }
       }
       #endregion 辅助方法
       #endregion 设置连接字符串与创建数据库文件

       #region 命令参数封装
       // <summary>
       /// 准备操作命令参数
       /// </summary>
       /// <param name="cmd">SQLiteCommand</param>
       /// <param name="conn">SQLiteConnection</param>
       /// <param name="cmdText">Sql命令文本</param>
       /// <param name="data">参数数组</param>
       private static void PrepareCommand(SQLiteConnection conn, SQLiteCommand cmd, string cmdText, params SQLiteParameter[] parms)
       {
           if (conn.State != ConnectionState.Open)
               conn.Open();
           cmd.Parameters.Clear();
           cmd.Connection = conn;
           cmd.CommandText = cmdText;
           cmd.CommandType = CommandType.Text;
           cmd.CommandTimeout = 30;
           if (parms != null && parms.Length > 0)
           {
               foreach (SQLiteParameter parameter in parms)
               {
                   if ((parameter.Direction == ParameterDirection.Input || parameter.Direction == ParameterDirection.InputOutput) && (parameter.Value == null))
                   {
                       parameter.Value = DBNull.Value;
                   }
               }
               cmd.Parameters.AddRange(parms);
           }
       }

       #endregion 命令参数封装

       #region 数据库操作
       #region 创建表
       /// <summary>
       /// 创建表
       /// </summary>
       /// <param name="sql"></param>
       /// <returns></returns>
       public static bool CreateTable(string sql)
       {
           bool rr = true;
           try
           {
               using (SQLiteConnection connection = new SQLiteConnection(connectionString))
               {
                   using (SQLiteCommand command = new SQLiteCommand(connection))
                   {
                       try
                       {
                           PrepareCommand(connection, command, sql, null);
                           int count = command.ExecuteNonQuery();
                           if (count > 0) rr = true;
                           else rr = false;
                       }
                       catch (Exception ex)
                       {
                           return false;
                       }
                   }
               }
           }
           catch (Exception ex)
           {

               return false;
           }
           return rr;
       }
       #endregion 创建表

       #region 增删改操作
       /// <summary> 
       /// 对SQLite数据库执行增删改操作，返回受影响的行数。 
       /// </summary> 
       /// <param name="sql">要执行的增删改的SQL语句。</param> 
       /// <param name="parameters">执行增删改语句所需要的参数，参数必须以它们在SQL语句中的顺序为准。</param> 
       /// <returns></returns> 
       /// <exception cref="Exception"></exception>
       public static int ExecuteNonQuery(string sql, params SQLiteParameter[] parameters)
       {
           int affectedRows = 0;
           using (SQLiteConnection connection = new SQLiteConnection(connectionString))
           {
               using (SQLiteCommand command = new SQLiteCommand(connection))
               {
                   try
                   {
                       PrepareCommand(connection, command, sql, parameters);
                       //connection.Open();
                       //command.CommandText = sql;
                       //if (parameters.Length != 0)
                       //{
                       //    command.Parameters.AddRange(parameters);
                       //}
                       affectedRows = command.ExecuteNonQuery();
                   }
                   catch (Exception) { throw; }
               }
           }
           return affectedRows;
       }
       #endregion 增删改操作

       #region 批量操作
       /// <summary>
       /// 批量处理数据操作语句。
       /// </summary>
       /// <param name="list">SQL语句集合。</param>
       /// <exception cref="Exception"></exception>
       public static void ExecuteNonQueryBatch(List<KeyValuePair<string, SQLiteParameter[]>> list)
       {
           using (SQLiteConnection conn = new SQLiteConnection(connectionString))
           {
               try { conn.Open(); }
               catch { throw; }
               using (SQLiteTransaction tran = conn.BeginTransaction())
               {
                   using (SQLiteCommand cmd = new SQLiteCommand(conn))
                   {
                       try
                       {
                           foreach (var item in list)
                           {
                               PrepareCommand(conn, cmd, item.Key, item.Value);
                               //cmd.CommandText = item.Key;
                               //if (item.Value != null)
                               //{
                               //    cmd.Parameters.AddRange(item.Value);
                               //}
                               cmd.ExecuteNonQuery();
                           }
                           tran.Commit();
                       }
                       catch (Exception) { tran.Rollback(); throw; }
                   }
               }
           }
       }
       #endregion 批量操作

       #region 查询 返回第一个
       /// <summary>
       /// 执行查询语句，并返回第一个结果。
       /// </summary>
       /// <param name="sql">查询语句。</param>
       /// <returns>查询结果。</returns>
       /// <exception cref="Exception"></exception>
       public static object ExecuteScalar(string sql, params SQLiteParameter[] parameters)
       {
           using (SQLiteConnection conn = new SQLiteConnection(connectionString))
           {
               using (SQLiteCommand cmd = new SQLiteCommand(conn))
               {
                   try
                   {
                       PrepareCommand(conn, cmd, sql, parameters);

      



  

   共2页: 
上一页
1
2
下一页

  

栏目列表