DataAdapter执行批量更新的实例代码

在以前版本的 ADO.NET 中,使用 DataSet 中的更改来更新数据库时,DataAdapter 的 Update 方法每次更新数据库的一行。因为该方法循环访问指定 DataTable 中的行,所以,会检查每个 DataRow,确定是否已修改。如果该行已修改,将根据该行的 RowState 属性值调用相应的 UpdateCommand、InsertCommand 或 DeleteCommand。每一次行更新都涉及网络与数据库之间的双向数据传输。
    在 ADO.NET 2.0 中,DataAdapter 公开了 UpdateBatchSize 属性。将 UpdateBatchSize 设置为正整数值将使对数据库的更新以指定大小的批次进行发送。例如,如果将 UpdateBatchSize 设置为 10,会将 10 个独立的语句组合在一起并作为一批提交。将 UpdateBatchSize 设置为 0 将导致 DataAdapter 使用服务器可以处理的最大批次的大小。如果将其设置为 1,则禁用批量更新,因为此时每次发送一行。
    执行非常大的批次可能会降低性能。因此,在实现应用程序之前,应测试最佳的批次大小设置。
    使用 UpdateBatchSize 属性
    启用了批量更新后,DataAdapter 的 UpdateCommand、InsertCommand 和 DeleteCommand 的 UpdatedRowSource 属性值应设置为 None 或 OutputParameters。在执行批量更新时,命令的 FirstReturnedRecord 或 Both 的 UpdatedRowSource 属性值无效。
    下面的过程演示如何使用 UpdateBatchSize 属性。该过程采用两个参数,一个 DataSet 对象,其中包含代表 PRoduction.ProductCategory 表中的 ProductCategoryID 和 Name 字段的列,一个代表批次大小的整数(批次中的行数)。该代码创建一个新的 SqlDataAdapter 对象,设置其 UpdateCommand、InsertCommand 和 DeleteCommand 属性。该代码假定 DataSet 对象已修改了行。它设置 UpdateBatchSize 属性并执行更新。


代码如下:

protected void btnUpdateAddress_Click(object sender, EventArgs e)
    {
    SqlDataAdapter EmpAdapter = new SqlDataAdapter();
    DataTable EmpDT = new DataTable();
    SqlConnection DBConSelect = new SqlConnection();
    SqlConnection DBConUpdate = new SqlConnection();
    SqlCommand SelectCommand = new SqlCommand();
    SqlCommand UpdateCommand = new SqlCommand();
    // Using different connection objects for select and updates from the
    // Northwind database.
    DBConSelect.ConnectionString =
    ConfigurationManager.ConnectionStrings["DSN_NorthWind"].ConnectionString;
    DBConUpdate.ConnectionString =
    ConfigurationManager.ConnectionStrings["DSN_NorthWind"].ConnectionString;
    // Reading all records from the Employees table
    SelectCommand.CommandText = "SELECT top 500 * FROM EMPLOYEES";
    SelectCommand.CommandType = CommandType.Text;
    SelectCommand.Connection = DBConSelect;

UpdateCommand.CommandText = " UPDATE EMPLOYEES SET Address=@Address, " +
    "City=@City, Region=@Region, Country=@Country";
    UpdateCommand.CommandType = CommandType.Text;
    UpdateCommand.Connection = DBConUpdate;
    SqlParameter AddressParam;
    AddressParam = new SqlParameter("@Address",
    SqlDbType.VarChar, 15, "Address");
    SqlParameter CityParam;
    CityParam = new SqlParameter("@City", SqlDbType.VarChar, 15, "City");
    SqlParameter RegionParam;
    RegionParam = new SqlParameter("@Region", SqlDbType.VarChar, 15, "Region");
    SqlParameter CountryParam;
    CountryParam = new SqlParameter("@Country",
    SqlDbType.VarChar, 15, "Country");
    UpdateCommand.Parameters.Add(AddressParam);
    UpdateCommand.Parameters.Add(CityParam);
    UpdateCommand.Parameters.Add(RegionParam);
    UpdateCommand.Parameters.Add(CountryParam);
    // Setting up Data Adapter with the Select and Update Commands
    // The Select command will be used to retrieve all employee
    // information from the Northwind database and the Update command
    // will be used to save changes back to the database
    EmpAdapter.SelectCommand = SelectCommand;
    EmpAdapter.UpdateCommand = UpdateCommand;
    EmpAdapter.Fill(EmpDT);
    DBConSelect.Close();
    // Looping through all employee records and assigning them the new
    // address
    foreach (DataRow DR in EmpDT.Rows)
    {
    DR["Address"] = "4445 W 77th Street, Suite 140";
    DR["City"] = "Edina";
    DR["Region"] = "Minnesota";
    DR["Country"] = "USA";
    }
    // Adding an event handler to listen to the RowUpdated event.
    // This event will will fire after each batch is executed
    EmpAdapter.RowUpdated +=  new SqlRowUpdatedEventHandler(OnRowUpdated);
    lblCounter.Text = "";
    EmpAdapter.UpdateBatchSize = 100;
    // It is important to set this property for batch processing of
    // updated records since batch updates are incapable of
    // updating the source with changes from the database
    UpdateCommand.UpdatedRowSource = UpdateRowSource.None;
    try
    {
    DBConUpdate.Open();
    EmpAdapter.Update(EmpDT);
    }
    catch (Exception ex)
    {
    lblCounter.Text += ex.Message + "<Br>";
    }
    finally
    {
    if (DBConUpdate.State == ConnectionState.Open)
    {
    DBConUpdate.Close();
    }
    }
    }
    private void OnRowUpdated(object sender, SqlRowUpdatedEventArgs args)
    {
    lblCounter.Text += "Batch is processed till row number = " +
    args.RowCount.ToString() + "<br>";
    }

(0)

相关推荐

  • DataAdapter执行批量更新的实例代码

    在以前版本的 ADO.NET 中,使用 DataSet 中的更改来更新数据库时,DataAdapter 的 Update 方法每次更新数据库的一行.因为该方法循环访问指定 DataTable 中的行,所以,会检查每个 DataRow,确定是否已修改.如果该行已修改,将根据该行的 RowState 属性值调用相应的 UpdateCommand.InsertCommand 或 DeleteCommand.每一次行更新都涉及网络与数据库之间的双向数据传输.    在 ADO.NET 2.0 中,Dat

  • mysql 循环批量插入的实例代码详解

    背景 前几天在MySql上做分页时,看到有博文说使用 limit 0,10 方式分页会有丢数据问题,有人又说不会,于是想自己测试一下.测试时没有数据,便安装了一个MySql,建了张表,在建了个while循环批量插入10W条测试数据的时候,执行时间之长无法忍受,便查资料找批量插入优化方法,这里做个笔记. 数据结构 寻思着分页时标准列分主键列.索引列.普通列3种场景,所以,测试表需要包含这3种场景,建表语法如下: drop table if exists `test`.`t_model`; Crea

  • Java使用多线程异步执行批量更新操作方法

    写在前面: 相信不少开发者在遇到项目对数据进行批量操作的时候,都会有不少的烦恼,尤其是针对数据量极大的情况下,效率问题就直接提上了菜板.因此,开多线程来执行批量任务是十分重要的一种批量操作思路,其实这种思路实现起来也十分简单,就拿批量更新的操作举例: 整体流程图 步骤 获取需要进行批量更新的大集合A,对大集合进行拆分操作,分成N个小集合A-1 ~ A-N . 开启线程池,针对集合的大小进行调参,对小集合进行批量更新操作. 对流程进行控制,控制线程执行顺序. 按照指定大小拆分集合的工具类 impo

  • mybatis执行批量更新batch update 的方法(oracle,mysql两种)

    Oracle和MySQL数据库的批量update在mybatis中配置不太一样: oracle数据库: <code class="hljs tcl" style=""><<span class="hljs-keyword" style="">update</span> id=<span class="hljs-string" style=""

  • Java执行hadoop的基本操作实例代码

    Java执行hadoop的基本操作实例代码 向HDFS上传本地文件 public static void uploadInputFile(String localFile) throws IOException{ Configuration conf = new Configuration(); String hdfsPath = "hdfs://localhost:9000/"; String hdfsInput = "hdfs://localhost:9000/user/

  • Android listview ExpandableListView实现多选,单选,全选,edittext实现批量输入的实例代码

    最近在项目开发中,由于项目的需求要实现一些列表的单选,多选,全选,批量输入之类的功能,其实功能的实现倒不是很复杂,需求中也没有涉及到复杂的动画什么之类,主要是解决列表数据复用的问题,解决好这个就可以了.下面是最近项目中涉及到的一些: listview实现多选.全选.取消全选: 下面是适配器,一开始在适配器的构造函数中,对数据进行初始化,同时定义一个集合用于管理listview的点击: class BatchAdpter extends BaseAdapter { private HashMap<

  • python之matplotlib学习绘制动态更新图实例代码

    简介 通过定时器Timer触发事件,定时更新绘图,可以形成动态更新图片.下面的实例是学习<matplotlib for python developers>一文的笔记. 实现 实现代码及简单介绍 通过self.user = self.user[1:] + [temp],每次删除列表的第一元素,在其尾部添加新的元素.这样完成user数据的动态更新.其他详细的解释见文中的注释部分. #-*-coding:utf-8-*- import wx from matplotlib.figure impor

  • PHP ajax+jQuery 实现批量删除功能实例代码小结

    目录结构 piliangshan.php <?php require_once './db_conn.php'; $sql = "select * from user"; $result = mysqli_query($conn, $sql); ?> <html lang="zh-CN"> <head> <meta charset="UTF-8"> <title>全选演示</tit

  • 使用Python进行QQ批量登录的实例代码

    具体代码如下所示: #coding=utf-8 __author__ = 'Eagle' import os import time import win32gui import win32api import win32con import SendKeys from ctypes import * def QQ(qq,pwd): a = win32gui.FindWindow(None, "QQ") #运行QQ os.system('"C:\Program Files (

  • Mybatis传入List实现批量更新的示例代码

    Dao层写法 /** * 批量更新新库存 * @param list * @return */ int updateNewStock(@Param(value = "list") List<GreenBeanMsg> list); xml具体实现代码 <update id="updateNewStock" parameterType="java.util.List"> <foreach collection=&quo

随机推荐