使用 DataAdapter 执行批量更新

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 [email protected], " +
                                    "[email protected], [email protected], [email protected]";

        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>";
    }