草庐IT

sql - 使用 pl sql 将 xml 文件解析为 2 个 oracle header-detail 表

coder 2024-07-02 原文

我正在尝试通过 pl sql 解析 xml 文件。有一个标题部分 (GrpHdr),其中包含一个应该插入到特定表中的 Id 元素及其详细信息 (Ntfctn),其元素将被插入到另一个表中,外键是第一个表的 ID。该文件如下:

<?xml version="1.0" encoding="utf-8" standalone="no"?>
<DMCTfh:DIASMCTFH xmlns:DMCTfh="urn:DMCTfh:xsd:$DIASMCTFH">
  <DMCTfh:DIASFileHdr>
    <DMCTfh:SndgInst>DIASGRA1</DMCTfh:SndgInst>
    <DMCTfh:RcvgInst>90874</DMCTfh:RcvgInst>
    <DMCTfh:FileRef>0252013352000001</DMCTfh:FileRef>
    <DMCTfh:SrvcID>DCT</DMCTfh:SrvcID>
    <DMCTfh:TstCode>T</DMCTfh:TstCode>
    <DMCTfh:FType>XCT</DMCTfh:FType>
    <DMCTfh:NumGrp>1</DMCTfh:NumGrp>
  </DMCTfh:DIASFileHdr>
  <DMCTfh:BkToCstmrDbtCdtNtfctn xmlns="urn:iso:std:iso:20022:tech:xsd:camt.054.001.03">
    <GrpHdr>
      <MsgId>024201335200000000000132</MsgId>
      <CreDtTm>2013-05-24T09:35:10</CreDtTm>
      <MsgRcpt>
        <Id>
          <OrgId>
            <Othr>
              <Id>90874</Id>
              <Issr>DIAS</Issr>
            </Othr>
          </OrgId>
        </Id>
      </MsgRcpt>
    </GrpHdr>
    <Ntfctn>
      <Id>024201335200000000000129</Id>
      <CreDtTm>2013-05-24T09:35:10</CreDtTm>
      <Acct>
        <Id>
          <IBAN>GR6302602320000590200493673</IBAN>
        </Id>
        <Svcr>
          <FinInstnId>
            <BICFI>ERBKGRAA</BICFI>
          </FinInstnId>
        </Svcr>
      </Acct>
      <TxsSummry>
        <TtlNtries>
          <NbOfNtries>1</NbOfNtries>
        </TtlNtries>
      </TxsSummry>
      <Ntry>
        <Amt Ccy="EUR">100.00</Amt>
        <CdtDbtInd>CRDT</CdtDbtInd>
        <Sts>BOOK</Sts>
        <ValDt>
          <Dt>2013-05-24</Dt>
        </ValDt>
        <BkTxCd>
          <Domn>
            <Cd>PMNT</Cd>
            <Fmly>
              <Cd>CNTR</Cd>
              <SubFmlyCd>CDPT</SubFmlyCd>
            </Fmly>
          </Domn>
        </BkTxCd>
        <NtryDtls>
          <Btch>
            <NbOfTxs>1</NbOfTxs>
            <TtlAmt Ccy="EUR">100.00</TtlAmt>
          </Btch>
          <TxDtls>
            <Refs>
              <InstrId>01913351000006</InstrId>
              <EndToEndId>NOTPROVIDED</EndToEndId>
              <TxId>CRED-874-0208-2</TxId>
            </Refs>
            <Amt Ccy="EUR">100.00</Amt>
            <CdtDbtInd>CRDT</CdtDbtInd>
            <RltdPties>
              <Dbtr>
                <Nm>Debtor-NAME-301-01-1</Nm>
              </Dbtr>
            </RltdPties>
            <RltdAgts>
              <DbtrAgt>
                <FinInstnId>
                  <BICFI>ETHNGRAA</BICFI>
                </FinInstnId>
              </DbtrAgt>
            </RltdAgts>
            <RmtInf>
              <Ustrd>00000042280000087428</Ustrd>
            </RmtInf>
            <RltdDts>
              <AccptncDtTm>2013-05-24T00:00:00</AccptncDtTm>
            </RltdDts>
          </TxDtls>
        </NtryDtls>
      </Ntry>
    </Ntfctn>
    <Ntfctn>
      <Id>024201335200000000000130</Id>
      <CreDtTm>2013-05-24T09:35:10</CreDtTm>
      <Acct>
        <Id>
          <IBAN>GR7301723510005351020742556</IBAN>
        </Id>
        <Svcr>
          <FinInstnId>
            <BICFI>PIRBGRAA</BICFI>
          </FinInstnId>
        </Svcr>
      </Acct>
      <TxsSummry>
        <TtlNtries>
          <NbOfNtries>1</NbOfNtries>
        </TtlNtries>
      </TxsSummry>
      <Ntry>
        <Amt Ccy="EUR">100.00</Amt>
        <CdtDbtInd>CRDT</CdtDbtInd>
        <Sts>BOOK</Sts>
        <ValDt>
          <Dt>2013-05-24</Dt>
        </ValDt>
        <BkTxCd>
          <Domn>
            <Cd>PMNT</Cd>
            <Fmly>
              <Cd>RCDT</Cd>
              <SubFmlyCd>ESCT</SubFmlyCd>
            </Fmly>
          </Domn>
        </BkTxCd>
        <NtryDtls>
          <Btch>
            <NbOfTxs>1</NbOfTxs>
            <TtlAmt Ccy="EUR">100.00</TtlAmt>
          </Btch>
          <TxDtls>
            <Refs>
              <InstrId>01913351000003</InstrId>
              <EndToEndId>NOTPROVIDED</EndToEndId>
              <TxId>DD087401305240001</TxId>
            </Refs>
            <Amt Ccy="EUR">100.00</Amt>
            <CdtDbtInd>CRDT</CdtDbtInd>
            <RltdPties>
              <Dbtr>
                <Nm>ΔΕΛΗΑΝΤΩΝΗ ΜΑΡΙΑ</Nm>
              </Dbtr>
            </RltdPties>
            <RltdAgts>
              <DbtrAgt>
                <FinInstnId>
                  <BICFI>GPSBGRAA</BICFI>
                </FinInstnId>
              </DbtrAgt>
            </RltdAgts>
            <RmtInf>
              <Ustrd>00000047780000087424</Ustrd>
            </RmtInf>
            <RltdDts>
              <AccptncDtTm>2013-05-24T00:00:00</AccptncDtTm>
            </RltdDts>
          </TxDtls>
        </NtryDtls>
      </Ntry>
    </Ntfctn>
    <Ntfctn>
      <Id>024201335200000000000131</Id>
      <CreDtTm>2013-05-24T09:35:10</CreDtTm>
      <Acct>
        <Id>
          <IBAN>GR9801100400000004050700154</IBAN>
        </Id>
        <Svcr>
          <FinInstnId>
            <BICFI>ETHNGRAA</BICFI>
          </FinInstnId>
        </Svcr>
      </Acct>
      <TxsSummry>
        <TtlNtries>
          <NbOfNtries>1</NbOfNtries>
        </TtlNtries>
      </TxsSummry>
      <Ntry>
        <Amt Ccy="EUR">600.00</Amt>
        <CdtDbtInd>CRDT</CdtDbtInd>
        <Sts>BOOK</Sts>
        <ValDt>
          <Dt>2013-05-24</Dt>
        </ValDt>
        <BkTxCd>
          <Domn>
            <Cd>PMNT</Cd>
            <Fmly>
              <Cd>CNTR</Cd>
              <SubFmlyCd>CDPT</SubFmlyCd>
            </Fmly>
          </Domn>
        </BkTxCd>
        <NtryDtls>
          <Btch>
            <NbOfTxs>2</NbOfTxs>
            <TtlAmt Ccy="EUR">600.00</TtlAmt>
          </Btch>
          <TxDtls>
            <Refs>
              <InstrId>01913351000001</InstrId>
              <EndToEndId>NOTPROVIDED</EndToEndId>
              <TxId>CRED-874-0208-1</TxId>
            </Refs>
            <Amt Ccy="EUR">100.00</Amt>
            <CdtDbtInd>CRDT</CdtDbtInd>
            <RltdPties>
              <Dbtr>
                <Nm>Debtor-NAME-301-01-1</Nm>
              </Dbtr>
            </RltdPties>
            <RltdAgts>
              <DbtrAgt>
                <FinInstnId>
                  <BICFI>CRBAGRAA</BICFI>
                </FinInstnId>
              </DbtrAgt>
            </RltdAgts>
            <RmtInf>
              <Ustrd>00000042270000087428</Ustrd>
            </RmtInf>
            <RltdDts>
              <AccptncDtTm>2013-05-24T00:00:00</AccptncDtTm>
            </RltdDts>
          </TxDtls>
          <TxDtls>
            <Refs>
              <InstrId>01913352000001</InstrId>
              <EndToEndId>3121990500874553</EndToEndId>
              <TxId>61229720000000291396</TxId>
            </Refs>
            <Amt Ccy="EUR">500.00</Amt>
            <CdtDbtInd>CRDT</CdtDbtInd>
            <RltdPties>
              <Dbtr>
                <Nm>ΠΑΠΑΙΟΡΔΑΝΟΥ ΠΑΥΛΟΣ</Nm>
              </Dbtr>
            </RltdPties>
            <RltdAgts>
              <DbtrAgt>
                <FinInstnId>
                  <BICFI>CITIGRAA</BICFI>
                </FinInstnId>
              </DbtrAgt>
            </RltdAgts>
            <RmtInf>
              <Ustrd>00000042270000087428</Ustrd>
            </RmtInf>
            <RltdDts>
              <AccptncDtTm>2013-05-22T00:00:00</AccptncDtTm>
            </RltdDts>
          </TxDtls>
        </NtryDtls>
      </Ntry>
    </Ntfctn>
  </DMCTfh:BkToCstmrDbtCdtNtfctn>
</DMCTfh:DIASMCTFH>

我是新手,它是一个精心设计的文件,所以我不确定该怎么做,尽管我浏览了一些看起来与我自己相似的帖子。任何帮助将不胜感激。

到目前为止我得到了这个:

DECLARE
  xmlClob CLOB;
  xmlFile BFILE;
  x XMLType;

  src_offset number := 1 ;
  dest_offset number := 1 ;
  lang_ctx number := DBMS_LOB.DEFAULT_LANG_CTX;
  warning integer;
BEGIN
  xmlFile := BFILENAME('Parse_XML', 'DCT9087413052401.XOO');
  DBMS_LOB.CREATETEMPORARY(xmlClob, true);
  DBMS_LOB.FILEOPEN(xmlFile, DBMS_LOB.FILE_READONLY);
  DBMS_LOB.LOADCLOBFROMFILE(xmlClob, xmlFile, DBMS_LOB.LOBMAXSIZE, src_offset,
    dest_offset, DBMS_LOB.DEFAULT_CSID, lang_ctx, warning);
  x := XMLType.createXML(xmlClob);
  DBMS_LOB.FILECLOSEALL();
  DBMS_LOB.FREETEMPORARY(xmlClob);

  FOR r IN (
   SELECT ExtractValue(Value(p),'/Ntfctn/Id/text()') as Ident
          ,ExtractValue(Value(p),'/Ntfctn/CreDtTm/text()') as Creation_Dt
          ,ExtractValue(Value(p),'/Ntfctn/Acct/Id/IBAN/text()') as IBAN
          ,ExtractValue(Value(p),'/Ntfctn/Acct/Svcr/FinInstnId/BICFI/text()') as BIC
          ,ExtractValue(Value(p),'/Ntfctn/TxsSummry/TtlNtries/NbOfNtries/text()') as Entries_No
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/Amt/text()') as Entry_Amnt
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/CdtDbtInd/text()') as Entry_Ind
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/Sts/text()') as Entry_Status
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/Sts/ValDt/Dt/text()') as Val_Dt
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/BkTxCd/Domn/Cd/text()') as Cd
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/BkTxCd/Domn/Fmly/Cd/text()') as Fmly_Cd
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/BkTxCd/Domn/Fmly/SubFmlyCd/text()') as Subfmly_Cd
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/NtryDtls/Btch/NbOfTxs/text()') as Trx_Cnt
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/NtryDtls/Btch/TtlAmt/text()') as Ttl_Amnt
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/NtryDtls/TxDtls/Refs/InstrId/text()') as Instr_Id
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/NtryDtls/TxDtls/Refs/EndToEndId/text()') as End_Id
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/NtryDtls/TxDtls/Refs/TxId/text()') as Trx_Id
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/NtryDtls/TxDtls/Amt/text()') as Dtls_Amnt
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/NtryDtls/TxDtls/CdtDbtInd/text()') as Dtls_Ind
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/NtryDtls/TxDtls/RltdPties/Dbtr/Nm/text()') as Dbtor_Name
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/NtryDtls/TxDtls/RltdAgts/DbtrAgt/FinInstnId/BICFI/text()') as Inst_BIC
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/NtryDtls/TxDtls/RmtInf/Ustrd/text()') as Ustrd
          ,ExtractValue(Value(p),'/Ntfctn/Ntry/NtryDtls/TxDtls/RltdDts/AccptncDtTm/text()') as Accept_Dt
    FROM   TABLE(XMLSequence(Extract(x,'/Ntfctn'))) p
   WHERE ExtractValue(Value(p),'/Ntfctn/text()') = 'CUZK'
   ) LOOP
          INSERT INTO DIAS_INCOMING_DT (FK_FILE_ID, ID_ORDER, DIAS_IDENTITY, BANK_IDENTITY, ORDER_IDENTITY, AMOUNT, CURRENCY, DEBITOR_NAME, BIC_DB_BANK,
                                   BIC_IDENTITY, REMITTANCE_INFO, BANK_ACCEPT_DATE, MESSAGE_IDENTITY, MESSAGE_DATE, TRX_DATE, COMMENTS, ACCOUNT_NUMBER,
                                     MOVEMENT_ID, PRS_STATUS, PRS_TMSTAMP, PRS_ERROR, FK_FILE_ID)
                            VALUES (1, trim(r.End_Id), trim(r.Ident), trim(r.IBAN), trim(r.Ustrd), to_number(r.Entry_Amnt), 'EUR', trim(r.Dbtor_Name), '1',
                                      '1', '1', to_date(trim(r.Accept_Dt), 'YYYYMMDDHH24MISS'), trim(r.Trx_Id), to_date(trim(r.Val_Dt), 'YYYYMMDDHH24MISS'),
                                      to_date(trim(r.Val_Dt), 'YYYYMMDDHH24MISS'), '1', 1, 1, 1, to_date(trim(r.Creation_Dt), 'YYYYMMDDHH24MISS'), 'no_error', '1');
                      commit;
   END LOOP;
 END;

最佳答案

您可以使用 XMLTABLE 函数从 XML 中提取行。作为测试,我创建了一个名为“text”的表,其中有一列名为“xmldata”。

然后,您可以像这样从 XML 文档中查询数据:

select header.id, data.*
from test, xmltable(-- GrpHdr as table
        xmlnamespaces(default 'urn:iso:std:iso:20022:tech:xsd:camt.054.001.03', 'urn:DMCTfh:xsd:$DIASMCTFH' as "DMCTfh" ),
        '/DMCTfh:DIASMCTFH/DMCTfh:BkToCstmrDbtCdtNtfctn/GrpHdr' 
        passing test.xmldata
        columns id varchar2(50) path 'MsgRcpt/Id/OrgId/Othr/Id'
    ) as header, 
    xmltable(-- Ntfctn as table
        xmlnamespaces(default 'urn:iso:std:iso:20022:tech:xsd:camt.054.001.03', 'urn:DMCTfh:xsd:$DIASMCTFH' as "DMCTfh" ),
        '/DMCTfh:DIASMCTFH/DMCTfh:BkToCstmrDbtCdtNtfctn/Ntfctn' 
        passing test.xmldata
        columns iban varchar2(50) path 'Acct/Id/IBAN',
            dt varchar2(50) path 'Ntry/ValDt/Dt' -- and so on
    ) as data;

关于sql - 使用 pl sql 将 xml 文件解析为 2 个 oracle header-detail 表,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31940312/

有关sql - 使用 pl sql 将 xml 文件解析为 2 个 oracle header-detail 表的更多相关文章

  1. ruby - 如何使用 Nokogiri 的 xpath 和 at_xpath 方法 - 2

    我正在学习如何使用Nokogiri,根据这段代码我遇到了一些问题:require'rubygems'require'mechanize'post_agent=WWW::Mechanize.newpost_page=post_agent.get('http://www.vbulletin.org/forum/showthread.php?t=230708')puts"\nabsolutepathwithtbodygivesnil"putspost_page.parser.xpath('/html/body/div/div/div/div/div/table/tbody/tr/td/div

  2. Ruby 解析字符串 - 2

    我有一个字符串input="maybe(thisis|thatwas)some((nice|ugly)(day|night)|(strange(weather|time)))"Ruby中解析该字符串的最佳方法是什么?我的意思是脚本应该能够像这样构建句子:maybethisissomeuglynightmaybethatwassomenicenightmaybethiswassomestrangetime等等,你明白了......我应该一个字符一个字符地读取字符串并构建一个带有堆栈的状态机来存储括号值以供以后计算,还是有更好的方法?也许为此目的准备了一个开箱即用的库?

  3. ruby - 使用 RubyZip 生成 ZIP 文件时设置压缩级别 - 2

    我有一个Ruby程序,它使用rubyzip压缩XML文件的目录树。gem。我的问题是文件开始变得很重,我想提高压缩级别,因为压缩时间不是问题。我在rubyzipdocumentation中找不到一种为创建的ZIP文件指定压缩级别的方法。有人知道如何更改此设置吗?是否有另一个允许指定压缩级别的Ruby库? 最佳答案 这是我通过查看ruby​​zip内部创建的代码。level=Zlib::BEST_COMPRESSIONZip::ZipOutputStream.open(zip_file)do|zip|Dir.glob("**/*")d

  4. ruby - 为什么我可以在 Ruby 中使用 Object#send 访问私有(private)/ protected 方法? - 2

    类classAprivatedeffooputs:fooendpublicdefbarputs:barendprivatedefzimputs:zimendprotecteddefdibputs:dibendendA的实例a=A.new测试a.foorescueputs:faila.barrescueputs:faila.zimrescueputs:faila.dibrescueputs:faila.gazrescueputs:fail测试输出failbarfailfailfail.发送测试[:foo,:bar,:zim,:dib,:gaz].each{|m|a.send(m)resc

  5. ruby-on-rails - 使用 Ruby on Rails 进行自动化测试 - 最佳实践 - 2

    很好奇,就使用ruby​​onrails自动化单元测试而言,你们正在做什么?您是否创建了一个脚本来在cron中运行rake作业并将结果邮寄给您?git中的预提交Hook?只是手动调用?我完全理解测试,但想知道在错误发生之前捕获错误的最佳实践是什么。让我们理所当然地认为测试本身是完美无缺的,并且可以正常工作。下一步是什么以确保他们在正确的时间将可能有害的结果传达给您? 最佳答案 不确定您到底想听什么,但是有几个级别的自动代码库控制:在处理某项功能时,您可以使用类似autotest的内容获得关于哪些有效,哪些无效的即时反馈。要确保您的提

  6. ruby - 在 Ruby 中使用匿名模块 - 2

    假设我做了一个模块如下:m=Module.newdoclassCendend三个问题:除了对m的引用之外,还有什么方法可以访问C和m中的其他内容?我可以在创建匿名模块后为其命名吗(就像我输入“module...”一样)?如何在使用完匿名模块后将其删除,使其定义的常量不再存在? 最佳答案 三个答案:是的,使用ObjectSpace.此代码使c引用你的类(class)C不引用m:c=nilObjectSpace.each_object{|obj|c=objif(Class===objandobj.name=~/::C$/)}当然这取决于

  7. ruby - 其他文件中的 Rake 任务 - 2

    我试图在一个项目中使用rake,如果我把所有东西都放到Rakefile中,它会很大并且很难读取/找到东西,所以我试着将每个命名空间放在lib/rake中它自己的文件中,我添加了这个到我的rake文件的顶部:Dir['#{File.dirname(__FILE__)}/lib/rake/*.rake'].map{|f|requiref}它加载文件没问题,但没有任务。我现在只有一个.rake文件作为测试,名为“servers.rake”,它看起来像这样:namespace:serverdotask:testdoputs"test"endend所以当我运行rakeserver:testid时

  8. ruby-on-rails - 在 Rails 中将文件大小字符串转换为等效千字节 - 2

    我的目标是转换表单输入,例如“100兆字节”或“1GB”,并将其转换为我可以存储在数据库中的文件大小(以千字节为单位)。目前,我有这个:defquota_convert@regex=/([0-9]+)(.*)s/@sizes=%w{kilobytemegabytegigabyte}m=self.quota.match(@regex)if@sizes.include?m[2]eval("self.quota=#{m[1]}.#{m[2]}")endend这有效,但前提是输入是倍数(“gigabytes”,而不是“gigabyte”)并且由于使用了eval看起来疯狂不安全。所以,功能正常,

  9. ruby - 使用 ruby​​ 和 savon 的 SOAP 服务 - 2

    我正在尝试使用ruby​​和Savon来使用网络服务。测试服务为http://www.webservicex.net/WS/WSDetails.aspx?WSID=9&CATID=2require'rubygems'require'savon'client=Savon::Client.new"http://www.webservicex.net/stockquote.asmx?WSDL"client.get_quotedo|soap|soap.body={:symbol=>"AAPL"}end返回SOAP异常。检查soap信封,在我看来soap请求没有正确的命名空间。任何人都可以建议我

  10. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声? - 2

    关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题?更新问题,以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点?我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等),但我确实想创建一个输出文件。

随机推荐