Package de.dfki.sds.aticsqlite

Class SqliteAticDatasetGraph

java.lang.Object
de.dfki.sds.aticsqlite.SqliteAticDatasetGraph
All Implemented Interfaces:
de.dfki.sds.atic.ac.SharingManagement, de.dfki.sds.atic.ac.UserGroupManagement, de.dfki.sds.atic.jenatic.AticDatasetGraph, org.apache.jena.atlas.lib.Closeable, org.apache.jena.sparql.core.DatasetGraph, org.apache.jena.sparql.core.Transactional
public class SqliteAticDatasetGraph extends Object implements de.dfki.sds.atic.jenatic.AticDatasetGraph, de.dfki.sds.atic.ac.UserGroupManagement, de.dfki.sds.atic.ac.SharingManagement

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.jena.sparql.core.Transactional

    org.apache.jena.sparql.core.Transactional.Promote

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final org.apache.jena.sparql.util.Symbol
    ATIC_LOCATION
     

    Fields inherited from interface de.dfki.sds.atic.ac.UserGroupManagement

    ADMIN_USERNAME, EVERYONE_GROUP

  • Constructor Summary

    Constructors
    Constructor
    Description
    SqliteAticDatasetGraph(Database db)
     
    SqliteAticDatasetGraph(Database db, RDFPatchListener mainListener)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    abort()
     
    void
    add(org.apache.jena.graph.Node g, org.apache.jena.graph.Node s, org.apache.jena.graph.Node p, org.apache.jena.graph.Node o, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    add(org.apache.jena.sparql.core.Quad quad, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    org.apache.jena.graph.Node
    addGraph(org.apache.jena.graph.Graph graph, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    addGraph(org.apache.jena.graph.Node graphName, org.apache.jena.graph.Graph graph, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    addGroup(String groupname, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    addListener(RDFPatchListener listener)
     
    String
    addUser(String firstname, String lastname, String email, String username, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    addVirtualGraph(org.apache.jena.graph.Node graphName, String factoryMethodPath, org.json.JSONObject config, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    apply(org.apache.jena.rdfpatch.RDFPatch rdfPatch, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    assignUserToGroup(String username, String groupname, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    begin(org.apache.jena.query.TxnType type)
     
    void
    clear(de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    close()
     
    void
    commit()
     
    boolean
    contains(org.apache.jena.graph.Node g, org.apache.jena.graph.Node s, org.apache.jena.graph.Node p, org.apache.jena.graph.Node o, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    boolean
    contains(org.apache.jena.sparql.core.Quad quad, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    boolean
    containsGraph(org.apache.jena.graph.Node graphNode, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    delete(org.apache.jena.graph.Node g, org.apache.jena.graph.Node s, org.apache.jena.graph.Node p, org.apache.jena.graph.Node o, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    delete(org.apache.jena.sparql.core.Quad quad, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    deleteAny(org.apache.jena.graph.Node g, org.apache.jena.graph.Node s, org.apache.jena.graph.Node p, org.apache.jena.graph.Node o, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    disableQueryLogger()
     
    void
    enableQueryLogger(String dbFilePath)
     
    void
    end()
     
    Iterator<org.apache.jena.sparql.core.Quad>
    find(org.apache.jena.graph.Node g, org.apache.jena.graph.Node s, org.apache.jena.graph.Node p, org.apache.jena.graph.Node o, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    Iterator<org.apache.jena.sparql.core.Quad>
    find(org.apache.jena.sparql.core.Quad quad, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    Iterator<org.apache.jena.sparql.core.Quad>
    findNG(org.apache.jena.graph.Node g, org.apache.jena.graph.Node s, org.apache.jena.graph.Node p, org.apache.jena.graph.Node o, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    generateLUBMftGraph(org.apache.jena.graph.Node graphName, int univNum, int startIndex, int seed, boolean names, boolean docs, int bufferSize, int batchSize, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    org.apache.jena.sparql.util.Context
    getContext()
     
    de.dfki.sds.atic.jenatic.AticGraph
    getDefaultGraph(de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    de.dfki.sds.atic.jenatic.AticGraph
    getGraph(org.apache.jena.graph.Node graphNode, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    de.dfki.sds.atic.ac.Group
    getGroup(String groupname, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    org.apache.jena.shared.Lock
    getLock()
     
    de.dfki.sds.atic.jenatic.AticGraph
    getUnionGraph(de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    de.dfki.sds.atic.jenatic.AticGraph
    getUnionGraph(Iterator<org.apache.jena.graph.Node> graphNodes, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    de.dfki.sds.atic.ac.User
    getUser(int userId, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    de.dfki.sds.atic.ac.User
    getUser(String username, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    Map<org.apache.jena.graph.Node,de.dfki.sds.atic.jenatic.AticVirtualGraph>
    getVirtualGraphMap()
     
    boolean
    isClosed()
     
    boolean
    isEmpty(de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    boolean
    isInTransaction()
     
    Iterator<org.apache.jena.graph.Node>
    listGraphNodes(de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    Map<String,de.dfki.sds.atic.ac.Permission>
    listGraphPermissions(Set<String> graphUris, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    Map<String,de.dfki.sds.atic.ac.Permission>
    listResourcePermissions(Set<String> resourceUris, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    org.apache.jena.riot.system.PrefixMap
    prefixes(de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    boolean
    promote(org.apache.jena.sparql.core.Transactional.Promote mode)
     
    void
    removeGraph(org.apache.jena.graph.Node graphName, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    removeListener(RDFPatchListener listener)
     
    List<de.dfki.sds.atic.ac.Group>
    searchGroups(String query, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    List<de.dfki.sds.atic.ac.Principal>
    searchPrincipals(String query, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    List<de.dfki.sds.atic.ac.User>
    searchUsers(String query, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    shareGraphs(Set<String> graphUris, Set<String> groupUris, de.dfki.sds.atic.ac.Permission permission, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    shareResources(Set<String> resourceUris, Set<String> groupUris, de.dfki.sds.atic.ac.Permission permission, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    long
    size(de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    boolean
    supportsTransactions()
     
    org.apache.jena.query.ReadWrite
    transactionMode()
     
    org.apache.jena.query.TxnType
    transactionType()
     
    void
    unassignUserFromGroup(String username, String groupname, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    unshareGraphs(Set<String> graphUris, Set<String> groupUris, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     
    void
    unshareResources(Set<String> resourceUris, Set<String> groupUris, de.dfki.sds.atic.jenatic.InvocationContext ctx)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    add, add, addGraph, clear, contains, contains, containsGraph, delete, delete, deleteAny, find, find, findNG, getDefaultGraph, getGraph, getUnionGraph, isEmpty, listGraphNodes, prefixes, removeGraph, size

    Methods inherited from interface org.apache.jena.sparql.core.DatasetGraph

    addAll, find, stream, stream, supportsTransactionAbort

    Methods inherited from interface org.apache.jena.sparql.core.Transactional

    begin, begin, calc, calculate, calculateRead, calculateWrite, exec, execute, executeRead, executeWrite, promote

  • Field Details

    • ATIC_LOCATION

      public static final org.apache.jena.sparql.util.Symbol ATIC_LOCATION

  • Constructor Details

    • SqliteAticDatasetGraph

      public SqliteAticDatasetGraph(Database db)

    • SqliteAticDatasetGraph

      public SqliteAticDatasetGraph(Database db, RDFPatchListener mainListener)

  • Method Details

    • enableQueryLogger

      public void enableQueryLogger(String dbFilePath)

    • disableQueryLogger

      public void disableQueryLogger()

    • addUser

      public String addUser(String firstname, String lastname, String email, String username, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      addUser in interface de.dfki.sds.atic.ac.UserGroupManagement

    • addGroup

      public void addGroup(String groupname, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      addGroup in interface de.dfki.sds.atic.ac.UserGroupManagement

    • getUser

      public de.dfki.sds.atic.ac.User getUser(String username, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      getUser in interface de.dfki.sds.atic.ac.UserGroupManagement

    • getUser

      public de.dfki.sds.atic.ac.User getUser(int userId, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      getUser in interface de.dfki.sds.atic.ac.UserGroupManagement

    • getGroup

      public de.dfki.sds.atic.ac.Group getGroup(String groupname, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      getGroup in interface de.dfki.sds.atic.ac.UserGroupManagement

    • assignUserToGroup

      public void assignUserToGroup(String username, String groupname, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      assignUserToGroup in interface de.dfki.sds.atic.ac.UserGroupManagement

    • unassignUserFromGroup

      public void unassignUserFromGroup(String username, String groupname, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      unassignUserFromGroup in interface de.dfki.sds.atic.ac.UserGroupManagement

    • searchUsers

      public List<de.dfki.sds.atic.ac.User> searchUsers(String query, de.dfki.sds.atic.jenatic.InvocationContext ctx)

    • searchGroups

      public List<de.dfki.sds.atic.ac.Group> searchGroups(String query, de.dfki.sds.atic.jenatic.InvocationContext ctx)

    • searchPrincipals

      public List<de.dfki.sds.atic.ac.Principal> searchPrincipals(String query, de.dfki.sds.atic.jenatic.InvocationContext ctx)

    • shareGraphs

      public void shareGraphs(Set<String> graphUris, Set<String> groupUris, de.dfki.sds.atic.ac.Permission permission, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      shareGraphs in interface de.dfki.sds.atic.ac.SharingManagement

    • unshareGraphs

      public void unshareGraphs(Set<String> graphUris, Set<String> groupUris, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      unshareGraphs in interface de.dfki.sds.atic.ac.SharingManagement

    • shareResources

      public void shareResources(Set<String> resourceUris, Set<String> groupUris, de.dfki.sds.atic.ac.Permission permission, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      shareResources in interface de.dfki.sds.atic.ac.SharingManagement

    • unshareResources

      public void unshareResources(Set<String> resourceUris, Set<String> groupUris, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      unshareResources in interface de.dfki.sds.atic.ac.SharingManagement

    • listResourcePermissions

      public Map<String,de.dfki.sds.atic.ac.Permission> listResourcePermissions(Set<String> resourceUris, de.dfki.sds.atic.jenatic.InvocationContext ctx)

    • listGraphPermissions

      public Map<String,de.dfki.sds.atic.ac.Permission> listGraphPermissions(Set<String> graphUris, de.dfki.sds.atic.jenatic.InvocationContext ctx)

    • getDefaultGraph

      public de.dfki.sds.atic.jenatic.AticGraph getDefaultGraph(de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      getDefaultGraph in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • getGraph

      public de.dfki.sds.atic.jenatic.AticGraph getGraph(org.apache.jena.graph.Node graphNode, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      getGraph in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • getUnionGraph

      public de.dfki.sds.atic.jenatic.AticGraph getUnionGraph(de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      getUnionGraph in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • getUnionGraph

      public de.dfki.sds.atic.jenatic.AticGraph getUnionGraph(Iterator<org.apache.jena.graph.Node> graphNodes, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      getUnionGraph in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • listGraphNodes

      public Iterator<org.apache.jena.graph.Node> listGraphNodes(de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      listGraphNodes in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • containsGraph

      public boolean containsGraph(org.apache.jena.graph.Node graphNode, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      containsGraph in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • addGraph

      public void addGraph(org.apache.jena.graph.Node graphName, org.apache.jena.graph.Graph graph, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      addGraph in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • addVirtualGraph

      public void addVirtualGraph(org.apache.jena.graph.Node graphName, String factoryMethodPath, org.json.JSONObject config, de.dfki.sds.atic.jenatic.InvocationContext ctx)

    • addGraph

      public org.apache.jena.graph.Node addGraph(org.apache.jena.graph.Graph graph, de.dfki.sds.atic.jenatic.InvocationContext ctx)

    • removeGraph

      public void removeGraph(org.apache.jena.graph.Node graphName, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      removeGraph in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • add

      public void add(org.apache.jena.graph.Node g, org.apache.jena.graph.Node s, org.apache.jena.graph.Node p, org.apache.jena.graph.Node o, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      add in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • delete

      public void delete(org.apache.jena.graph.Node g, org.apache.jena.graph.Node s, org.apache.jena.graph.Node p, org.apache.jena.graph.Node o, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      delete in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • apply

      public void apply(org.apache.jena.rdfpatch.RDFPatch rdfPatch, de.dfki.sds.atic.jenatic.InvocationContext ctx)

    • deleteAny

      public void deleteAny(org.apache.jena.graph.Node g, org.apache.jena.graph.Node s, org.apache.jena.graph.Node p, org.apache.jena.graph.Node o, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      deleteAny in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • find

      public Iterator<org.apache.jena.sparql.core.Quad> find(org.apache.jena.graph.Node g, org.apache.jena.graph.Node s, org.apache.jena.graph.Node p, org.apache.jena.graph.Node o, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      find in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • findNG

      public Iterator<org.apache.jena.sparql.core.Quad> findNG(org.apache.jena.graph.Node g, org.apache.jena.graph.Node s, org.apache.jena.graph.Node p, org.apache.jena.graph.Node o, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      findNG in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • contains

      public boolean contains(org.apache.jena.graph.Node g, org.apache.jena.graph.Node s, org.apache.jena.graph.Node p, org.apache.jena.graph.Node o, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      contains in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • clear

      public void clear(de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      clear in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • size

      public long size(de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      size in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • delete

      public void delete(org.apache.jena.sparql.core.Quad quad, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      delete in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • find

      public Iterator<org.apache.jena.sparql.core.Quad> find(org.apache.jena.sparql.core.Quad quad, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      find in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • contains

      public boolean contains(org.apache.jena.sparql.core.Quad quad, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      contains in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • add

      public void add(org.apache.jena.sparql.core.Quad quad, de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      add in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • isEmpty

      public boolean isEmpty(de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      isEmpty in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • prefixes

      public org.apache.jena.riot.system.PrefixMap prefixes(de.dfki.sds.atic.jenatic.InvocationContext ctx)
      Specified by:
      prefixes in interface de.dfki.sds.atic.jenatic.AticDatasetGraph

    • getLock

      public org.apache.jena.shared.Lock getLock()
      Specified by:
      getLock in interface org.apache.jena.sparql.core.DatasetGraph

    • getContext

      public org.apache.jena.sparql.util.Context getContext()
      Specified by:
      getContext in interface org.apache.jena.sparql.core.DatasetGraph

    • close

      public void close()
      Specified by:
      close in interface org.apache.jena.atlas.lib.Closeable
      Specified by:
      close in interface org.apache.jena.sparql.core.DatasetGraph

    • isClosed

      public boolean isClosed()

    • supportsTransactions

      public boolean supportsTransactions()
      Specified by:
      supportsTransactions in interface org.apache.jena.sparql.core.DatasetGraph

    • begin

      public void begin(org.apache.jena.query.TxnType type)
      Specified by:
      begin in interface org.apache.jena.sparql.core.Transactional

    • promote

      public boolean promote(org.apache.jena.sparql.core.Transactional.Promote mode)
      Specified by:
      promote in interface org.apache.jena.sparql.core.Transactional

    • commit

      public void commit()
      Specified by:
      commit in interface org.apache.jena.sparql.core.Transactional

    • abort

      public void abort()
      Specified by:
      abort in interface org.apache.jena.sparql.core.Transactional

    • end

      public void end()
      Specified by:
      end in interface org.apache.jena.sparql.core.Transactional

    • transactionMode

      public org.apache.jena.query.ReadWrite transactionMode()
      Specified by:
      transactionMode in interface org.apache.jena.sparql.core.Transactional

    • transactionType

      public org.apache.jena.query.TxnType transactionType()
      Specified by:
      transactionType in interface org.apache.jena.sparql.core.Transactional

    • isInTransaction

      public boolean isInTransaction()
      Specified by:
      isInTransaction in interface org.apache.jena.sparql.core.Transactional

    • addListener

      public void addListener(RDFPatchListener listener)

    • removeListener

      public void removeListener(RDFPatchListener listener)

    • getVirtualGraphMap

      public Map<org.apache.jena.graph.Node,de.dfki.sds.atic.jenatic.AticVirtualGraph> getVirtualGraphMap()

    • generateLUBMftGraph

      public void generateLUBMftGraph(org.apache.jena.graph.Node graphName, int univNum, int startIndex, int seed, boolean names, boolean docs, int bufferSize, int batchSize, de.dfki.sds.atic.jenatic.InvocationContext ctx)