org.apache.clerezza.rdf.virtuoso.storage.access

Class VirtuosoWeightedProvider

java.lang.Object

org.apache.clerezza.rdf.virtuoso.storage.access.VirtuosoWeightedProvider

All Implemented Interfaces:

QueryableTcProvider, TcProvider, WeightedTcProvider

@Service(value={WeightedTcProvider.class,TcProvider.class,QueryableTcProvider.class})
@Properties(value={@Property(name="password",description="User password"),@Property(name="host",description="The host running the Virtuoso server"),@Property(name="port",description="The port number"),@Property(name="user",description="User name"),@Property(name="weight",intValue=110,description="Weight assigned to this provider"),@Property(name="general.purpose.tc",boolValue=true)})
public class VirtuosoWeightedProvider
extends Object
implements WeightedTcProvider, QueryableTcProvider

A WeightedTcProvider for Virtuoso.

Author:

enridaga

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACTIVE_GRAPHS_GRAPH
static int	DEFAULT_WEIGHT
static String	DRIVER
static String	HOST
static String	PASSWORD
static String	PORT
static String	USER
static String	WEIGHT

Constructor Summary

Constructors

Constructor and Description
VirtuosoWeightedProvider() Creates a new VirtuosoWeightedProvider.
VirtuosoWeightedProvider(String host, Integer port, String jdbcUser, String jdbcPassword)

Method Summary

Methods

Modifier and Type	Method and Description
void	activate(org.osgi.service.component.ComponentContext cCtx) Activates this component.
boolean	canModify(UriRef graph)
boolean	canRead(UriRef graph)
DataAccess	createDataAccess()
Graph	createGraph(UriRef name, TripleCollection triples) Creates a new graph with the given triples, then returns the readable (not modifiable) version of the graph
MGraph	createMGraph(UriRef name) Creates an initially empty MGraph.
void	deactivate(org.osgi.service.component.ComponentContext cCtx) Deactivates this component.
void	deleteTripleCollection(UriRef name) Clears the given graph and removes it from the loaded graphs.
Object	executeSparqlQuery(String query, UriRef defaultGraphUri) Executes a SPARQL query
Connection	getConnection()
static String	getConnectionString(String hostName, Integer portNumber)
Graph	getGraph(UriRef name) Retrieves the Graph (unmodifiable) with the given UriRef If no graph exists with such name, throws a NoSuchEntityException
MGraph	getMGraph(UriRef name) Retrieves the MGraph (modifiable) with the given UriRef.
Set<UriRef>	getNames(Graph graph) Returns the names of a graph.
TripleCollection	getTriples(UriRef name) Generic implementation of the get(M)Graph method.
int	getWeight() Returns the weight of this provider.
Set<UriRef>	listGraphs() Returns the list of graphs in the virtuoso quad store.
Set<UriRef>	listMGraphs() Lists the name of the MGraphs available through this TcProvider, implementations may take into account the security context and omit MGraphs for which access is not allowed.
Set<UriRef>	listTripleCollections() Lists the name of the TripleCollections available through this TcProvider indifferently whether they are Graphs or an MGraphs, implementations may take into account the security context and omit TripleCollections for which access is not allowed.
void	setWeight(int weight) Sets the weight

Methods inherited from class java.lang.Object

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

Field Detail

DRIVER

public static final String DRIVER

See Also:

Constant Field Values

DEFAULT_WEIGHT

public static final int DEFAULT_WEIGHT

See Also:

Constant Field Values

HOST

public static final String HOST

See Also:

Constant Field Values

PORT

public static final String PORT

See Also:

Constant Field Values

USER

public static final String USER

See Also:

Constant Field Values

PASSWORD

public static final String PASSWORD

See Also:

Constant Field Values

WEIGHT

public static final String WEIGHT

See Also:

Constant Field Values

ACTIVE_GRAPHS_GRAPH

public static final String ACTIVE_GRAPHS_GRAPH

See Also:

Constant Field Values

Constructor Detail

VirtuosoWeightedProvider

public VirtuosoWeightedProvider()

Creates a new VirtuosoWeightedProvider. Before the weighted provider can be used, the method activate has to be called.

VirtuosoWeightedProvider

public VirtuosoWeightedProvider(String host,
                        Integer port,
                        String jdbcUser,
                        String jdbcPassword)

Method Detail

activate

@Activate
public void activate(org.osgi.service.component.ComponentContext cCtx)

Activates this component.

Parameters:

cCtx - Execution context of this component. A value of null is acceptable when you set the property connection

Throws:

org.osgi.service.cm.ConfigurationException

IllegalArgumentException - No component context given and connection was not set.

getConnectionString

public static final String getConnectionString(String hostName,
                         Integer portNumber)

deactivate

@Deactivate
public void deactivate(org.osgi.service.component.ComponentContext cCtx)

Deactivates this component.

Parameters:

cCtx - component context provided by OSGi

getConnection

public Connection getConnection()
                         throws SQLException

Throws:

SQLException

getGraph

public Graph getGraph(UriRef name)
               throws NoSuchEntityException

Retrieves the Graph (unmodifiable) with the given UriRef If no graph exists with such name, throws a NoSuchEntityException

Specified by:

getGraph in interface TcProvider

Parameters:

name - the name of the Graph

Returns:

the Graph with the specified name

Throws:

NoSuchEntityException - if there is no Graph with the specified name

getMGraph

public MGraph getMGraph(UriRef name)
                 throws NoSuchEntityException

Retrieves the MGraph (modifiable) with the given UriRef. If no graph exists with such name, throws a NoSuchEntityException.

Specified by:

getMGraph in interface TcProvider

Returns:

mgraph

Throws:

NoSuchEntityException - if there is no MGraph with the specified name

createDataAccess

public DataAccess createDataAccess()

getTriples

public TripleCollection getTriples(UriRef name)
                            throws NoSuchEntityException

Generic implementation of the get(M)Graph method. If the named graph is modifiable, behaves the same as getMGraph(UriRef name), elsewhere, behaves as getGraph(UriRef name)

Specified by:

getTriples in interface TcProvider

Parameters:

name - the name of the Graph or MGraph

Returns:

the Graph or MGraph

Throws:

NoSuchEntityException - if there is no Graph or MGraph with the specified name

listGraphs

public Set<UriRef> listGraphs()

Returns the list of graphs in the virtuoso quad store. The returned set is unmodifiable.

Specified by:

listGraphs in interface TcProvider

Returns:

graphs

listMGraphs

public Set<UriRef> listMGraphs()

Description copied from interface: TcProvider

Lists the name of the MGraphs available through this TcProvider, implementations may take into account the security context and omit MGraphs for which access is not allowed.

Specified by:

listMGraphs in interface TcProvider

Returns:

the list of MGraphs

canRead

public boolean canRead(UriRef graph)

canModify

public boolean canModify(UriRef graph)

listTripleCollections

public Set<UriRef> listTripleCollections()

Description copied from interface: TcProvider

Lists the name of the TripleCollections available through this TcProvider indifferently whether they are Graphs or an MGraphs, implementations may take into account the security context and omit TripleCollections for which access is not allowed.

Specified by:

listTripleCollections in interface TcProvider

Returns:

the list of TripleCollections

createMGraph

public MGraph createMGraph(UriRef name)
                    throws UnsupportedOperationException,
                           EntityAlreadyExistsException

Creates an initially empty MGraph. If the name already exists in the store, throws an EntityAlreadyExistsException

Specified by:

createMGraph in interface TcProvider

Parameters:

name - names the new MGraph

Returns:

the newly created MGraph

Throws:

UnsupportedOperationException - if this provider doesn't support creating MGraphS

EntityAlreadyExistsException - if an MGraph with the specified name already exists

createGraph

public Graph createGraph(UriRef name,
                TripleCollection triples)
                  throws UnsupportedOperationException,
                         EntityAlreadyExistsException

Creates a new graph with the given triples, then returns the readable (not modifiable) version of the graph

Specified by:

createGraph in interface TcProvider

Parameters:

name - the name of the Graph to be created

triples - the triples of the new Graph

Returns:

the newly created Graph

Throws:

UnsupportedOperationException - if this provider doesn't support creating GraphS

EntityAlreadyExistsException - if a Graph with the specified name already exists

deleteTripleCollection

public void deleteTripleCollection(UriRef name)
                            throws UnsupportedOperationException,
                                   NoSuchEntityException,
                                   EntityUndeletableException

Clears the given graph and removes it from the loaded graphs.

Specified by:

deleteTripleCollection in interface TcProvider

Parameters:

name - the entity to be removed

Throws:

UnsupportedOperationException - if this provider doesn't support entities deletion.

NoSuchEntityException - if name doesn't refer to a Graph or an MGraph.

EntityUndeletableException - if the specified Graph is undeletable

getNames

public Set<UriRef> getNames(Graph graph)

Returns the names of a graph. Personally don't know why a graph should have more then 1 identifier. Anyway, this does not happen with Virtuoso

Specified by:

getNames in interface TcProvider

Returns:

names

getWeight

public int getWeight()

Returns the weight of this provider.

Specified by:

getWeight in interface WeightedTcProvider

Returns:

a positive number indicating the weight of the provider

setWeight

public void setWeight(int weight)

Sets the weight

Parameters:

weight -

executeSparqlQuery

public Object executeSparqlQuery(String query,
                        UriRef defaultGraphUri)

Executes a SPARQL query

Specified by:

executeSparqlQuery in interface QueryableTcProvider

Parameters:

query - the sparql query to execute

Returns:

the resulting ResultSet, Graph or Boolean value