diff --git a/ibis/backends/datafusion/__init__.py b/ibis/backends/datafusion/__init__.py index 63ea71d52854..03bf78cf2fa3 100644 --- a/ibis/backends/datafusion/__init__.py +++ b/ibis/backends/datafusion/__init__.py @@ -644,7 +644,7 @@ def create_table( with self._safe_raw_sql(create_stmt): pass - return self.table(name, schema=database) + return self.table(name, database=database) def truncate_table( self, name: str, database: str | None = None, schema: str | None = None diff --git a/ibis/backends/duckdb/__init__.py b/ibis/backends/duckdb/__init__.py index abea8e8c5e0a..55f9aa1f232e 100644 --- a/ibis/backends/duckdb/__init__.py +++ b/ibis/backends/duckdb/__init__.py @@ -246,7 +246,7 @@ def create_table( ).sql(self.name) ) - return self.table(name, schema=database) + return self.table(name, database=database) def _load_into_cache(self, name, expr): self.create_table(name, expr, schema=expr.schema(), temp=True) @@ -1060,7 +1060,7 @@ def read_mysql( with self._safe_raw_sql(query_con): pass - return self.table(table_name, schema=database, database=catalog) + return self.table(table_name, database=(database, catalog)) def read_sqlite(self, path: str | Path, table_name: str | None = None) -> ir.Table: """Register a table from a SQLite database into a DuckDB table. diff --git a/ibis/backends/mssql/__init__.py b/ibis/backends/mssql/__init__.py index 365ca2019e5c..6ebdb259fd69 100644 --- a/ibis/backends/mssql/__init__.py +++ b/ibis/backends/mssql/__init__.py @@ -513,7 +513,7 @@ def create_table( cur.execute(f"EXEC sp_rename '{old}', '{new}'") if schema is None: - return self.table(name, schema=database) + return self.table(name, database=database) # preserve the input schema if it was provided return ops.DatabaseTable( diff --git a/ibis/backends/mysql/__init__.py b/ibis/backends/mysql/__init__.py index 40d3b568b3c6..f09768054d19 100644 --- a/ibis/backends/mysql/__init__.py +++ b/ibis/backends/mysql/__init__.py @@ -435,7 +435,7 @@ def create_table( ) if schema is None: - return self.table(name, schema=database) + return self.table(name, database=database) # preserve the input schema if it was provided return ops.DatabaseTable( diff --git a/ibis/backends/postgres/__init__.py b/ibis/backends/postgres/__init__.py index fbd351c1dc00..7a0ddcfd28bd 100644 --- a/ibis/backends/postgres/__init__.py +++ b/ibis/backends/postgres/__init__.py @@ -737,7 +737,7 @@ def create_table( ) if schema is None: - return self.table(name, schema=database) + return self.table(name, database=database) # preserve the input schema if it was provided return ops.DatabaseTable( diff --git a/ibis/backends/risingwave/__init__.py b/ibis/backends/risingwave/__init__.py index 0f6142c1f4a0..9456b00688b9 100644 --- a/ibis/backends/risingwave/__init__.py +++ b/ibis/backends/risingwave/__init__.py @@ -202,7 +202,7 @@ def create_table( ) if schema is None: - return self.table(name, schema=database) + return self.table(name, database=database) # preserve the input schema if it was provided return ops.DatabaseTable( diff --git a/ibis/tests/benchmarks/test_benchmarks.py b/ibis/tests/benchmarks/test_benchmarks.py index 5bf0db6a47c9..ac565aa98186 100644 --- a/ibis/tests/benchmarks/test_benchmarks.py +++ b/ibis/tests/benchmarks/test_benchmarks.py @@ -669,7 +669,7 @@ def test_snowflake_medium_sized_to_pandas(benchmark): # to make the benchmark fast enough for development, yet large enough to show a # difference if there's a performance hit lineitem = con.table( - "LINEITEM", schema="TPCH_SF1", database="SNOWFLAKE_SAMPLE_DATA" + "LINEITEM", database=("SNOWFLAKE_SAMPLE_DATA", "TPCH_SF1") ).limit(1_000_000) benchmark.pedantic(lineitem.to_pandas, rounds=5, iterations=1, warmup_rounds=1)