INDRA World Database (indra_world.service.db)

Database Manager (indra_world.service.db.manager)

class indra_world.service.db.manager.DbManager(url)

Manages transactions with the assembly database and exposes an API for various operations.

add_curation_for_project(project_id, stmt_hash, curation)

Add curations for a given project.

add_dart_record(reader, reader_version, document_id, storage_key, date, output_version=None, labels=None, tenants=None)

Insert a DART record into the database.

add_project(project_id, name, corpus_id=None)

Add a new project.

Parameters:

• project_id (str) – The project ID.

• name (str) – The project name

• corpus_id (Optional[str]) – The corpus ID from which the project was derived, if available.

add_records_for_project(project_id, record_keys)

Add document IDs for a project with the given ID.

add_statements_for_record(record_key, stmts, indra_version)

Add a set of prepared statements for a given document.

create_all()

Create all the database tables in the schema.

execute(operation)

Execute an insert operation on the current session and return results.

get_corpus_for_project(project_id)

Return the corpus ID that a project was derived from, if available.

get_curations_for_project(project_id)

Return curations for a given project

get_dart_records(reader=None, document_id=None, reader_version=None, output_version=None, labels=None, tenants=None)

Return storage keys for DART records given constraints.

get_full_dart_records(reader=None, document_id=None, reader_version=None, output_version=None, labels=None, tenants=None)

Return full DART records given constraints.

get_projects()

Retyurn a list of all projects.

get_session()

Return the current active session or create one if not available.

get_statements()

Return all prepared statements in the DB.

get_statements_for_document(document_id, reader=None, reader_version=None, indra_version=None)

Return prepared statements for a given document.

get_statements_for_record(record_key)

Return prepared statements for given record key.

get_statements_for_records(record_keys, batch_size=1000)

Return prepared statements for given list of record keys.

get_tenant_for_corpus(corpus_id)

Return the tenant for a given corpus, if available.

query(*query_args)

Run and return results of a generic query.

sql_query(query_str)

Run and return results of a generic SQL query.

Database Schema (indra_world.service.db.Schema)

class indra_world.service.db.schema.Corpora(**kwargs)

class indra_world.service.db.schema.CorpusRecords(**kwargs)

class indra_world.service.db.schema.Curations(**kwargs)

class indra_world.service.db.schema.DartRecords(**kwargs)

class indra_world.service.db.schema.Ontologies(**kwargs)

class indra_world.service.db.schema.PreparedStatements(**kwargs)

class indra_world.service.db.schema.ProjectRecords(**kwargs)

class indra_world.service.db.schema.Projects(**kwargs)