本文实例讲述了C#中增加SQLite事务操作支持与使用方法。分享给大家供大家参考，具体如下：

在C#中使用Sqlite增加对transaction支持

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SQLite;
using System.Globalization;
using System.Linq;
using System.Windows.Forms;
namespace Simple_Disk_Catalog
{
  public class SQLiteDatabase
  {
    String DBConnection;
    private readonly SQLiteTransaction _sqLiteTransaction;
    private readonly SQLiteConnection _sqLiteConnection;
    private readonly bool _transaction;
    /// <summary>
    ///   Default Constructor for SQLiteDatabase Class.
    /// </summary>
    /// <param name="transaction">Allow programmers to insert, update and delete values in one transaction</param>
    public SQLiteDatabase(bool transaction = false)
    {
      _transaction = transaction;
      DBConnection = "Data Source=recipes.s3db";
      if (transaction)
      {
        _sqLiteConnection = new SQLiteConnection(DBConnection);
        _sqLiteConnection.Open();
        _sqLiteTransaction = _sqLiteConnection.BeginTransaction();
      }
    }
    /// <summary>
    ///   Single Param Constructor for specifying the DB file.
    /// </summary>
    /// <param name="inputFile">The File containing the DB</param>
    public SQLiteDatabase(String inputFile)
    {
      DBConnection = String.Format("Data Source={0}", inputFile);
    }
    /// <summary>
    ///   Commit transaction to the database.
    /// </summary>
    public void CommitTransaction()
    {
      _sqLiteTransaction.Commit();
      _sqLiteTransaction.Dispose();
      _sqLiteConnection.Close();
      _sqLiteConnection.Dispose();
    }
    /// <summary>
    ///   Single Param Constructor for specifying advanced connection options.
    /// </summary>
    /// <param name="connectionOpts">A dictionary containing all desired options and their values</param>
    public SQLiteDatabase(Dictionary<String, String> connectionOpts)
    {
      String str = connectionOpts.Aggregate("", (current, row) => current + String.Format("{0}={1}; ", row.Key, row.Value));
      str = str.Trim().Substring(0, str.Length - 1);
      DBConnection = str;
    }
    /// <summary>
    ///   Allows the programmer to create new database file.
    /// </summary>
    /// <param name="filePath">Full path of a new database file.</param>
    /// <returns>true or false to represent success or failure.</returns>
    public static bool CreateDB(string filePath)
    {
      try
      {
        SQLiteConnection.CreateFile(filePath);
        return true;
      }
      catch (Exception e)
      {
        MessageBox.Show(e.Message, e.GetType().ToString(), MessageBoxButtons.OK, MessageBoxIcon.Error);
        return false;
      }
    }
    /// <summary>
    ///   Allows the programmer to run a query against the Database.
    /// </summary>
    /// <param name="sql">The SQL to run</param>
    /// <param name="allowDBNullColumns">Allow null value for columns in this collection.</param>
    /// <returns>A DataTable containing the result set.</returns>
    public DataTable GetDataTable(string sql, IEnumerable<string> allowDBNullColumns = null)
    {
      var dt = new DataTable();
      if (allowDBNullColumns != null)
        foreach (var s in allowDBNullColumns)
        {
          dt.Columns.Add(s);
          dt.Columns[s].AllowDBNull = true;
        }
      try
      {
        var cnn = new SQLiteConnection(DBConnection);
        cnn.Open();
        var mycommand = new SQLiteCommand(cnn) {CommandText = sql};
        var reader = mycommand.ExecuteReader();
        dt.Load(reader);
        reader.Close();
        cnn.Close();
      }
      catch (Exception e)
      {
        throw new Exception(e.Message);
      }
      return dt;
    }
    public string RetrieveOriginal(string value)
    {
      return
        value.Replace("&", "&").Replace("<", "<").Replace(">", "<").Replace(""", "\"").Replace(
          "'", "'");
    }
    /// <summary>
    ///   Allows the programmer to interact with the database for purposes other than a query.
    /// </summary>
    /// <param name="sql">The SQL to be run.</param>
    /// <returns>An Integer containing the number of rows updated.</returns>
    public int ExecuteNonQuery(string sql)
    {
      if (!_transaction)
      {
        var cnn = new SQLiteConnection(DBConnection);
        cnn.Open();
        var mycommand = new SQLiteCommand(cnn) {CommandText = sql};
        var rowsUpdated = mycommand.ExecuteNonQuery();
        cnn.Close();
        return rowsUpdated;
      }
      else
      {
        var mycommand = new SQLiteCommand(_sqLiteConnection) { CommandText = sql };
        return mycommand.ExecuteNonQuery();
      }
    }
    /// <summary>
    ///   Allows the programmer to retrieve single items from the DB.
    /// </summary>
    /// <param name="sql">The query to run.</param>
    /// <returns>A string.</returns>
    public string ExecuteScalar(string sql)
    {
      if (!_transaction)
      {
        var cnn = new SQLiteConnection(DBConnection);
        cnn.Open();
        var mycommand = new SQLiteCommand(cnn) {CommandText = sql};
        var value = mycommand.ExecuteScalar();
        cnn.Close();
        return value != null ? value.ToString() : "";
      }
      else
      {
        var sqLiteCommand = new SQLiteCommand(_sqLiteConnection) { CommandText = sql };
        var value = sqLiteCommand.ExecuteScalar();
        return value != null ? value.ToString() : "";
      }
    }
    /// <summary>
    ///   Allows the programmer to easily update rows in the DB.
    /// </summary>
    /// <param name="tableName">The table to update.</param>
    /// <param name="data">A dictionary containing Column names and their new values.</param>
    /// <param name="where">The where clause for the update statement.</param>
    /// <returns>A boolean true or false to signify success or failure.</returns>
    public bool Update(String tableName, Dictionary<String, String> data, String where)
    {
      String vals = "";
      Boolean returnCode = true;
      if (data.Count >= 1)
      {
        vals = data.Aggregate(vals, (current, val) => current + String.Format(" {0} = '{1}',", val.Key.ToString(CultureInfo.InvariantCulture), val.Value.ToString(CultureInfo.InvariantCulture)));
        vals = vals.Substring(0, vals.Length - 1);
      }
      try
      {
        ExecuteNonQuery(String.Format("update {0} set {1} where {2};", tableName, vals, where));
      }
      catch
      {
        returnCode = false;
      }
      return returnCode;
    }
    /// <summary>
    ///   Allows the programmer to easily delete rows from the DB.
    /// </summary>
    /// <param name="tableName">The table from which to delete.</param>
    /// <param name="where">The where clause for the delete.</param>
    /// <returns>A boolean true or false to signify success or failure.</returns>
    public bool Delete(String tableName, String where)
    {
      Boolean returnCode = true;
      try
      {
        ExecuteNonQuery(String.Format("delete from {0} where {1};", tableName, where));
      }
      catch (Exception fail)
      {
        MessageBox.Show(fail.Message, fail.GetType().ToString(), MessageBoxButtons.OK, MessageBoxIcon.Error);
        returnCode = false;
      }
      return returnCode;
    }
    /// <summary>
    ///   Allows the programmer to easily insert into the DB
    /// </summary>
    /// <param name="tableName">The table into which we insert the data.</param>
    /// <param name="data">A dictionary containing the column names and data for the insert.</param>
    /// <returns>returns last inserted row id if it's value is zero than it means failure.</returns>
    public long Insert(String tableName, Dictionary<String, String> data)
    {
      String columns = "";
      String values = "";
      String value;
      foreach (KeyValuePair<String, String> val in data)
      {
        columns += String.Format(" {0},", val.Key.ToString(CultureInfo.InvariantCulture));
        values += String.Format(" '{0}',", val.Value);
      }
      columns = columns.Substring(0, columns.Length - 1);
      values = values.Substring(0, values.Length - 1);
      try
      {
        if (!_transaction)
        {
          var cnn = new SQLiteConnection(DBConnection);
          cnn.Open();
          var sqLiteCommand = new SQLiteCommand(cnn)
                    {
                      CommandText =
                        String.Format("insert into {0}({1}) values({2});", tableName, columns,
                               values)
                    };
          sqLiteCommand.ExecuteNonQuery();
          sqLiteCommand = new SQLiteCommand(cnn) { CommandText = "SELECT last_insert_rowid()" };
          value = sqLiteCommand.ExecuteScalar().ToString();
        }
        else
        {
          ExecuteNonQuery(String.Format("insert into {0}({1}) values({2});", tableName, columns, values));
          value = ExecuteScalar("SELECT last_insert_rowid()");
        }
      }
      catch (Exception fail)
      {
        MessageBox.Show(fail.Message, fail.GetType().ToString(), MessageBoxButtons.OK, MessageBoxIcon.Error);
        return 0;
      }
      return long.Parse(value);
    }
    /// <summary>
    ///   Allows the programmer to easily delete all data from the DB.
    /// </summary>
    /// <returns>A boolean true or false to signify success or failure.</returns>
    public bool ClearDB()
    {
      try
      {
        var tables = GetDataTable("select NAME from SQLITE_MASTER where type='table' order by NAME;");
        foreach (DataRow table in tables.Rows)
        {
          ClearTable(table["NAME"].ToString());
        }
        return true;
      }
      catch
      {
        return false;
      }
    }
    /// <summary>
    ///   Allows the user to easily clear all data from a specific table.
    /// </summary>
    /// <param name="table">The name of the table to clear.</param>
    /// <returns>A boolean true or false to signify success or failure.</returns>
    public bool ClearTable(String table)
    {
      try
      {
        ExecuteNonQuery(String.Format("delete from {0};", table));
        return true;
      }
      catch
      {
        return false;
      }
    }
    /// <summary>
    ///   Allows the user to easily reduce size of database.
    /// </summary>
    /// <returns>A boolean true or false to signify success or failure.</returns>
    public bool CompactDB()
    {
      try
      {
        ExecuteNonQuery("Vacuum;");
        return true;
      }
      catch (Exception)
      {
        return false;
      }
    }
  }
}

更多关于C#相关内容感兴趣的读者可查看本站专题：《C#常见数据库操作技巧汇总》、《C#常见控件用法教程》、《C#窗体操作技巧汇总》、《C#数据结构与算法教程》、《C#面向对象程序设计入门教程》及《C#程序设计之线程使用技巧总结》

希望本文所述对大家C#程序设计有所帮助。

# C#  # SQLite  # 事务  # c#中SqlHelper封装SqlDataReader的方法  # C#中SQL Command的基本用法  # C#中sqlDataRead 的三种方式遍历读取各个字段数值的方法  # C# 中用 Sqlparameter 的两种用法  # C# SQLite执行效率的优化教程  # C#实现MySQL命令行备份和恢复  # C# 启用事务提交多条带参数的SQL语句实例代码  # C# 启动 SQL Server 服务的实例  # C# 操作PostgreSQL 数据库的示例代码  # C#实现连接SQL Server2012数据库并执行SQL语句的方法  # 详解使用C#编写SqlHelper类  # C#连接到sql server2008数据库的实例代码  # SQLite在C#中的安装与操作技巧  # C#连接加密的Sqlite数据库的方法  # C#使用SQL DataReader访问数据的优点和实例  # 程序设计  # 操作技巧  # 相关内容  # 感兴趣  # 数据结构  # 给大家  # 更多关于  # 所述  # 使用技巧  # 面向对象  # 讲述了  # connection  # options  # connectionOpts  # Dispose  # Close  # advanced  # str  # Aggregate  # current 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： Laravel如何升级到最新的版本_Laravel版本升级流程与兼容性处理  如何有效防御Web建站篡改攻击？  悟空识字如何进行跟读录音_悟空识字开启麦克风权限与录音  车管所网站制作流程,交警当场开简易程序处罚决定书，在交警网站查询不到怎么办？  怎么用AI帮你设计一套个性化的手机App图标？  网站制作软件免费下载安装,有哪些免费下载的软件网站？  Laravel如何部署到服务器_线上部署Laravel项目的完整流程与步骤  javascript和jQuery中的AJAX技术详解【包含AJAX各种跨域技术】  Laravel集合Collection怎么用_Laravel集合常用函数详解  如何在IIS管理器中快速创建并配置网站？  浅谈redis在项目中的应用  Laravel Seeder怎么填充数据_Laravel数据库填充器的使用方法与技巧  Win11怎么设置默认图片查看器_Windows11照片应用关联设置  中国移动官方网站首页入口 中国移动官网网页登录  创业网站制作流程,创业网站可靠吗？  Laravel如何使用Blade模板引擎？（完整语法和示例）  如何用景安虚拟主机手机版绑定域名建站？  教你用AI润色文章，让你的文字表达更专业  Windows10如何删除恢复分区_Win10 Diskpart命令强制删除分区  html5的keygen标签为什么废弃_替代方案说明【解答】  手机怎么制作网站教程步骤,手机怎么做自己的网页链接？  js实现获取鼠标当前的位置  php8.4header发送头信息失败怎么办_php8.4header函数问题解决【解答】  简历没回改：利用AI润色让你的文字更专业  jquery插件bootstrapValidator表单验证详解  如何用虚拟主机快速搭建网站？详细步骤解析  Laravel路由Route怎么设置_Laravel基础路由定义与参数传递规则【详解】  如何在Ubuntu系统下快速搭建WordPress个人网站？  Win11怎么关闭专注助手 Win11关闭免打扰模式设置【操作】  laravel怎么为应用开启和关闭维护模式_laravel应用维护模式开启与关闭方法  Laravel怎么上传文件_Laravel图片上传及存储配置  Windows家庭版如何开启组策略(gpedit.msc)？（安装方法）  Laravel如何使用Service Provider注册服务_Laravel服务提供者配置与加载  如何用西部建站助手快速创建专业网站？  微信小程序制作网站有哪些,微信小程序需要做网站吗？  如何快速搭建虚拟主机网站？新手必看指南  武汉网站设计制作公司,武汉有哪些比较大的同城网站或论坛，就是里面都是武汉人的？  php打包exe后无法访问网络共享_共享权限设置方法【教程】  Windows10电脑怎么设置虚拟光驱_Win10右键装载ISO镜像文件  Laravel如何处理CORS跨域请求？（配置示例）  Laravel如何实现文件上传和存储？（本地与S3配置）  INTERNET浏览器怎样恢复关闭标签页_INTERNET浏览器标签恢复快捷键与方法【指南】  如何在宝塔面板创建新站点？  Laravel怎么配置S3云存储驱动_Laravel集成阿里云OSS或AWS S3存储桶【教程】  如何正确下载安装西数主机建站助手？  网站广告牌制作方法,街上的广告牌，横幅，用PS还是其他软件做的？  如何在云主机快速搭建网站站点？  新三国志曹操传主线渭水交兵攻略  宙斯浏览器视频悬浮窗怎么开启 边看视频边操作其他应用教程  如何在建站主机中优化服务器配置？