經過上面篇文章的介紹,整個系統的框架算是基本搭建完了,下面,我們要具體實現各個層次。關於數據訪問層的實現,我准備討論三種實 現方式,這一篇文章討論第一種:Access+動態生成SQL。
顧名思義,這種實現將使用Access作為後台數據庫,而操作方式也是最基本的 使用SQL命令。
在具體編寫實現代碼之前,我們需要做一些准備工作:
第一步,我們要將Access數據庫搭建完成,具體做法如下 。
在Web工程下新建一個文件夾,命名為AccessData,並在其中新建一個mdb文件(即Access數據庫文件),按照前面介紹過的數據庫設計構架,將數據表及表間關系建好,這裡不再贅述。
第二步,我們要進行一些配置。
打開Web工程下的Web.config文件,在其中 的appSettings節點下,添加如下鍵值:
<add key="AccessConnectionString" value="Provider=Microsoft.Jet.OLEDB.4.0;Data Source={DBPath}"/>
<add key="AccessPath" value="~/AccessData/AccessDatabase.mdb"/>
第一條為Access的連接字符串,第二條為Access數據庫文件的路 徑,其中“~”表示網站根目錄。
第三步,新建一個工程。
我們要新建一個工程AccessDAL,用來存放Access數據訪 問層的代碼。
准備工作做完了,現在來實現具體的代碼。
1.編寫數據訪問助手類
因為很多數據訪問操作流程很相似,所 以,這裡將一些可復用的代碼抽取出來,編寫成助手類,以此減少代碼量,提高代碼復用性。
這個助手類放在AccessDAL下,叫 AccessDALHelper,主要負責Access數據庫的訪問。它包括三個方法:
GetConnectionString:從配置文件中讀取配置項,組合成連接字 符串。
ExecuteSQLNonQuery:執行指定SQL語句,不返回任何值,一般用於Insert,Delete,Update命令。
ExecuteSQLDataReader:執行SQL語句返回查詢結果,一般用於Select命令。
具體代碼如下:
AccessDALHelper.cs:
AccessDALHelper
1using System;
2using System.Web;
3using System.Web.Caching;
4using System.Configuration;
5using System.Data;
6using System.Data.OleDb;
7using NGuestBook.Utility;
8
9namespace NGuestBook.AccessDAL
10{
11 /**//// <summary>
12 /// Access數據庫操作助手
13 /// </summary>
14 public sealed class AccessDALHelper
15 {
16 /**//// <summary>
17 /// 讀取Access數據庫的連接字符串
18 /// 首先從緩存裡讀取,如果不存在則 到配置文件中讀取,並放入緩存
19 /// </summary>
20 /// <returns>Access數據庫的連接字符串 </returns>
21 private static string GetConnectionString()
22 {
23 if (CacheAccess.GetFromCache("AccessConnectionString") != null)
24 {
25 return CacheAccess.GetFromCache("AccessConnectionString").ToString();
26 }
27 else
28 {
29 string dbPath = ConfigurationManager.AppSettings["AccessPath"];
30 string dbAbsolutePath = HttpContext.Current.Server.MapPath(dbPath);
31 string connectionString = ConfigurationManager.AppSettings["AccessConnectionString"];
32
33 CacheDependency fileDependency = new CacheDependency(HttpContext.Current.Server.MapPath("Web.Config"));
34 CacheAccess.SaveToCache("AccessConnectionString", connectionString.Replace("{DBPath}", dbAbsolutePath), fileDependency);
35
36 return connectionString.Replace("{DBPath}", dbAbsolutePath);
37 }
38 }
39
40 /**//// <summary>
41 /// 執行SQL語句並且不返回任 何值
42 /// </summary>
43 /// <param name="SQLCommand">所執行的SQL命令 </param>
44 /// <param name="parameters">參數集合</param>
45 public static void ExecuteSQLNonQuery(string SQLCommand,OleDbParameter[] parameters)
46 {
47 OleDbConnection connection = new OleDbConnection(GetConnectionString());
48 OleDbCommand command = new OleDbCommand(SQLCommand, connection);
49
50 for (int i = 0; i < parameters.Length; i++)
51 {
52 command.Parameters.Add(parameters[i]);
53 }
54
55 connection.Open();
56 command.ExecuteNonQuery();
57 connection.Close();
58 }
59
60 /**//// <summary>
61 /// 執行SQL語句並返回包含查詢結果的DataReader
62 /// </summary>
63 /// <param name="SQLCommand">所執行的SQL命令</param>
64 /// <param name="parameters">參數集合</param>
65 /// <returns></returns>
66 public static OleDbDataReader ExecuteSQLDataReader(string SQLCommand,OleDbParameter[] parameters)
67 {
68 OleDbConnection connection = new OleDbConnection(GetConnectionString());
69 OleDbCommand command = new OleDbCommand(SQLCommand, connection);
70
71 for (int i = 0; i < parameters.Length; i++)
72 {
73 command.Parameters.Add(parameters[i]);
74 }
75
76 connection.Open();
77 OleDbDataReader dataReader = command.ExecuteReader();
78 //connection.Close();
79
80 return dataReader;
81 }
82 }
83}
2. 實現具體的數據訪問操作類
因為前面已經定義了數據訪問層接口,所以實現數據訪問操作類就是很機械的工作了。下面僅以Admin的數 據訪問操作類為例:
AdminDAL:
AdminDAL
1using System;
2using System.Collections.Generic;
3using System.Text;
4using System.Data;
5using System.Data.OleDb;
6using NGuestBook.IDAL;
7using NGuestBook.Entity;
8
9namespace NGuestBook.AccessDAL
10{
11 public class AdminDAL : IAdminDAL
12 {
13 /**//// <summary>
14 /// 插入管理員
15 /// </summary>
16 /// <param name="admin">管理員實體類</param>
17 /// <returns>是否成功</returns>
18 public bool Insert(AdminInfo admin)
19 {
20 string SQLCommand = "insert into [TAdmin]([Name],[Password]) values(@name,@password)";
21 OleDbParameter[] parameters ={
22 new OleDbParameter("name",admin.Name),
23 new OleDbParameter("password",admin.Password)
24 };
25
26 try
27 {
28 AccessDALHelper.ExecuteSQLNonQuery(SQLCommand, parameters);
29 return true;
30 }
31 catch
32 {
33 return false;
34 }
35 }
36
37 /**//// <summary>
38 /// 刪除管理員
39 /// </summary>
40 /// <param name="id">欲刪除的管理員的ID</param>
41 /// <returns>是否成功</returns>
42 public bool Delete(int id)
43 {
44 string SQLCommand = "delete from [TAdmin] where [ID]=@id";
45 OleDbParameter[] parameters ={
46 new OleDbParameter("id",id)
47 };
48
49 try
50 {
51 AccessDALHelper.ExecuteSQLNonQuery(SQLCommand, parameters);
52 return true;
53 }
54 catch
55 {
56 return false;
57 }
58 }
59
60 /**//// <summary>
61 /// 更新管理員信息
62 /// </summary>
63 /// <param name="admin">管理員實體類</param>
64 /// <returns>是否成功</returns>
65 public bool Update(AdminInfo admin)
66 {
67 string SQLCommand = "update [TAdmin] set [Name]=@name,[Password]=@password where [ID]=@id";
68 OleDbParameter[] parameters ={
69 new OleDbParameter("id",admin.ID),
70 new OleDbParameter("name",admin.Name),
71 new OleDbParameter("password",admin.Password)
72 };
73
74 try
75 {
76 AccessDALHelper.ExecuteSQLNonQuery(SQLCommand, parameters);
77 return true;
78 }
79 catch
80 {
81 return false;
82 }
83 }
84
85 /**//// <summary>
86 /// 按ID取得管理員信息
87 /// </summary>
88 /// <param name="id">管理員ID</param>
89 /// <returns>管理員實體類</returns>
90 public AdminInfo GetByID(int id)
91 {
92 string SQLCommand = "select * from [TAdmin] where [ID]=@id";
93 OleDbParameter[] parameters ={
94 new OleDbParameter ("id",id)
95 };
96
97 try
98 {
99 OleDbDataReader dataReader = AccessDALHelper.ExecuteSQLDataReader(SQLCommand, parameters);
100 if (! dataReader.HasRows)
101 {
102 throw new Exception();
103 }
104
105 AdminInfo admin = new AdminInfo();
106 dataReader.Read();
107 admin.ID=(int)dataReader["ID"];
108 admin.Name=(string)dataReader["Name"];
109 admin.Password=(string)dataReader["Password"];
110
111 return admin;
112 }
113 catch
114 {
115 return null;
116 }
117 }
118
119 /**//// <summary>
120 /// 按用戶名及密碼取得管理員信 息
121 /// </summary>
122 /// <param name="name">用戶名</param>
123 /// <param name="password">密碼</param>
124 /// <returns>管理員實體類,不存在 時返回null</returns>
125 public AdminInfo GetByNameAndPassword(string name, string password)
126 {
127 string SQLCommand = "select * from [TAdmin] where [Name]=@name and [Password] =@password";
128 OleDbParameter[] parameters ={
129 new OleDbParameter ("name",name),
130 new OleDbParameter("password",password),
131 };
132
133 try
134 {
135 OleDbDataReader dataReader = AccessDALHelper.ExecuteSQLDataReader(SQLCommand, parameters);
136 if (!dataReader.HasRows)
137 {
138 throw new Exception();
139 }
140
141 AdminInfo admin = new AdminInfo();
142 dataReader.Read();
143 admin.ID = (int) dataReader["ID"];
144 admin.Name = (string)dataReader["Name"];
145 admin.Password = (string)dataReader["Password"];
146
147 return admin;
148 }
149 catch
150 {
151 return null;
152 }
153 }
154
155 /**//// <summary>
156 /// 按管理員名取得管理員信息
157 /// </summary>
158 /// <param name="name">管理員名</param>
159 /// <returns>管理員實體類</returns>
160 public AdminInfo GetByName(string name)
161 {
162 string SQLCommand = "select * from [TAdmin] where [Name]=@name";
163 OleDbParameter[] parameters ={
164 new OleDbParameter("name",name),
165 };
166
167 try
168 {
169 OleDbDataReader dataReader = AccessDALHelper.ExecuteSQLDataReader(SQLCommand, parameters);
170 if (!dataReader.HasRows)
171 {
172 throw new Exception();
173 }
174
175 AdminInfo admin = new AdminInfo();
176 dataReader.Read();
177 admin.ID = (int) dataReader["ID"];
178 admin.Name = (string)dataReader["Name"];
179 admin.Password = (string)dataReader["Password"];
180
181 return admin;
182 }
183 catch
184 {
185 return null;
186 }
187 }
188
189 /**//// <summary>
190 /// 取得全部管理員信息
191 /// </summary>
192 /// <returns>管理員實體類集合</returns>
193 public IList<AdminInfo> GetAll()
194 {
195 string SQLCommand = "select * from [TAdmin] ";
196 try
197 {
198 OleDbDataReader dataReader = AccessDALHelper.ExecuteSQLDataReader(SQLCommand, null);
199 if (!dataReader.HasRows)
200 {
201 throw new Exception();
202 }
203
204 IList<AdminInfo> adminCollection = new List<AdminInfo>();
205 int i = 0;
206 while (dataReader.Read())
207 {
208 AdminInfo admin = new AdminInfo();
209 admin.ID = (int)dataReader["ID"];
210 admin.Name = (string) dataReader["Name"];
211 admin.Password = (string)dataReader["Password"];
212
213 adminCollection.Add(admin);
214 i++;
215 }
216
217 return adminCollection;
218 }
219 catch
220 {
221 return null;
222 }
223 }
224 }
225}
可以看到 ,這裡主要包括三種類型的操作,一種是修改型,如Insert;一種是返回單個實體類型,如GetByID;還有一種是返回實體類集合型,如GetAll 。
MessageDAL和CommentDAL的實現非常相似,在這裡不再贅述。