|
1、作用
实现SQLite小型数据的操作，包含：创建、读取、修改、写入。如果你想传入临时表（DataTable）、临时数数据集（DataSet）、范式类型（IList）达到更新目的，需要添加 DataOperation类支持，个人也已经封装。
2、引入组件
System.Data.SQLite.dll
SQLite.Interop.dll（该组件如果没有注册可能引入不进去，可以直接放在bin目录即可）
3、帮助类，可以直接创建类SQLiteHelper.cs，复制以下代码：
using AutoPlayer.Common;
using System;
using System.Data;
using System.Data.SQLite;
namespace AutoPlayer.DAL
{
? ? public class SQLiteHelper
? ? {
? ? ? ? //从配置文本中读取连接字符串
? ? ? ? private static string connectionString = XmlHelper.GetAppConfig("dbcon");
? ? ? ? /// <summary>
? ? ? ? /// 创建一个数据库文件。如果存在同名数据库文件，则会覆盖。
? ? ? ? /// </summary>
? ? ? ? /// <param name="dbName"></param>
? ? ? ? public static void CreateDB(string dbName)
? ? ? ? {
? ? ? ? ? ? string l_strdbName = dbName;
? ? ? ? ? ? if (!dbName.Contains("."))
? ? ? ? ? ? {
? ? ? ? ? ? ? ? l_strdbName = dbName + ".sqlite3";
? ? ? ? ? ? }
? ? ? ? ? ? try
? ? ? ? ? ? {
? ? ? ? ? ? ? ? SQLiteConnection.CreateFile(l_strdbName);
? ? ? ? ? ? }
? ? ? ? ? ? catch (Exception)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? throw;
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 创建连接到指定数据库
? ? ? ? /// </summary>
? ? ? ? /// <param name="datasource"></param>
? ? ? ? /// <param name="password"></param>
? ? ? ? /// <param name="version"></param>
? ? ? ? public static void SetConnectionString(string datasource, string password = "", int version = 3)
? ? ? ? {
? ? ? ? ? ? connectionString = string.Format("Data Source={0};password={1},Version={2};",
? ? ? ? ? ? ? ? datasource, password, version);
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 执行命令的方法：insert,update,delete
? ? ? ? /// </summary>
? ? ? ? /// <param name="sql"></param>
? ? ? ? /// <param name="parameters">可变参数，目的是省略了手动构造数组的过程，直接指定对象，编译器会帮助我们构造数组，并将对象加入数组中，传递过来</param>
? ? ? ? /// <returns></returns>
? ? ? ? public static int ExecuteNonQuery(string sql, params SQLiteParameter[] parameters)
? ? ? ? {
? ? ? ? ? ? using (SQLiteConnection connection = new SQLiteConnection(connectionString))
? ? ? ? ? ? {
? ? ? ? ? ? ? ? using (SQLiteCommand command = new SQLiteCommand(connection))
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? try
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? connection.Open();
? ? ? ? ? ? ? ? ? ? ? ? command.CommandText = sql;
? ? ? ? ? ? ? ? ? ? ? ? if (parameters.Length > 0)
? ? ? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? ? ? command.Parameters.AddRange(parameters);
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? return command.ExecuteNonQuery();
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? catch (Exception) { throw; }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 执行查询语句，并返回第一个结果。
? ? ? ? /// </summary>
? ? ? ? /// <param name="sql"></param>
? ? ? ? /// <param name="parameters"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public static object ExecuteScalar(string sql, params SQLiteParameter[] parameters)
? ? ? ? {
? ? ? ? ? ? using (SQLiteConnection conn = new SQLiteConnection(connectionString))
? ? ? ? ? ? {
? ? ? ? ? ? ? ? using (SQLiteCommand cmd = new SQLiteCommand(conn))
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? try
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? conn.Open();
? ? ? ? ? ? ? ? ? ? ? ? cmd.CommandText = sql;
? ? ? ? ? ? ? ? ? ? ? ? if (parameters.Length != 0)
? ? ? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? ? ? cmd.Parameters.AddRange(parameters);
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? return cmd.ExecuteScalar();
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? catch (Exception) { throw; }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 执行一个查询语句，返回一个包含查询结果的DataTable。?
? ? ? ? /// </summary>
? ? ? ? /// <param name="sql"></param>
? ? ? ? /// <param name="parameters"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public static DataTable ExecuteQuery(string sql, params SQLiteParameter[] parameters)
? ? ? ? {
? ? ? ? ? ? using (SQLiteConnection connection = new SQLiteConnection(connectionString))
? ? ? ? ? ? {
? ? ? ? ? ? ? ? using (SQLiteCommand command = new SQLiteCommand(sql, connection))
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? if (parameters.Length != 0)
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? command.Parameters.AddRange(parameters);
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? SQLiteDataAdapter adapter = new SQLiteDataAdapter(command);
? ? ? ? ? ? ? ? ? ? DataTable data = new DataTable();
? ? ? ? ? ? ? ? ? ? try
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? adapter.Fill(data);
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? catch (Exception)
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? throw;
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? return data;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 执行一个查询语句，返回一个关联的SQLiteDataReader实例。?
? ? ? ? /// </summary>
? ? ? ? /// <param name="sql"></param>
? ? ? ? /// <param name="parameters"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public static SQLiteDataReader ExecuteReader(string sql, params SQLiteParameter[] parameters)
? ? ? ? {
? ? ? ? ? ? SQLiteConnection connection = new SQLiteConnection(connectionString);
? ? ? ? ? ? SQLiteCommand command = new SQLiteCommand(sql, connection);
? ? ? ? ? ? try
? ? ? ? ? ? {
? ? ? ? ? ? ? ? if (parameters.Length != 0)
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? command.Parameters.AddRange(parameters);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? connection.Open();
? ? ? ? ? ? ? ? return command.ExecuteReader(CommandBehavior.CloseConnection);
? ? ? ? ? ? }
? ? ? ? ? ? catch (Exception) { throw; }
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 查询表字段类型
? ? ? ? /// </summary>
? ? ? ? /// <returns></returns>
? ? ? ? public static DataTable GetSchema()
? ? ? ? {
? ? ? ? ? ? using (SQLiteConnection connection = new SQLiteConnection(connectionString))
? ? ? ? ? ? {
? ? ? ? ? ? ? ? try
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? connection.Open();
? ? ? ? ? ? ? ? ? ? return connection.GetSchema("TABLES");
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? catch (Exception) { throw; }
? ? ? ? ? ? }
? ? ? ? }
? ? }
}
?
|