如何使用SSIS加载在EDI 823密码箱文件中找到的父子数据？
|
我必须使用ssis将EDI 823锁盒文件加载到SQl服务器数据库中。谁能告诉我如何处理不同线条之间的父子关系。
没有找到相关结果
已邀请:
1 个回复
款去芳尾脊
和的表。有关这些表的创建脚本，请参见第5节。在此示例SSIS包的帮助下，我们将通过读取平面文件内容来填充这些表。 在SSIS包上，拖放两个数据流任务。将它们分别命名为和。请参阅屏幕快照2，以了解如何放置它们。 创建一个名为string8 data的数据类型字符串的变量。将值“ 1”分配给变量。请参阅屏幕截图3。 配置Header数据流任务，如屏幕截图4所示。下面的步骤5-11描述了Header数据流任务中的每个转换任务。是平面文件源，它被配置为读取屏幕快照＃1中所示的文件。屏幕快照＃5-＃9中显示了此任务中使用的平面文件连接的配置设置。是派生的列转换任务，用于删除输入中存在的任何空格。请参阅屏幕截图10。是脚本组件转换任务。拖放脚本组件时，选择“转换”选项。请参阅截图11，以了解如何在此任务上配置ѭ13。请参阅屏幕截图12，以了解如何在此任务上配置ѭ14。输出列“ 15”的数据类型为DT_BOOL，输出列HeaderKey为数据类型的DT_STR，长度为50。在左侧选择“ 16”，然后单击“ 17”。将脚本组件中的代码替换为脚本任务组件部分中使用的代码下给出的代码。 顾名思义，“ 18”是组播转换任务。它没有任何特殊配置。是条件分割变换任务。请参阅屏幕快照＃13来配置此任务。 “ 6”是配置为连接到新创建的表dbo.Header的OLE DB目标。屏幕快照＃14中显示了此任务的字段映射。是配置为写入CSV文件的平面文件目标。屏幕截图＃15-＃16中显示了此连接管理器的配置。登台连接管理器中有四列。和列的数据类型为DT_STR，长度为255；的数据类型为DT_BOOL；的数据类型字符串的长度为50。任务的字段映射如屏幕快照17所示。 然后，我们继续下一个数据流任务task7。 配置细节数据流任务，如屏幕截图18所示。下面的步骤14-16描述了Detail数据流任务中的每个转换任务。是平面文件源，配置为使用在步骤＃11中创建的连接管理器。 “ 30”是配置为指向表dbo.Header的查找转换。屏幕快照＃19中显示了此任务的列配置。 “ 7”是配置为连接到新创建的表dbo.Detail的OLE DB目标。屏幕快照＃20中显示了此任务的字段映射。 屏幕截图＃21和＃22显示了数据流任务Header和Detail的执行。 屏幕截图＃23显示了加载到表中的数据。 希望能有所帮助。 脚本任务组件中使用的代码（在上面的步骤＃7中提及）： 只能在中使用的C＃代码。 。/*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 { string currentValue = string.Empty; string previousHeader = string.Empty; public override void PreExecute() { base.PreExecute(); } public override void PostExecute() { base.PostExecute(); } public override void Input0_ProcessInputRow(Input0Buffer Row) { IDTSVariables100 varCollection = null; this.VariableDispenser.LockForRead(\"User::HeaderCode\"); this.VariableDispenser.GetVariables(out varCollection); currentValue = Row.ValueTrimmed.ToString(); if (Row.CodeTrimmed.ToString() == varCollection[\"User::HeaderCode\"].Value.ToString()) { Row.IsHeader = true; if (previousHeader != currentValue) { previousHeader = currentValue; } } Row.HeaderKey = previousHeader; varCollection.Unlock(); } }CREATE TABLE [dbo].[Detail]( [DetailId] [int] IDENTITY(1,1) NOT NULL, [Name] [varchar](255) NOT NULL, [HeaderId] [int] NOT NULL, CONSTRAINT [PK_Detail] PRIMARY KEY CLUSTERED ( [DetailId] ASC )) ON [PRIMARY] GO CREATE TABLE [dbo].[Header]( [HeaderId] [int] IDENTITY(1,1) NOT NULL, [Name] [varchar](255) NOT NULL, CONSTRAINT [PK_Header] PRIMARY KEY CLUSTERED ( [HeaderId] ASC )) ON [PRIMARY] GO