ssis - 使用 Foreach 从多个数据库读取

Question

目前，我有一个连接到20多个数据库（相同结构）的控制流

在此 controlf 流中除了数据流仅在与数据库的连接方面不同之外，一切都是相同的。 这是数据流的示例：

OLE DB 源实际上有所不同。

在这种情况下是否可以使用 Foreach 循环来避免这些重复？ 如果可以的话，该怎么做呢？我找不到任何描述如何连接到不同数据库的好文章。

谢谢，
伊利亚

编辑：
我发现一篇文章描述了我需要的大部分内容： http://sql-bi-dev.blogspot.com/2010/07/dynamic-database-connection-using-ssis.html

我按照此处的所有步骤进行操作，但我不明白带有查询的部分。这是该文章中的查询：

SELECT '' TableName, N'' ConnString, 0 RecordCount, GETDATE() ActionTime

我不明白这种语法，我猜这就是错误的来源：

[OLE DB 源 1] 错误：输出列出现错误 输出“OLE DB 源输出”(11) 上的“ConnString”(37)。专栏 返回的状态是：“文本被截断或者一个或多个字符被截断 目标代码页中没有匹配项。”。

[OLE DB 源 1] 错误：“输出列“ConnString”(37 ）” 由于发生截断而失败，并且截断行处置 “输出列“ConnString”(37)”上指定截断失败。 指定对象的指定对象发生截断错误 组件。

[SSIS.Pipeline] 错误：SSIS 错误代码 DTS_E_PRIMEOUTPUTFAILED。这 组件“OLE DB Source”(1) 上的 PrimeOutput 方法返回错误 代码 0xC020902A。当组件返回失败代码时 管道引擎称为 PrimeOutput()。故障代码的含义 是由组件定义的，但是错误是致命的并且管道 停止执行。在此之前可能已发布错误消息 有关失败的更多信息。

我想从名为 Agency 的表中获取数据（我在变量 SourceTable = 'Agency' 中定义 - 如果我设置不存在的表，那么我会收到错误，所以我猜与源数据库的连接是好的）...让我感到困惑的是，我没有在任何地方定义我需要的列，所以我猜这个查询中有错误，但我不理解它的语法。有什么建议吗？

编辑2：
我遇到的另一个问题是消息框总是在连接字符串中返回相同的值 - 变量 ConnString 不会改变。如何将 SourceList 变量中的值赋给它？

Answer 1

我认为这是可能的。我会这样做：

1. Foreach循环的集合应该是“Foreach Item Enumerator”。此时，您可以在“枚举器配置”面板中制作一个小表。添加一个类型为字符串的列。这里将出现数据库的连接字符串。
2. 创建一个字符串变量并将其与此列关联：转到 Foreach 循环编辑器中的变量映射，选择字符串变量（例如 User::ConnString），给出索引 0。循环将迭代您在第一步中设置的条目，然后您可以通过此 User::ConnString 变量访问这些值。
3. 将数据流任务添加到 Foreach 循环容器中。里面设置一个OLE DB Source。它需要一个连接管理器。选择与 OLE DB 连接关联的连接管理器，转到“属性”、“表达式”。选择 ConnectionString 属性，然后在表达式列中键入 @[User::ConnString]（或使用您的变量名称）。
4. 找到您当前使用的所有连接字符串并将其输入到枚举项中。

我认为通过这些步骤您可以简化数据流。

此过程假设您在所有数据库中具有相同的表名。在其他情况下，您还可以迭代要连接的表名称。 （枚举配置中的第二列，并用适当的表名称填充单元格。您还需要第二个变量。）

当然，您不必复制整个连接字符串，而是复制其中的更改部分。在这种情况下，你应该适当地形成你的表达方式。

编辑

你是对的。这个例子有一些问题。 （我认为这对于您的解决方案来说有点复杂，但可以使用。）

第一个是（正如您提到的）它没有将值传递给变量。我将用这些完成第六步：将 User::SourceList 设置为 ADO 对象源变量后，选择左侧的变量映射。在“变量”列中，首先选择“User::ConnString”（将索引设置为 0），然后选择“User::SourceTable”（将索引设置为 1）。这将解决您使用 MessageBox 进行的第二次编辑。从现在开始，它应该显示出正确的价值观。

第二个问题是你写的，有这个截断错误。如果您仔细查看错误消息，它们会说某些字符串列的长度为 1。这就是发生某些截断的原因。要解决此问题，请右键单击 OLE DB 源，选择“显示高级编辑器”。转到最后一个选项卡（输入和输出属性），展开 OLE DB 源输出/输出列。首先选择表名。在右侧的数据类型属性中，您应该看到长度 = 1。（我猜，SSIS 无法正确确定此列的长度，因为您选择 SQL 命令变量作为数据访问模式）。根据结果​​表定义，将此值设置为 128。还将 ConnString 列的长度从 1 更改为 256。

在这些更改之后，示例应该可以运行。 （在我的例子中，它有效。）这个示例使用了与我编写的基本相同的概念，只是它从数据存储中获取连接字符串，而不是从包本身内部获取连接字符串。我接受，前者可能是一个更强大的解决方案。我希望你能让你的包裹发挥作用。如果没有，请告诉我。