aea.helpers.storage.backends.sqlite

This module contains sqlite storage backend implementation.

SqliteStorageBackend Objects

class SqliteStorageBackend(AbstractStorageBackend)

Sqlite storage backend.

__init__

 | __init__(uri: str) -> None

Init backend.

connect

 | async connect() -> None

Connect to backend.

disconnect

 | async disconnect() -> None

Disconnect the backend.

ensure_collection

 | async ensure_collection(collection_name: str) -> None

Create collection if not exits.

Arguments:

• collection_name: str.

Returns:

None

put

 | async put(collection_name: str, object_id: str, object_body: JSON_TYPES) -> None

Put object into collection.

Arguments:

• collection_name: str.
• object_id: str object id
• object_body: python dict, json compatible.

Returns:

None

get

 | async get(collection_name: str, object_id: str) -> Optional[JSON_TYPES]

Get object from the collection.

Arguments:

• collection_name: str.
• object_id: str object id

Returns:

dict if object exists in collection otherwise None

remove

 | async remove(collection_name: str, object_id: str) -> None

Remove object from the collection.

Arguments:

• collection_name: str.
• object_id: str object id

Returns:

None

find

 | async find(collection_name: str, field: str, equals: EQUALS_TYPE) -> List[OBJECT_ID_AND_BODY]

Get objects from the collection by filtering by field value.

Arguments:

• collection_name: str.
• field: field name to search: example "parent.field"
• equals: value field should be equal to

Returns:

None

list

 | async list(collection_name: str) -> List[OBJECT_ID_AND_BODY]

List all objects with keys from the collection.

Arguments:

• collection_name: str.

Returns:

Tuple of objects keys, bodies.