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 idobject_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.