From aa842fc3d9e205b6034720ba69858677a28067e1 Mon Sep 17 00:00:00 2001
From: junjun <junjie.xia@fit2cloud.com>
Date: Wed, 20 Aug 2025 15:38:12 +0800
Subject: [PATCH] feat: support Apache Doris datasource

---
 backend/apps/db/db_sql.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/backend/apps/db/db_sql.py b/backend/apps/db/db_sql.py
index 5b04a8dd..54be1617 100644
--- a/backend/apps/db/db_sql.py
+++ b/backend/apps/db/db_sql.py
@@ -115,7 +115,7 @@ def get_field_sql(ds: CoreDatasource, conf: DatasourceConf, table_name: str = No
         sql2 = f" AND C.TABLE_NAME = '{table_name}'" if table_name is not None and table_name != "" else ""
         return sql1 + sql2
     elif ds.type == "pg" or ds.type == "excel":
-        sql1 = """
+        sql1 = f"""
                SELECT a.attname                                       AS COLUMN_NAME,
                       pg_catalog.format_type(a.atttypid, a.atttypmod) AS DATA_TYPE,
                       col_description(c.oid, a.attnum)                AS COLUMN_COMMENT
@@ -124,7 +124,7 @@ def get_field_sql(ds: CoreDatasource, conf: DatasourceConf, table_name: str = No
                     pg_catalog.pg_class c ON a.attrelid = c.oid
                         JOIN
                     pg_catalog.pg_namespace n ON n.oid = c.relnamespace
-               WHERE n.nspname = current_schema()
+               WHERE n.nspname = '{conf.dbSchema}'
                  AND a.attnum > 0
                  AND NOT a.attisdropped \
                """