程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> .NET網頁編程 >> 關於.NET >> 基於.NET平台的分層架構實戰(七)—數據訪問層的第一種實現:Access+SQL

基於.NET平台的分層架構實戰(七)—數據訪問層的第一種實現:Access+SQL

編輯:關於.NET

經過上面篇文章的介紹,整個系統的框架算是基本搭建完了,下面,我們要具體實現各個層次。關於數據訪問層的實現,我准備討論三種實 現方式,這一篇文章討論第一種: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的實現非常相似,在這裡不再贅述。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved