博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
关于DataSet事务处理以及SqlDataAdapter四种用法
阅读量:5037 次
发布时间:2019-06-12

本文共 2055 字,大约阅读时间需要 6 分钟。

如果是直接执行SQL语句时,事务很好处理,对于大多数的Erp应用,不能能用SQL来处理数据,所以更新DataSet更为常用,更新单个的DataSet也非常简单,不需要事务的处理,给多个DataSet增加事务多数应用于分布式的程序代码中,下面为在Webservice中更新Winform传递过来的经过压缩的数据集的事务处理代码,多个DataSet 情况。
/// <summary>
    /// 更新经过压缩的DataSet
    /// </summary>
    /// <param >环境变量</param>
    /// <param >二进制的DataSet</param>
    /// <returns>出现异常,返回一个错误信息</returns>
        public object UpdataSet(object[] env, byte[] byt)
    {
        object info = null;
        SqlConnection sqlconn = null;
        //定义事务
        SqlTransaction transaction = null;
        DataSet ds = null;
        try
        {
            ds = md.BytesToDs(byt);
            string Url = "数据库连接语名";
            sqlconn = new SqlConnection(Url);
            sqlconn.Open();
            transaction = sqlconn.BeginTransaction(IsolationLevel.ReadCommitted, "transname");//实例化事务
            SqlDataAdapter adapter;
            SqlCommandBuilder objCommandBuilder;
            for (int i = 0; i < ds.Tables.Count; i++)
            {
                adapter = new SqlDataAdapter("select * from " + ds.Tables[i].TableName + " where 2>3", sqlconn);//传统用法
                objCommandBuilder = new SqlCommandBuilder(adapter);
                //开始挂起
                //挂起操作
                adapter.DeleteCommand = new SqlCommand("...删除语句..", sqlconn, transaction);
                //adapter的增删查改可以与事务一起用,注意这里没有实例SqlCommand对象所以new SqlCommand
                adapter.InsertCommand = new SqlCommand("............", sqlconn, transaction);
                adapter.UpdateCommand = new SqlCommand(".............", sqlconn, transaction);
                adapter.SelectCommand = new SqlCommand("select * from " + ds.Tables[i].TableName + " where 2>3", sqlconn, transaction);
                //以上是adapter的新用法,new SqlCommand后面写sql语句,SqlConnection,还可以写事务...就不用实例SqlCommand对象
                //没有实例SqlCommand对象所以获取
                adapter.DeleteCommand = objCommandBuilder.GetDeleteCommand();
                adapter.InsertCommand = objCommandBuilder.GetInsertCommand();
                adapter.UpdateCommand = objCommandBuilder.GetUpdateCommand();
                objCommandBuilder.DataAdapter.Update(ds, ds.Tables[i].TableName.ToString());//
                
            }
            transaction.Commit();//无误后提交事务
            sqlconn.Close();
        }
        catch (Exception err)
        {
            Console.Out.WriteLine("存盘时发生错误:" + err.Message);
            info = "存盘时发生错误:" + err.Message;
            //事务回滚
            transaction.Rollback();
        }
        finally
        {
            if (sqlconn != null)
            {
                sqlconn.Close();
            }
        }
        return info;
    }

转载于:https://www.cnblogs.com/top5/archive/2011/10/28/2227317.html

你可能感兴趣的文章
多变量微积分笔记24——空间线积分
查看>>
Magento CE使用Redis的配置过程
查看>>
poi操作oracle数据库导出excel文件
查看>>
(转)Intent的基本使用方法总结
查看>>
Mac 下的Chrome 按什么快捷键调出页面调试工具
查看>>
Windows Phone开发(24):启动器与选择器之发送短信
查看>>
JS截取字符串常用方法
查看>>
Google非官方的Text To Speech和Speech Recognition的API
查看>>
stdext - A C++ STL Extensions Libary
查看>>
Django 内建 中间件组件
查看>>
bootstrap-Table服务端分页,获取到的数据怎么再页面的表格里显示
查看>>
进程间通信系列 之 socket套接字及其实例
查看>>
天气预报插件
查看>>
Unity 游戏框架搭建 (十三) 无需继承的单例的模板
查看>>
模块与包
查看>>
mysql忘记root密码
查看>>
安卓电量优化之AlarmManager使用全部解析
查看>>
apache服务器中设置目录不可访问
查看>>
嵌入式Linux驱动学习之路(十)字符设备驱动-my_led
查看>>
[bzoj1025][SCOI2009]游戏
查看>>