使用OLEDBSource自动映射带有EZApi的列

使用EZApi，创建EzOleDbSource对象，并为其分配Table属性。 添加了另一个任务（EzDerivedColumn）并附加到EzOleDbSource对象。 当我打开包时，我需要单击OLEDB源以获得列输出到派生任务的输入。

有没有办法使用EzApi以编程方式设置输入和输出映射？ 注意：我正在使用LinkAllInputsToOutputs（）;

码：

EzSqlOleDbCM RefConn = new EzSqlOleDbCM(package, dataVault_ConMgr); EzOleDbSource ezOleDbSource_SatFromStaging = new EzOleDbSource(satelliteDft); ezOleDbSource_SatFromStaging.Table = formatSQLTableName(settings.bd_datavault_schema_staging, stgTable); ezOleDbSource_SatFromStaging.Name = settings.ssis_prefix_dataflow_oledb_source + stgTable; 

ezOleDbSource_SatFromStaging.LinkAllInputsToOutputs（）;

  EzDerivedColumn ezDerivedColumn = new EzDerivedColumn(satelliteDft); ezDerivedColumn.LinkAllInputsToOutputs(); ezDerivedColumn.AttachTo(ezOleDbSource_SatFromStaging); ezDerivedColumn.Name = settings.ssis_prefix_task_derived + stgTable; 

Answer 1

可能不是最好的代码，但这对我有用。 它生成一个包含数据流的包，该数据流具有OLE DB源，派生列只执行子串并写入表。

我得到一些警告和信息消息，但我认为这是由于没有足够的时间以编程方式使用派生列。

  /// 
 /// Create a package with a data flow that pulls from table src_dWolf ///  /// CREATE TABLE dbo.src_dWolf /// ( /// le_key int NOT NULL PRIMARY KEY /// , le_value varchar(50) NOT NULL /// ); /// /// CREATE TABLE dbo.dst_dWolf /// ( /// le_key int NOT NULL PRIMARY KEY /// , le_value varchar(50) NOT NULL /// , le_newValue varchar(20) NOT NULL /// ); /// /// INSERT INTO dbo.src_dWolf /// ( /// le_key /// , le_value /// ) /// VALUES /// ( /// 10 /// , 'ABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTU' /// ); ///  /// 
 public static void Demo() { string dataVault_ConMgr = @"Data Source=localhost\DEV2012;Provider=SQLNCLI10.1;Integrated Security=SSPI;Initial Catalog=TypeMoreClickLess;"; EzPackage package = new EzPackage(); string stgTable = "src_dWolf"; string bd_datavault_schema_staging = "dbo"; string ssis_prefix_dataflow_oledb_source = "SRC "; string ssis_prefix_task_derived = "DST "; EzDataFlow satelliteDft = new EzDataFlow(package); satelliteDft.Name = "DFT demo"; EzSqlOleDbCM RefConn = new EzSqlOleDbCM(package, dataVault_ConMgr); RefConn.Name = "TMCL"; RefConn.ConnectionString = dataVault_ConMgr; EzOleDbSource ezOleDbSource_SatFromStaging = new EzOleDbSource(satelliteDft); ezOleDbSource_SatFromStaging.Table = String.Format("[{0}].[{1}]", bd_datavault_schema_staging, stgTable); ezOleDbSource_SatFromStaging.Name = ssis_prefix_dataflow_oledb_source + stgTable; ezOleDbSource_SatFromStaging.Connection = RefConn; EzDerivedColumn ezDerivedColumn = new EzDerivedColumn(satelliteDft); ezDerivedColumn.Name = ssis_prefix_task_derived + stgTable; ezDerivedColumn.InsertOutputColumn("le_newValue"); ezDerivedColumn.SetOutputColumnDataTypeProperties("le_newValue", Microsoft.SqlServer.Dts.Runtime.Wrapper.DataType.DT_STR, 20, 0, 0, 1252); // http://social.msdn.microsoft.com/Forums/sqlserver/en-US/137af5f4-3d35-45c2-9a3f-2127dc98fb6c/ezapi-how-to-working-with-ezderivedcolumn?forum=sqlintegrationservices Microsoft.SqlServer.Dts.Pipeline.Wrapper.IDTSOutputColumn100 derCol = ezDerivedColumn.OutputCol("le_newValue"); derCol.CustomPropertyCollection["FriendlyExpression"].Value = "SUBSTRING([le_value], 1, 20 )"; derCol.CustomPropertyCollection["Expression"].Value = "SUBSTRING([le_value], 1, 20 )"; ezDerivedColumn.AttachTo(ezOleDbSource_SatFromStaging); EzOleDbDestination ezOleDbDestination = new EzOleDbDestination(satelliteDft); ezOleDbDestination.Name = "DST dst_dWolf"; ezOleDbDestination.Table = "[dbo].[dst_dWolf]"; ezOleDbDestination.Connection = RefConn; ezOleDbDestination.FastLoadKeepIdentity = true; ezOleDbDestination.FastLoadKeepNulls = true; ezOleDbDestination.FastLoadOptions = "TABLOCK,CHECK_CONSTRAINTS"; ezOleDbDestination.AccessMode = AccessMode.AM_OPENROWSET_FASTLOAD; ezOleDbDestination.AttachTo(ezDerivedColumn); ezOleDbDestination.LinkAllInputsToOutputs(); package.SaveToFile(@"C:\sandbox\TypeMoreClickLess\EzAPIDemo\dwolf.dtsx"); }