如何从Data Hub Framework中的Collector.xqy执行任何更新语句？

Question

我有一个完整的逻辑，我需要修改或删除STAGING和FINAL数据库中的文档，最后我需要将过滤后的数据插入到DataHub Framework中的FINAL数据库中。

我在collector.xqy中标记了我的代码，但它说Cannot apply an update function from a query

代码如下─

let $a := 
  for $i in cts:search(doc(),cts:collection-query(("ABC")))
  return 
    let $uri := fn:base-uri($i)
    let $a := $i/*:envelope/*:a/text()
    let $b := $i/*:envelope/*:b/text()

    let $c := if(($a eq "123") or ($b eq "345")) then base-uri($i) else ()

    let $condition := 
      for $j in $c
      let $id1 := $j/*:envelope/*:id1/text()
      let $id2 := $j/*:envelope/*:id2/text()

      let $node1 := $j/*:envelope/*:NODE1
      let $node2 := $j/*:envelope/*:NODE2
      let $result :=
        xdmp:invoke-function(
          function() { 
            cts:search(doc(),
              cts:and-query((
                cts:or-query((
                  cts:element-value-query(xs:QName("id1"),$id1),
                  cts:element-value-query(xs:QName("id2"),$id2)
                )),
                cts:collection-query(("ABC"))
              ))
            )
          },
          <options xmlns="xdmp:eval">
            <database>{xdmp:database("FINAL")}</database>
          </options>)
        return 
          if(fn:exists($result) eq fn:true()) then 
            () 
          else (
            xdmp:node-replace($node1,<NODE1>Replacing Node 1</NODE1>),
            xdmp:node-replace($node2,<NODE2>Replacing Node 2</NODE2>)
          )

    return $uri
return ()

此代码不能从collector.xqy工作，因为它具有update语句。我不能在writer.xqy中写这个，因为初始条件，即let $c := if(($a eq "123") or ($b eq "345")) then base-uri($i) else ()我需要从STAGING数据库检查。

有什么建议 ？

Answer 1

您可以通过针对该数据库调用它来从编写器对STAGING数据库运行检查：

let $c := 
  xdmp:invoke-function(
    function() {
      if(($a eq "123") or ($b eq "345")) then base-uri($i) else ()
    },
    map:entry("database", $config:STAGING-DATABASE)
  )

假设您已经导入了config library module。