fix(duckdb): deduplicate results from list_schemas()

ibis/backends/duckdb/__init__.py

@@ -28,7 +28,8 @@
 import ibis.expr.schema as sch
 import ibis.expr.types as ir
 from ibis import util
-from ibis.backends.base.sql.alchemy import AlchemyCanCreateSchema, BaseAlchemyBackend
+from ibis.backends.base import CanCreateSchema
+from ibis.backends.base.sql.alchemy import BaseAlchemyBackend
 from ibis.backends.duckdb.compiler import DuckDBSQLCompiler
 from ibis.backends.duckdb.datatypes import DuckDBType, parse
 from ibis.expr.operations.relations import PandasDataFrameProxy
@@ -71,7 +72,7 @@ def _format_kwargs(kwargs: Mapping[str, Any]):
 }
 
 
-class Backend(BaseAlchemyBackend, AlchemyCanCreateSchema):
+class Backend(BaseAlchemyBackend, CanCreateSchema):
     name = "duckdb"
     compiler = DuckDBSQLCompiler
     supports_create_or_replace = True
@@ -82,6 +83,23 @@ def current_database(self) -> str:
         with self.begin() as con:
             return con.execute(query).scalar()
 
+    def list_schemas(self, like: str | None = None) -> list[str]:
+        s = sa.table(
+            "schemata",
+            sa.column("catalog_name", sa.TEXT()),
+            sa.column("schema_name", sa.TEXT()),
+            schema="information_schema",
+        )
+
+        where = s.c.catalog_name == sa.func.current_database()
+
+        if like is not None:
+            where &= s.c.schema_name.like(like)
+
+        query = sa.select(s.c.schema_name).select_from(s).where(where)
+        with self.begin() as con:
+            return list(con.execute(query).scalars())
+
     @staticmethod
     def _convert_kwargs(kwargs: MutableMapping) -> None:
         read_only = str(kwargs.pop("read_only", "False")).capitalize()

ibis/backends/tests/test_client.py

@@ -1342,7 +1342,8 @@ def test_create_schema(con_create_schema):
 
 
 def test_list_schemas(con_create_schema):
-    assert con_create_schema.list_schemas()
+    schemas = con_create_schema.list_schemas()
+    assert len(schemas) == len(set(schemas))
 
 
 @pytest.mark.notyet(["datafusion"], reason="cannot list or drop databases")