我一直在努力了解其他用户如何完成他们的项目,但我的理解仍然有限。
我想要将任何给定的XML源转换为数据流任务,并将其数据传递到与XML文件表名匹配的OLE DB目标。使用可视化工具运行它意味着我无法进行动态数据流任务,因为元数据不会刷新。
我创建了一个脚本来创建一个包,但是当我在Visual Studio中打开该包时,它会显示红色的X,表示不能有零个输入列。当我深入挖掘并查看OLE DB目标的映射,然后单击确定 - 它会为我进行更正。我无法弄清楚如何以编程方式执行此操作。
我已经看到其他人通过使用foreach循环并遍历输入列来解决这个问题,但我似乎无法弄清楚其中的细节。
我还有一个单独的脚本,我试图模仿几个人的脚本,但它有不同的问题。不确定如何将其作为附件发布。
非常感谢您的帮助 :)
编辑
我一直在尝试BIML,并得到了积极的反馈,我会继续尝试...但是在短期内,我想知道是否有人可以帮助我弄清楚为什么这不会填充我的输入的ExternalMetaDataColumnId。我在下面发布了我的更新代码,其中包含未能按预期工作的foreach循环。
谢谢
我想要将任何给定的XML源转换为数据流任务,并将其数据传递到与XML文件表名匹配的OLE DB目标。使用可视化工具运行它意味着我无法进行动态数据流任务,因为元数据不会刷新。
我创建了一个脚本来创建一个包,但是当我在Visual Studio中打开该包时,它会显示红色的X,表示不能有零个输入列。当我深入挖掘并查看OLE DB目标的映射,然后单击确定 - 它会为我进行更正。我无法弄清楚如何以编程方式执行此操作。
我已经看到其他人通过使用foreach循环并遍历输入列来解决这个问题,但我似乎无法弄清楚其中的细节。
我还有一个单独的脚本,我试图模仿几个人的脚本,但它有不同的问题。不确定如何将其作为附件发布。
非常感谢您的帮助 :)
编辑
我一直在尝试BIML,并得到了积极的反馈,我会继续尝试...但是在短期内,我想知道是否有人可以帮助我弄清楚为什么这不会填充我的输入的ExternalMetaDataColumnId。我在下面发布了我的更新代码,其中包含未能按预期工作的foreach循环。
谢谢
namespace ConsoleApplication3
{
class Program
{
static void Main(string[] args)
{
#region Initial Setup
Application a = new Application();
Package p = new Package();
TaskHost t = p.Executables.Add("DTS.Pipeline") as TaskHost;
t.Name = "DataFlow Task";
t.Description = "Flat File to Database";
MainPipe mp = t.InnerObject as MainPipe;
#endregion
#region Flat File Source in Dataflow Task
IDTSComponentMetaData100 md = mp.ComponentMetaDataCollection.New();
md.ComponentClassID = "Microsoft.XmlSourceAdapter";
md.Name = "XML Source";
CManagedComponentWrapper wrp = md.Instantiate();
wrp.ProvideComponentProperties();
#endregion
#region Add connection manager to OLE DB
ConnectionManager conn = p.Connections.Add("OLEDB");
conn.Name = "westcoastuserDBO";
conn.ConnectionString = "Data Source=SERVER;Initial Catalog=DBO;Provider=SQLNCLI11.1;Integrated Security=SSPI;Auto Translate=False;";
#endregion
#region XML Source Properties
wrp.SetComponentProperty("XMLData", @"C:\Users\file.xml");
wrp.SetComponentProperty("XMLSchemaDefinition", @"C:\Users\file.xsd");
wrp.SetComponentProperty("AccessMode", 0);
wrp.SetComponentProperty("UseInlineSchema", false);
//below does not work
//wrp.SetComponentProperty("XMLIntegerMapping", 0).TypeConverter = "Microsoft.SqlServer.Dts.Pipeline.XmlSourceAdapter + XMLIntegerMappingConverter";
wrp.ReinitializeMetaData();
wrp.ReleaseConnections();
IDTSComponentMetaData100 md2 = mp.ComponentMetaDataCollection.New();
md2.ComponentClassID = "Microsoft.OLEDBDestination";
CManagedComponentWrapper wrp2 = md2.Instantiate();
wrp2.ProvideComponentProperties();
md2.Name = "OLE DB Connection";
md2.UsesDispositions = true;
md2.Version = 4;
wrp2.SetComponentProperty("OpenRowset", "dbo.authorizations");
#endregion
IDTSPath100 path = mp.PathCollection.New();
path.AttachPathAndPropagateNotifications(md.OutputCollection[0], md2.InputCollection[0]);
IDTSInput100 input = md2.InputCollection[0];
IDTSVirtualInput100 vInput = input.GetVirtualInput();
//below taken from https://dev59.com/TmjWa4cB1Zd3GeqPutqA
IDTSExternalMetadataColumnCollection100 externalColumnCollection = input.ExternalMetadataColumnCollection;
// Iterate through the virtual input column collection.
foreach (IDTSVirtualInputColumn100 vColumn in vInput.VirtualInputColumnCollection)
{
// Call the SetUsageType method of the destination
// to add each available virtual input column as an input column.
wrp2.SetUsageType(
input.ID, vInput, vColumn.LineageID, DTSUsageType.UT_READONLY);
}
// Get the destination's default output collection
IDTSOutputCollection100 outColl = md2.OutputCollection;
// Iterate through the outputs in default output collection
foreach (IDTSOutput100 output in outColl)
{
// Iterate through the default output columns in the output
int count = output.OutputColumnCollection.Count;
foreach (IDTSOutputColumn100 outputColumn in output.OutputColumnCollection)
{
// Get the output's external metadata column collection
IDTSExternalMetadataColumnCollection100 extMetadataColumnColl = output.ExternalMetadataColumnCollection;
// Iterate through the external metadata column collection's external metadata columns
foreach (IDTSExternalMetadataColumn100 extMetadataColumn in extMetadataColumnColl)
{
// Call the MapOutPutColumn method of the destination to map
// each available output column to an external metadata column
wrp2.MapOutputColumn(
output.ID, outputColumn.ID, extMetadataColumn.ID, true);
}
}
}
md2.RuntimeConnectionCollection[0].ConnectionManager = DtsConvert.GetExtendedInterface(conn);
md2.RuntimeConnectionCollection[0].ConnectionManagerID = conn.ID;
conn.AcquireConnection(null);
#region Save Package to FileSystem
string packageXml = @"C:\Users\test.dtsx";
XmlDocument myPkgDocument = new XmlDocument();
p.SaveToXML(ref myPkgDocument, null, null);
a.SaveToXml(packageXml, p, null);
#endregion
}
}
}