SQLLite的使用

namespace SQLLiteHelper
{
    /// <summary>
    /// 数据库操作抽象
    /// </summary>
    public interface IDataAccess
    {
        /// <summary>
        /// 打开
        /// </summary>
        void Open();
        /// <summary>
        /// 关闭
        /// </summary>
        void Close();

        /// <summary>
        /// 执行 增 删 改 查
        /// </summary>
        /// <param name="sql">Sql语句</param>
        /// <param name="queryParameter">参数</param>
        int ExecuteNonQuery(string sql, QueryParameter[] queryParameter);

        /// <summary>
        /// 查询某一个值
        /// </summary>
        /// <param name="sql">Sql语句</param>
        /// <param name="parameters">参数</param>
        /// <returns>Object</returns>
        object GetScalar(string sql, QueryParameter[] parameters);

        /// <summary>
        /// 查询多条条数据
        /// </summary>
        /// <param name="sql">Sql语句</param>
        /// <param name="dt">DataTabel </param>
        /// <param name="parameters">参数</param>
        /// <returns>DataTable</returns>
        DataTable GetTable(string sql, DataTable dt, QueryParameter[] parameters);

        /// <summary>
        /// 查询多条值
        /// </summary>
        /// <param name="sql">Sql语句</param>
        /// <param name="parameters">参数</param>
        /// <returns>DataReader</returns>
        IDataReader GetReader(string sql, QueryParameter[] parameters);

        /// <summary>
        /// 开始事务
        /// </summary>
        void BeginTran();
        /// <summary>
        /// 提交事务
        /// </summary>
        void CommitTran();
        /// <summary>
        ///  回滚事务
        /// </summary>
        void RollBackTran();

    }
}

 public  class DataAccessFactory
    {
      
        public static IDataAccess CreateDataAccess()
        {
            string conStr = System.Configuration.ConfigurationManager.AppSettings["conStr"];
            string conType = System.Configuration.ConfigurationManager.AppSettings["conType"]; 
            switch (conType)
            {
                case "SQLLite":return new SqlLiteDalHelper(conStr);
                    break;
                case "SQLServer":
                    return new SqlLiteDalHelper(conStr);
                    break;

                default:throw new Exception("该数据库不支持!");
            }
        }

    }

    public class QueryParameter
    {

        public string Name
        {
            get;
            set;
        }
        public object Value
        {
            get;
            set;
        }
        public DbType DbType
        {
            get;
            set;
        }

        private ParameterDirection _driection = ParameterDirection.Input;

        public ParameterDirection Driection
        {
            get { return _driection; }
            set { _driection = value; }
        }
        public QueryParameter(string name, object value, DbType dbType)
        {
            this.DbType = dbType;
            this.Value = value;
            this.Name = name;
        }
    }

 public class SqlLiteDalHelper : IDataAccess
    {
        private readonly SQLiteConnection _connection;
        private SQLiteTransaction _tran;
        public SqlLiteDalHelper(string constr)
        {
            _connection = new SQLiteConnection(constr);
        }

        public void Open()
        {
            if (this._connection == null || this._connection.State == ConnectionState.Closed)
            {
                try
                {
                    _connection.Open();
                }
                catch (ArgumentException)
                {
                    throw;
                }
              }
        }

        public void Close()
        {
            if (this._connection != null || _tran != null)
            {
                _connection.Close();
            }
        }

        public int ExecuteNonQuery(string sql, QueryParameter[] queryParameter)
        {
            SQLiteCommand cmd = new SQLiteCommand();
            PrepareCommond(cmd, CommandType.Text, queryParameter, sql);
            int i = cmd.ExecuteNonQuery();
            cmd.Parameters.Clear();
            return i;
        }

        public object GetScalar(string sql, QueryParameter[] parameters)
        {
            SQLiteCommand cmd = new SQLiteCommand();
            PrepareCommond(cmd, CommandType.Text, parameters, sql);
            object obj = cmd.ExecuteScalar();
            cmd.Parameters.Clear();
            return obj;
        }

        public System.Data.DataTable GetTable(string sql, DataTable dt, QueryParameter[] parameters)
        {
            SQLiteCommand cmd = new SQLiteCommand();
            PrepareCommond(cmd, CommandType.Text, parameters, sql);
            SQLiteDataAdapter sda = new SQLiteDataAdapter(cmd);
            sda.Fill(dt);
            cmd.Parameters.Clear();
            return dt;
        }

        public System.Data.IDataReader GetReader(string sql, QueryParameter[] parameters)
        {
            SQLiteCommand cmd = new SQLiteCommand();
            PrepareCommond(cmd, CommandType.Text, parameters, sql);
            SQLiteDataReader dr = cmd.ExecuteReader();
            cmd.Parameters.Clear();
            return dr;
        }

        public void BeginTran()
        {
            this._tran = this._connection.BeginTransaction();
        }

        public void CommitTran()
        {
            this._tran.Commit();
        }

        public void RollBackTran()
        {
            this._tran.Rollback();
        }

        private void PrepareCommond(SQLiteCommand cmd, CommandType commandType, QueryParameter[] parameters, string commandtext)
        {
            cmd.CommandType = commandType;
            cmd.CommandText = commandtext;
            cmd.Connection = _connection;
            cmd.Transaction = this._tran;
            if (parameters != null && parameters.Length > 0)
            {
                for (int i = 0; i < parameters.Length; i++)
                {
                    cmd.Parameters.AddWithValue(parameters[i].Name, parameters[i].Value);
                }
            }
        }


    }

使用方法：

    public DataTable   FindAllTRoleOperator()
    {
        try
        {
            string sql;
            sql="SELECT COMMENTARY,OPERATORID,ROLEID from T_ROLE_OPERATOR";
            DataTable dt = new DataTable("MINORITY");
            data.GetTable(sql, dt, null);
            return dt;
        }
        catch(Exception e)
        {
            throw e;
        }
    }

public DataTable   FindAllTRoleOperator()
    {
        IDataAccess dataAccess  =null;
            try
            {
                dataAccess  =  DataAccessFactory.CreateDataAccess();
                dataAccess.Open();
                RoleOperatorService dal  =  new RoleOperatorService(dataAccess);
                return dal.FindAllTRoleOperator();
            }
            catch (Exception e)
            {
                throw e;
            }
            finally
            {
                if (dataAccess != null) dataAccess.Close();
            }
       }

运行结果：