using System;
using System.Configuration;

namespace MyCms.DBUtility
{
public class PubConstant
{
public static string ConnectionString
{
get
{
return ConfigurationSettings.AppSettings["ConnectionString"];
}
}
}
}

using System;
using System.Collections;
using System.Text;
using System.Data;
using System.Data.OleDb;

namespace MyCms.DBUtility
{
//數(shù)據(jù)訪問(wèn)基類(基于OleDb)
public partial class DbHelperOleDb
{
//數(shù)據(jù)庫(kù)連接字符串，在web.config中配置
public static string ConnectionString = PubConstant.ConnectionString;
public DbHelperOleDb()
{
}

/// <summary>
/// 執(zhí)行SQL語(yǔ)句，返回影響的記錄數(shù)
/// </summary>
/// <param name="strSql">SQL語(yǔ)句</param>
/// <returns>影響的記錄數(shù)</returns>
public static int ExecuteSql(string strSql)
{
using (OleDbConnection conn = new OleDbConnection(ConnectionString))
{
using (OleDbCommand cmd = new OleDbCommand(strSql, conn))
{
try
{
conn.Open();
return cmd.ExecuteNonQuery();
}
catch(OleDbException E)
{
conn.Close();
throw new Exception(E.Message);
}

}
}
}

/// <summary>
/// 執(zhí)行多條SQL語(yǔ)句，實(shí)現(xiàn)數(shù)據(jù)庫(kù)事務(wù)
/// </summary>
/// <param name="SqlStrList">多條SQL語(yǔ)句</param>
public static void ExecuteSqlTran(ArrayList SqlStrList)
{
using (OleDbConnection conn = new OleDbConnection(ConnectionString))
{
conn.Open();
OleDbCommand cmd = new OleDbCommand();
cmd.Connection = conn;
OleDbTransaction tx = conn.BeginTransaction();
cmd.Transaction = tx;
try
{
for (int n = 0; n < SqlStrList.Count; n++)
{
string strSql = SqlStrList[n].ToString();
if (strSql.Trim().Length > 1)
{
cmd.CommandText = strSql;
cmd.ExecuteNonQuery();
}
}
tx.Commit();
}
catch (System.Data.OleDb.OleDbException E)
{
tx.Rollback();
throw new Exception(E.Message);
}
}
}

/// <summary>
/// 執(zhí)行帶一個(gè)存儲(chǔ)過(guò)程參數(shù)的SQL語(yǔ)句
/// </summary>
/// <param name="strSql">SQL語(yǔ)句</param>
/// <param name="content">參數(shù)內(nèi)容，比如一個(gè)字段是格式復(fù)雜的文章</param>
/// <returns>影響的記錄數(shù)</returns>
public static int ExecuteSinglePro(string strSql, string content)
{
using (OleDbConnection conn = new OleDbConnection(ConnectionString))
{
OleDbCommand cmd = new OleDbCommand(strSql, conn);
OleDbParameter myParameter = new OleDbParameter("@content",OleDbType.VarChar);
myParameter.Value = content;
cmd.Parameters.Add(myParameter);
try
{
conn.Open();
return cmd.ExecuteNonQuery();
}
catch (OleDbException E)
{
throw new Exception(E.Message);
}
finally
{
cmd.Dispose();
conn.Close();
}

}
}

/// <summary>
/// 執(zhí)行一條計(jì)算查詢結(jié)果語(yǔ)句，返回查詢結(jié)果
/// </summary>
/// <param name="strSql">SQL語(yǔ)句</param>
/// <returns>查詢結(jié)果</returns>
public static object GetSingle(string strSql)
{
using (OleDbConnection conn = new OleDbConnection(ConnectionString))
{
using (OleDbCommand cmd = new OleDbCommand(strSql, conn))
{
try
{
conn.Open();
object obj = cmd.ExecuteScalar();
if ((Equals(obj, null)) || Equals(obj, DBNull.Value))
{
return null;
}
else
{
return obj;
}
}
catch (OleDbException E)
{
conn.Close();
throw new Exception(E.Message);
}
}
}
}

/// <summary>
/// 返回OleDbDataReader
/// </summary>
/// <param name="strSql">查詢語(yǔ)句</param>
/// <returns>OleDbDataReader</returns>
public static OleDbDataReader ExecuteReader(string strSql)
{
OleDbDataReader dr = null;
using (OleDbConnection conn = new OleDbConnection(ConnectionString))
{
using(OleDbCommand cmd = new OleDbCommand(strSql,conn))
{
try
{
conn.Open();
cmd.CommandText = strSql;
cmd.CommandType = CommandType.Text;
dr = cmd.ExecuteReader();
}
catch
{
dr.Close();
conn.Close();
cmd.Dispose();
}
}
}
return dr;
}

/// <summary>
/// 執(zhí)行查詢語(yǔ)句，返回DataSet
/// </summary>
/// <param name="strSql">查詢語(yǔ)句</param>
/// <returns>DataSet</returns>
public static DataSet Query(string strSql)
{
using (OleDbConnection conn = new OleDbConnection(ConnectionString))
{
DataSet ds = new DataSet();
try
{
conn.Close();
OleDbDataAdapter da = new OleDbDataAdapter(strSql, conn);
da.Fill(ds, "ds");
}
catch (OleDbException E)
{
throw new Exception(E.Message);
}
return ds;
}
}


}
}