nosql - MarkLogic:在单个事务中提交多个语句

标签 nosql xquery marklogic marklogic-8

我想对文档进行版本控制,为此我们遵循以下方法在单个事务中 checkout 和 checkin 文档。

(:--------------------------- XQuery Starts ---------------------------:)
xquery version "1.0-ml";
declare namespace html = "http://www.w3.org/1999/xhtml";
import module namespace dls = "http://marklogic.com/xdmp/dls" at "/MarkLogic/dls.xqy";

declare function local:ManageDocument($docUri)
{
    let $query := fn:concat('
      xquery version "1.0-ml";
      declare namespace html = "http://www.w3.org/1999/xhtml";
      import module namespace dls = "http://marklogic.com/xdmp/dls" at "/MarkLogic/dls.xqy";
      declare variable $docUri as xs:string external;
      dls:document-manage($docUri,fn:false(),fn:concat("First Version of ", $docUri))'
    )

    return xdmp:eval(
      $query,
      (xs:QName("docUri"), $docUri),
      <options xmlns="xdmp:eval">
        <prevent-deadlocks>true</prevent-deadlocks>
      </options>
    )
};

let $docUri := "/searchable/as-2018-1981_standard.pdf.xml"
let $isManaged  := dls:document-is-managed($docUri)
let $manageDoc := if($isManaged) then() else local:ManageDocument($docUri)

let $chechoutStatus := dls:document-checkout-status($docUri)
let $checkOut   := if($chechoutStatus and $isManaged) then (fn:error(xs:QName('Error'), "Already Editing")) else dls:document-checkout-update-checkin($docUri, element {"ROOT"} {"HELLO WORLD!"}, "document-checkout-update-checkin", fn:true())

return $manageDoc
(:--------------------------- XQuery Ends ---------------------------:)

但是,它抛出以下异常:

[1.0-ml] XDMP-PREVENTDEADLOCKS: xdmp:eval("&#10; xquery version &quot;1.0-
ml&quot;;&#10; declare ...", (fn:QName("","docUri"), "/searchable
/as-2018-1981_standard.pdf.xml"), <options xmlns="xdmp:eval"><prevent-
deadlocks>true</prevent-deadlocks></options>) -- Processing an update from an
update with different-transaction isolation could deadlock

为了克服这个问题,我修改了 XQuery 来解决我们的目的:

(:--------------------------- New XQuery Starts ---------------------------:)
xquery version "1.0-ml";
declare namespace html = "http://www.w3.org/1999/xhtml";
import module namespace dls = "http://marklogic.com/xdmp/dls" at "/MarkLogic/dls.xqy";

declare function local:ManageDocument($docUri)
{
    let $query := fn:concat('
      xquery version "1.0-ml";
      declare namespace html = "http://www.w3.org/1999/xhtml";
      import module namespace dls = "http://marklogic.com/xdmp/dls" at "/MarkLogic/dls.xqy";
      declare variable $docUri as xs:string external;
      dls:document-manage($docUri,fn:false(),fn:concat("First Version of ", $docUri))'
    )

    return xdmp:eval(
      $query,
      (xs:QName("docUri"), $docUri),
      <options xmlns="xdmp:eval">
        <prevent-deadlocks>true</prevent-deadlocks>
      </options>
    )
};

declare function local:CheckouotDocument($docUri)
{
  let $query := fn:concat('
    xquery version "1.0-ml";
    declare namespace html = "http://www.w3.org/1999/xhtml";
    import module namespace dls = "http://marklogic.com/xdmp/dls" at "/MarkLogic/dls.xqy";
    declare variable $docUri as xs:string external;
    (: dls:document-checkout($docUri, fn:true(), "updating doc", 3600) :)
    dls:document-checkout-update-checkin($docUri, element {"ROOT"} {"HELLO WORLD!"}, "document-checkout-update-checkin", fn:true())
   ')

   return xdmp:eval(
      $query,
      (xs:QName("docUri"), $docUri),
      <options xmlns="xdmp:eval">
        <prevent-deadlocks>true</prevent-deadlocks>
      </options>
    )
};

let $docUri := "/searchable/as-2018-1981_standard.pdf.xml"
let $isManaged  := dls:document-is-managed($docUri)
let $manageDoc := if($isManaged) then() else local:ManageDocument($docUri)

let $chechoutStatus := dls:document-checkout-status($docUri)
let $checkOut   := if($chechoutStatus and $isManaged) then (fn:error(xs:QName('Error'), "Already Editing")) else local:CheckouotDocument($docUri)

return $manageDoc
(:--------------------------- New XQuery Ends ---------------------------:)

上面的 XQuery 正在按预期工作,但是,如果有人能帮助我以更高效和简化的方式解决我的目的,那就太好了。

最佳答案

您可以使用 xdmp:invoke-function() 稍微简化您的代码而不是为 xdmp:eval() 构造字符串,并通过声明变量避免重复选项:

xquery version "1.0-ml";
declare namespace html = "http://www.w3.org/1999/xhtml";
import module namespace dls = "http://marklogic.com/xdmp/dls" at "/MarkLogic/dls.xqy";

declare variable $OPTIONS := 
  <options xmlns="xdmp:eval">
    <prevent-deadlocks>true</prevent-deadlocks>
  </options>;

declare function local:ManageDocument($docUri)
{
  xdmp:invoke-function(function() {
    dls:document-manage($docUri, fn:false(), "First Version of "||$docUri)
  }, $OPTIONS)
};

declare function local:CheckouotDocument($docUri)
{
  xdmp:invoke-function(function() {
    (: dls:document-checkout($docUri, fn:true(), "updating doc", 3600) :)
    dls:document-checkout-update-checkin($docUri, element {"ROOT"} {"HELLO WORLD!"}, "document-checkout-update-checkin", fn:true())
  }, $OPTIONS)
};

let $docUri := "/searchable/as-2018-1981_standard.pdf.xml"
let $isManaged  := dls:document-is-managed($docUri)
let $manageDoc := if ($isManaged) then() else local:ManageDocument($docUri)

let $chechoutStatus := dls:document-checkout-status($docUri)
let $checkOut   := if ($chechoutStatus and $isManaged) then (fn:error(xs:QName('Error'), "Already Editing")) else local:CheckouotDocument($docUri)

return $manageDoc

关于nosql - MarkLogic:在单个事务中提交多个语句,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49194438/

相关文章:

javascript - 处理 meteor 集合中可变的键值对(无模式困境)

xquery - Marklogic 6如何使用xquery获取属性值?

java - 应用这个词是否适合使用 Redis?

nosql - 嵌套集合中的 Cosmos Db DateTime 查询

java - 当所有消息都被过滤后停止路由

sql - 在 XMLTYPE 列中插入子节点

xml - 如何将祖先元素下的所有后代文本节点作为单个字符串检索?

xml - 如何在 Marklogic 中为 Element 声明命名空间?

java - 使用 java api 对文档元数据执行范围搜索

mongodb - 用于时间序列/记录仪器读取数据的 NoSQL,该数据也是版本化的