diff --git a/src/based/db.py b/src/based/db.py index 2203e48..da2ba17 100644 --- a/src/based/db.py +++ b/src/based/db.py @@ -137,6 +137,13 @@ class DBConnector: conn.execute(stmt) self.removeTableMetadata(table_name) + def getTable(self, table_name: str): + stmt = SQL("SELECT * FROM tables_metadata WHERE table_name = {}").format( + Literal(table_name) + ) + with self.connection() as conn: + return conn.execute(stmt).fetchone() + def insertIntoTable(self, table_name: str, columns: dict[str, Any]): if len(columns) == 0: stmt = SQL("INSERT INTO {} DEFAULT VALUES").format(Identifier(table_name))