不仅如此&＃xff0c;如果点击右上角象箭头一样的符号&＃xff0c;还可才把这些容器折叠起来&＃xff0c;整个包就更加清楚明了&＃xff0c;一目了然了。如图&＃xff1a;
&＃xff08;二&＃xff09;For 循环。
For 循环组件&＃xff0c;类似于编程语言中的For 循环&＃xff0c;当人们需要反复执行同一个工作任务或者一系列工作任务的时候&＃xff0c;就需要用到For 循环&＃xff0c;它既可以用于有限次循环&＃xff0c;也可以用于“无限次循环”&＃xff0c;比如我们监控包的运行状况&＃xff0c;当错误数据&＃xff1e;&＃xff1d;5时&＃xff0c;包停止运行&＃xff0c;并通知管理员&＃xff1b;又如监控某个文件夹是否有新文件产生、监控网络链接是否正常、监控服务器的各项指标&＃xff08;Cpu、内存&＃xff09;是否正常等&＃xff0c;论询特定事件是否发生&＃xff0c;这就可以设置为无限次循环。
For 循环的使用非常简单&＃xff0c;它主要有三个表达式&＃xff0c;分别控制循环的执行和终止&＃xff0c;如图&＃xff1a;
按照如图所示&＃xff0c;完成表达式的值&＃xff0c;For 循环就算完成了&＃xff08;&＃64;ErrorCount 是用户自定义变量&＃xff0c;需要按照上一课的内容&＃xff0c;先定义变量&＃xff0c;此处才可以使用&＃xff09;。然后再将需要重复执行的任务&＃xff0c;拖入For 循环容器中就可以了。
&＃xff08;三&＃xff09;Foreach 循环。
在.net 编程语言中&＃xff0c;有一个循环也叫做Foreach &＃xff0c;从语义来讲&＃xff0c;这两种循环如出一彻&＃xff0c;没有什么差异。在Integration Services 中&＃xff0c;Foreach 循环是最重要的一种循环&＃xff0c;也是使用最频繁的一种循环&＃xff0c;常用于对一个集合对象中的每一个元素&＃xff0c;都要进行处理的场景。比如枚举某一个文件夹下的所有文件&＃xff0c;枚举一个DataTable 中的某一条记录、枚举一颗树&＃xff08;tree )下的每个结点&＃xff08;Node)等。下面我们将Foreach 最常用的两种类型&＃xff1a;Foreach 文件枚举器、Foreach ADO 枚举进行简单的说明。
Foreach 文件枚举器。
通常情况下&＃xff0c;我们需要循环处理某一文件夹下的每一个文件&＃xff0c;这时就需要用到Foreach 文件枚举器了&＃xff0c;比如前面我们说到IISLOG的导入&＃xff0c;IisLog 文件很多&＃xff0c;每天都会产生很多个这样的文件&＃xff0c;如果靠手工一个一个地处理&＃xff0c;将很不现实&＃xff0c;工作量非常大&＃xff0c;如果我们用Foreach 文件枚举器&＃xff0c;就会非常简单。如图&＃xff0c;打开Foreach 循环编辑器&＃xff1a;
我们选择“Foreach 文件枚举器”&＃xff0c;然后在枚举器配置项中&＃xff0c;输入文件夹的位置&＃xff08;注意这里是文件夹的位置&＃xff0c;而不是文件的位置&＃xff09;&＃xff0c;输入文件名通配符&＃xff08;如*.log
*.txt 等&＃xff09;&＃xff0c;其它按照默认设置就可以了&＃xff0c;如果需要遍历文件夹下的子目录&＃xff0c;请勾选“遍历子文件夹”选项。
下一步&＃xff0c;选择“变量映射”&＃xff0c;如图&＃xff1a;
点击“确定”&＃xff0c;回到控制流开发面板。
最后&＃xff0c;在“连接管理器”中&＃xff0c;找到映射log 文件的平面文件连接(IisLog),设置属性Expressions 的ConnectionString &＃xff1d;User::LogFile。
Foreach 文件枚举器就算完成了&＃xff0c;F5就可以达到你你想要的效果了。结果如下&＃xff1a;
其中的“文件系统任务”是将处理完成的文件复份到另外一个文件夹&＃xff0c;或者删除&＃xff0c;以免重复执行。
Foreach ADO 枚举器&＃xff1a;枚举表或者表中每一行记录。
这种枚举器在日常开发过程中&＃xff0c;也用得非常普遍&＃xff0c;类似于TSQL中的游标&＃xff0c;先Select 出一批数据&＃xff0c;存储在ADO记录集中&＃xff0c;然后再一行一行地处理。
假设有一个商业公司&＃xff0c;它在全国或者全市的各个地方&＃xff0c;都有连锁专卖店&＃xff0c;每个专卖店都是通过POS进行销售和收银&＃xff0c;为了保证前端销售快速稳定地运行&＃xff0c;POS系统一般都采用C/S模式&＃xff0c;数据与系统程序都存储在本地。集团公司的中高层主管为了随时了解各专卖店销售经营情况&＃xff0c;就需要定时或者不定时地将专卖店的数据同步到总部数据中心。
如果我们对每个专卖店DB&＃xff0c;都建立一个链接&＃xff0c;再建立一个对应的同步任务&＃xff0c;随着专卖店的增加&＃xff0c;同步任务也随之增加&＃xff0c;到最后&＃xff0c;功能类似的同步任务就会越来越多&＃xff0c;而且每增加一个专卖店&＃xff0c;ETL包都要增加一个任务&＃xff0c;管理起来&＃xff0c;将非常困难。
根据我的经验是&＃xff0c;在总部数据中心建立一张表&＃xff0c;专门配置各专卖店DB的链接凭证&＃xff08;ConnectionString)&＃xff0c; 在同步时&＃xff0c;先Select 出各DB的ConnectionString &＃xff0c;然后再动态创建DB连接。这样一来&＃xff0c;程序就小巧、稳定多了。下面我们来看看如何实现这一需求&＃xff1a;
首先&＃xff0c;定义两个变量&＃xff0c;一个于用存储ConnectionString&＃xff08;字符型)&＃xff1b;一个用于存储ADO 记录 集(Object 型)。如图&＃xff1a;
然后在控制流中增加一个SQL任务&＃xff0c;配置如下&＃xff1a;
Connection&＃xff1a;选择“数据中心”的链接器。
SQLStatement&＃xff1a; 输入如下SQL&＃xff0c;以取出所有配置记录。
代码 &＃39;;Initial Catalog&＃61;HumanResource;Provider&＃61;SQLNCLI10;Auto Translate&＃61;True;&＃39; AS
ConnectionString
FROM DbConfig
ResultSet &＃xff1a;选择“完整结果集”。
然后切换到“结果集”&＃xff0c;配置结果集选项&＃xff0c;如图&＃xff1a;&＃xff08;注意&＃xff1a;User::DataSet 一定要是Object 类型的变量&＃xff0c;其它变量都不可用&＃xff09;
点击“确定”&＃xff0c;就完成了各DB的连接配置&＃xff0c;下面就看Foreach ADO 循环如何来应用这个结果集了。
找开Foreach 循环编辑器&＃xff0c;在Enumerator 中选择“Foreach Ado 枚举”&＃xff0c;如图&＃xff1a;
请注意如图所示的每一个选项&＃xff0c;如果选错&＃xff0c;都可能达不到你想要的效果。
变量映射&＃xff0c;如图&＃xff1a;
最后一步&＃xff0c;就是将变量映射到OLE DB 的连接上了&＃xff0c;从连接管理器中&＃xff0c;选择 DB连接&＃xff0c;右击配置Expressions属性的ConnectionString &＃xff1d;User::ConnectionString &＃xff0c;如图&＃xff1a;
整个Foreach ADO 循环完成了&＃xff0c;F5一切如你所愿&＃xff0c;绿油油的一遍就会呈现在你的眼前。
常用的三种容器就介绍完了&＃xff0c;当然还有一些其它容器&＃xff0c;比如一个包&＃xff0c;是一个容器&＃xff0c;一个分组&＃xff08;在控制流中选择一批任务&＃xff0c;右键菜单“分组”&＃xff0c;就可以将这批任务放在一个Group 内&＃xff09;也是一个容器&＃xff0c;但是这些容器都非常简单&＃xff0c;就此略过&＃xff0c;不做详细说明。
在Inegration Services 中&＃xff0c;容器还可以嵌套&＃xff0c;每个容器都可以相互嵌套&＃xff0c;它们可以有各自的作用域&＃xff0c;有各自的命名空间&＃xff0c;如果我们善加利用&＃xff0c;将会为Integration Services 的结构化开发&＃xff0c;提供很多的方便。
导读&＃xff1a;
SSIS 学习(1) 概要
SSIS 学习&＃xff08;2&＃xff09;&＃xff1a;数据流任务&＃xff08;上&＃xff09;
Integration Services学习&＃xff08;3&＃xff09;&＃xff1a;数据流任务&＃xff08;下&＃xff09;
Integration Services 学习&＃xff08;4&＃xff09;:变量和表达式
京公网安备 11010802041100号