@Test public void testQuery() throws IOException { final TripleTransaction transaction = this.store.begin(true); final CloseableIteration<BindingSet, QueryEvaluationException> cursor = transaction.query( SelectQuery.from("SELECT * WHERE {?s ?p ?o}"), null, null); int statementsCount = 0; try { while (cursor.hasNext()) { final BindingSet current = cursor.next(); assertTrue(current.hasBinding("s")); assertTrue(current.hasBinding("p")); assertTrue(current.hasBinding("o")); assertNotNull(current.getBinding("s").getValue()); assertNotNull(current.getBinding("p").getValue()); assertNotNull(current.getBinding("o").getValue()); statementsCount++; } } catch (final QueryEvaluationException ex) { throw new IOException(ex); } assertEquals(NUM_OF_DEFAULT_STATEMENTS, statementsCount); }
@Override public TripleTransaction begin(final boolean readOnly) throws DataCorruptedException, IOException { if (existsTransactionMarker()) { throw new DataCorruptedException("The triple store performed a bulk operation " + "that didn't complete successfully."); } return new VirtuosoTripleTransaction(this, readOnly); }
VirtuosoTripleStore implements TripleStore { @Override public TripleTransaction begin(final boolean readOnly) throws DataCorruptedException, IOException { if (existsTransactionMarker()) { throw new DataCorruptedException("The triple store performed a bulk operation " + "that didn't complete successfully."); } return new VirtuosoTripleTransaction(this, readOnly); } }
VirtuosoTripleStore implements TripleStore { @Override public TripleTransaction begin(final boolean readOnly) throws DataCorruptedException, IOException { if (existsTransactionMarker()) { throw new DataCorruptedException("The triple store performed a bulk operation " + "that didn't complete successfully."); } return new VirtuosoTripleTransaction(this, readOnly); } VirtuosoTripleStore(final FileSystem fileSystem, @Nullable final String host,
            @Nullable final Integer port, @Nullable final String username,
            @Nullable final String password);  VirtuosoTripleStore(final FileSystem fileSystem, @Nullable final String host,
            @Nullable final Integer port, @Nullable final String username,
            @Nullable final String password, @Nullable final Boolean pooling,
            @Nullable final Integer batchSize, @Nullable final Integer fetchSize,
            @Nullable final String markerFilename); }
VirtuosoTripleStore implements TripleStore { @Override public TripleTransaction begin(final boolean readOnly) throws DataCorruptedException, IOException { if (existsTransactionMarker()) { throw new DataCorruptedException("The triple store performed a bulk operation " + "that didn't complete successfully."); } return new VirtuosoTripleTransaction(this, readOnly); } VirtuosoTripleStore(final FileSystem fileSystem, @Nullable final String host,
            @Nullable final Integer port, @Nullable final String username,
            @Nullable final String password);  VirtuosoTripleStore(final FileSystem fileSystem, @Nullable final String host,
            @Nullable final Integer port, @Nullable final String username,
            @Nullable final String password, @Nullable final Boolean pooling,
            @Nullable final Integer batchSize, @Nullable final Integer fetchSize,
            @Nullable final String markerFilename); @Override void init(); @Override TripleTransaction begin(final boolean readOnly); @Override void reset(); @Override void close(); @Override String toString(); }
VirtuosoTripleStore implements TripleStore { @Override public TripleTransaction begin(final boolean readOnly) throws DataCorruptedException, IOException { if (existsTransactionMarker()) { throw new DataCorruptedException("The triple store performed a bulk operation " + "that didn't complete successfully."); } return new VirtuosoTripleTransaction(this, readOnly); } VirtuosoTripleStore(final FileSystem fileSystem, @Nullable final String host,
            @Nullable final Integer port, @Nullable final String username,
            @Nullable final String password);  VirtuosoTripleStore(final FileSystem fileSystem, @Nullable final String host,
            @Nullable final Integer port, @Nullable final String username,
            @Nullable final String password, @Nullable final Boolean pooling,
            @Nullable final Integer batchSize, @Nullable final Integer fetchSize,
            @Nullable final String markerFilename); @Override void init(); @Override TripleTransaction begin(final boolean readOnly); @Override void reset(); @Override void close(); @Override String toString();  }