diff --git a/pyproject.toml b/pyproject.toml index a3d5149..2df337a 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,7 +1,7 @@ [project] # https://pip.pypa.io/en/stable/reference/build-system/pyproject-toml/ name = 'questdb-connect' -version = '1.1.4' # Standalone production version (with engine) +version = '1.1.5' # Standalone production version (with engine) # version = '0.0.113' # testing version authors = [{ name = 'questdb.io', email = 'support@questdb.io' }] description = "SqlAlchemy library" diff --git a/src/questdb_connect/dialect.py b/src/questdb_connect/dialect.py index c547dc1..4a236b4 100644 --- a/src/questdb_connect/dialect.py +++ b/src/questdb_connect/dialect.py @@ -79,7 +79,7 @@ def get_schema_names(self, conn, **kw): def get_table_names(self, conn, schema=None, **kw): return [row.table_name for row in self._exec(conn, "SHOW tables")] - def has_table(self, conn, table_name, schema=None): + def has_table(self, conn, table_name, schema=None, **kw): return table_name in set(self.get_table_names(conn, schema)) @sqlalchemy.engine.reflection.cache diff --git a/tests/test_dialect.py b/tests/test_dialect.py index ba529cf..26aa19f 100644 --- a/tests/test_dialect.py +++ b/tests/test_dialect.py @@ -244,6 +244,8 @@ def test_dialect_has_table(test_engine): raise AssertionError() if not dialect.has_table(conn, table_name, schema="public"): raise AssertionError() + if not dialect.has_table(conn, table_name, schema="questdb", kw={'key': "value"}): + raise AssertionError() def test_functions(test_engine):