66import java .util .Set ;
77
88import com .marklogic .client .DatabaseClient ;
9+ import com .marklogic .client .document .JSONDocumentManager ;
910import com .marklogic .client .document .TextDocumentManager ;
1011import com .marklogic .client .document .XMLDocumentManager ;
1112import com .marklogic .client .helper .LoggingObject ;
13+ import com .marklogic .client .io .DocumentMetadataHandle ;
1214import com .marklogic .client .io .FileHandle ;
1315import com .marklogic .client .io .Format ;
1416import com .marklogic .client .schemasloader .SchemasFinder ;
@@ -20,15 +22,22 @@ public class DefaultSchemasLoader extends LoggingObject implements SchemasLoader
2022 public Set <File > loadSchemas (File baseDir , SchemasFinder schemasDataFinder , DatabaseClient client ) {
2123 XMLDocumentManager xmlDocMgr = client .newXMLDocumentManager ();
2224 TextDocumentManager textDocMgr = client .newTextDocumentManager ();
25+ JSONDocumentManager jsonDocMgr = client .newJSONDocumentManager ();
2326
2427 List <File > schemasData = schemasDataFinder .findSchemas (baseDir );
2528
2629 Set <File > loadedSchemas = new HashSet <>();
27-
30+ DocumentMetadataHandle tdeCollection = new DocumentMetadataHandle (). withCollections ( "http://marklogic.com/xdmp/tde" );
2831 for (File f : schemasData ) {
2932 String extension = getExtensionNameFromFile (f );
3033 FileHandle handle = new FileHandle (f );
31- if (extension .equals ("tde" ) || extension .equals ("xsd" )) {
34+ if (extension .equals ("tdej" )) {
35+ jsonDocMgr .write (f .getName (), tdeCollection , handle .withFormat (Format .JSON ));
36+ }
37+ else if (extension .equals ("tdex" )) {
38+ xmlDocMgr .write (f .getName (), tdeCollection , handle .withFormat (Format .XML ));
39+ }
40+ else if (extension .equals ("xsd" )) {
3241 xmlDocMgr .write (f .getName (), handle .withFormat (Format .XML ));
3342 } else {
3443 textDocMgr .write (f .getName (), handle .withFormat (Format .TEXT ));
0 commit comments