XQSync

• INPUT_DOCUMENT_URIS
• INPUT_COLLECTION_URI
• INPUT_DIRECTORY_URI
• INPUT_QUERY

If this property and INPUT_CONNECTION_STRING are both set, the named module will be used to process each document as it is read from the input database. The module must define a module variable $URI as xs:string external. The module must return a document-node.

Here is a simple example module, which recursively transforms the input document to lower-case all element names. Note that the first call to local:lc() will always receive a document-node (unless the document $URI does not exist), and so the entire module will always return a document-node.

xquery version "1.0-ml" ;

declare variable $URI as xs:string external ;

declare function local:lc($list as node()*)
 as node()*
{
  for $n in $list
  return typeswitch($n)
  case document-node() return document {
    local:lc($n/node()) }
  case element() return element { node-name($n) } {
    $n/@*,
    local:lc($n/node())
  }
  default return $n
} ;

local:lc(doc($URI))
      

In combination with INPUT_CONNECTION_STRING, all uris returned by the query will be transferred. This sample query would transfer the first 100 documents, in document order:
for $i in doc()[1 to 100] return xdmp:node-uri($i)
If the document URI lexicon is enabled, this could be written as:
cts:uris('', 'document')[1 to 100]
to transfer the first 100 documents, sorted by document URI.

If the query contains any repeated semicolons (";;"), it will be split into multiple queries and run separately. This permits faster start-up with complex queries.

declare variable $URI external;

(: must return 0 for empty or non-existence URIs :)

if ($URI and fn:doc-available($URI)) then
xdmp:md5(fn:concat(
  xdmp:quote(fn:doc($URI)),
  xdmp:quote(xdmp:document-properties($URI)),
  for $i in xdmp:quote(xdmp:document-get-collections($URI))
  order by $i
  return $i
))
else 0