.net三層結(jié)構(gòu)初探分析第3/4頁(yè)

更新時(shí)間：2008年09月08日 20:42:54 作者：

最近開(kāi)始對(duì)架構(gòu)開(kāi)始了研究，當(dāng)然由于水平不夠，先研究了“簡(jiǎn)單的三層結(jié)構(gòu)”，至于“抽象工廠模式”放后面來(lái)研究吧！

下面貼出相關(guān)代碼：
web.config
<appSettings>
<add key="ConnectionString" value="Provider=Microsoft.Jet.OleDb.4.0;Data Source=|DataDirectory|data.mdb" />
</appSettings>
DBUtility--PubConstant.cs(連接字符串)

復(fù)制代碼代碼如下:

using System; 
using System.Configuration; 

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

DBUtility--DbHelperOleDb.cs(數(shù)據(jù)基類SQL語(yǔ)句)

復(fù)制代碼代碼如下:

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; 
} 
} 


} 
} 