Разработка динамических REST-сервисов на документо-ориентированной БД Bagri29.11.2016 16:05

Для прикладного ресурса Patient создадим другой модуль XQuery:

/data/fhir/patient_module.xq. Так же в заголовке объявим используемые пространства имен:

module namespace fhir = "http://hl7.org/fhir/patient"; 
declare namespace http = "http://www.expath.org/http";
declare namespace rest = "http://www.expath.org/restxq";
declare namespace bgdm = "http://bagridb.com/bagri-xdm";
declare namespace p = "http://hl7.org/fhir"; 

declare 
  %rest:GET  (: определяет метод HTTP, через который ресурс будет доступен :)
  %rest:path("/{id}")  (: определяет путь доступа к ресурсу; id - шаблонный параметр пути :)
  %rest:produces("application/fhir+xml")  (:  устанавливает формат возвращаемых данных :)
function fhir:get-patient-by-id($id as xs:string) as element()? {
  collection("Patients")/p:Patient[p:id/@value = $id]
};

declare 
  %rest:GET
  %rest:path("/{id}")
  %rest:produces("application/fhir+xml")
function fhir:get-patient-by-id($id as xs:string) as element()* {
  let $itr := collection("Patients")/p:Patient[p:id/@value = $id]
  return
    if ($itr) then 
      (
         
          (: запрашиваемый ресурс имеет версию? :)
         {if ($itr/p:meta/p:versionId/@value) then (
            (: заголовок ETag должен содержать номер версии найденного ресурса Patient :)
           ,
            (: заголовок Content-Location должен содержать адрес, по которому доступна последняя версия ресурса :)
            
          ) else (
            (: иначе заголовок Content-Location должен содержать базовый адрес ресурса :)
            
          )}
            (: заголовок Last-Modified должен содержать дату/время последней модификации ресурса :)
           
                              
       , $itr)
    else 
      (: возвращаем статус 404 если пациент с заданным id не найден :)
      
        
      
};

Конечно, такая полная реализация требований спецификации получается гораздо более многословной. Но не берусь сказать, с помощью какого языка/технологии можно выполнить требования FHIR компактнее. С другой стороны, сильно привлекают возможности XQuery по работе с XML и с последовательностями данных.

Ниже я уже не буду отвлекаться на обработку всех возможных дополнительных сценариев, в примере выше было показано, как возвращать на сервер дополнительные статусы и заголовки HTTP.
Базовая реализация метода vread выглядит очень похоже:

declare 
  %rest:GET
  %rest:path("/{id}/_history/{vid}")  (: кроме идентификатора здесь в качестве шаблона пути также используется номер версии :)
  %rest:produces("application/fhir+xml")
function fhir:get-patient-by-id-version($id as xs:string, $vid as xs:string) as element()? {
  collection("Patients")/p:Patient[p:id/@value = $id and p:meta/p:versionId/@value = $vid]
};

declare 
  %rest:GET
  %rest:produces("application/fhir+xml")
  %rest:query-param("identifier", "{$identifier}")  (: параметры поиска передаём в строке :)
  %rest:query-param("birthdate", "{$birthdate}") (: запроса http; все они не обязательные :)
  %rest:query-param("gender", "{$gender}") 
  %rest:query-param("name", "{$name}")
  %rest:query-param("telecom", "{$telecom}")
function fhir:search-patients($identifier as xs:string?, $birthdate as xs:date?, $gender as xs:string?, $name as xs:string?, $telecom as xs:string?) as element()* {
(: получим набор результатов (пациентов), удовлетворяющих условиям поиска :)
  let $itr := collection("Patients")/p:Patient[ 
	(not(exists($gender)) or p:gender/@value = $gender)
    and (not(exists($birthdate)) or p:birthDate/@value = $birthdate) 
    and (not(exists($name)) or contains(data(p:text), $name)) 
    and (not(exists($identifier)) or contains(p:identifier/p:value/@value, $identifier)) 
    and (not(exists($telecom)) or contains(string-join(p:telecom/p:value/@value, " "), $telecom))] 
(: возвращаем результаты внутри контейнера Bundle :)
  return
    
        (: сгенерируем уникальный bundle ID :)
      
        
      
      
      
      
        
        
      
      {for $ptn in $itr
       return  
         
           {$ptn}
         
      }
    
};  

declare 
  %rest:POST (: создание нового ресурса осуществляется методом POST :)
  %rest:consumes("application/fhir+xml")  (: ожидаем получить полное состояние ресурса в теле запроса в формате XML :)
  %rest:produces("application/fhir+xml")  (: новое состояние ресурса вернем клиенту в том же формате :)
function fhir:create-patient($content as xs:string) as element()? {
  let $doc := parse-xml($content)  (: распарсим входную строку в документ XML, заодно и провалидируем его :)
  let $uri := xs:string($doc/p:Patient/p:id/@value) || ".xml"  (: сформируем uri нового ресурса :)
  let $uri := bgdm:store-document(xs:anyURI($uri), $content, ())  (: сохраним документ и получим в ответ его uri, хотя он не должен отличаться от сформированного нами 2мя строками выше :)
  let $content := bgdm:get-document-content($uri)  (: а вот состояние ресурса, в соответствие со спецификацией, может отличаться от полученного на вход, например система могла заполнить некоторые пропущенные поля их значениями по умолчанию :)
  let $doc := parse-xml($content)
  return $doc/p:Patient  
};

declare 
  %rest:PUT (: изменение существующего ресурса осуществляется методом PUT :)
  %rest:path("/{id}"). (: изменяем ресурс соответствующий заданному шаблонному параметру :)
  %rest:consumes("application/fhir+xml")  
  %rest:produces("application/fhir+xml")
function fhir:update-patient($id as xs:string, $content as xs:string) as element()? {
  for $uri in fhir:get-patient-uri($id)  (: используем утилитную функцию чтобы не дублировать код :)
  let $uri := bgdm:store-document($uri, $content, ())
  let $content := bgdm:get-document-content($uri, ())
  let $doc := parse-xml($content) 
  return $doc/p:Patient
};

declare 
  %rest:DELETE  (: удаление ресурса, естественно, с помощью DELETE :)
  %rest:path("/{id}")
function fhir:delete-patient($id as xs:string) as item()? {
  for $uri in fhir:get-patient-uri($id)
  return bgdm:remove-document($uri)  (: удалить соответствующий ресурсу документ :)
};

declare 
  %private
function fhir:get-patient-uri($id as xs:string) as xs:anyURI? {
  (: сформируем динамический запрос XQuery :)
  let $query := 
' declare namespace p = "http://hl7.org/fhir"; 
  declare variable $id external;
  for $ptn in fn:collection("Patients")/p:Patient
  where $ptn/p:id/@value = $id
  return $ptn'


  (: выполнив его, получим в ответ uri документа, удовлетворяющего условиям запроса :)
  let $uri := bgdm:query-document-uris($query, ("id", $id), ())
  return xs:anyURI($uri)
};

bgdm:get-uuid() as xs:string - сгенерировать уникальный идентификатор uuid
bgdm:query-document-uris(xs:string, xs:anyType*, xs:anyAtomicType*) as xs:string* - вернуть uri документов, которые попадают в динамическую выборку XQuery
bgdm:store-document(xs:anyURI, xs:string, xs:anyAtomicType*) as xs:anyURI - зарегистрировать в системе новый документ, либо новую версию имеющегося документа
bgdm:get-document-content(xs:anyURI) as xs:string* - вернуть текстовое содержимое документа
bgdm:remove-document(xs:anyURI) as xs:anyURI - удалить документ