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入库。

  • 相关阅读:
    Tair分布式key/value存储
    Ehcache详细解读
    专访阿里中间件高级专家沈询
    boost之词法解析器spirit
    快速部署Python应用:Nginx+uWSGI配置详解
    CMake如何执行shell命令
    show engine innodb status 详解
    HTTP Request header
    json python api
    mysql 索引对于select速度提升作用实验
  • 原文地址:https://www.cnblogs.com/lilin/p/1795715.html
Copyright © 2011-2022 走看看