使用DataAdpater自动批量更新DataSet中的数据到数据库

时间：2015-10-22 12:14:38 阅读：259 评论：0 收藏：0 [点我收藏+]

标签：

[WebMethod(Description = "Update服务提供的方法，将包含修改后数据的DateSet与本地数据库同步更新，成功返回更新的行数，失败返回-1。"), SoapHeader("currentUser")]
public int Update(DataSet ds)
{
    if (!ValidateUser(currentUser.UserName, currentUser.UserPass))
    {
        return -1;
    }
    else
    {
        int res = 0;

        using (SqlConnection sqlconn = new SqlConnection("Data Source=.;Initial Catalog=xxxx;User ID=sa;Password=sa"))
        {
            sqlconn.Open();

            / / //使用加强读写锁事务
            SqlTransaction tran = sqlconn.BeginTransaction(IsolationLevel.ReadCommitted);
            try
            {

                foreach (DataRow dr in ds.Tables[0].Rows)
                {
                    //所有行设为修改状态
                    dr.SetModified();
                }


                //为Adapter定位目标表
                SqlCommand cmd = new SqlCommand(string.Format("select * from {0} where 1=0 ", ds.Tables[0].TableName), sqlconn, tran);

                SqlDataAdapter da = new SqlDataAdapter(cmd);


                SqlCommandBuilder sqlCmdBuilder = new SqlCommandBuilder(da);
                da.AcceptChangesDuringUpdate = false;


                SqlCommand updatecmd = new SqlCommand(string.Format(" UPDATE [{0}] SET  [Name] = @Name WHERE ([ID] = @ID) ", ds.Tables[0].TableName));
                //不修改源DataTable
                updatecmd.UpdatedRowSource = UpdateRowSource.None;
                da.UpdateCommand = updatecmd;


                da.UpdateCommand.Parameters.Add("@Name", SqlDbType.NVarChar, 50, "Name");
                da.UpdateCommand.Parameters.Add("@ID", SqlDbType.Int, 4, ds.Tables[0].Columns[0].ColumnName);



                da.UpdateBatchSize = 10000;


                res = da.Update(ds.Tables[0]);


                ds.AcceptChanges();
                tran.Commit();

                sqlconn.Close();

            }
            catch
            {

                tran.Rollback();
                return -1;
            }


        }
        return res;
    }


}

注意：如果不指定DataAdapter的UpdateCommand ，则DataAdapter的CommandBuilder会自动构造默认的Update命令

使用DataAdpater自动批量更新DataSet中的数据到数据库

标签：

原文地址：http://www.cnblogs.com/binyao/p/4900124.html

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行