Modules

stardog.connection

stardog.admin

Administer a Stardog server.

class stardog.admin.Admin(endpoint='http://localhost:5820', username='admin', password='admin', auth=None, run_as=None)

Bases: object

Admin Connection.

This is the entry point for admin-related operations on a Stardog server. .. seealso:: Stardog Docs - Operating Stardog

__init__(endpoint='http://localhost:5820', username='admin', password='admin', auth=None, run_as=None)

Initializes an admin connection to a Stardog server.

Parameters:

• endpoint (Optional[str], default: 'http://localhost:5820') – URL of the Stardog server endpoint.

• username (Optional[str], default: 'admin') – Username to use in the connection.

• password (Optional[str], default: 'admin') – Password to use in the connection.

• auth (Optional[AuthBase], default: None) – requests.auth.AuthBase object. Used as an alternative authentication scheme. If not provided, HTTP Basic auth will be attempted with the username and password.

• run_as (Optional[str], default: None) – the user to impersonate

Note

auth and username/password should not be used together. If they are, the value of auth will take precedent.

Examples

>>> admin = Admin(endpoint='http://localhost:9999',
                  username='admin', password='admin')

alive()

Determine whether the server is running

Return type:

bool

Returns:

is the server alive?

backup_all(location=None)

Create a backup of all databases on the server. This is also known as a server backup.

Parameters:

location (Optional[str], default: None) – where to write the server backup to on the Stardog server’s file system.

Note

By default, backups are stored in the .backup directory in $STARDOG_HOME, but you can use the backup.dir property in your stardog.properties file to specify a different location for backups or you can override it using the location parameter.

cache(name)

Retrieve an object representing a cached dataset.

Parameters:

name (str) – the name of the cache to retrieve

Return type:

Cache

cache_status(*names)

Retrieves the status of one or more cached graphs.

Parameters:

names (str) – Names of the cached graphs to retrieve status for

Return type:

List[Dict]

Returns:

list of statuses

cache_targets()

Retrieves all cache targets.

Return type:

List[CacheTarget]

cached_graphs()

Retrieves all cached graphs.

Return type:

List[Cache]

cached_queries()

Retrieves all cached queries.

Warning

This method is deprecated in Stardog 8+

Return type:

List[Cache]

Returns:

cached queries

cached_status()

Retrieves all cached graphs.

Return type:

List[Cache]

clear_stored_queries()

Remove all stored queries on the server.

Return type:

None

cluster_coordinator_check()

Determine if a specific cluster node is the cluster coordinator

Return type:

bool

Returns:

whether the node is a coordinator or not.

cluster_info()

Prints info about the nodes in the Stardog cluster.

Return type:

Dict

Returns:

information about nodes in the cluster

cluster_join()

Instruct a standby node to join its cluster as a full node

Return type:

None

cluster_list_standby_nodes()

List standby nodes

Return type:

Dict

Returns:

all standby nodes in the cluster

cluster_revoke_standby_access(registry_id)

Instruct a standby node to stop syncing

Parameters:

registry_id (str) – ID of the standby node.

Return type:

None

cluster_shutdown()

Shutdown all nodes in the cluster

Return type:

bool

Returns:

whether the cluster was shutdown successfully or not.

cluster_start_readonly()

Start read only mode

Return type:

None

cluster_status()

Prints status information for each node in the cluster

Return type:

Dict

Returns:

status information about each node in the cluster

cluster_stop_readonly()

Stops read only mode

Return type:

None

database(name)

Retrieves an object representing a database.

Parameters:

name (str) – The database name

Return type:

Database

Returns:

the database

databases()

Retrieves all databases.

Return type:

List[Database]

datasource(name)

Retrieves an object representing a DataSource.

Parameters:

name (str) – The name of the data source

Return type:

DataSource

datasources()

Retrieves all data sources.

Return type:

List[DataSource]

datasources_info()

List all data sources with their details

Return type:

List[Dict]

Returns:

a list of data sources with their details

get_all_metadata_properties()

Get information on all database metadata properties, including description and example values

Return type:

Dict

Returns:

Metadata properties

See also

HTTP API - Get all database metadata properties

get_prometheus_metrics()

Return type:

str

get_server_metrics()

Returns metric information from the registry in JSON format

Return type:

Dict

Returns:

Server metrics

See also

HTTP API - Server metrics

get_server_properties()

Get the value of any set server-level properties

Return type:

Dict

Returns:

server properties

healthcheck()

Determine whether the server is running and able to accept traffic

Return type:

bool

Returns:

is the server accepting traffic?

import_file(db, mappings, input_file, options=None, named_graph=None)

Import a JSON or CSV file.

Parameters:

• db (str) – Name of the database to import the data

• mappings (Union[MappingRaw, MappingFile]) – Mappings specifying how to import the data contained in the CSV/JSON.

• input_file (Union[ImportFile, ImportRaw]) – the JSON or CSV file to import

• options (Optional[Dict], default: None) – Options for the import.

• named_graph (Optional[str], default: None) – The named graph to import the mapped CSV/JSON into.

Return type:

bool

Returns:

was the import successful?

import_virtual_graph(db, mappings, named_graph, remove_all, options)

Import (materialize) a virtual graph directly into the Stardog database.

Warning

Deprecated: stardog.admin.Admin.materialize_virtual_graph() should be preferred.

Parameters:

• db (str) – The database into which to import the graph

• mappings (Union[MappingRaw, MappingFile, str]) – New mapping contents. An empty string can be passed for autogenerated mappings.

• named_graph (str) – Name of the graph to import the virtual graph into.

• remove_all (Optional[bool]) – Should the target named graph be cleared before importing?

• options (Dict) – Options for the new virtual graph. See Stardog Docs - Virtual Graph Properties for all available options.

Return type:

None

Examples:

Import a MySQL virtual graph into the db-name database using the mappings specified in mappings.ttl. The virtual graph will be imported into the named graph my-graph and prior to the import will have its contents cleared.

admin.import_virtual_graph(
      'db-name',
      mappings=File('mappings.ttl'),
      named_graph='my-graph',
      remove_all=True,
      options={'jdbc.driver': 'com.mysql.jdbc.Driver'}
)

kill_query(id)

Kills a running query.

Parameters:

id (str) – ID of the query to kill

Return type:

None

materialize_virtual_graph(db, mappings, data_source=None, options=None, named_graph='tag:stardog:api:context:default', remove_all=False)

Import (materialize) a virtual graph directly into a database.

Parameters:

• db (str) – The database into which to import the graph

• mappings (Union[MappingFile, MappingRaw, str]) – New mapping contents. An empty string can be passed for autogenerated mappings.

• data_source (Optional[str], default: None) – The datasource to load from

• options (Optional[Dict], default: None) –

  Options for the new virtual graph, See Stardog Docs - Virtual Graph Properties for all available options.

• named_graph (Optional[str], default: 'tag:stardog:api:context:default') – Name of the graph into which import the virtual graph.

• remove_all (bool, default: False) – Should the target named graph be cleared before importing?

Note

data_source or options must be provided.

new_cache_target(name, hostname, port, username, password, use_existing_db=False)

Creates a new cache target.

Parameters:

• name (str) – The name of the cache target

• hostname (str) – The hostname of the cache target server

• port (int) – The port of the cache target server

• username (str) – The username for the cache target

• password (str) – The password for the cache target

• use_existing_db (bool, default: False) – If True, check for an existing cache database to use before creating a new one

Return type:

CacheTarget

Returns:

the new CacheTarget

new_cached_graph(name, target, graph, database=None, refresh_script=None, register_only=False)

Creates a new cached graph.

Parameters:

• name (str) – The name (URI) of the cached query

• target (str) – The name (URI) of the cache target

• graph (str) – The name of the graph to cache

• database (Optional[str], default: None) – The name of the database. Optional for virtual graphs, required for named graphs.

• refresh_script (Optional[str], default: None) – An optional SPARQL update query to run when refreshing the cache.

• register_only (bool, default: False) – An optional value that if True, register a cached dataset without loading data from the source graph or query into the cache target’s databases.

Return type:

Cache

Returns:

The new Cache

new_cached_query(name, target, query, database, refresh_script=None, register_only=False)

Creates a new cached query.

Warning

This method is deprecated in Stardog 8+

Parameters:

• name (str) – The name (URI) of the cached query

• target (str) – The name (URI) of the cache target

• query (str) – The query to cache

• database (str) – The name of the database

• refresh_script (Optional[str], default: None) – A SPARQL insert query to run when refreshing the cache

• register_only (bool, default: False) – If True, register a cached dataset without loading data from the source graph or query into the cache target’s databases

Return type:

Cache

Returns:

the new Cache

new_database(name, options=None, *contents, **kwargs)

Creates a new database.

Parameters:

• name (str) – the database name

• options (Optional[Dict], default: None) – Dictionary with database options

• contents (Union[Content, Tuple[Content, str], None]) – Datasets to perform bulk-load with. Named graphs are made with tuples of Content and the name.

Keyword Arguments:

copy_to_server – . If True, sends the files to the Stardog server; if running as a cluster, data will be replicated to all nodes in the cluster.

Return type:

Database

Examples

Options

>>> admin.new_database('db', {'search.enabled': True})

bulk-load

>>> admin.new_database('db', {},
                       File('example.ttl'), File('test.rdf'))

bulk-load to named graph

>>> admin.new_database('db', {}, (File('test.rdf'), 'urn:context'))

new_datasource(name, options)

Creates a new DataSource.

Parameters:

• name (str) – The name of the data source

• options (Dict) – Data Source options

Return type:

DataSource

Returns:

The new DataSource object

new_role(name)

Creates a new role.

Parameters:

name (str) – the name of the new role

Returns:

the new Role object

new_stored_query(name, query, options=None)

Creates a new Stored Query.

Parameters:

• name (str) – the name of the stored query

• query (str) – the query to store

• options (Optional[Dict], default: None) – Additional options (e.g. {"shared": True, "database": "myDb" })

Return type:

StoredQuery

Returns:

the new StoredQuery object

Examples:

Create a new stored query named all triples and make it only executable against the database mydb.

new_stored_query = admin.new_stored_query(
    'all triples',
    'select * where { ?s ?p ?o . }',
    { 'database': 'mydb' }
)

new_user(username, password, superuser=False)

Creates a new user.

Parameters:

• username (str) – The username

• password (str) – The password

• superuser (bool, default: False) – Create the user as a superuser. Only superusers can make other superusers.

Return type:

User

Returns:

The new User object

new_virtual_graph(name, mappings=None, options=None, datasource=None, db=None)

Creates a new Virtual Graph.

Parameters:

• name (str) – The name of the virtual graph.

• mappings (Union[MappingFile, MappingRaw, None], default: None) – New mapping contents. If None provided, mappings will be autogenerated.

• options (Optional[Dict], default: None) – Options for the new virtual graph. If None provided, then a datasource must be specified.

• datasource (Optional[str], default: None) – Name of the datasource to use. If None provided, options with a datasource key must be set.

• db (Optional[str], default: None) – Name of the database to associate the virtual graph. If None provided, the virtual graph will be associated with all databases.

Return type:

VirtualGraph

Returns:

the new VirtualGraph

Examples:

Create a new virtual graph named users and associate it with all databases. The SMS2 mappings are provided in the mappings.ttl file.

new_vg = admin.new_virtual_graph(
             name='users',
             mappings=MappingFile('mappings.ttl','SMS2'),
             datasource='my_datasource'
        )

queries()

Gets information about all running queries.

Return type:

Dict

Returns:

information about all running queries

query(id)

Gets information about a running query.

Parameters:

id (str) – Query ID

Return type:

Dict

Returns:

Query information

restore(from_path, *, name=None, force=False)

Restore a database.

Parameters:

• from_path (str) – the full path on the server’s file system to the backup

• name (Optional[str], default: None) – the name of the database to restore to if different from the backup

• force (Optional[bool], default: False) – by default, a backup will not be restored in place of an existing database of the same name; the force parameter should be used to overwrite the database

Return type:

None

Examples:

simple restore

admin.restore("/data/stardog/.backup/db/2019-12-01")

restore the backup and overwrite db2 database

admin.restore("/data/stardog/.backup/db/2019-11-05",
              name="db2", force=True)

See also

Stardog Docs - Restoring a Database

HTTP API - Restore a Database

role(name)

Retrieves a Role.

Parameters:

name (str) – The name of the role

Return type:

Role

roles()

Retrieves all roles.

Return type:

List[Role]

shutdown()

Shuts down the server.

Return type:

None

standby_node_pause(pause)

Pause/Unpause standby node

Parameters:

pause (bool) – True should be provided to pause the standby node. False should be provided to unpause.

Return type:

bool

Returns:

whether the pause status was successfully changed or not.

standby_node_pause_status()

Get the pause status of a standby node

Return type:

Dict

Returns:

Pause status of a standby node, possible values are: WAITING, SYNCING, PAUSING, PAUSED

See also

HTTP API - Get Paused State of Standby Node

stored_queries()

Retrieves all stored queries.

Return type:

List[StoredQuery]

stored_query(name)

Retrieves a Stored Query.

Parameters:

name (str) – The name of the stored query to retrieve

Return type:

StoredQuery

user(name)

Retrieves a User object.

Parameters:

name (str) – The name of the user

Return type:

User

users()

Retrieves all users.

Return type:

List[User]

validate()

Validates an admin connection.

Return type:

bool

Returns:

whether the connection is valid or not

virtual_graph(name)

Retrieves a Virtual Graph.

Parameters:

name (str) – The name of the virtual graph to retrieve

Return type:

VirtualGraph

virtual_graphs()

Retrieves all virtual graphs.

Return type:

List[VirtualGraph]

class stardog.admin.Cache(name, client)

Bases: object

Cached data

A cached dataset from a query or named/virtual graph.

See also

Stardog Docs - Cache Management

__init__(name, client)

Initializes a new cached dataset from a query or named/virtual graph.

Use stardog.admin.Admin.new_cached_graph() or stardog.admin.Admin.new_cached_query() instead of constructing manually.

drop()

Drops the cache.

Return type:

None

refresh()

Refreshes the cache.

Return type:

None

status()

Retrieves the status of the cache.

Return type:

Dict

class stardog.admin.CacheTarget(name, client)

Bases: object

Cache Target Server

__init__(name, client)

Initializes a cache target.

Use stardog.admin.Admin.new_cache_target() instead of constructing manually.

info()

Get info for the cache target

Returns:

Info

Return type:

dict

property name

The name (URI) of the cache target.

orphan()

Orphans the cache target but do not destroy its contents.

remove()

Removes the cache target and destroy its contents.

class stardog.admin.DataSource(name, client)

Bases: object

Initializes a DataSource

See also

Stardog Docs - Data Sources

__init__(name, client)

Initializes a DataSource.

Use stardog.admin.Admin.data_source(), stardog.admin.Admin.data_sources(), or stardog.admin.Admin.new_data_source() instead of constructing manually.

available()

Checks if the data source is available.

Return type:

bool

Returns:

whether the data source is available or not

delete()

Deletes a data source

Return type:

None

get_options()

Get data source options

Return type:

List[Dict]

info()

Get data source info

Return type:

Dict

Returns:

data source information

property name: str

The name of the data source.

online()

Online a data source

Return type:

None

refresh_count(meta=None)

Refresh table row-count estimates

Parameters:

meta (Optional[Dict], default: None) – dict containing the table to refresh. Examples: {"name": "catalog.schema.table"}, {"name": "schema.table"}, {"name": "table"}

Return type:

None

See also

HTTP API - Refresh table row-count estimates

refresh_metadata(meta=None)

Refresh metadata for one or all tables that are accessible to a data source. Will clear the saved metadata for a data source and reload all of its dependent virtual graphs with fresh metadata.

Parameters:

meta (Optional[Dict], default: None) – dict containing the table to refresh. Examples: {"name": "catalog.schema.table"}, {"name": "schema.table"}, {"name": "table"}

Return type:

None

See also

Stardog Docs - Refreshing Data Source Metadata

HTTP API - Refresh Data Source Metadata

Stardog CLI - stardog-admin data-source refresh-metadata

share()

Share a private data source. When a virtual graph is created without specifying a data source name, a private data source is created for that, and only that virtual graph. This methods makes the data source available to other virtual graphs, as well as decouples the data source life cycle from the original virtual graph.

Return type:

None

update(options=None, force=False)

Update data source

Parameters:

• options (Optional[Dict], default: None) – Dict with data source options

• force (bool, default: False) – a data source will not be updated while in use unless force=True

Return type:

None

Examples

>>> admin.update({"sql.dialect": "MYSQL"})
>>> admin.update({"sql.dialect": "MYSQL"}, force=True)

See also

Stardog Docs - DataSource options

class stardog.admin.Database(name, client)

Bases: object

Represents a Stardog database.

__init__(name, client)

Initializes a Database.

Use stardog.admin.Admin.database(), stardog.admin.Admin.databases(), or stardog.admin.Admin.new_database() instead of constructing manually.

add_namespace(prefix, iri)

Adds a specific namespace to a database

Parameters:

• prefix (str) – the prefix of the namespace to be added

• iri (str) – the iri associated with the prefix to be added

Return type:

bool

Returns:

whether the operation succeeded or not.

backup(*, to=None)

Create a backup of a database on the server.

Parameters:

to (Optional[str], default: None) – specify a path on the Stardog server’s file system to store the backup

Return type:

None

See also

Stardog Docs - Backup a Database

copy(to)

Makes a copy of this database under another name.

Warning

This method is deprecated and not valid for Stardog versions 6+.

The database must be offline.

Parameters:

to (str) – Name of the new database to be created

Returns:

The new Database

Return type:

Database

drop()

Drops the database.

Return type:

None

get_all_options()

Get the value of every metadata option for a database

Return type:

Dict

Returns:

All database metadata

get_options(*options)

Get the value of specific metadata options for a database

Parameters:

options (str) – Database option names

Return type:

Dict

Returns:

Database options

Examples

>>> db.get_options('search.enabled', 'spatial.enabled')

import_namespaces(content)

Imports namespace prefixes from an RDF file that contains prefix declarations into the database, overriding any previous mappings for those prefixes. Only the prefix declarations in the file are processed, the rest of the file is not parsed.

Parameters:

content (Content) – RDF File containing prefix declarations

Return type:

Dict

Returns:

Dictionary with all namespaces after import

property name: str

The name of the database.

namespaces()

Retrieve the namespaces stored in the database

Return type:

Dict

Returns:

A dict listing the prefixes and IRIs of the stored namespaces

See also

HTTPI API - Get Namespaces

offline()

Sets a database to offline state.

Return type:

None

online()

Sets a database to online state.

Return type:

None

optimize()

Optimizes a database.

Return type:

None

remove_namespace(prefix)

Removes a specific namespace from a database

Parameters:

prefix (str) – the prefix of the namespace to be removed

Return type:

bool

Returns:

whether the operation succeeded or not.

repair()

Attempt to recover a corrupted database.

Note

The database must be offline.

Return type:

bool

Returns:

whether the database was successfully repaired or not

set_options(options)

Sets database options.

Parameters:

options (Dict) – Database options

Return type:

None

Note

The database must be offline to set some options (e.g. search.enabled).

Examples

>>> db.set_options({'spatial.enabled': False})

verify()

verifies a database.

Return type:

None

class stardog.admin.Role(name, client)

Bases: object

See also

Stardog Docs - Authorization

__init__(name, client)

Initializes a Role.

Use stardog.admin.Admin.role(), stardog.admin.Admin.roles(), or stardog.admin.Admin.new_role() instead of constructing manually.

add_permission(action, resource_type, resource)

Adds a permission to the role.

See also

Stardog Docs - Grant Permissions to a Role

HTTP API - Grant Permission to Role

Parameters:

• action (str) – Action type (e.g., ‘read’, ‘write’)

• resource_type (str) – Resource type (e.g., ‘user’, ‘db’)

• resource (str) – Target resource (e.g., ‘username’, ‘*’)

Examples

>>> role.add_permission('read', 'user', 'username')
>>> role.add_permission('write', '*', '*')

delete(force=None)

Deletes the role.

Parameters:

force (bool) – Force deletion of the role

property name

The name of the Role.

permissions()

Gets the role permissions.

See also

HTTP API - Get Role Permissions

Returns:

Role permissions

Return type:

dict

remove_permission(action, resource_type, resource)

Removes a permission from the role.

See also

HTTP API - Revoke Role Permission

Parameters:

• action (str) – Action type (e.g., ‘read’, ‘write’)

• resource_type (str) – Resource type (e.g., ‘user’, ‘db’)

• resource (str) – Target resource (e.g., ‘username’, ‘*’)

Examples

>>> role.remove_permission('read', 'user', 'username')
>>> role.remove_permission('write', '*', '*')

users()

Lists the users for this role.

Returns:

list[User]

class stardog.admin.StoredQuery(name, client, details=None)

Bases: object

Stored Query

See also

Stardog Docs - Stored Queries

__init__(name, client, details=None)

Initializes a stored query.

Use stardog.admin.Admin.stored_query(), stardog.admin.Admin.stored_queries(), or stardog.admin.Admin.new_stored_query() instead of constructing manually.

property creator: str

The creator of the stored query.

property database: str

The database the stored query applies to.

delete()

Deletes the Stored Query.

Return type:

None

property description: str

The description of the stored query.

property name: str

The name of the stored query.

property query: str

The text of the stored query.

property reasoning: bool

The value of the reasoning property.

property shared: bool

The value of the shared property.

update(**options)

Updates the Stored Query.

Return type:

None

Parameters:

**options (str) – Named arguments to update.

Examples

Update description

>>> stored_query.update(description='this query finds all the relevant...')

class stardog.admin.User(name, client)

Bases: object

Represents a Stardog user

__init__(name, client)

Initializes a User.

Use stardog.admin.Admin.user(), stardog.admin.Admin.users(), or stardog.admin.Admin.new_user() instead of constructing manually.

add_permission(action, resource_type, resource)

Add a permission to the user.

Parameters:

• action (str) – Action type (e.g., read, write)

• resource_type (str) – Resource type (e.g., user, db)

• resource (str) – Target resource (e.g., username, *)

Return type:

None

See also

Stardog Docs - Grant Permissions to a User

HTTP API - Grant permission to a User

Examples

>>> user.add_permission('read', 'user', 'username')
>>> user.add_permission('write', '*', '*')

add_role(role)

Adds an existing role to the user.

Parameters:

role (Union[Role, str]) – The stardog.admin.Role or name of the role to add

Return type:

None

Examples

>>> user.add_role('reader')
>>> user.add_role(admin.role('reader'))

delete()

Deletes the user.

Return type:

None

effective_permissions()

Gets the user’s effective permissions.

Return type:

Dict

Returns:

User’s effective permissions

is_enabled()

Checks if the user is enabled.

Return type:

bool

Returns:

whether the user is enabled or not

is_superuser()

Checks if the user is a superuser.

Return type:

bool

Returns:

whether the user is a superuser or not.

property name: str

The username.

permissions()

Gets the user permissions.

See also

Stardog Docs - Permissions

Return type:

Dict

Returns:

user permissions

remove_permission(action, resource_type, resource)

Removes a permission from the user.

Parameters:

• action (str) – Action type (e.g., read, write)

• resource_type (str) – Resource type (e.g., user, db)

• resource (str) – Target resource (e.g., username, *)

See also

HTTP API - Revoke User Permission

Examples

>>> user.remove_permission('read', 'user', 'username')
>>> user.remove_permission('write', '*', '*')

remove_role(role)

Removes a role from the user.

Parameters:

role (Union[str, Role]) – The stardog.admin.Role or name of the role to remove

Return type:

None

Examples

>>> user.remove_role('reader')
>>> user.remove_role(admin.role('reader'))

roles()

Gets all the User’s roles.

Return type:

List[Role]

set_enabled(enabled)

Enables or disables the user.

Parameters:

enabled (bool) – Desired state. True for enabled, False for disabled.

Return type:

None

set_password(password)

Sets a new password.

Parameters:

password (str) – the new password for the user

Return type:

None

set_roles(*roles)

Sets the roles of the user.

Parameters:

roles (Union[str, Role]) – The stardog.admin.Role (s) or name of the role(s) to add to the user

Return type:

None

Examples

>>> user.set_roles('reader', admin.role('writer'))

class stardog.admin.VirtualGraph(name, client)

Bases: object

Virtual Graph

See also

Stardog Docs - Virtual Graphs

__init__(name, client)

Initializes a virtual graph.

Use stardog.admin.Admin.virtual_graph(), stardog.admin.Admin.virtual_graphs(), or stardog.admin.Admin.new_virtual_graph() instead of constructing manually.

available()

Checks if the virtual graph is available.

Return type:

bool

Returns:

whether the virtual graph is available or not

delete()

Deletes the virtual graph.

Return type:

None

get_database()

Gets database associated with the virtual graph.

Return type:

str

Returns:

the database name

get_datasource()

Gets datasource associated with the virtual graph

Return type:

str

Returns:

datasource name with data-source:// prefix removed

info()

Gets virtual graph info.

Return type:

Dict

mappings(content_type='text/turtle')

Gets the Virtual Graph mappings

Warning

Deprecated: stardog.admin.VirtualGraph.mappings_string() should be preferred.

Parameters:

content_type (str, default: 'text/turtle') – Content type for mappings.

Return type:

bytes

Returns:

Mappings in given content type

mappings_string(syntax='SMS')

Returns graph mappings from virtual graph

Parameters:

syntax (str, default: 'SMS') – The desired syntax of the mappings ('STARDOG', 'R2RML', or 'SMS2').

Returns:

Mappings in desired syntax

property name: str

The name of the virtual graph.

options()

Gets virtual graph options.

Return type:

Dict

update(name, mappings, options={}, datasource=None, db=None)

Updates the Virtual Graph.

Parameters:

• name (str) – The new name

• mappings (Content) – New mapping contents

• options (Dict, default: {}) – New virtual graph options

• datasource (Optional[str], default: None) – new data source for the virtual graph

• db (Optional[str], default: None) – the database to associate with the virtual graph

Return type:

None

Examples:

vg.update(
        name='users',
        mappings=File('mappings.ttl'),
        options={'jdbc.driver': 'com.mysql.jdbc.Driver'}
)

stardog.content

Content that can be loaded into Stardog.

class stardog.content.Content

Bases: object

Content base class.

class stardog.content.File(file=None, content_type=None, content_encoding=None, name=None, fname=None)

Bases: Content

File-based content.

__init__(file=None, content_type=None, content_encoding=None, name=None, fname=None)

Initializes a File object.

Parameters:

• file (Optional[str], default: None) – the filename/path of the file

• content_type (Optional[str], default: None) – Content type. It will be automatically detected from the filename

• content_encoding (Optional[str], default: None) – Content encoding. It will be automatically detected from the filename

• name (Optional[str], default: None) – Name of the file object. It will be automatically detected from the filename

• fname (Optional[str], default: None) – backward compatible parameter for file

Examples

>>> File('data.ttl')
>>> File('data.doc', 'application/msword')

data()

class stardog.content.ImportFile(file, input_type=None, content_type=None, content_encoding=None, separator=None, name=None, iri=None)

Bases: Content

File-based content for Delimited and JSON file.

__init__(file, input_type=None, content_type=None, content_encoding=None, separator=None, name=None, iri=None)

Initializes a File object.

Parameters:

• file (str) – filename/path of the file

• input_type (Optional[str], default: None) – 'DELIMITED' or 'JSON'

• content_type (Optional[str], default: None) – Content type

• content_encoding (Optional[str], default: None) – Content encoding

• separator (Optional[str], default: None) – Required if input_type is 'DELIMITED'. Use ',' for a CSV. Use \\t for a TSV.

• name (Optional[str], default: None) – Object name. It will be automatically detected from the file if omitted.

• iri (Optional[str], default: None) – IRI that uniquely identifies this file. It will default to “file://name” if omitted.

Note

If file has a recognized extension (i.e. 'data.csv', 'data.tsv', or 'data.json'), it will auto-detect most required parameters (input_type, separator, content_type, content_encoding) - otherwise you must specify them.

Examples

>>> ImportFile('data.csv')
>>> ImportFile('data.tsv')
>>> ImportFile('data.txt','DELIMITED',"\\t" )
>>> ImportFile('data.json')

data()

class stardog.content.ImportRaw(content, input_type=None, separator=None, content_type=None, content_encoding=None, name=None, iri=None)

Bases: Content

User-defined content.

__init__(content, input_type=None, separator=None, content_type=None, content_encoding=None, name=None, iri=None)

Initializes a Raw object.

Parameters:

• content (object) – Object representing the content (e.g., str, file)

• input_type (Optional[str], default: None) – 'DELIMITED' or 'JSON'

• separator (Optional[str], default: None) – Required if input_type is 'DELIMITED'. Use ',' for a CSV. Use \\t for a TSV.

• content_type (Optional[str], default: None) – Content type

• content_encoding (Optional[str], default: None) – Content encoding

• name (Optional[str], default: None) – Object name

• iri (Optional[str], default: None) – IRI that uniquely identifies this content. It will default to “file://name” if omitted.

Note

if name is provided like a pseudo filename (i.e. 'data.csv', 'data.tsv', or 'data.json'), it will auto-detect most required parameters (input_type, separator, content_type, content_encoding) - otherwise you must specify them.

Examples

>>> ImportRaw('a,b,c',  name='data.csv')
>>> ImportRaw('a      b       c', name='data.tsv')
>>> ImportRaw({'foo':'bar'}, name='data.json')

data()

class stardog.content.MappingFile(file, syntax=None, name=None)

Bases: Content

File-based content.

__init__(file, syntax=None, name=None)

Initializes a File object.

Parameters:

• file (str) – the filename/path of the file

• syntax (Optional[str], default: None) – The mapping syntax ('STARDOG', 'R2RML', or 'SMS2') If not provided, it will try to detect it from the file’s extension.

• name (Optional[str], default: None) – the name of the object. If not provided, will fall back to the basename of the file.

Examples

>>> MappingFile('data.sms')
>>> MappingFile('data.sms2')
>>> MappingFile('data.rq')
>>> MappingFile('data.r2rml')

data()

class stardog.content.MappingRaw(content, syntax=None, name=None)

Bases: Content

User-defined Mapping.

__init__(content, syntax=None, name=None)

Initializes a MappingRaw object.

Parameters:

• content (str) – the actual mapping content (e.g. 'MAPPING\n FROM SQL ...')

• syntax (Optional[str], default: None) – The mapping syntax ('STARDOG', 'R2RML', or 'SMS2') If not provided, it will try to detect it from name if provided, otherwise from the content itself

• name (Optional[str], default: None) – name of object

Examples

>>> mapping = '''
MAPPING
FROM SQL {
  SELECT *
  FROM `benchmark`.`person`
}
TO {
  ?subject rdf:type :person
} WHERE {
  BIND(template("http://api.stardog.com/person/nr={nr}") AS ?subject)
}
'''
>>> MappingRaw(mapping)

data()

class stardog.content.Raw(content, content_type=None, content_encoding=None, name=None)

Bases: Content

User-defined content.

__init__(content, content_type=None, content_encoding=None, name=None)

Initializes a Raw object.

Parameters:

• content (object) – Object representing the content (e.g., str, file)

• content_type (Optional[str], default: None) – Content type

• content_encoding (Optional[str], default: None) – Content encoding

• name (Optional[str], default: None) – Object name

Examples

>>> Raw(':luke a :Human', 'text/turtle', name='data.ttl')
>>> Raw(':βüãäoñr̈ a :Employee .'.encode('utf-8'), 'text/turtle')

data()

class stardog.content.URL(url, content_type=None, content_encoding=None, name=None)

Bases: Content

Url-based content.

__init__(url, content_type=None, content_encoding=None, name=None)

Initializes a URL object.

Parameters:

• url (str) – URL to the content

• content_type (Optional[str], default: None) – Content type. It will be automatically detected from the url if not provided.

• content_encoding (Optional[str], default: None) – Content encoding. It will be automatically detected from the url if not provided.

• name (Optional[str], default: None) – Object name. It will be automatically detected from the url if not provided.

Examples

>>> URL('http://example.com/data.ttl')
>>> URL('http://example.com/data.doc', 'application/msword')

data()

stardog.results

stardog.exceptions

exception stardog.exceptions.StardogException(message, http_code=None, stardog_code=None)

Bases: Exception

General Stardog Exceptions

exception stardog.exceptions.TransactionException(message, http_code=None, stardog_code=None)

Bases: StardogException

Transaction Exceptions