C# *** 作SQLite的辅助类

概述C# *** 作SQLite的辅助类

下面是内存溢出 jb51.cc 通过网络收集整理的代码片段。

内存溢出小编现在分享给大家，也给大家做个参考。

sqlite这个精巧的小数据库，无需安装软件，只需要一个System.Data.sqlite.DLL文件即可 *** 作sqlite数据库。sqlite是 一个开源数据库，现在已变得越来越流行，它的体积很小，被广泛应用于各种不同类型的应用中。

 using System;  using System.Collections.Generic;  using System.Text;  using System.Web;  using System.Configuration;  using System.Data;  using System.Data.sqlite;      namespace DAL  {      public class sqlite      {          /// <summary>          /// 获得连接对象          /// </summary>          /// <returns></returns>          public static sqliteConnection GetsqliteConnection()          {              return new sqliteConnection("Data Source=" + System.Web.httpContext.Current.Server.MapPath(System.Configuration.ConfigurationManager.AppSettings["db"].ToString()));          }              private static voID PrepareCommand(sqliteCommand cmd,sqliteConnection conn,string cmdText,params object[] p)          {                  if (conn.State != ConnectionState.Open)                  conn.open();              cmd.Parameters.Clear();              cmd.Connection = conn;              cmd.CommandText = cmdText;                  cmd.CommandType = CommandType.Text;              cmd.CommandTimeout = 30;                  if (p != null)              {                  foreach (object parm in p)                      cmd.Parameters.AdDWithValue(string.Empty,parm);                  //for (int i = 0; i < p.Length; i++)                  //    cmd.Parameters[i].Value = p[i];              }          }              public static DataSet ExecuteDataset(string cmdText,params object[] p)          {              DataSet ds = new DataSet();              sqliteCommand command = new sqliteCommand();              using (sqliteConnection connection = GetsqliteConnection())              {                  PrepareCommand(command,connection,cmdText,p);                  sqliteDataAdapter da = new sqliteDataAdapter(command);                  da.Fill(ds);              }                  return ds;          }              public static DaTarow ExecuteDaTarow(string cmdText,params object[] p)          {              DataSet ds = ExecuteDataset(cmdText,p);              if (ds != null && ds.tables.Count > 0 && ds.tables[0].Rows.Count > 0)                  return ds.tables[0].Rows[0];              return null;          }              /// <summary>          /// 返回受影响的行数          /// </summary>          /// <param name="cmdText">a</param>          /// <param name="commandParameters">传入的参数</param>          /// <returns></returns>          public static int ExecuteNonquery(string cmdText,params object[] p)          {              sqliteCommand command = new sqliteCommand();                  using (sqliteConnection connection = GetsqliteConnection())              {                  PrepareCommand(command,p);                  return command.ExecuteNonquery();              }          }              /// <summary>          /// 返回sqlDataReader对象          /// </summary>          /// <param name="cmdText"></param>          /// <param name="commandParameters">传入的参数</param>          /// <returns></returns>          public static sqliteDataReader ExecuteReader(string cmdText,params object[] p)          {              sqliteCommand command = new sqliteCommand();              sqliteConnection connection = GetsqliteConnection();              try              {                  PrepareCommand(command,p);                  sqliteDataReader reader = command.ExecuteReader(CommandBehavior.CloseConnection);                  return reader;              }              catch              {                  connection.Close();                  throw;              }          }              /// <summary>          /// 返回结果集中的第一行第一列，忽略其他行或列          /// </summary>          /// <param name="cmdText"></param>          /// <param name="commandParameters">传入的参数</param>          /// <returns></returns>          public static object ExecuteScalar(string cmdText,params object[] p)          {              sqliteCommand cmd = new sqliteCommand();                  using (sqliteConnection connection = GetsqliteConnection())              {                  PrepareCommand(cmd,p);                  return cmd.ExecuteScalar();              }          }              /// <summary>          /// 分页          /// </summary>          /// <param name="recordCount"></param>          /// <param name="pageIndex"></param>          /// <param name="pageSize"></param>          /// <param name="cmdText"></param>          /// <param name="countText"></param>          /// <param name="p"></param>          /// <returns></returns>          public static DataSet ExecutePager(ref int recordCount,int pageIndex,int pageSize,string countText,params object[] p)          {              if (recordCount < 0)                  recordCount = int.Parse(ExecuteScalar(countText,p).ToString());                  DataSet ds = new DataSet();                  sqliteCommand command = new sqliteCommand();              using (sqliteConnection connection = GetsqliteConnection())              {                  PrepareCommand(command,p);                  sqliteDataAdapter da = new sqliteDataAdapter(command);                  da.Fill(ds,(pageIndex - 1) * pageSize,pageSize,"result");              }              return ds;          }      }  } 

以上是内存溢出(jb51.cc)为你收集整理的全部代码内容，希望文章能够帮你解决所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。

总结

以上是内存溢出为你收集整理的C# *** 作SQLite的辅助类全部内容，希望文章能够帮你解决C# *** 作SQLite的辅助类所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。