@Test public void pcjToMetadata() throws Exception { final MongoPcjDocuments docConverter = new MongoPcjDocuments(getMongoClient(), conf.getRyaInstanceName()); final String sparql = "SELECT * WHERE { ?a <http: final Document actual = docConverter.makeMetadataDocument("pcjTest", sparql); final Document expected = new Document() .append(MongoPcjDocuments.CARDINALITY_FIELD, 0) .append(MongoPcjDocuments.PCJ_METADATA_ID, "pcjTest_METADATA") .append(MongoPcjDocuments.SPARQL_FIELD, sparql) .append(MongoPcjDocuments.VAR_ORDER_FIELD, Sets.newHashSet(new VariableOrder("a", "b"), new VariableOrder("b", "a"))); assertEquals(expected, actual); }
public Document makeMetadataDocument(final String pcjId, final String sparql) throws PCJStorageException { requireNonNull(pcjId); requireNonNull(sparql); final Set<VariableOrder> varOrders; try { varOrders = pcjVarOrderFactory.makeVarOrders(sparql); } catch (final MalformedQueryException e) { throw new PCJStorageException("Can not create the PCJ. The SPARQL is malformed.", e); } return new Document() .append(PCJ_METADATA_ID, makeMetadataID(pcjId)) .append(SPARQL_FIELD, sparql) .append(CARDINALITY_FIELD, 0) .append(VAR_ORDER_FIELD, varOrders); }
MongoPcjDocuments { public Document makeMetadataDocument(final String pcjId, final String sparql) throws PCJStorageException { requireNonNull(pcjId); requireNonNull(sparql); final Set<VariableOrder> varOrders; try { varOrders = pcjVarOrderFactory.makeVarOrders(sparql); } catch (final MalformedQueryException e) { throw new PCJStorageException("Can not create the PCJ. The SPARQL is malformed.", e); } return new Document() .append(PCJ_METADATA_ID, makeMetadataID(pcjId)) .append(SPARQL_FIELD, sparql) .append(CARDINALITY_FIELD, 0) .append(VAR_ORDER_FIELD, varOrders); } }
MongoPcjDocuments { public Document makeMetadataDocument(final String pcjId, final String sparql) throws PCJStorageException { requireNonNull(pcjId); requireNonNull(sparql); final Set<VariableOrder> varOrders; try { varOrders = pcjVarOrderFactory.makeVarOrders(sparql); } catch (final MalformedQueryException e) { throw new PCJStorageException("Can not create the PCJ. The SPARQL is malformed.", e); } return new Document() .append(PCJ_METADATA_ID, makeMetadataID(pcjId)) .append(SPARQL_FIELD, sparql) .append(CARDINALITY_FIELD, 0) .append(VAR_ORDER_FIELD, varOrders); } MongoPcjDocuments(final MongoClient client, final String ryaInstanceName); }
MongoPcjDocuments { public Document makeMetadataDocument(final String pcjId, final String sparql) throws PCJStorageException { requireNonNull(pcjId); requireNonNull(sparql); final Set<VariableOrder> varOrders; try { varOrders = pcjVarOrderFactory.makeVarOrders(sparql); } catch (final MalformedQueryException e) { throw new PCJStorageException("Can not create the PCJ. The SPARQL is malformed.", e); } return new Document() .append(PCJ_METADATA_ID, makeMetadataID(pcjId)) .append(SPARQL_FIELD, sparql) .append(CARDINALITY_FIELD, 0) .append(VAR_ORDER_FIELD, varOrders); } MongoPcjDocuments(final MongoClient client, final String ryaInstanceName); Document makeMetadataDocument(final String pcjId, final String sparql); void createPcj(final String pcjId, final String sparql); void createAndPopulatePcj(
            final RepositoryConnection ryaConn,
            final String pcjId,
            final String sparql); PcjMetadata getPcjMetadata(final String pcjId); void addResults(final String pcjId, final Collection<VisibilityBindingSet> results); void purgePcjs(final String pcjId); void populatePcj(final String pcjId, final RepositoryConnection ryaConn); List<String> listPcjDocuments(); CloseableIterator<BindingSet> listResults(final String pcjId); CloseableIterator<BindingSet> getResults(final String pcjId, final Collection<BindingSet> restrictionBindings); void dropPcj(final String pcjId); }
MongoPcjDocuments { public Document makeMetadataDocument(final String pcjId, final String sparql) throws PCJStorageException { requireNonNull(pcjId); requireNonNull(sparql); final Set<VariableOrder> varOrders; try { varOrders = pcjVarOrderFactory.makeVarOrders(sparql); } catch (final MalformedQueryException e) { throw new PCJStorageException("Can not create the PCJ. The SPARQL is malformed.", e); } return new Document() .append(PCJ_METADATA_ID, makeMetadataID(pcjId)) .append(SPARQL_FIELD, sparql) .append(CARDINALITY_FIELD, 0) .append(VAR_ORDER_FIELD, varOrders); } MongoPcjDocuments(final MongoClient client, final String ryaInstanceName); Document makeMetadataDocument(final String pcjId, final String sparql); void createPcj(final String pcjId, final String sparql); void createAndPopulatePcj(
            final RepositoryConnection ryaConn,
            final String pcjId,
            final String sparql); PcjMetadata getPcjMetadata(final String pcjId); void addResults(final String pcjId, final Collection<VisibilityBindingSet> results); void purgePcjs(final String pcjId); void populatePcj(final String pcjId, final RepositoryConnection ryaConn); List<String> listPcjDocuments(); CloseableIterator<BindingSet> listResults(final String pcjId); CloseableIterator<BindingSet> getResults(final String pcjId, final Collection<BindingSet> restrictionBindings); void dropPcj(final String pcjId); static final String PCJ_COLLECTION_NAME; static final String CARDINALITY_FIELD; static final String SPARQL_FIELD; static final String PCJ_METADATA_ID; static final String VAR_ORDER_FIELD; }