关闭 x
IT技术网
    技 采 号
    ITJS.cn - 技术改变世界
    • 实用工具
    • 菜鸟教程
    IT采购网 中国存储网 科技号 CIO智库

    IT技术网

    IT采购网
    • 首页
    • 行业资讯
    • 系统运维
      • 操作系统
        • Windows
        • Linux
        • Mac OS
      • 数据库
        • MySQL
        • Oracle
        • SQL Server
      • 网站建设
    • 人工智能
    • 半导体芯片
    • 笔记本电脑
    • 智能手机
    • 智能汽车
    • 编程语言
    IT技术网 - ITJS.CN
    首页 » SQL语言 »SQL点滴之SSIS中的事务处理

    SQL点滴之SSIS中的事务处理

    2011-04-27 16:09:00 出处:ITJS
    分享

    在介绍了SQL Server中的事务的概念之后,现在我们可以继续介绍这次的点滴了。

    我们可以把SSIS中的整个package包含在一个事务中,但是假如在package的执行过程中有一个表需要锁定应该怎么处理呢?SSIS内建的事务处理可以解决这个问题。

    SSIS中的包,容器(例如Loop,Foreach Loop,Sequence)或者一个单独的任务中都可以设置事务处理选项。事务处理选项有下面一些值      

    Required-如有事务则添加,否则新添加一个 Supported-如有有事务添加一个,没有则不添加,这是默认选项+ NotSupported-不添加事务处理

    内建的事务处理要使用Distributed Transaction Coordinator(MSDTC)服务,这个服务必须开启。MSDTC允许使用分布式事务处理,例如在一个事务中同时处理SQL Server数据库和Oracle数据库。假如没有开启这个服务会得到下面的错误提示.

    Error: 0xC001401A at Transaction: The SSIS Runtime has failed to start the distributed transaction due to error 0x8004D01B "The Transaction Manager is not available.".  The DTC transaction failed to start. This could occur because the MSDTC Service is not running.  

    注意SSIS中包中的元素的事务隔离级别是Serializable,这种级别会影响锁的持续时间。下面我们来用一个例子说明在如何package中锁定一个表

    1.新建一个SequenceContainer,命名为Test Initialization。

    2.这个SequenceContainer主要用来创建测试的环境,创建连个表TranQueue,TranQueueHistory,向第一个表中添加一条记录,这样模拟一个事物处理过程。我们只是使用这个SequenceContainer来创建测试环境,所以设置它的TransactionOption选项为NotSupported在这个SequenceContainer中依次添加三个Execute SQL,依次他们的设置如下 

    /*命名*/                   Create TranQueue Table       /*SQLstatement设置*/       IF NOT EXISTS ( SELECT * FROM sys.objects WHERE object_id =       OBJECT_ID(N'dbo.TranQueue') AND type in (N'U') )   BEGIN   execute('CREATE TABLE dbo.TranQueue(message nvarchar(256))')   END /*命名*/  Populate TranQueue          /*SQLstatement设置*/  INSERT INTO dbo.TranQueue VALUES ('Test Message' + CONVERT  (NVARCHAR(23), GETDATE(), 121))  /*命名*/  Create TranQueueHistory table      /*SQLstatement设置*/  IF NOT EXISTS ( SELECT * FROM sys.objects WHERE object_id =    OBJECT_ID(N'dbo.TranQueueHistory') AND type in (N'U') )  BEGIN execute('CREATE TABLE dbo.TranQueueHistory(message nvarchar(256))')  END 

    3.创建第二个SequenceContainer,命名为Process,TransactionOption属性设置为Supported,这样就会添加事务处理。  

    4.在这个SequenceContainer中添加一个Execute SQL,命名为ProcessTranQueue,它的SQLStatement设置为下面的语句。这个语句的作用,模拟事务处理,删除TranQueue表中前10条数据;OUTPUT字句将删除的数据插入到TranQueueHistory表中,模拟处理结束,更新历史记录

    DELETE TOP(10) dbo.TranQueue  OUTPUT DELETED.*  INTO dbo.TranQueueHistory  FROM dbo.TranQueue WITH (TABLOCKX)  

    5.添加一个Execute SQL,命名为Placeholder for Breakpoint。这个任务不进行任何操作,只是为了在这设置一个断点然后在这里停下来让我们有时间验证是否会锁定表。

    6.右击Control Flow界面添加一个变量v_SimulateFailure,类型为Int32,值为1。

    7.添加一个Execute SQL命名为Simulate Failure。用它来模拟错误,设置SQLStatement为select 1/0,当pacakage执行到这里的时候会造成错误进而回滚。

    8.右击Placeholder for Breakpoint和Simulate Failure之间的连线,点击Edit,设置Evaluation operation为Expression and Constraint,设置Expression为@[User::v_SimulateFailure] == 1,其他保持默认。这样之后这个自定义变量的值为1的时候才会继续往下执行。

    9.执行package,会得到如图1的结果,package在断点处终止。 

     

    图1              

    10.打开SQL Server Management Studion,选择对应的数据库,新建一个Query,执行下面的语句,NOLOCK选项忽略锁,这个语句查询得到一条记录 Message2011-04-10 14:22:31.043,但是这条记录并没有提交

    SELECT * FROM dbo.TranQueueHistory WITH (NOLOCK)  

    11.执行下面的语句

    SELECT * FROM dbo.TranQueue  

    语句将阻塞在这里,语句一直停留在执行状态,不会结束。因为在Process TranQueue任务中我们使用TABLOCKX,在这里将等待任务回滚或者提交。或者可以写成这样,它任然会阻塞

    DELETE TOP(10) dbo.TranQueue  INSERT INTO dbo.TranQueueHistory VALUES ('Test Message' + CONVERT(NVARCHAR(23), GETDATE(), 121))  

    12. 点击Continue按钮或者Debuge按钮,会看到package执行失败,执行SELECT * FROM dbo.TranQueueHistory WITH (NOLOCK);因为执行了回滚,不会得到任何结果。SELECT * FROM dbo.TranQueue,任然有一条记录。

    SELECT * FROM dbo.TranQueueHistory WITH (NOLOCK)  

    NOLOCK提示忽略锁,这个语句查询得到一条记录 Message2011-04-10 14:22:31.043,但是这条记录并没有提交

    13.  执行下面的语句,

    SELECT * FROM dbo.TranQueue  

    sql语句将阻塞在这里,语句一直执行。因为在Process TranQueue任务中我们使用TABLOCKX,在这里将等待任务回滚或者提交。或者可以写成这样

    DELETE TOP(10) dbo.TranQueue;  INSERT INTO dbo.TranQueueHistory VALUES ('Test Message' + CONVERT(NVARCHAR(23), GETDATE(), 121)), 

    它任然会阻塞     

    14.  点击Continue按钮或者Debuge按钮,会看到package执行失败,执行SELECT * FROM dbo.TranQueueHistory WITH (NOLOCK);因为执行了回滚,不会得到任何结果。执行SELECT * FROM dbo.TranQueue,任然有一条记录。

    假如设置变量User::v_SimulateFailure的值为0,不会执行Simulate Failure任务,就不会回滚,TranQueue中的记录会被写入到TranQueueHistory中。这里有一个很有意思的语句:

    DELETE TOP(10) dbo.TranQueue  OUTPUT DELETED.*  INTO dbo.TranQueueHistory  FROM dbo.TranQueue WITH (TABLOCKX)  

    假如两个表的结构有一部分是是一样的,现在想把一个表的数据导入到另外一个表中,可以使用DELETE SourceTable OUTPUT DELETE.*/DELETE.Column1,DELETE.Column2... INTO DestinationTable FROM SourceTable,这样第一个表中的数据会被“剪切”到第二个表中。

    原文链接:http://www.cnblogs.com/tylerdonet/archive/2011/04/10/2011806.html

    上一篇返回首页 下一篇

    声明: 此文观点不代表本站立场;转载务必保留本文链接;版权疑问请联系我们。

    别人在看

    Edge浏览器百度被劫持/篡改怎么办,地址后边跟着尾巴#tn=68018901_7_oem_dg

    Google Chrome 在 iPhone 上新增了 Safari 数据导入选项

    Windows 11专业版 KMS工具激活产品密钥的方法

    DEDECMS安全策略官方出品

    Microsoft Text Input Application 可以关闭吗?

    新版本QQ如何关闭自带的浏览器?

    C++编程语言中continue的用法和功能,附举例示范代码

    c++ map 的数据结构、基本操作以及其在实际应用中的使用。

    C语言如何避免内存泄漏、缓冲区溢出、空指针解引用等常见的安全问题

    C语言中的break语句详解

    IT头条

    马斯克2026最新采访总结:2040年,全球机器人数量将突破100亿台

    23:52

    专家解读|规范人工智能前沿业态健康发展的新探索:解读《人工智能拟人化互动服务管理暂行办法》

    00:54

    用至强 6高存力搞定MoE卸载!

    17:53

    美国将允许英伟达向中国“经批准的客户”出售H200 GPU

    02:08

    苹果与微信就15%手续费达成一致?腾讯未置可否

    22:00

    技术热点

    PHP 和 Node.js 的10项对比挑战

    Javascript闭包深入解析及实现方法

    windows 7、windows 8.1手动增加右键菜单功能技巧

    MYSQL出错代码大汇总

    windows 7假死机怎么办 windows 7系统假死机的原因以及解决方法

    Ubuntu(Linux)下配置IP地址的方法

      友情链接:
    • IT采购网
    • 科技号
    • 中国存储网
    • 存储网
    • 半导体联盟
    • 医疗软件网
    • 软件中国
    • ITbrand
    • 采购中国
    • CIO智库
    • 考研题库
    • 法务网
    • AI工具网
    • 电子芯片网
    • 安全库
    • 隐私保护
    • 版权申明
    • 联系我们
    IT技术网 版权所有 © 2020-2025,京ICP备14047533号-20,Power by OK设计网

    在上方输入关键词后,回车键 开始搜索。Esc键 取消该搜索窗口。