微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

在BIML中使用Oracle Source&Attunity

如何解决在BIML中使用Oracle Source&Attunity

我想使用biml将数据从oracle传输到sql

到目前为止,我已经能够创建一个(简单的)包来手动传输数据。该软件包包含一个sql_Destination-Connection(本机OLEDB),一个Oracle-Source Connection(Oracle连接管理器\ attunity),一个Oracle Source Task和一个OleDBDestination。

创建此程序包后,我尝试将该程序包转换为BIML,但只得到了“ CustomSsisConnection”(= Oracle Source-Connection)和“ Connection”(sql-Destination-Connection)。该软件包本身不包含在新的biml脚本中。

基于创建的连接,我尝试自行对代码包进行“编码”,并提出了以下代码

<Biml xmlns="http://schemas.varigence.com/biml.xsd">
    <Connections>
        <Connection Name="sql.DWH_NEW" ConnectionString="data source=SOMESERVER;initial catalog=DWH_NEW;provider=sqlNCLI11.1;integrated security=sspI;auto translate=False;" />
        <CustomSsisConnection Name="OracleSource" CreationName="ORACLE" ObjectData="&lt;DTS:ConnectionManager xmlns:DTS=&quot;www.microsoft.com/sqlServer/Dts&quot;&gt;&#xD;&#xA;  &lt;OraConnectionString&gt;SERVER=SomeOracleServer;USERNAME=myUser;WINAUTH=0;data source=SomeOracleServer;user id=myUser;&lt;/OraConnectionString&gt;&#xD;&#xA;  &lt;OraPassword Sensitive=&quot;1&quot;&gt;&lt;/OraPassword&gt;&#xD;&#xA;  &lt;OraRetain&gt;False&lt;/OraRetain&gt;&#xD;&#xA;  &lt;OraInitialCatalog&gt;&lt;/OraInitialCatalog&gt;&#xD;&#xA;  &lt;OraServerName&gt;SomeOracleServer&lt;/OraServerName&gt;&#xD;&#xA;  &lt;OraUserName&gt;ext-bi-pg&lt;/OraUserName&gt;&#xD;&#xA;  &lt;OraOracleHome&gt;&lt;/OraOracleHome&gt;&#xD;&#xA;  &lt;OraOracleHome64&gt;&lt;/OraOracleHome64&gt;&#xD;&#xA;  &lt;OraWinAuthentication&gt;False&lt;/OraWinAuthentication&gt;&#xD;&#xA;  &lt;OraEnableDetailedTracing&gt;False&lt;/OraEnableDetailedTracing&gt;&#xD;&#xA;&lt;/DTS:ConnectionManager&gt;" />
    </Connections>
    <Packages>
        <Package Name="Package2" Language="None" ConstraintMode="LinearOnCompletion" ProtectionLevel="EncryptSensitiveWithPassword">
            <Tasks>
                <Dataflow Name="Data Flow Task">
                    <Transformations>
                       <OracleSource Name="oracleSourceStmt" Connection="OracleSource" >
                           <DirectInput>"SELECT * FROM SoMetable"</DirectInput>
                       </OracleSource>
                        <OleDbDestination Name="OLE DB Destination" ConnectionName="sql.DWH_NEW">
                            <ExternalTableOutput Table="[dbo].[SoMetable]" />
                        </OleDbDestination>
                    </Transformations>
                </Dataflow>
            </Tasks>
        </Package>
    </Packages>
</Biml>

如果我检查错误,则会收到“无法解析对....属性“ Connection”中的引用。”无效。请提供有效的作用域名称

我也曾尝试使用“ OracelConnection”代替CustomSSISConnection,但是后来我确实收到了另一条错误消息:未检测到Oracle Client Access。安装与您的Biml / BimlStudio版本匹配的32位或64位版本的oracle客户端访问。

我确实读过Scott Currie的“在Biml中使用Attunity Oracle连接器”,但这没有帮助,因为现在应该可以使用attunity连接器的内置支持

  • 有人可以提供一个提示\可以弄清我的错误是什么吗?
  • 我应该(仍然)使用CustomSSISConnection还是 OracelConnection的正确选择?如果我应该使用 oracleConnection是否有任何提示
  • 有人吗 在biml中创建了一个oracle到sql ssis-package(成功;)?

这么多问题-希望有人能帮忙! :-)

关于, 格里高

解决方法

我发现仅使用BimlExpress时就可用于Oracle连接的格式是下面的格式,尽管散布着我个人开发的Biml框架中的嵌入式变量名,但应该可以使您朝正确的方向前进。

Oracle连接节点

如何设置Expressions节点以从“项目参数”中获取值,我一直发现将其用作保存重新部署以仅更改较小的配置值的选项非常有用:

    <CustomSsisConnection Name="<#=ConnectionName#>"
                          CreationName="MSORA"
                          ObjectData="&lt;OracleXMLPackage&gt;&lt;OraConnectionString&gt;<#=conn#>&lt;/OraConnectionString&gt;&lt;OraRetain&gt;False&lt;/OraRetain&gt;&lt;OraInitialCatalog&gt;&lt;/OraInitialCatalog&gt;&lt;OraServerName&gt;<#=ServerName#>&lt;/OraServerName&gt;&lt;OraUserName&gt;<#=Username#>&lt;/OraUserName&gt;&lt;OraOracleHome&gt;<#=Config.GetConfigValue(@"OracleHome")#>&lt;/OraOracleHome&gt;&lt;OraOracleHome64&gt;<#=Config.GetConfigValue(@"OracleHome")#>&lt;/OraOracleHome64&gt;&lt;OraWinAuthentication&gt;False&lt;/OraWinAuthentication&gt;&lt;OraEnableDetailedTracing&gt;False&lt;/OraEnableDetailedTracing&gt;&lt;OraPassword Sensitive=&quot;1&quot; Encrypted=&quot;0&quot;&gt;<#=Password#>&lt;/OraPassword&gt;&lt;/OracleXMLPackage&gt;"
                          CreateInProject="true"
                          >
        <Expressions>
            <Expression ExternalProperty="ConnectionString"
                        >@[$Project::<#=ConnectionName#>_Conn]</Expression>
            <Expression ExternalProperty="OracleHome"
                        >@[$Project::OracleHome]</Expression>
            <Expression ExternalProperty="OracleHome64"
                        >@[$Project::OracleHome64]</Expression>
        </Expressions>
    </CustomSsisConnection>

Oracle数据源节点

请注意,这是一个自定义组件,它将输出Attunity Oracle Source。因此,您必须在计算机上使用此功能。再次,那里的框架有一些遗物,但是它们应该可以帮助您了解发生了什么。如果您不像我一样以编程方式进行此操作,那么麻烦就在于添加所有列及其数据类型:

    <CustomComponent Name="<#=SourceTechType#>Src - Retrieve Rows - <#=FromSchema#> <#=FromTable#>"
                     LocaleId="None"
                     Version="4"
                     UsesDispositions="true"
                     ComponentClassId="{CB67CD40-126C-4280-912D-2A625DFAFB66}"
                     ComponentTypeName="CB67CD40-126C-4280-912D-2A625DFAFB66"
                     ContactInfo="Oracle Source;Microsoft Connector for Oracle by Attunity; Attunity Ltd.; All Rights Reserved; http://www.attunity.com;4"
                     >
        <Annotations>
            <Annotation AnnotationType="Description">Microsoft Oracle Source Component by Attunity</Annotation>
        </Annotations>
        <CustomProperties>
            <CustomProperty Name="BatchSize" DataType="Int32" SupportsExpression="true" Description="The number of rows fetched in a batch.">100000</CustomProperty>
            <CustomProperty Name="PrefetchCount" DataType="Int32" SupportsExpression="true" Description="Number of pre-fetched rows.">0</CustomProperty>
            <CustomProperty Name="LobChunkSize" DataType="Int32" SupportsExpression="true" Description="Determines the chunk size allocation for LOB columns">32768</CustomProperty>
            <CustomProperty Name="DefaultCodePage" DataType="Int32" SupportsExpression="true" Description="The code page to use when code page information is unavailable from the data source.">1252</CustomProperty>
            <CustomProperty Name="AccessMode" DataType="Int32" TypeConverter="AccessMode" Description="The mode used to access the database.">1</CustomProperty>
            <CustomProperty Name="TableName" DataType="String" SupportsExpression="true" Description="The name of the table to be fetched."></CustomProperty>
            <CustomProperty Name="SqlCommand" DataType="String" SupportsExpression="true" Description="The SQL command to be executed.">
select cols
from tables
where conditions = met
            </CustomProperty>
        </CustomProperties>
        <Connections>
            <Connection Name="MSOraConnection"
                        ConnectionName="<#=SourceConnectionName#>"
                        />
        </Connections>
        <OutputPaths>
            <OutputPath Name="Output"
                        ErrorRowDisposition="FailComponent"
                        TruncationRowDisposition="FailComponent"
                        IsErrorOutput="false"
                        >
                <OutputColumns>
                <#  foreach (var column in table.Columns) { #>
                        <OutputColumn Name="<#=column.Name#>"
                                      ExternalMetadataColumnName="<#=column.Name#>"
                                      DataType="<# if(column.GetTag("ConvertFrom").Length > 0) { #><#=column.GetTag("ConvertFrom")#><# } else { #><#=column.DataType#><# } #>"
                                      <# if(column.DataType.ToString() == "String"){ #>CodePage="1252"<# } #>
                                      Length="<#=column.Length#>"
                                      Precision="<#=column.Precision#>"
                                      Scale="<#=column.Scale#>"
                                      />
                <#  } #>
                </OutputColumns>
                
                <ExternalColumns>
                <#  foreach (var column in table.Columns) { #>
                    <ExternalColumn Name="<#=column.Name#>"
                                    DataType="<# if(column.GetTag("ConvertFrom").Length > 0) { #><#=column.GetTag("ConvertFrom")#><# } else { #><#=column.DataType#><# } #>"
                                    <# if(column.DataType.ToString() == "String"){ #>CodePage="1252"<# } #>
                                    Length="<#=column.Length#>"
                                    Precision="<#=column.Precision#>"
                                    Scale="<#=column.Scale#>"
                                    />
                <#  } #>
                </ExternalColumns>
            </OutputPath>
            
            <OutputPath Name="Error"
                        IsErrorOutput="true">
                <OutputColumns>
                <#  foreach (var column in table.Columns) { #>
                    <OutputColumn Name="<#=column.Name#>"
                                  DataType="<# if(column.GetTag("ConvertFrom").Length > 0) { #><#=column.GetTag("ConvertFrom")#><# } else { #><#=column.DataType#><# } #>"
                                  <# if(column.DataType.ToString() == "String"){ #>CodePage="1252"<# } #>
                                  Length="<#=column.Length#>"
                                  Precision="<#=column.Precision#>"
                                  Scale="<#=column.Scale#>"
                                  />
                <#  } #>
                </OutputColumns>
            </OutputPath>
        </OutputPaths>
    </CustomComponent>

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。