zoukankan      html  css  js  c++  java
  • SqlDataAdapter.RowUpdated事件用法

      利用SqlDataAdapter.Update(DataTable) 批量操作数据时(如Insert操作),当没有事物处理时,如果入库出现致命错误(如主键冲突),SQL语句就会停止。如何才能实现SQL语句不停止,继续执行剩下的DataTable入库,这时可利用SqlDataAdapter.RowUpdated事件来实现。
    事件是这样定义的:public event SqlRowUpdatedEventHandler RowUpdated

    实现原理就是定阅这个事件,当更新某行出错时,清除本行,在回调Insert方法。
    代码如下:

    void Insert(DataTable dt)
    {
    if(dt.Rows.Count > 0)
    {
    SqlConnection conn = new SqlConnection(connString);
    SqlCommand com = new SqlCommand();
    com.CommandText = "Insert Into table (id,CallID) Values (@id,@CallID)";
    com.Connection = conn;

    com.Parameters.Add("@id", SqlDbType.Int, 8, "id");
    com.Parameters.Add("@CallID", SqlDbType.Int, 8, "CallID");

    SqlDataAdapter adapter = new SqlDataAdapter();
    adapter.InsertCommand = com;
    adapter.RowUpdated += new SqlRowUpdatedEventHandler(adapter_RowUpdated);
               //吃掉异常
                try
                {
                    adapter.Update(dt);
                }
                catch (Exception ex)
                {
                }
    }
    void adapter_RowUpdated(object sender, SqlRowUpdatedEventArgs e)
    {
    //出现异常时
    if (e.RecordsAffected == 0)
    {
    System.Data.SqlClient.SqlException sqle = e.Errors as System.Data.SqlClient.SqlException;
    int n = sqle.Number;
    if (n == 2627)
    {
    //移出出错行,
    dt.Rows.Remove(e.Row);
    Insert(dt);
    }
    }
    }

    上面代码中e.RecordsAffected 为已插入的行数;如果语句失败,则为 0。
    sqle.Number为SQL错误类型。
    2627就是主键冲突错误,这个错误类型是.Net类库通过SQL系统表master得到的,
    select * from master.dbo.sysmessages


    这样当入库时出现致命错误,SQL还可以继续往下执行,完成剩下的DataTable入库。

  • 相关阅读:
    迭代器
    装饰器
    函数对象和闭包
    函数的使用
    文件操作
    基本数据类型及内置方法
    MySQL数据库
    网络编程进阶(进程、线程、协程、IO模型)
    网络编程基础---网络通讯原理、ssh远程执行命令、粘包问题处理、文件传输处理
    面向对象、类、元类、封装、异常处理
  • 原文地址:https://www.cnblogs.com/lilin/p/1795715.html
Copyright © 2011-2022 走看看