位置: 编程技术 - 正文

使用SSIS创建同步数据库数据任务的方法

编辑:rootadmin
这些包可以独立使用,也可以与其他包一起使用以满足复杂的业务需求。Integration Services 可以提取和转换来自多种源(如 XML 数据文件、平面文件和关系数据源)的数据,然后将这些数据加载到一个或多个目标。(摘自MSDN,更多详细信息可参考: 下面我使用SSIS来演示一个实际例子。比如我有一个数据库,出于备份数据或者其它的目的,会定期的对这个数据库的数据迁移到其它的数据库去。迁移的时候,有些新增的字段会被插入备份数据库,而有些被修改过的字段也会在备份数据库被修改。现在我们就用SSIS来完成这项任务。 首先在我源数据库db_source和目标数据库db_destination中运行以下SQL创建好需要的表,就以这一个表test_1来进行示范。

建好表好在源数据表中可以随便加几条记录,目标数据库暂时留空。

现在我们打开VS,创建一个Intergration Services Project。(注意:如果SQL Server 装的是Express版的话是没有这个项目工程模板的)

创建好工程后,在Control Flow这个Tab下拖入一个Data Flow Task,如下图:

双击这个Data Flow Task,我们就会进入Data Flow这个Tab标签中。

然后我们在左边工具栏里找到OLE DB Source,继续拖两个OLE DB Source出来。分别给它们命名为Source DB和Destination DB。

将数据源拖出来后,双击它,可以对它进行一些设置,主要就是链接数据库及选择你要进行迁移的表或者视图等设置,这里我就不详细说明了。注意一点的是就像上图所示,如果一个图形上出现一个红X的话说明设置有错误。

再来就是拖两个Sort及一个Merge Join出来,将之前的数据源箭头分别指向两个Sort,最后两个Sort出来的数据同时输入Merge Join中。

分别双击两个Sort,钩选表中的ID,对ID这个字段进行一次排序。因为Merge Join这个流程要求输入的数据是已排序好的。这个排序也可以直接在数据源中对它们的输出字段设置SortKeyPosition这个属性来排序。(详见: Join的时候,会让我们选择这个输入的数据是作为左输入还是右输入,我们按照图示的那样,左边的作为左输入,右边的作为右输入。然后我们双击Merge Join,按照如下图所示设置:

这里打钩的是这个流程之后输出的数据,Join Type需要选择为Left outer join,因为左边是我们的原始数据表,右边是我们备份的表,右表可以看成是一个左表的一个子集,如果左表有的数据,右表没有的,那些就是需要新插入备份数据库的数据。

现在我们需要一个分支,即新的数据需要插入备份数据库中,而已有的数据需要更新为新的值。我们从工具栏中拖入一个Conditional Split来进行这样的分支处理。我们将Merge Sort中的输出指向Conditional Split,然后双击Conditional Split,如下图所示设置(注意条件一个是ISNULL,一个是非ISNULL)。

这时它们的输入值就被分成两种条件输出,最后我们再拖入一个OLE DB Destination来插入数据和一个OLE DB Command来更新数据库,最终流程如下图:

双击设置OLE DB Destionation,选择好数据导入的目标数据库中的表,这里需要注意的就是要钩选Keep identity这个选项,因为我创建表的时候对ID字段使用了自增属性。

双击设置OLE DB Command,首先在Connection Managers这个Tab中选择好链接对象,然后在Component Properties这个选项卡中,设置你的SqlCommand属性。如下图:

这里的参数值都是用?号来代替,之后在Column Mappings这个Tab中设置代替值实际代替的列,如下图:

至此,任务就创建完毕了,没有编写任何代码,直接拖拉完成了。现在可以直接在VS中按F5运行看下效果,我们的目标数据表将插入源数据表中的值。然后我们修改一下原数据表,再来运行一下上面这个任务,就可以在目标数据库中看到更改了。

那么如何去定时完成任务哩?这里可以用SQL Server Agent去调用上面我们写好的包, 或者在Windows计划任务中使用DTExec.exe去执行上面的任务。

推荐整理分享使用SSIS创建同步数据库数据任务的方法,希望有所帮助,仅作参考,欢迎阅读内容。

使用SSIS创建同步数据库数据任务的方法

文章相关热门搜索词:,内容如对您有帮助,希望把文章链接给更多的朋友!

SQL语句实例说明 方便学习mysql的朋友 MySQL中模式就是数据库SHOWDATABASES;showdatabases;罗列所有数据库名称CREATEDATABASE数据库名createdatabaseTEST;创建名为TEST的数据库DROPDATABASE数据库名dropdatabaseTEST;

SQL Server 到底需要使用哪些端口? 下面就来介绍下SQLServer中使用的端口有哪些:首先,最常用最常见的就是端口。这个是数据库引擎的端口,如果我们要远程连接数据库引擎,那么

sqlserver 存储过程带事务 拼接id 返回值 删除一条留言信息会级联删除回复信息,这时我们需要用到事务,如下SQLALTERPROCEDURE[dbo].[proc_tb_leaveword_delete](@leavewordIDINT,@recordTINYINTOUTPUT)ASBEGINBEGINTRYBEGIN

标签: 使用SSIS创建同步数据库数据任务的方法

本文链接地址:https://www.jiuchutong.com/biancheng/348194.html 转载请保留说明!

上一篇:编程经验点滴 动态SQL的拼接技巧(编程经验点滴怎么写)

下一篇:SQL语句实例说明 方便学习mysql的朋友(sql语句示例)

  • 个人独资企业要承担无限责任吗
  • 利润表中其他业务利润是什么
  • 收了押金不退
  • 存货损失
  • 结转损益类账户余额
  • 出口报关单上的运费和保费和实际不一致
  • 定货合同有法律效力吗?
  • 未分配利润转增股本需要交税吗
  • 营改增后非增值税应税项目包括哪些
  • 个税申报没交会收滞纳金吗
  • 税控盘费用抵减增值税
  • 账本印花税税金及附加怎么入账?
  • 6月份税务新政热点问题有哪些?
  • 房地产行业应收帐款周转率平均值
  • 分公司注销未分配利润转给总部,总部如何做账
  • 在会计上主营业务利润和营业利润有什么区别?
  • 发票销货清单需要到税务局吗
  • 机械租赁的发票
  • 职工福利费扣除限额
  • u盘加载缓慢
  • 快速迅雷
  • 没有系统U盘,电脑密码忘记了如何打开电脑
  • 购买商品接受劳务的现金流包括哪些
  • 无序树有几种
  • 电子设备摊销额怎么算
  • 投标保证金退回是什么意思
  • 收到保险公司赔付的车辆维修费的会计分录
  • vue浏览器版本
  • 服装制造业现状和发展趋势
  • 职工教育经费支出包括哪些内容
  • 银行票据贴现业务发展中遇到的困难
  • 小程序怎么自定义tabbar
  • php购物车订单处理
  • 交暖气费可以开单位发票吗
  • 蓬莱德尔塔
  • thinkphp技巧
  • 现在前端的现状
  • 计提折旧是哪个凭证
  • js框架jquery
  • 未开票交税怎么做账
  • 高效快速编制会计分录如何做?
  • 定额计税的有哪些
  • 小微企业认定需要哪些资料
  • 删除一张表的某一条记录
  • 公司控股另一家公司好与坏
  • 房屋租赁物业费谁承担
  • 融资租赁开什么发票
  • 销售收入发生变动的影响
  • 分公司挣的钱归谁所有
  • 限制性股票应纳税额的确定
  • 注册资本认缴制度
  • 怎么查公司的对公账户
  • 包工包料工程如何报价合理
  • 行政单位工会经费
  • 一般纳税人出现以下哪些情况时,其进项税额不得抵扣( )
  • 保险增值税发票是什么
  • 个体户未进行抄报税怎么处罚
  • 餐费发票报销需提供清单吗
  • 旅游饮食服务企业财务会计制度
  • sql中分页
  • 开机蓝屏怎么回事
  • 苹果系统最新版本
  • mac备忘录怎么使用
  • wmiex.exe是什么程序
  • macbookair网页全屏
  • 苹果mac双系统怎么删除
  • 用u盘安装ubuntu
  • win10怎么设置net3.5
  • 标签windows
  • win8快捷方式
  • win8桌面右键无法使用
  • win7服务在哪里打开
  • 史上最全的领域学说
  • c++11视频教程
  • jquery 图片插件
  • 浙江电子税务开票系统
  • 医保月底结算规定是什么
  • 中国地税国税
  • 撤销存款证明需要什么手续
  • 河南电子税务局电话
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设