| 18 | |
| 19 | class SqliteEntityStorage(sqlite_dao.SqliteStorage, IEntityStorage): |
| 20 | def __init__(self, get_connection, schema, owner=None): |
| 21 | # type: (Callable[[], sqlite3.Connection], sqlite_dao.TableSchema, Union[str, int, None]) -> None |
| 22 | |
| 23 | super(SqliteEntityStorage, self).__init__(get_connection, schema, owner) |
| 24 | if len(self.schema.primary_key) != 1: |
| 25 | raise ValueError(f'SqliteEntityStorage: Primary key to have one column.') |
| 26 | |
| 27 | def get_entity(self, uid): |
| 28 | results = list(self.select_by_filter(self.schema.primary_key, [uid])) |