C#编写的OleDb数据库连接通用类库
2006-09-20 06:32
507 查看
ADOHelper.cs
using System;
using System.Data;
using System.Configuration;
using System.Data.SqlClient;
using System.Data.OleDb;
using IBMDADB2Lib;
using HR1930.COM.Util;
namespace HR1930.COM.DB
{
/// <summary>
/// Summary description for ADOHelper.
/// </summary>
public class ADOHelper
{
// private member variables
OleDbConnection con;
static String m_ConnectionString;
public ADOHelper()
{
con = new OleDbConnection(ADOHelper.ConnectionString());
}
public DataSet ExecuteGet(string cmd)
{
this.CheckConnection();
DataSet dataSet = new DataSet();
try
{
OleDbCommand dataCommand = new OleDbCommand(cmd,con);
OleDbDataAdapter dataAdapter = new OleDbDataAdapter();
dataAdapter.SelectCommand = dataCommand;
dataAdapter.Fill(dataSet, "recordSet");
}
catch(SqlException se)
{
ErrorLog el = new ErrorLog(se);
throw new Exception("Error in SQL", se);
}
this.Dispose();
return dataSet;
}
public OleDbDataReader ExecuteRead(String cmd)
{
this.CheckConnection();
OleDbDataReader dr = null;
try
{
OleDbCommand dc = new OleDbCommand(cmd, con);
dr = dc.ExecuteReader();
return dr;
}
catch(SqlException se)
{
ErrorLog el = new ErrorLog(se);
}
this.Dispose();
return dr;
}
public void ExecuteUpdate(string cmd)
{
this.CheckConnection();
try
{
OleDbCommand dc = new OleDbCommand(cmd, con);
dc.ExecuteNonQuery();
}
catch(SqlException se)
{
ErrorLog el = new ErrorLog(se);
}
this.Dispose();
return;
}
private void CheckConnection()
{
try
{
if (con.State != ConnectionState.Open)
con.Open();
}
catch (System.Data.SqlClient.SqlException se)
{
ErrorLog el = new ErrorLog(se);
throw new Exception("Failed to Open connection.", se);
}
}
public static String ConnectionString()
{
// Pull the ConnectionString from the ASP+ AppSettings section.
// Cache in static field for faster repeat access.
if (m_ConnectionString == null)
{
m_ConnectionString = (String) ConfigurationSettings.AppSettings["ConnectionString"];
if (m_ConnectionString == null)
{
throw new Exception("Connect string value not set in Web.config");
}
}
return m_ConnectionString;
}
public void Dispose()
{
try
{
if (con.State == ConnectionState.Open)
con.Close();
//con = null;
}
catch(Exception e)
{
ErrorLog el = new ErrorLog(e);
}
}
}
}
using System;
using System.Data;
using System.Configuration;
using System.Data.SqlClient;
using System.Data.OleDb;
using IBMDADB2Lib;
using HR1930.COM.Util;
namespace HR1930.COM.DB
{
/// <summary>
/// Summary description for ADOHelper.
/// </summary>
public class ADOHelper
{
// private member variables
OleDbConnection con;
static String m_ConnectionString;
public ADOHelper()
{
con = new OleDbConnection(ADOHelper.ConnectionString());
}
public DataSet ExecuteGet(string cmd)
{
this.CheckConnection();
DataSet dataSet = new DataSet();
try
{
OleDbCommand dataCommand = new OleDbCommand(cmd,con);
OleDbDataAdapter dataAdapter = new OleDbDataAdapter();
dataAdapter.SelectCommand = dataCommand;
dataAdapter.Fill(dataSet, "recordSet");
}
catch(SqlException se)
{
ErrorLog el = new ErrorLog(se);
throw new Exception("Error in SQL", se);
}
this.Dispose();
return dataSet;
}
public OleDbDataReader ExecuteRead(String cmd)
{
this.CheckConnection();
OleDbDataReader dr = null;
try
{
OleDbCommand dc = new OleDbCommand(cmd, con);
dr = dc.ExecuteReader();
return dr;
}
catch(SqlException se)
{
ErrorLog el = new ErrorLog(se);
}
this.Dispose();
return dr;
}
public void ExecuteUpdate(string cmd)
{
this.CheckConnection();
try
{
OleDbCommand dc = new OleDbCommand(cmd, con);
dc.ExecuteNonQuery();
}
catch(SqlException se)
{
ErrorLog el = new ErrorLog(se);
}
this.Dispose();
return;
}
private void CheckConnection()
{
try
{
if (con.State != ConnectionState.Open)
con.Open();
}
catch (System.Data.SqlClient.SqlException se)
{
ErrorLog el = new ErrorLog(se);
throw new Exception("Failed to Open connection.", se);
}
}
public static String ConnectionString()
{
// Pull the ConnectionString from the ASP+ AppSettings section.
// Cache in static field for faster repeat access.
if (m_ConnectionString == null)
{
m_ConnectionString = (String) ConfigurationSettings.AppSettings["ConnectionString"];
if (m_ConnectionString == null)
{
throw new Exception("Connect string value not set in Web.config");
}
}
return m_ConnectionString;
}
public void Dispose()
{
try
{
if (con.State == ConnectionState.Open)
con.Close();
//con = null;
}
catch(Exception e)
{
ErrorLog el = new ErrorLog(e);
}
}
}
}
相关文章推荐
- C#使用ODBC与OLEDB连接数据库的方法示例
- C++类库:OTL通用的数据库连接类库
- 用C#访问带密码ACCESS数据库(OLEDB连接各种数据库)
- C# 连接 Oracle 数据库(三种方式:OracleClient、ODBC、OLEDB)
- C#建立MSSQL数据库本地通用连接
- C++类库:OTL通用的数据库连接类库
- C#-继承IDbConnection连接不同数据库,通用的DbHelper(2)
- JDBC连接数据库之编写通用的Dao(7)
- c# 数据库,连接类库 ---DbHelp.cs
- C#编写的OLEDB数据库操作基本类
- 用C#访问带密码ACCESS数据库(OLEDB连接各种数据库)
- C#通过三层连接数据库编写QQ(二)(含资源)
- C#使用OleDb连接Excel数据源编写查询语句捕获到“无法识别的关键字when”的异常
- C#学习—连接数据库通用增删改,查询
- C#连接OleDBConnection数据库的操作
- C# 使用oledb 方式连接本地或者远程oracel 数据库的方式
- C# 读取 appconfig文件配置数据库连接字符串,和配置文件
- C#和SQL Server2000数据库连接,查询语句总结
- c#.net连接access操作类 (转)|| C#中如何连接Access2007数据库