com.epimorphics.server.stores

Class StoreBase

java.lang.Object

com.epimorphics.server.core.ServiceBase

com.epimorphics.server.stores.StoreBase

All Implemented Interfaces:

Service, Store

Direct Known Subclasses:

MemStore, TDBStore

public abstract class StoreBase
extends ServiceBase
implements Store, Service

Base implementation of a generic store. Supports linking to indexer and mutator services. Supports optional logging of all requests to a nominated file system.

Author:

Dave Reynolds

Field Summary

Fields

Modifier and Type	Field and Description
static String	ADD_ACTION
protected com.hp.hpl.jena.query.Dataset	dataset
static String	DELETE_ACTION
static String	INDEXER_PARAM
protected List<Indexer>	indexers
protected boolean	inWrite
static String	JENA_TEXT_PARAM
static String	LOG_PARAM
protected String	logDirectory
static String	MUTATOR_PARAM
protected List<Mutator>	mutators
static String	QUERY_ENDPOINT_PARAM
static String	UPDATE_ACTION

Fields inherited from class com.epimorphics.server.core.ServiceBase

config

Constructor Summary

Constructors

Constructor and Description
StoreBase()

Method Summary

Methods

Modifier and Type	Method and Description
void	abort() Unlock the dataset, aborting the transaction.
void	addGraph(String graphname, InputStream input, String mimeType)
void	addGraph(String graphname, com.hp.hpl.jena.rdf.model.Model graph)
void	addIndexer(Indexer indexer)
void	addMutator(Mutator mutator)
abstract com.hp.hpl.jena.query.Dataset	asDataset()
void	deleteGraph(String graphname)
protected abstract void	doAddGraph(String graphname, InputStream input, String mimeType)
protected abstract void	doAddGraph(String graphname, com.hp.hpl.jena.rdf.model.Model graph)
protected abstract void	doDeleteGraph(String graphname)
protected void	index(String graphname, com.hp.hpl.jena.rdf.model.Model graph, boolean update)
protected void	indexNamed(String graphname, boolean update)
void	init(Map<String,String> config, javax.servlet.ServletContext context)
protected void	installJenaText() Install a jena-text dataset wrapper round this store.
protected void	installQueryEndpoint(javax.servlet.ServletContext context) Configure a Fuseki query servlet for this store.
void	lock() Lock the dataset for reading
void	lockWrite() Lock the dataset for write
protected void	logAction(String action, String graph, com.hp.hpl.jena.rdf.model.Model data)
protected void	logNamed(String action, String graphname)
protected void	mutate(com.hp.hpl.jena.rdf.model.Model graph)
protected void	mutateNamed(String graphname)
void	postInit()
void	unlock() Unlock the dataset
void	updateGraph(String graphname, InputStream input, String mimeType)
void	updateGraph(String graphname, com.hp.hpl.jena.rdf.model.Model graph)

Methods inherited from class com.epimorphics.server.core.ServiceBase

getFileParam, getNamedService, getRequiredFileParam, getRequiredIntParam, getRequiredParam, postPostInit

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.epimorphics.server.core.Store

getUnionModel

Methods inherited from interface com.epimorphics.server.core.Service

postPostInit

Field Detail

INDEXER_PARAM

public static final String INDEXER_PARAM

See Also:

Constant Field Values

MUTATOR_PARAM

public static final String MUTATOR_PARAM

See Also:

Constant Field Values

JENA_TEXT_PARAM

public static final String JENA_TEXT_PARAM

See Also:

Constant Field Values

LOG_PARAM

public static final String LOG_PARAM

See Also:

Constant Field Values

ADD_ACTION

public static final String ADD_ACTION

See Also:

Constant Field Values

UPDATE_ACTION

public static final String UPDATE_ACTION

See Also:

Constant Field Values

DELETE_ACTION

public static final String DELETE_ACTION

See Also:

Constant Field Values

QUERY_ENDPOINT_PARAM

public static final String QUERY_ENDPOINT_PARAM

See Also:

Constant Field Values

dataset

protected com.hp.hpl.jena.query.Dataset dataset

indexers

protected volatile List<Indexer> indexers

mutators

protected volatile List<Mutator> mutators

logDirectory

protected String logDirectory

inWrite

protected boolean inWrite

Constructor Detail

StoreBase

public StoreBase()

Method Detail

init

public void init(Map<String,String> config,
        javax.servlet.ServletContext context)

Specified by:

init in interface Service

Overrides:

init in class ServiceBase

installJenaText

protected void installJenaText()

Install a jena-text dataset wrapper round this store. This is an alternative to the indexer system.

installQueryEndpoint

protected void installQueryEndpoint(javax.servlet.ServletContext context)

Configure a Fuseki query servlet for this store. The web.xml file needs to map the servlet to a matching context path.

postInit

public void postInit()

Specified by:

postInit in interface Service

Overrides:

postInit in class ServiceBase

doAddGraph

protected abstract void doAddGraph(String graphname,
              com.hp.hpl.jena.rdf.model.Model graph)

doAddGraph

protected abstract void doAddGraph(String graphname,
              InputStream input,
              String mimeType)

doDeleteGraph

protected abstract void doDeleteGraph(String graphname)

asDataset

public abstract com.hp.hpl.jena.query.Dataset asDataset()

Specified by:

asDataset in interface Store

addGraph

public void addGraph(String graphname,
            com.hp.hpl.jena.rdf.model.Model graph)

Specified by:

addGraph in interface Store

updateGraph

public void updateGraph(String graphname,
               com.hp.hpl.jena.rdf.model.Model graph)

Specified by:

updateGraph in interface Store

deleteGraph

public void deleteGraph(String graphname)

Specified by:

deleteGraph in interface Store

addGraph

public void addGraph(String graphname,
            InputStream input,
            String mimeType)

Specified by:

addGraph in interface Store

updateGraph

public void updateGraph(String graphname,
               InputStream input,
               String mimeType)

Specified by:

updateGraph in interface Store

addIndexer

public void addIndexer(Indexer indexer)

Specified by:

addIndexer in interface Store

addMutator

public void addMutator(Mutator mutator)

Specified by:

addMutator in interface Store

lock

public void lock()

Lock the dataset for reading

Specified by:

lock in interface Store

lockWrite

public void lockWrite()

Lock the dataset for write

Specified by:

lockWrite in interface Store

unlock

public void unlock()

Unlock the dataset

Specified by:

unlock in interface Store

abort

public void abort()

Unlock the dataset, aborting the transaction. Only useful if the dataset is transactional

mutate

protected void mutate(com.hp.hpl.jena.rdf.model.Model graph)

mutateNamed

protected void mutateNamed(String graphname)

index

protected void index(String graphname,
         com.hp.hpl.jena.rdf.model.Model graph,
         boolean update)

indexNamed

protected void indexNamed(String graphname,
              boolean update)

logAction

protected void logAction(String action,
             String graph,
             com.hp.hpl.jena.rdf.model.Model data)

logNamed

protected void logNamed(String action,
            String graphname)