/*************************************************
OleDb
**************************************************/
using System;
using System.IO;
using System.Data;
using System.Data.OleDb;
using System.Configuration;
namespace Db
{
/// <summary>
///
/// </summary>
public class OleDb
{
public OleDb()
{
//
// TODO: 在此处添加构造函数逻辑
m_oleDbCnn = null;
//
}
/// <summary>
/// Connecion连接 字符
/// </summary>
private string m_strCnn;// = System.Configuration.ConfigurationSettings.AppSettings["ConnectionString"];
/// <summary>
/// OleDbConnection
/// </summary>
private OleDbConnection m_oleDbCnn = null;//new OleDbConnection(m_strCnn);
/// <summary>
/// 打开Connection
/// </summary>
private void OpenCnn()
{
if (m_oleDbCnn.State==ConnectionState.Open)
{
m_oleDbCnn.Close();
}
m_oleDbCnn.Open();
}
/// <summary>
/// //执行delete，update,insert等操作
/// </summary>
public int ExeNoQuery(string strSql)
{
int nRet = -1;
m_strError = "";
OleDbCommand oleDbCmd = new OleDbCommand(strSql,m_oleDbCnn);
try
{
OpenCnn();
nRet = oleDbCmd.ExecuteNonQuery();
}
catch (OleDbException ex)
{
nRet = -1;
m_strError = ex.ToString();
}
finally
{
if (m_oleDbCnn.State==ConnectionState.Open)
{
oleDbCmd.Dispose();
m_oleDbCnn.Close();
}
}
return nRet;
}
/// <summary>
/// //执行delete,update,insert等操作
/// </summary>
public int ExeNoQuery(OleDbCommand oleDbCmd)
{
int nRet = -1;
m_strError = "";
oleDbCmd.Connection = m_oleDbCnn;
try
{
nRet = oleDbCmd.ExecuteNonQuery();
}
catch (OleDbException ex)
{
nRet = -1;
m_strError = ex.ToString();
}
finally
{
if (m_oleDbCnn.State==ConnectionState.Open)
{
m_oleDbCnn.Close();
}
}
return nRet;
}
/// <summary>
/// 判断是否存在
/// </summary>
public int ExeIsExist(string strSql)
{
int nExist = -1;
m_strError = "";
OleDbCommand oleDbCmd = new OleDbCommand(strSql,m_oleDbCnn);
try
{
OpenCnn();
OleDbDataReader dr= oleDbCmd.ExecuteReader();
if (dr.Read())
{
nExist = 1;
}
else
{
nExist = 0;
}
}
catch (OleDbException ex)
{
nExist = -1;
m_strError = ex.ToString();
}
finally
{
if (m_oleDbCnn.State==ConnectionState.Open)
{
oleDbCmd.Dispose();
m_oleDbCnn.Close();
}
}
return nExist;
}
/// <summary>
/// 判断是否存在
/// </summary>
public int ExeIsExist(OleDbCommand oleDbCmd)
{
int nExist = -1;
m_strError = "";
oleDbCmd.Connection = m_oleDbCnn;
try
{
OpenCnn();
OleDbDataReader dr = oleDbCmd.ExecuteReader();
if (dr.Read())
{
nExist = 1;
}
else
{
nExist = 0;
}
}
catch (OleDbException ex)
{
nExist = -1;
m_strError = ex.ToString();
}
finally
{
if (m_oleDbCnn.State==ConnectionState.Open)
{
m_oleDbCnn.Close();
}
}
return nExist;
}
/// <summary>
/// 执行ExecuteScalar
/// </summary>
public int ExeScalar(string strSql)
{
int nNum = -1;
m_strError = "";
OleDbCommand oleDbCmd = new OleDbCommand(strSql,m_oleDbCnn);
try
{
OpenCnn();
nNum = (int)oleDbCmd.ExecuteScalar();
}
catch (OleDbException ex)
{
nNum = -1;
m_strError = ex.ToString();
}
finally
{
if (m_oleDbCnn.State==ConnectionState.Open)
{
oleDbCmd.Dispose();
m_oleDbCnn.Close();
}
}
return nNum;
}
/// <summary>
/// 返回OleDbDataReader
/// </summary>
public OleDbDataReader ExeSqlDr(string strSql)
{
OleDbDataReader dr = null;
m_strError = "";
OleDbCommand oleDbCmd = new OleDbCommand(strSql,m_oleDbCnn);
try
{
OpenCnn();
dr = oleDbCmd.ExecuteReader();
}
catch (OleDbException ex)
{
dr = null;
m_strError = ex.ToString();
}
finally
{
if (m_oleDbCnn.State==ConnectionState.Open)
{
oleDbCmd.Dispose();
}
}
return dr;
}
/// <summary>
/// 返回DataSet
/// </summary>
public DataSet ExeSqlDs(string strSql, string strTable)
{
m_strError = "";
DataSet ds = new DataSet();
OleDbDataAdapter oleDbAdapter = new OleDbDataAdapter(strSql,m_oleDbCnn);
try
{
oleDbAdapter.Fill(ds,strTable);
}
catch (OleDbException ex)
{
ds = null;
m_strError = ex.ToString();
}
return ds;
}
/// <summary>
/// 返回DataSet
/// </summary>
public DataSet ExeSqlDs(string strSql, int nStart, int nCount, string strTable)
{
m_strError = "";
DataSet ds
