oledbhelper.cs

一个开源企业网站

using System;
using System.Web;
using System.Collections.Generic;
using System.Text;
using System.Collections;
using System.Data;
using System.Data.OleDb;
using System.Configuration;
using System.ComponentModel;

namespace OleDbHelper
{
    public class OleDbHelper
    {
        /// 连接数据源
        private OleDbConnection MyConn = null;
        private readonly string RETURNVALUE = "RETURNVALUE";

        /// <summary>
        /// 打开数据库连接.
        /// </summary>
        private void Open()
        {
            // 打开数据库连接
            if (MyConn == null)
            {
                MyConn = new OleDbConnection(ConfigurationManager.AppSettings["OLEDBCONNECTIONSTRING"].ToString() + System.Web.HttpContext.Current.Server.MapPath(ConfigurationManager.AppSettings["dbPath"]));
            }
            if (MyConn.State == ConnectionState.Closed)
            {
                try
                {
                    ///打开数据库连接
                    MyConn.Open();
                }
                catch (Exception ex)
                {
                    SystemError.CreateErrorLog(ex.Message);
                }
                finally
                {
                    ///关闭已经打开的数据库连接				
                }
            }
        }

        /// <summary>
        /// 关闭数据库连接
        /// </summary>
        public void Close()
        {
            ///判断连接是否已经创建
            if (MyConn != null)
            {
                ///判断连接的状态是否打开
                if (MyConn.State == ConnectionState.Open)
                {
                    MyConn.Close();
                }
            }
        }

        /// <summary>
        /// 释放资源
        /// </summary>
        public void Dispose()
        {
            // 确认连接是否已经关闭
            if (MyConn != null)
            {
                MyConn.Dispose();
                MyConn = null;
            }
        }

        private OleDbCommand TrySqlCommand(string cmdText)
        {
            OleDbCommand cmd = new OleDbCommand(cmdText, MyConn);
            cmd.ExecuteNonQuery();
            return cmd;
        }
        private OleDbCommand CreateSQLCommand(string cmdText)
        {
            Open();
            OleDbCommand cmd = new OleDbCommand(cmdText, MyConn);
            return cmd;
        }
        public void TryCmd(string cmdText)
        {
            OleDbCommand cmd = TrySqlCommand(cmdText);
        }
        public void RunCmd(string cmdText, out OleDbDataReader dataReader)
        {
            ///创建Command
            OleDbCommand cmd = CreateSQLCommand(cmdText);

            try
            {
                ///读取数据
                dataReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
            }
            catch (Exception ex)
            {
                dataReader = null;
                ///记录错误日志
                SystemError.CreateErrorLog(ex.Message);
            }
        }
        //创建ADAPTER
        private OleDbDataAdapter CreateProcDataAdapter(string cmdText)
        {
            ///打开数据库连接
            Open();
            ///设置SqlDataAdapter对象
            OleDbDataAdapter da = new OleDbDataAdapter(cmdText, MyConn);
            da.SelectCommand.CommandType = CommandType.Text;
            return da;
        }

    }

}