`
hendryxu
  • 浏览: 123430 次
  • 来自: ...
最近访客 更多访客>>
社区版块
存档分类
最新评论

ADO.NET中的多数据表操作浅析—修改

阅读更多
http://blog.csdn.net/zhzuo/archive/2004/08/06/67037.aspx


三、更新数据集

首先需要说明的是我这里去掉了Order Details表,对两个表的操作只是其中的几个字段。下面是窗体界面:






图3-1

单选框用来选择不同的更新方法。

在DataAccess类中增加两个类成员变量:

     private SqlDataAdapter _customerDataAdapter; //客户数据适配器

     private SqlDataAdapter _orderDataAdapter; //订单数据适配器



customerDataAdapter在构造函数中的初始化为

//实例化_customerDataAdapter

SqlCommand selectCustomerComm = new SqlCommand("GetCustomer",_conn);

selectCustomerComm.CommandType = CommandType.StoredProcedure;

selectCustomerComm.Parameters.Add("@CustomerID",SqlDbType.NChar,5,"CustomerID");

        

SqlCommand insertCustomerComm = new SqlCommand("AddCustomer",_conn);

insertCustomerComm.CommandType = CommandType.StoredProcedure;

insertCustomerComm.Parameters.Add("@CustomerID",SqlDbType.NChar,5,"CustomerID");

insertCustomerComm.Parameters.Add("@CompanyName",SqlDbType.NVarChar,40,"CompanyName");

insertCustomerComm.Parameters.Add("@ContactName",SqlDbType.NVarChar,30,"ContactName");



SqlCommand updateCustomerComm = new SqlCommand("UpdateCustomer",_conn);

updateCustomerComm.CommandType = CommandType.StoredProcedure;

updateCustomerComm.Parameters.Add("@CustomerID",SqlDbType.NChar,5,"CustomerID");

updateCustomerComm.Parameters.Add("@CompanyName",SqlDbType.NVarChar,40,"CompanyName");

updateCustomerComm.Parameters.Add("@ContactName",SqlDbType.NVarChar,30,"ContactName");

             

SqlCommand deleteCustomerComm = new SqlCommand("DeleteCustomer",_conn);

deleteCustomerComm.CommandType = CommandType.StoredProcedure;

deleteCustomerComm.Parameters.Add("@CustomerID",SqlDbType.NChar,5,"CustomerID");



_customerDataAdapter = new SqlDataAdapter(selectCustomerComm);

_customerDataAdapter.InsertCommand = insertCustomerComm;

_customerDataAdapter.UpdateCommand = updateCustomerComm;

_customerDataAdapter.DeleteCommand = deleteCustomerComm;



上面的代码完全可以用设计器生成,觉得有些东西自己写感觉更好,不过代码还是很多。

对于_orderDataAdapter的初始化同上面的差不多,这里我们只看订单增加的处理,下面是存储过程:

CREATE PROCEDURE  AddOrder

(

     @OrderID INT OUT,

     @CustomerID NCHAR(5),

     @OrderDate DATETIME

)

AS

INSERT INTO Orders

(

     CustomerID ,

     OrderDate

)

VALUES

(

     @CustomerID ,

     @OrderDate

)

--SELECT @OrderID = @@IDENTITY  //使用触发器有可能出现问题

SET @OrderID = SCOPE_IDENTITY()

GO



OrderID自动增长值的获取通过输出参数来完成,这个相当不错,如果使用SqlDataAdapter.RowUpdated事件来处理那效率会很低。

对insertOrderComm对象的定义为:

SqlCommand insertOrderComm = new SqlCommand("AddOrder",_conn);

insertOrderComm.CommandType = CommandType.StoredProcedure;

insertOrderComm.Parameters.Add("@OrderID",SqlDbType.Int,4,"OrderID");

insertOrderComm.Parameters["@OrderID"].Direction = ParameterDirection.Output;

insertOrderComm.Parameters.Add("@OrderDate",SqlDbType.DateTime,8,"OrderDate");

insertOrderComm.Parameters.Add("@CustomerID",SqlDbType.NChar,5,"CustomerID");



在实现数据的更新方法之前我们先来明确一些更新逻辑:

对于标记为删除的行,先删除订单表的数据,再删除客户表的数据;

对于标记为添加的行,先添加客户表的数据,再添加订单表的数据。



(1)实现用获取修改过的DataSet的副本子集来更新数据的方法。

这也是调用Xml Web Service更新数据的常用方法,先来看第一个版本,子集的获取通过DataSet.GetChangs方法来完成。

//使用数据集子集更新数据

public void UpdateCustomerOrders(DatasetOrders ds)

{            

     DataSet dsModified = ds.GetChanges(DataRowState.Modified);//获取修改过的行

     DataSet dsDeleted = ds.GetChanges(DataRowState.Deleted);//获取标记为删除的行

     DataSet dsAdded = ds.GetChanges(DataRowState.Added);//获取增加的行

     try

     {   

         _conn.Open();//先添加客户表数据,再添加订单表数据

         if(dsAdded != null)

         {

              _customerDataAdapter.Update(dsAdded,"Customers");

              _orderDataAdapter.Update(dsAdded,"Orders");

              ds.Merge(dsAdded);

         }

         if(dsModified != null)//更新数据表

         {

              _customerDataAdapter.Update(dsModified,"Customers");

              _orderDataAdapter.Update(dsModified,"Orders");

              ds.Merge(dsModified);

         }

         if(dsDeleted != null)//先删除订单表数据,再删除客户表数据

         {

              _orderDataAdapter.Update(dsDeleted,"Orders");

              _customerDataAdapter.Update(dsDeleted,"Customers");

              ds.Merge(dsDeleted);

         }                 

     }

     catch(Exception ex)

     {

         throw new Exception("更新数据出错",ex);

     }

     finally

     {

         if(_conn.State != ConnectionState.Closed)

              _conn.Close();

     }

}

上面的方法看上去比较清晰,不过效率不会很高,至少中间创建了三个DataSet,然后又进行了多次合并。

(2)另一方法就是引用更新,不创建副本。

相对来说性能会高许多,但是如果用在Web服务上传输的数据量会更大(可以结合两个方法进行改进)。具体的实现就是通过DataTable.Select方法选择行状态来实现。

//引用方式更新数据

public void UpdateCustomerOrders(DataSet ds)

{

     try

     {   

         _conn.Open();

         //先添加客户表数据,再添加订单表数据      _customerDataAdapter.Update(ds.Tables["Customers"].Select("","",DataViewRowState.Added));

     _orderDataAdapter.Update(ds.Tables["Orders"].Select("","",DataViewRowState.Added));

     //更新数据表

     _customerDataAdapter.Update(ds.Tables["Customers"].Select("","",DataViewRowState.ModifiedCurrent));

     _orderDataAdapter.Update(ds.Tables["Orders"].Select("","",DataViewRowState.ModifiedCurrent));

//先删除订单表数据,再删除客户表数据

     _orderDataAdapter.Update(ds.Tables["Orders"].Select("","",DataViewRowState.Deleted));

     _customerDataAdapter.Update(ds.Tables["Customers"].Select("","",DataViewRowState.Deleted));           

     }

     catch(Exception ex)

     {

         throw new Exception("更新数据出错",ex);

     }

     finally

     {

         if(_conn.State != ConnectionState.Closed)

              _conn.Close();

     }

}

结合上面的两个方法我们可想到调用Web Service有更合理的方法来完成。

(3)使用事务

public void UpdateCustomerOrdersWithTransaction(DataSet ds)

{

     SqlTransaction trans = null;

     try

     {   

         _conn.Open();

         trans = _conn.BeginTransaction();

         _customerDataAdapter.DeleteCommand.Transaction = trans;

         _customerDataAdapter.InsertCommand.Transaction = trans;

         _customerDataAdapter.UpdateCommand.Transaction = trans;

         _orderDataAdapter.DeleteCommand.Transaction = trans;

         _orderDataAdapter.InsertCommand.Transaction = trans;

         _orderDataAdapter.UpdateCommand.Transaction = trans;

     _customerDataAdapter.Update(ds.Tables["Customers"].Select("","",DataViewRowState.Added));

                   _orderDataAdapter.Update(ds.Tables["Orders"].Select("","",DataViewRowState.Added));

     _customerDataAdapter.Update(ds.Tables["Customers"].Select("","",DataViewRowState.ModifiedCurrent));

     _orderDataAdapter.Update(ds.Tables["Orders"].Select("","",DataViewRowState.ModifiedCurrent));

     _orderDataAdapter.Update(ds.Tables["Orders"].Select("","",DataViewRowState.Deleted));

     _customerDataAdapter.Update(ds.Tables["Customers"].Select("","",DataViewRowState.Deleted)); 

          trans.Commit();

     }

     catch(Exception ex)

     {

         trans.Rollback();

         throw new Exception("更新数据出错",ex);

     }

     finally

     {

         if(_conn.State != ConnectionState.Closed)

              _conn.Close();

     }

}

最后让我们来看看窗体的按钮更新事件的代码:

private void buttonUpdate_Click(object sender, System.EventArgs e)

{

              //提交编辑数据

     this.BindingContext[this._ds].EndCurrentEdit();

    

     if(radioButtonRef.Checked == true)//引用方式更新

         _dataAccess.UpdateCustomerOrders((DataSet)_ds);

     else if(radioButtonTrans.Checked == true)//启用事务更新数据表

         _dataAccess.UpdateCustomerOrdersWithTransaction((DataSet)_ds);

     else

     {

         DatasetOrders changedData =  (DatasetOrders)_ds.GetChanges();

         if(radioButtonWeb.Checked == true)//Web服务的更正更新

         {                     

              _dataAccess.UpdateCustomerOrders((DataSet)changedData);

         }

         else//创建副本合并方式更新

         {                 

              _dataAccess.UpdateCustomerOrders(changedData);

         }

         //去除订单表中添加的虚拟行

         foreach(DataRow row in _ds.Orders.Select("","",DataViewRowState.Added))

              _ds.Orders.RemoveOrdersRow((DatasetOrders.OrdersRow)row);

         //去除客户表中添加的虚拟行

         foreach(DataRow row in _ds.Customers.Select("","",DataViewRowState.Added))

              _ds.Customers.RemoveCustomersRow((DatasetOrders.CustomersRow)row);

         _ds.Merge(changedData);

     }

     //提交数据集状态

     _ds.AcceptChanges();

}



本文参考:《ADO.NET Core Reference》

分享到:
评论

相关推荐

    ADO.NET中的多数据表操作之读取

    在ADO.NET中,可以通过SqlConnection的BeginTransaction方法启动事务,然后在每个SqlCommand的ExecuteNonQuery方法之前设置其CommandBehavior为CommandBehavior.SequentialAccess,以确保在事务中正确处理数据。...

    ADO.net大数据量操作数据库实验

    2. **Bulk Copy(批量拷贝)**:在ADO.NET中,SqlBulkCopy类提供了快速批量插入数据的能力。它允许一次性将大量数据从DataTable或IDataReader对象复制到SQL Server表,大大提高了性能。使用时,首先创建SqlBulkCopy...

    ado.net连接多个表

    4. **操作数据**:现在,`DataSet`包含了来自数据库的两个表的数据,我们可以对这些数据进行各种操作,如查询、修改、添加和删除。例如,如果我们想要找到`Table1`中特定条件的记录: ```csharp foreach (DataRow ...

    一个ADO.NET数据库操作实例

    在ADO.NET中,可以使用`SqlConnection`对象建立到SQL Server数据库的连接,然后通过`SqlCommand`对象执行这些SQL语句。 `ADO.NET与数据控件综合实例.pptx`可能是一个演示文稿,详细介绍了如何在Windows Forms或ASP...

    学生管理系统+ADO.NET+SQL2005

    接着,ADO.NET的DataSet和DataTable对象扮演了数据容器的角色,它们可以加载从SQL Server查询到的数据,同时提供了在内存中操作数据的能力。在添加、修改或删除学生信息时,可以通过DataTable对象直接操作,然后使用...

    ASP.NET ADO.NET 数据访问 Demo

    在ASP.NET应用中,ADO.NET常用于实现数据的读取、写入、更新和删除操作。 在本Demo中,我们可能会遇到以下几个核心概念和技术: 1. **Connection对象**:这是与数据库建立连接的关键。开发者需要提供正确的连接...

    .NET C# ADO.NET 2.0 公共数据层类库

    3. **数据适配器(DataAdapter)**:它是ADO.NET中负责在数据库和数据集之间传递数据的关键对象。`SqlDataAdapter`类用于填充`DataSet`或更新数据库中的数据。 4. **数据集(DataSet)**:`DataSet`是一个内存中的...

    ADO.NET的数据更新

    在ADO.NET中,我们可以创建一个SqlCommand对象,然后设置其CommandText属性为SQL插入语句。通过使用SqlParameter对象,我们可以将动态值安全地传递给SQL命令。例如,在上述代码中,创建了一个新的SqlCommand对象,...

    ADO.NET 全面解析ADO.NET

    6. **DataSet对象**:DataSet是一个内存中的数据集合,它可以包含多张DataTable,模拟了数据库的表结构。DataSet是离线数据存储,支持数据的添加、删除、修改等操作,而且可以实现强类型化的DataSet,提高代码的...

    ADO.NET数据查询操作源码

    这个"ADO.NET数据查询操作源码"很可能是包含了一系列使用ADO.NET进行数据查询、操作的示例代码,帮助开发者理解和实践如何在实际项目中应用ADO.NET。 首先,我们来看一下ADO.NET的主要组成部分: 1. **DataSet**: ...

    数据访问技术系列课程(2):ADO.NET 连接方式进行数据访问

    3. **数据适配器(DataAdapter)**:`SqlDataAdapter`是ADO.NET中的关键组件,它充当了数据库与数据集(DataSet)之间的桥梁。数据适配器可以从数据库填充数据集,也可以将数据集中的更改同步回数据库,实现数据的...

    ADO.NET2.0 XML操作

    ADO.NET 2.0 是微软.NET框架中用于处理数据的核心组件,它提供了一种高效、灵活的方式来访问和操作各种数据库。在ADO.NET 2.0中,XML支持得到了显著增强,使得开发人员能够轻松地在XML和关系数据库之间进行数据交换...

    实验七 ADO.NET管理数据库

    本实验将通过创建一个的“C#学习网”,使同学们掌握ASP.NET服务器验证控件、ADO.NET对象的使用方法,并初步熟悉数据绑定控件GridView。该网站各页的效果图如图7-1、7-2、7-3、7-4、7-5、7-6、7-7、7-8所示。大体上...

    ado.net操作oracle简单参数化sql操作

    在ADO.NET中,我们使用OracleCommand对象来执行SQL命令,并通过OracleParameter对象来定义参数。假设我们有一个查询,需要根据用户输入的ID查找记录: ```csharp string sql = "SELECT * FROM YourTable WHERE ID =...

    ado.net面试题

    ADO.NET 是微软为.NET Framework 设计的一种全新的数据库访问技术,它是对传统ADO(ActiveX Data Objects)的升级,旨在提供更高效、更易用的数据访问接口。ADO.NET 的设计核心是面向数据集而非数据库,这使得它更适合...

    ADO.NET 4从入门到精通源代码

    - **DataSet**: ADO.NET的核心组件,它是一个离线数据集合,可以包含多个DataTable,支持数据的增删改查操作。 - **DataTable**: 表示数据库中的表,包含行(DataRow)和列(DataColumn)。 - **Connection对象**...

    ADO.NET_DataSet(数据集

    ADO.NET中的DataSet是.NET Framework中一个非常重要的组件,它提供了一种在应用程序中存储和处理数据的方式,即使在没有与数据库连接的情况下也能进行数据操作。DataSet可以被看作是一个轻量级的数据库,它在内存中...

    ADO.NET sql、LINQ to sql、ADO.NET Entity Framework(EF)数据库连接性能比较

    ADO.NET SQL是最原始的.NET数据访问接口,它提供了对SQL Server的直接、低级的访问。开发者可以直接编写SQL语句,执行存储过程,并通过DataSets、DataTables等对象处理结果。这种方式灵活性高,但需要编写大量的SQL...

    ADO.NET核心技术(我看过最好的ADO。NET书)

    3. **离线操作**:ADO.NET的核心离线对象——数据集(`DataSet`),支持对数据进行排序、搜索、筛选、存储挂起更改,并在层次化数据中进行浏览等操作。 4. **XML集成**:数据集还具有强大的XML支持能力,填补了传统...

Global site tag (gtag.js) - Google Analytics