打造自己的数据访问层一

打造自己的数据访问层一

项目开发中，大多数开发人员的核心工作就是如何对数据进行存储及访问。为了进行数据操作，我们首先得解决几个基本问题：

1、如何与一个数据库建立连接。

2、如何从数据库读取相应的数据。

3、如何对数据表进行增改操作。

.NET中，ADO.NET很方便的解决了上面三个问题，我们可以使用DbConnection进行连接，DataSet进行数据存储，DataAdapter进行数据更新。先看一段代码：

//创建DbConnection对象连接数据库
SqlConnection conn = new SqlConnection();
conn.ConnectionString = "server=.;uid=sa;password=123456; database=DATA_BASE; max pool size=300;";
//创建DataAdapter、Command对象，读取数据
SqlDataAdapter da = new SqlDataAdapter();
SqlCommand cmd = new SqlCommand();
cmd.Connection = conn;
cmd.CommandText = "SELECT * FROM TEST";
da.SelectCommand = cmd;
//创建DataSet对象，存储数据，建立与物理表的映射
DataSet ds = new DataSet();
da.Fill(ds, "TEST"); 

上述代码实现对数据库“DATA_BASE”中“TEST”表数据读取，并用DataSet时行存储。

既然读出了TEST表中的数据，接下来要解决的就是如何对TEST表进行增、删、改操作。

为实现增、删、改操作，需要为DataAdapter指定InsertCommand、DeleteCommand以及UpdateCommand，并为每个Command对象绑定参数：

//新增数据  
cmd = new SqlCommand();  
cmd.Connection = conn;  
cmd.CommandText = "INSERT INTO TEST (ID, NAME, VAL) VALUES (@ID, @NAME, @VAL)";  
SqlParameter param = new SqlParameter("@ID", null);  
param.SourceColumn = "ID";  
cmd.Parameters.Add(param);  
param = new SqlParameter("@NAME", null);  
param.SourceColumn = "NAME";  
cmd.Parameters.Add(param);  
param = new SqlParameter("@VAL", null);  
param.SourceColumn = "VAL";  
cmd.Parameters.Add(param);  
da.InsertCommand = cmd;  
 
//修改数据  
cmd = new SqlCommand();  
cmd.Connection = conn;  
cmd.CommandText = "UPDATE TEST SET NAME = @NAME, VAL = @VAL WHERE ID = @ID";  
param = new SqlParameter("@ID", null);  
param.SourceColumn = "ID";  
cmd.Parameters.Add(param);  
param = new SqlParameter("@NAME", null);  
param.SourceColumn = "NAME";  
cmd.Parameters.Add(param);  
param = new SqlParameter("@VAL", null);  
param.SourceColumn = "VAL";  
cmd.Parameters.Add(param);  
da.UpdateCommand = cmd;  
 
//删除数据  
cmd = new SqlCommand();  
cmd.Connection = conn;cmd.CommandText = "DELETE FROM TEST WHERE ID = @ID";  
param = new SqlParameter("@ID", null);  
param.SourceColumn = "ID";  
cmd.Parameters.Add(param);  
da.DeleteCommand = cmd;  

完成准备工作后，利用DataTable进行数据操作：

DataTable dt = ds.Tables["TEST"];  
dt.PrimaryKey = new DataColumn[] { dt.Columns["ID"] };  
dt.Rows.Add(new object[]{  
    Guid.NewGuid().ToString(), string.Format("测试：{0}", DateTime.Now), string.Format("测试值：{0}", DateTime.Now)  
});  
DataRow dr = dt.Rows.Find("f8dc2c64-f51a-4e99-bde1-a20069b09c3a");  
if (dr != null){  
    dr["NAME"] = string.Format("测试修改：{0}", DateTime.Now);  
}  
dr = dt.Rows.Find("ed7d079b-81ec-4ba4-bf85-688621e495e7");  
if (dr != null){      
dr.Delete();  
} 

最后调用DataAdapter的Update方法保存变更后的数据：

da.Update(ds, "TEST");

利用ADO.NET的上述方法，我们已经完成了对数据库的完整操作。

注：上述代码是利用DataAdapter对数据库进行读写的基本原理，非常重要，我们后面的改造都将以此作为依据。

虽然我们已经能完成对数据的操作，但现实际上还是存在很多问题：

1、我们只是对MSSql数据库进行操作，如果要对Oracle或MySql进行操作我们得定义新的Oracle或MySql数据对象，如果能由系统自动判断操作的数据库类型，我们就能省去对数据对象的关注。

2、我们做了太多的准备工作，我们只对一张表进行操作，如查我们要对多张表进行操作，参数又很多，实际上会产生大量的重复代码，我们得考虑消除这些代码。

对于上述问题，如果我们自己实现一个数据访问层，对ADO.NET对象进行封装，只关注实际的数据的操作，而不关注系统是如何与数据库进行连接、如何进行参数传递，那我们的需求就算基本满足了。

我们可以先进行假设，需要达成如下效果，以伪码的形式给出：

创建数据执行者：DataExecuter：execObj；    
创建数据映射对象：DataMapping map;    
由映射对象填充数据集：map.Fill(sqlText, "TEST", ds);    
设置映射对象更新命令：map.SetCommands(Insert | Update | Delete, ds);    
DataTable进行实际增、删、改操作。    
数据执行者执行最后的变更操作：execObj.Update(ds);    

后面我将一步步看到上述假设是如何实现的。