如何将多个输入分组到一个输出中

Question

我有一个像这样的 Excel

region    state    city
-------------------------
south     state1    city1
north     state2    city2

，我想填充这样的数据库表

  id      name       type
 ------------------------
   1      state1     state
   2      south      region
   3      city1      city

，但我不知道如何对这些列和标题进行分组以填充数据库表。有什么想法吗？我对这个应用程序很迷茫

Answer 1

您可以使用数据流任务中提供的Unpivot Transformation在SSIS中实现此目的。以下示例说明了如何做到这一点。该示例使用 SSIS 2008 R2 和 SQL 2008 R2 数据库。

分步过程：

1. 使用示例数据创建一个 Excel 文件，如屏幕截图 #1 所示。我已将该文件命名为 Source.xlsx。

2. 使用SQL 脚本部分中给出的脚本在 SQL Server 数据库中创建一个名为dbo.Destination 的表。该表将填充 Excel 数据。我引入了一个名为 GroupId 的新字段，以便可以将数据分组在一起。

3. 在 SSIS 包上，创建一个名为 Excel 的 Excel 连接和一个名为 SQLServer 的 OLE DB 连接，如屏幕截图 #2 所示。 Excel 连接管理器 应按屏幕截图 #3 所示进行配置。 OLE DB 连接将配置为连接到您选择的数据库。

4. 在包的控制流选项卡上，放置一个数据流任务，如屏幕截图#4所示。

5. 使用 Excel 源、脚本组件、逆透视转换配置数据流选项卡，如屏幕截图 #5 所示code> 和 OLE DB 目标。

6. 配置 Excel 源，如屏幕截图 #6 和 #7 所示。这将从 Excel 文件中读取数据。

7. 将脚本组件配置为转换并添加输出列，如屏幕截图#8所示。在脚本部分，单击编辑脚本并将代码替换为脚本组件代码部分下给出的代码。

8. 配置 Unpivot 转换，如屏幕截图 #9 所示。我们不想转换 GroupId，因此不要对其进行配置，而是将其设置为 Pass Through。

9. 配置 OLE DB 目标，如屏幕截图 #10 和 #11 所示。

10. Screenshot #12 显示包执行之前dbo.Destination表中的数据。

11. 屏幕截图 #13 显示包执行。

12. Screenshot #14 显示包执行之后dbo.Destination表中的数据。

希望有帮助。

SQL 脚本：

CREATE TABLE [dbo].[Destination](
    [Id] [int] IDENTITY(1,1) NOT NULL,
    [Name] [nvarchar](255) NULL,
    [Type] [nvarchar](255) NULL,
    [GroupId] [int] NULL,
 CONSTRAINT [PK_Destination] PRIMARY KEY CLUSTERED ([Id] ASC)
) ON [PRIMARY]
GO

脚本组件代码：

C# 代码，只能在 SSIS 2008 或更高版本中使用。

/* Microsoft SQL Server Integration Services Script Component
*  Write scripts using Microsoft Visual C# 2008.
*  ScriptMain is the entry point class of the script.*/

using System;
using System.Data;
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;
using Microsoft.SqlServer.Dts.Runtime.Wrapper;

[Microsoft.SqlServer.Dts.Pipeline.SSISScriptComponentEntryPointAttribute]
public class ScriptMain : UserComponent
{
    int groupId = 1;
    public override void PreExecute()
    {
        base.PreExecute();
    }

    public override void PostExecute()
    {
        base.PostExecute();
    }

    public override void Input0_ProcessInputRow(Input0Buffer Row)
    {
        Row.GroupId = groupId;
        groupId += 1;
    }
}

屏幕截图 #1：

屏幕截图 #2：

屏幕截图 #3：

屏幕截图 #4：

屏幕截图 #5：

屏幕截图 #6：

屏幕截图 #7：

屏幕截图 #8：

屏幕截图#9：

屏幕截图 #10：

屏幕截图 #11：

屏幕截图 #12：

屏幕截图 #13：

屏幕截图 #14：< /strong>