Changeset 1368 for fmts/trunk

Timestamp:

Feb 27, 2012, 11:51:28 PM (13 years ago)

Author:

George Lilly

Message:

changes for getGraph and rdf out

Location:

fmts/trunk/p

Files:

• C0XF2N.m (modified) (1 diff)
• C0XGET1.m (modified) (3 diffs)
• C0XRDF.m (modified) (2 diffs)

fmts/trunk/p/C0XF2N.m

@@ -596 +596 @@
  Q
  ;
+DELGRAPH(ZGRF,FARY) ; delete a graph from the triplestore
+ ; (doesn't delete strings)
+ ;
+ I '$D(FARY) D  ;
+ . D INITFARY("C0XFARY")
+ . S FARY="C0XFARY"
+ D USEFARY(FARY)
+ N ZGRAPH
+ D TING(.ZGRAPH,ZGRF,FARY)
+ I '$D(ZGRAPH) D  Q  ;
+ . W !,"NO TRIPLES IN GRAPH"
+ K C0XFDA
+ N ZI S ZI=""
+ F  S ZI=$O(ZGRAPH(ZI)) Q:ZI=""  D  ;
+ . S C0XFDA(C0XTFN,ZI_",",.01)="@"
+ D UPDIE(.C0XFDA)
+ Q
+ ;
+TING(ZRTN,ZGRF,FARY) ; return the iens for graph ZGRF
+ ; ZRTN is passed by reference
+ I '$D(FARY) D  ;
+ . D INITFARY("C0XFARY")
+ . S FARY="C0XFARY"
+ D USEFARY(FARY)
+ K ZRTN
+ N ZI,ZG S ZI=""
+ S ZG=$$IENOF(ZGRF)
+ I ZG="" D  Q  ;
+ . W !,"ERROR GRAPH NOT FOUND"
+ I '$D(@C0XTN@("G",ZG)) Q  ;
+ F  S ZI=$O(@C0XTN@("G",ZG,ZI)) Q:ZI=""  D  ;
+ . S ZRTN(ZI)=""
+ Q
+ ;  
 SWUPDIE(ZFDA) ; SWITCH BETWEEN UPDIE AND BULKLOAD
  . I $G(BLKLOAD) D  ; bulk load

fmts/trunk/p/C0XGET1.m

@@ -83 +83 @@
  s qrtn(1)=q1_"^"_q2_"^"_q3 ; more lines to come later
  q
+ ;
+getGraph(zrtn,zgrf,form) ; get all triples in graph zgrf
+ ; forms planned: "rdf" "json" "array" "turtle" "triples"
+ ; forms supported: "rdf" "json" "array"
+ I '$D(form) S form="rdf"
+ N ZIENS,ZTRIP
+ D TING^C0XF2N(.ZIENS,zgrf)
+ I '$D(ZIENS) Q  ;
+ D ien2tary(.ZTRIP,"ZIENS")
+ I form="json" d jsonout(.zrtn,.ZTRIP) q  ; what follows is else
+ i form="rdf" d rdfout^C0XRDF(.zrtn,.ZTRIP) q  ;
+ i form="array" d arrayout^C0XGET1(.zrtn,.ZTRIP) q  ;
+ W !,"Form not supported: ",form
+ Q
  ;
 rpctrip(rtn,query,limit,offset) ; rpc to access triples with a query
@@ -101 +115 @@
  q
  ;
-triples(triplertn,sub,pred,obj,graph,fary) ; returns triples
+triples(triplertn,sub,pred,obj,graph,form,fary) ; returns triples
  I '$D(fary) D  ;
  . D INITFARY^C0XF2N("C0XFARY")
  . S fary="C0XFARY"
  D USEFARY^C0XF2N(fary)
+ I '$D(form) S form="json"
  k triplertn ; start with a clean return
  n zsub,zpred,zobj,zgraph,tmprtn
@@ -116 +131 @@
  d ien2tary(.zrary,"tmprtn") ; convert to triples
  ;
- d rdfout^C0XRDF(.triplertn,.zrary) q  ;
- i REPLYFMT="JSON" d jsonout(.triplertn,.zrary) q  ; what follows is 'else'
- ;
- ; if no reply format is found we just output an array of triples
+ i form="json" d jsonout(.triplertn,.zrary) q  ; what follows is 'else'
+ i form="rdf" d rdfout^C0XRDF(.triplertn,.zrary) q  ;
+ i form="array" d arrayout(.triplertn,.zrary) q ;
+ w !,"form not supported: ",form 
+ q
+ ;
+arrayout(rtn,zary) ; output an array of triples
  ;
  s zrsub=""
  s zcnt=1
- f  s zrsub=$o(zrary(zrsub)) q:zrsub=""  d  ; organized by subject
+ f  s zrsub=$o(zary(zrsub)) q:zrsub=""  d  ; organized by subject
  . s zzz=""
- . f  s zzz=$o(zrary(zrsub,zzz)) q:zzz=""  d  ; pred and obj
- . . s triplertn(zcnt)=zrsub_"^"_zzz
+ . f  s zzz=$o(zary(zrsub,zzz)) q:zzz=""  d  ; pred and obj
+ . . s rtn(zcnt)=zrsub_"^"_zzz
  . . s zcnt=zcnt+1
  q

fmts/trunk/p/C0XRDF.m

@@ -39 +39 @@
  I ZPRED[":" D  Q  ;
  . I ZPRED="rdf:type" D  Q  ;
- . . D ADD(ZARY,"rdf:type rdf:Resource="""_ZOBJ_"""/>")
- . N ZA,ZB
+ . . D ADD(ZARY,"rdf:type rdf:Resource="""_$$EXT^C0XUTIL(ZOBJ)_"""/>")
+ . N ZA,ZB,ZC
  . S ZA=$P(ZPRED,":",1)
  . S ZB=$P(ZPRED,":",2)
- . D ADD(ZARY,"<"_ZA_" xmlns="""_ZB_""">"_ZOBJ_"</"_ZA_">")
+ . S ZC=C0XVOC(ZA)
+ . D ADD(ZARY,"<"_ZB_" xmlns="""_ZC_""">"_$$EXT^C0XUTIL(ZOBJ)_"</"_ZB_">")
  Q
  ;
@@ -70 +71 @@
  f  s zi=$o(zary(zi)) q:zi=""  d  ; for each subject
  . n zii s zii=""
- . D DICTSTART("rdfout",zi)
+ . D DICTSTART("rdfout",$$EXT^C0XUTIL(zi))
  . f  s zii=$o(zary(zi,zii)) q:zii=""  d  ; for each pred^obj pair
  . . d DASSERT("rdfout",$p(zii,"^",1),$p(zii,"^",2))