C#操作Access通用类

using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
using System.Data.OleDb;
using System.Collections;
/// 
/// AcceHelper 的摘要说明
/// 
public static class AccessHelper
{
    //数据库连接字符串
    public static readonly string conn = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + HttpContext.Current.Request.PhysicalApplicationPath + System.Configuration.ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
    // 用于缓存参数的HASH表
    private static Hashtable parmCache = Hashtable.Synchronized(new Hashtable());
    /// 
    ///  给定连接的数据库用假设参数执行一个sql命令（不返回数据集）
    /// 
    /// 一个有效的连接字符串
    /// 存储过程名称或者sql命令语句
    /// 执行命令所用参数的集合
    /// 执行命令所影响的行数
    public static int ExecuteNonQuery(string connectionString, string cmdText, params OleDbParameter[] commandParameters)
    {
        OleDbCommand cmd = new OleDbCommand();
        using (OleDbConnection conn = new OleDbConnection(connectionString))
        {
            PrepareCommand(cmd, conn, null, cmdText, commandParameters);
            int val = cmd.ExecuteNonQuery();
            cmd.Parameters.Clear();
            return val;
        }
    }
    /// 
    /// 用现有的数据库连接执行一个sql命令（不返回数据集）
    /// 
    /// 
    ///举例:  
    ///  int result = ExecuteNonQuery(connString, "PublishOrders", new OleDbParameter("@prodid", 24));
    /// 
    /// 一个现有的数据库连接
    /// 存储过程名称或者sql命令语句
    /// 执行命令所用参数的集合
    /// 执行命令所影响的行数
    public static int ExecuteNonQuery(OleDbConnection connection, string cmdText, params OleDbParameter[] commandParameters)
    {
        OleDbCommand cmd = new OleDbCommand();
        PrepareCommand(cmd, connection, null, cmdText, commandParameters);
        int val = cmd.ExecuteNonQuery();
        cmd.Parameters.Clear();
        return val;
    }
    /// 
    ///使用现有的SQL事务执行一个sql命令（不返回数据集）
    /// 
    /// 
    ///举例:  
    ///  int result = ExecuteNonQuery(trans, "PublishOrders", new OleDbParameter("@prodid", 24));
    /// 
    /// 一个现有的事务
    /// 存储过程名称或者sql命令语句
    /// 执行命令所用参数的集合
    /// 执行命令所影响的行数
    public static int ExecuteNonQuery(OleDbTransaction trans, string cmdText, params OleDbParameter[] commandParameters)
    {
        OleDbCommand cmd = new OleDbCommand();
        PrepareCommand(cmd, trans.Connection, trans, cmdText, commandParameters);
        int val = cmd.ExecuteNonQuery();
        cmd.Parameters.Clear();
        return val;
    }
    /// 
    /// 用执行的数据库连接执行一个返回数据集的sql命令
    /// 
    /// 
    /// 举例:  
    ///  OleDbDataReader r = ExecuteReader(connString, "PublishOrders", new OleDbParameter("@prodid", 24));
    /// 
    /// 一个有效的连接字符串
    /// 存储过程名称或者sql命令语句
    /// 执行命令所用参数的集合
    /// 包含结果的读取器
    public static OleDbDataReader ExecuteReader(string connectionString, string cmdText, params OleDbParameter[] commandParameters)
    {
        //创建一个SqlCommand对象
        OleDbCommand cmd = new OleDbCommand();
        //创建一个SqlConnection对象
        OleDbConnection conn = new OleDbConnection(connectionString);
        //在这里我们用一个try/catch结构执行sql文本命令/存储过程，因为如果这个方法产生一个异常我们要关闭连接，因为没有读取器存在，
        //因此commandBehaviour.CloseConnection 就不会执行
        try
        {
            //调用 PrepareCommand 方法，对 SqlCommand 对象设置参数
            PrepareCommand(cmd, conn, null, cmdText, commandParameters);
            //调用 SqlCommand  的 ExecuteReader 方法
            OleDbDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
            //清除参数
            cmd.Parameters.Clear();
            return reader;
        }
        catch
        {
            //关闭连接，抛出异常
            conn.Close();
            throw;
        }
    }
    /// 
    /// 返回一个DataSet数据集
    /// 
    /// 一个有效的连接字符串
    /// 存储过程名称或者sql命令语句
    /// 执行命令所用参数的集合
    /// 包含结果的数据集
    public static DataSet ExecuteDataSet(string connectionString, string cmdText, params OleDbParameter[] commandParameters)
    {
        //创建一个SqlCommand对象，并对其进行初始化
        OleDbCommand cmd = new OleDbCommand();
        using (OleDbConnection conn = new OleDbConnection(connectionString))
        {
            PrepareCommand(cmd, conn, null, cmdText, commandParameters);
            //创建SqlDataAdapter对象以及DataSet
            OleDbDataAdapter da = new OleDbDataAdapter(cmd);
            DataSet ds = new DataSet();
            try
            {
                //填充ds
                da.Fill(ds);
                // 清除cmd的参数集合 
                cmd.Parameters.Clear();
                //返回ds
                return ds;
            }
            catch
            {
                //关闭连接，抛出异常
                conn.Close();
                throw;
            }
        }
    }
    /// 
    /// 用指定的数据库连接字符串执行一个命令并返回一个数据集的第一列
    /// 
    /// 
    ///例如:  
    ///  Object obj = ExecuteScalar(connString, "PublishOrders", new OleDbParameter("@prodid", 24));
    /// 
    ///一个有效的连接字符串
    /// 存储过程名称或者sql命令语句
    /// 执行命令所用参数的集合
    /// 用 Convert.To{Type}把类型转换为想要的 
    public static object ExecuteScalar(string connectionString, string cmdText, params OleDbParameter[] commandParameters)
    {
        OleDbCommand cmd = new OleDbCommand();
        using (OleDbConnection connection = new OleDbConnection(connectionString))
        {
            PrepareCommand(cmd, connection, null, cmdText, commandParameters);
            object val = cmd.ExecuteScalar();
            cmd.Parameters.Clear();
            return val;
        }
    }
    /// 
    /// 用指定的数据库连接执行一个命令并返回一个数据集的第一列
    /// 
    /// 
    /// 例如:  
    ///  Object obj = ExecuteScalar(connString, "PublishOrders", new OleDbParameter("@prodid", 24));
    /// 
    /// 一个存在的数据库连接
    /// 存储过程名称或者sql命令语句
    /// 执行命令所用参数的集合
    /// 用 Convert.To{Type}把类型转换为想要的 
    public static object ExecuteScalar(OleDbConnection connection, string cmdText, params OleDbParameter[] commandParameters)
    {
        OleDbCommand cmd = new OleDbCommand();
        PrepareCommand(cmd, connection, null, cmdText, commandParameters);
        object val = cmd.ExecuteScalar();
        cmd.Parameters.Clear();
        return val;
    }
    /// 
    /// 将参数集合添加到缓存
    /// 
    /// 添加到缓存的变量
    /// 一个将要添加到缓存的sql参数集合
    public static void CacheParameters(string cacheKey, params OleDbParameter[] commandParameters)
    {
        parmCache[cacheKey] = commandParameters;
    }
    /// 
    /// 找回缓存参数集合
    /// 
    /// 用于找回参数的关键字
    /// 缓存的参数集合
    public static OleDbParameter[] GetCachedParameters(string cacheKey)
    {
        OleDbParameter[] cachedParms = (OleDbParameter[])parmCache[cacheKey];
        if (cachedParms == null)
            return null;
        OleDbParameter[] clonedParms = new OleDbParameter[cachedParms.Length];
        for (int i = 0, j = cachedParms.Length; i < j; i++)
            clonedParms =(OleDbParameter[])((ICloneable)cachedParms).Clone();
        return clonedParms;
    }
    /// 
    /// 准备执行一个命令
    /// 
    /// sql命令
    /// Sql连接
    /// Sql事务
    /// 命令文本,例如：Select * from Products
    /// 执行命令的参数
    private static void PrepareCommand(OleDbCommand cmd, OleDbConnection conn, OleDbTransaction trans, string cmdText, OleDbParameter[] cmdParms)
    {
        //判断连接的状态。如果是关闭状态，则打开
        if (conn.State != ConnectionState.Open)
            conn.Open();
        //cmd属性赋值
        cmd.Connection = conn;
        cmd.CommandText = cmdText;
        //是否需要用到事务处理
        if (trans != null)
            cmd.Transaction = trans;
        cmd.CommandType = CommandType.Text;
        //添加cmd需要的存储过程参数
        if (cmdParms != null)
        {
            foreach (OleDbParameter parm in cmdParms)
                cmd.Parameters.Add(parm);
        }
    }
}