>>51aspx首页 | >>Winform源码 | >>.Net源码大搜捕 | >>问题/帮助

Asp.net源码交流论坛

登录 注册
  • 标签
  • 会员
  • 搜索
  • 帮助

Asp.net源码交流论坛 » Asp.net交流讨论区 » Asp.net技术问答 » Access数据库操作类AccessHelper

帖子标题
业务申请区
  • 实名认证申请
  • 免费.Net主机申请
  • 积分奖励申请
  • 有偿服务申请
Asp.net交流讨论区
  • Asp.net技术问答
  • .Net项目、服务交易区
  • .Net源码问答区
  • Asp.net技术文章
  • 常用工具下载
Asp.net资源发布区
  • [源码发布区]
  • [视频发布区]
  • [商业代码区]
  • [其他.net相关资源]
Asp.net专题讨论区
  • Ajax/Atlas无刷新技术
  • 面向对象开发
  • ADO.net讨论区
  • 控件专题讨论
源码环境搭建和部署视频! 源码使用常见问题 51Aspx自有服务产品 开业特惠 快速通道:[源码发布] | [实名认证]
1/2页12 跳转到页查看:7159
发新话题 回复该主题
键盘左右键可以进行前后翻页操作
帮助

Access数据库操作类AccessHelper

离线 hevod
头像

  • [学员]
  • [26]
  • 19
  • 2007-05-25
hevod 2008-01-30 09:57 | 只看楼主 树型| 收藏| 小 中 大 1 #

Access数据库操作类AccessHelper





[复制到剪贴板]
CODE:

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;
/// <summary>
/// AcceHelper 的摘要说明
/// </summary>
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());
    /// <summary>
    ///  给定连接的数据库用假设参数执行一个sql命令(不返回数据集)
    /// </summary>
    /// <param name="connectionString">一个有效的连接字符串</param>
    /// <param name="commandText">存储过程名称或者sql命令语句</param>
    /// <param name="commandParameters">执行命令所用参数的集合</param>
    /// <returns>执行命令所影响的行数</returns>
    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;
        }
    }
    /// <summary>
    /// 用现有的数据库连接执行一个sql命令(不返回数据集)
    /// </summary>
    /// <remarks>
    ///举例: 
    ///  int result = ExecuteNonQuery(connString, "PublishOrders", new OleDbParameter("@prodid", 24));
    /// </remarks>
    /// <param name="conn">一个现有的数据库连接</param>
    /// <param name="commandText">存储过程名称或者sql命令语句</param>
    /// <param name="commandParameters">执行命令所用参数的集合</param>
    /// <returns>执行命令所影响的行数</returns>
    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;
    }
    /// <summary>
    ///使用现有的SQL事务执行一个sql命令(不返回数据集)
    /// </summary>
    /// <remarks>
    ///举例: 
    ///  int result = ExecuteNonQuery(trans, "PublishOrders", new OleDbParameter("@prodid", 24));
    /// </remarks>
    /// <param name="trans">一个现有的事务</param>
    /// <param name="commandText">存储过程名称或者sql命令语句</param>
    /// <param name="commandParameters">执行命令所用参数的集合</param>
    /// <returns>执行命令所影响的行数</returns>
    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;
    }
    /// <summary>
    /// 用执行的数据库连接执行一个返回数据集的sql命令
    /// </summary>
    /// <remarks>
    /// 举例: 
    ///  OleDbDataReader r = ExecuteReader(connString, "PublishOrders", new OleDbParameter("@prodid", 24));
    /// </remarks>
    /// <param name="connectionString">一个有效的连接字符串</param>
    /// <param name="commandText">存储过程名称或者sql命令语句</param>
    /// <param name="commandParameters">执行命令所用参数的集合</param>
    /// <returns>包含结果的读取器</returns>
    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;
        }
    }
    /// <summary>
    /// 返回一个DataSet数据集
    /// </summary>
    /// <param name="connectionString">一个有效的连接字符串</param>
    /// <param name="cmdText">存储过程名称或者sql命令语句</param>
    /// <param name="commandParameters">执行命令所用参数的集合</param>
    /// <returns>包含结果的数据集</returns>
    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;
            }
        }
    }
    /// <summary>
    /// 用指定的数据库连接字符串执行一个命令并返回一个数据集的第一列
    /// </summary>
    /// <remarks>
    ///例如: 
    ///  Object obj = ExecuteScalar(connString, "PublishOrders", new OleDbParameter("@prodid", 24));
    /// </remarks>
    ///<param name="connectionString">一个有效的连接字符串</param>
    /// <param name="commandText">存储过程名称或者sql命令语句</param>
    /// <param name="commandParameters">执行命令所用参数的集合</param>
    /// <returns>用 Convert.To{Type}把类型转换为想要的 </returns>
    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;
        }
    }
    /// <summary>
    /// 用指定的数据库连接执行一个命令并返回一个数据集的第一列
    /// </summary>
    /// <remarks>
    /// 例如: 
    ///  Object obj = ExecuteScalar(connString, "PublishOrders", new OleDbParameter("@prodid", 24));
    /// </remarks>
    /// <param name="conn">一个存在的数据库连接</param>
    /// <param name="commandText">存储过程名称或者sql命令语句</param>
    /// <param name="commandParameters">执行命令所用参数的集合</param>
    /// <returns>用 Convert.To{Type}把类型转换为想要的 </returns>
    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;
    }
    /// <summary>
    /// 将参数集合添加到缓存
    /// </summary>
    /// <param name="cacheKey">添加到缓存的变量</param>
    /// <param name="cmdParms">一个将要添加到缓存的sql参数集合</param>
    public static void CacheParameters(string cacheKey, params OleDbParameter[] commandParameters)
    {
        parmCache[cacheKey] = commandParameters;
    }
    /// <summary>
    /// 找回缓存参数集合
    /// </summary>
    /// <param name="cacheKey">用于找回参数的关键字</param>
    /// <returns>缓存的参数集合</returns>
    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;
    }
    /// <summary>
    /// 准备执行一个命令
    /// </summary>
    /// <param name="cmd">sql命令</param>
    /// <param name="conn">Sql连接</param>
    /// <param name="trans">Sql事务</param>
    /// <param name="cmdText">命令文本,例如:Select * from Products</param>
    /// <param name="cmdParms">执行命令的参数</param>
    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);
        }
    }
}


 

TOP

 

发送短消息

查看公共资料

查找该会员全部帖子

  • 20
  • 1
  • 2 分
  • 3.2 元
  • 离线
离线 and1.net
头像

aNd1.coder

  • [程序员]
  • 1986-11-18
  • [74]
  • 56
  • 2008-01-17
and1.net 2008-03-04 21:39 树型| 收藏| 小 中 大 2 #

回复:Access数据库操作类AccessHelper



谢谢..很受用..类似SqlHelpr...
 

TOP

 

发送短消息

查看公共资料

查找该会员全部帖子

  • 5501
  • 0
  • 18 分
  • 3.75 元
  • 湖南长沙
  • 离线
  • MSN Messenger: aNd1coder@hotmail.com aNd1coder@hotmail.com
  • QQ: 290310398 290310398
离线 wangking
头像

  • [学员]
  • [3]
  • 5
  • 2008-01-14
wangking 2008-09-24 21:10 树型| 收藏| 小 中 大 3 #

回复:Access数据库操作类AccessHelper



问一下,<connectionStrings>中的字段要什么样子的?
 

TOP

 

发送短消息

查看公共资料

查找该会员全部帖子

  • 5281
  • 0
  • -2 分
  • 0.9 元
  • 离线
离线 wangking
头像

  • [学员]
  • [3]
  • 5
  • 2008-01-14
wangking 2008-09-24 21:15 树型| 收藏| 小 中 大 4 #

回复:Access数据库操作类AccessHelper



请问一下<connectionStrings>中字段是什么?另外能举个例子吗?
 

TOP

 

发送短消息

查看公共资料

查找该会员全部帖子

  • 5281
  • 0
  • -2 分
  • 0.9 元
  • 离线
离线 ccjnet
头像

  • [学员]
  • [4]
  • 4
  • 2008-09-30
ccjnet 2008-09-30 13:51 树型| 收藏| 小 中 大 5 #

回复:Access数据库操作类AccessHelper



看贴要回帖,这是美德,呵呵
 

TOP

 

发送短消息

查看公共资料

查找该会员全部帖子

  • 32748
  • 0
  • 0 分
  • 0.4 元
  • 离线
离线 app
头像

  • [学员]
  • [1]
  • 1
  • 2008-07-06
app 2008-11-19 16:56 树型| 收藏| 小 中 大 6 #

回复:Access数据库操作类AccessHelper



对新手来说 都不知道该怎么用

最好能弄点调用的实例
 

TOP

 

发送短消息

查看公共资料

查找该会员全部帖子

  • 24164
  • 0
  • 0 分
  • 0.1 元
  • 离线
离线 xumingxiang
头像

祥叔

  • [工程师]
  • [167]
  • 58
  • 2008-11-10
源码贡献奖
xumingxiang 2008-11-19 20:04 树型| 收藏| 小 中 大 7 #

回复:Access数据库操作类AccessHelper



把SqlHelper修改修改,想搞成OracleHelper 、MySQlHelper  都是可以的......
 

TOP

 

发送短消息

查看公共资料

查找该会员全部帖子

  • 37146
  • 0
  • 109 分
  • 13.55 元
  • 江苏
  • 离线
  • QQ: 115402708 115402708
离线 flyerwon
头像

小迷糊

  • [工程师]
  • 2005-11-26
  • [405]
  • 357
  • 2007-11-30
flyerwon 2008-11-22 18:30 树型| 收藏| 小 中 大 8 #

回复:Access数据库操作类AccessHelper



<add name="ConnectString" value="连接字符串"/>
无论是疯狂自信,还是超级自卑;如果自信,也请以能力为基础!
只要是人就给我拉进来,结果那些18罗汉都成功了!
能力和学历并不是最重要的
细节决定成败,完美决定高度....
 

TOP

 

发送短消息

查看公共资料

查找该会员全部帖子

  • 1267
  • 0
  • 48 分
  • 33.4 元
  • 西安
  • 离线
  • QQ: 75641535 75641535
离线 mandog
头像

  • [学员]
  • [7]
  • 1
  • 2009-06-04
mandog 2009-06-04 15:15 树型| 收藏| 小 中 大 9 #



thanks
 

TOP

 

发送短消息

查看公共资料

查找该会员全部帖子

  • 58331
  • 0
  • 6 分
  • 5 元
  • 离线
离线 hdeqi2005
头像

Eli_king

  • [工程师]
  • [138]
  • 71
  • 2008-06-19
实名用户
hdeqi2005 2009-08-28 10:06 树型| 收藏| 小 中 大 10 #

AccessHelper

[实名用户所发信息,推荐关注实名贴,值得关注]


using System;
using System.Web;
using System.Configuration;
using System.Data;
using System.Collections;
using System.Data.OleDb;

namespace AccessDAL
{
    public abstract class AccessHelper
    {
          //Database connection strings

        public static string SystemPath = ConfigurationManager.AppSettings["SystemPath"].ToString();

        public static readonly string ConnectionStringProfile = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + HttpContext.Current.Server.MapPath(SystemPath) + ConfigurationManager.ConnectionStrings["AccessConnstr"].ConnectionString;


        // Hashtable to store cached parameters
        private static Hashtable parmCache = Hashtable.Synchronized(new Hashtable());

   

        public static int ExecuteNonQuery(string connectionString, CommandType cmdType, string cmdText)
        {

            OleDbCommand cmd = new OleDbCommand();

            using (OleDbConnection conn = new OleDbConnection(connectionString))
            {
                PrepareCommand(cmd, conn, null, cmdType, cmdText);
                int val = cmd.ExecuteNonQuery();
                cmd.Parameters.Clear();
                return val;
               
            }
        }

        public static int ExecuteNonQuery(string strSql)
        {

            OleDbCommand cmd ;
            int i=0;
            using (OleDbConnection conn = new OleDbConnection(ConnectionStringProfile))
            {
                conn.Open();
                cmd = new OleDbCommand(strSql, conn);
                i = cmd.ExecuteNonQuery();
            }
            return i;
        }
   

        public static int ExecuteNonQuery(OleDbConnection connection, CommandType cmdType, string cmdText)
        {

            OleDbCommand cmd = new OleDbCommand();

            PrepareCommand(cmd, connection, null, cmdType, cmdText);
            int val = cmd.ExecuteNonQuery();
            cmd.Parameters.Clear();
            return val;
        }
   
        public static int ExecuteNonQuery(OleDbTransaction trans, CommandType cmdType, string cmdText)
        {
            OleDbCommand cmd = new OleDbCommand();
            PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText);
            int val = cmd.ExecuteNonQuery();
            cmd.Parameters.Clear();
            return val;
        }

   


        public static OleDbDataReader ExecuteReader(string connectionString, CommandType cmdType, string cmdText)
        {
            OleDbCommand cmd = new OleDbCommand();
            OleDbConnection conn = new OleDbConnection(connectionString);

            // we use a try/catch here because if the method throws an exception we want to
            // close the connection throw code, because no datareader will exist, hence the
            // commandBehaviour.CloseConnection will not work
            try
           
            {
                PrepareCommand(cmd, conn, null, cmdType, cmdText);
                OleDbDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
                cmd.Parameters.Clear();
                return rdr;
            }
            catch
            {
                conn.Close();
                throw;
            }
        }


   
        public static DataSet ExecuteDataSet( string  connectionString,  CommandType cmdType,  string  cmdText)
        {

            //Create the command and connection
            OleDbConnection  conn = new OleDbConnection(connectionString);
            OleDbCommand  cmd = new OleDbCommand();

            try
            {
                //Prepare the command to execute
                PrepareCommand(cmd, conn, null, cmdType, cmdText);

                OleDbDataAdapter myDataAdapter = new OleDbDataAdapter(cmdText, conn);

                DataSet  ds = new DataSet();

                myDataAdapter.Fill(ds);

                return ds;

            }
            catch
            {

                //if ( an error occurs close the connection as the reader will not be used and we expect it to close the connection
                conn.Close();
                throw;
            }
        }


        public static OleDbDataAdapter ExecuteDataAdapter(string connectionString, CommandType cmdType, string cmdText)
        {

            //Create the command and connection
            OleDbConnection conn = new OleDbConnection(connectionString);
            OleDbCommand cmd = new OleDbCommand();

            try
            {
                //Prepare the command to execute
                PrepareCommand(cmd, conn, null, cmdType, cmdText);
                OleDbDataAdapter myDataAdapter = new OleDbDataAdapter(cmdText, conn);
                return myDataAdapter;

            }
            catch
            {

                //if ( an error occurs close the connection as the reader will not be used and we expect it to close the connection
                conn.Close();
                throw;
            }
        }


       
        public static object ExecuteScalar(string connectionString, CommandType cmdType, string cmdText)
        {
            OleDbCommand cmd = new OleDbCommand();

            using (OleDbConnection connection = new OleDbConnection(connectionString))
            {
                PrepareCommand(cmd, connection, null, cmdType, cmdText);
                object val = cmd.ExecuteScalar();
                cmd.Parameters.Clear();
                return val;
            }
        }


        public static object  ExecuteScalar(string strSql)
        {
         
            OleDbConnection conn = new OleDbConnection(ConnectionStringProfile);
            conn.Open();
            OleDbCommand cmd = new OleDbCommand(strSql, conn);
            object str = cmd.ExecuteScalar();
            conn.Close();
            return str;
        }
   

        public static object ExecuteScalar(OleDbConnection connection, CommandType cmdType, string cmdText)
        {

            OleDbCommand cmd = new OleDbCommand();

            PrepareCommand(cmd, connection, null, cmdType, cmdText);
            object val = cmd.ExecuteScalar();
            cmd.Parameters.Clear();
            return val;
        }

     
      private static void PrepareCommand(OleDbCommand cmd, OleDbConnection conn, OleDbTransaction trans, CommandType cmdType, string cmdText)
        {

            if (conn.State != ConnectionState.Open)
                conn.Open();

            cmd.Connection = conn;
            cmd.CommandText = cmdText;

            if (trans != null)
                cmd.Transaction = trans;

            cmd.CommandType = cmdType;

           
        }
       
    }
}
 

TOP

 

发送短消息

查看公共资料

查找该会员全部帖子

  • 22687
  • 0
  • 67 分
  • 7.1 元
  • 离线
  • QQ: 57237184 57237184
<<上一主题|下一主题>>
1/2页12 跳转到页
发表新主题 回复该主题

相关主题

1日-10日 ASP空间只要55元/年免费试用3天 送SQL数据库50M 送CN域名
数据库索引的作用和优点缺点
酒店管理系统
中级网站源码
使用Repeater控件开发RssFeed
  • 发新主题

Asp.net源码下载专业站  - 源码推荐 - 最新源码  Sitemap

bbs.51Aspx.com - 简洁版本 - TOP - 界面风格

  • Default

Discuz!NT

Powered by Discuz!NT 2.6.1 © 2000-2010 51Aspx.com.

Processed in 0.15625 second(s) , 5 queries. 京ICP备06046876号

  • 我的资料
  • 我的主题
  • 我的回复
  • 我的精华
  • 我的附件
  • 我的收藏
  • 基本状况
  • 流量统计
  • 客户软件
  • 发帖量记录
  • 版块排行
  • 主题排行
  • 发帖排行
  • 积分排行
  • 在线时间
帖子标题
作  者