fix(conn): database conn fix special symbols (#898)

pilot/base_modules/meta_data/meta_data.py

@@ -11,6 +11,7 @@
 from alembic.config import Config as AlembicConfig
 from urllib.parse import quote
 from pilot.configs.config import Config
+from urllib.parse import quote_plus as urlquote
 
 
 logger = logging.getLogger(__name__)
@@ -29,14 +30,7 @@
 
 if CFG.LOCAL_DB_TYPE == "mysql":
     engine_temp = create_engine(
-        f"mysql+pymysql://"
-        + quote(CFG.LOCAL_DB_USER)
-        + ":"
-        + quote(CFG.LOCAL_DB_PASSWORD)
-        + "@"
-        + CFG.LOCAL_DB_HOST
-        + ":"
-        + str(CFG.LOCAL_DB_PORT)
+        f"mysql+pymysql://{quote(CFG.LOCAL_DB_USER)}:{urlquote(CFG.LOCAL_DB_PASSWORD)}@{CFG.LOCAL_DB_HOST}:{str(CFG.LOCAL_DB_PORT)}"
     )
     # check and auto create mysqldatabase
     try:
@@ -51,15 +45,7 @@
         logger.error(f"{db_name} not connect success!")
 
     engine = create_engine(
-        f"mysql+pymysql://"
-        + quote(CFG.LOCAL_DB_USER)
-        + ":"
-        + quote(CFG.LOCAL_DB_PASSWORD)
-        + "@"
-        + CFG.LOCAL_DB_HOST
-        + ":"
-        + str(CFG.LOCAL_DB_PORT)
-        + f"/{db_name}"
+        f"mysql+pymysql://{quote(CFG.LOCAL_DB_USER)}:{urlquote(CFG.LOCAL_DB_PASSWORD)}@{CFG.LOCAL_DB_HOST}:{str(CFG.LOCAL_DB_PORT)}/{db_name}"
     )
 else:
     engine = create_engine(f"sqlite:///{db_path}")

pilot/connections/rdbms/base.py

@@ -1,9 +1,10 @@
 from __future__ import annotations
-from urllib.parse import quote
 import warnings
 import sqlparse
 import regex as re
 import pandas as pd
+from urllib.parse import quote
+from urllib.parse import quote_plus as urlquote
 from typing import Any, Iterable, List, Optional
 from pydantic import BaseModel, Field, root_validator, validator, Extra
 from abc import ABC, abstractmethod
@@ -113,17 +114,7 @@ def from_uri_db(
             engine_args (Optional[dict]):other engine_args.
         """
         db_url: str = (
-            cls.driver
-            + "://"
-            + quote(user)
-            + ":"
-            + quote(pwd)
-            + "@"
-            + host
-            + ":"
-            + str(port)
-            + "/"
-            + db_name
+            f"{cls.driver}://{quote(user)}:{urlquote(pwd)}@{host}:{str(port)}/{db_name}"
         )
         return cls.from_uri(db_url, engine_args, **kwargs)
 

pilot/connections/rdbms/conn_clickhouse.py

@@ -1,6 +1,8 @@
 import re
 from typing import Optional, Any
 from sqlalchemy import text
+from urllib.parse import quote
+from urllib.parse import quote_plus as urlquote
 
 from pilot.connections.rdbms.base import RDBMSDatabase
 
@@ -30,17 +32,7 @@ def from_uri_db(
         **kwargs: Any,
     ) -> RDBMSDatabase:
         db_url: str = (
-            cls.driver
-            + "://"
-            + user
-            + ":"
-            + pwd
-            + "@"
-            + host
-            + ":"
-            + str(port)
-            + "/"
-            + db_name
+            f"{cls.driver}://{quote(user)}:{urlquote(pwd)}@{host}:{str(port)}/{db_name}"
         )
         return cls.from_uri(db_url, engine_args, **kwargs)
 

pilot/connections/rdbms/conn_duckdb.py

@@ -82,25 +82,3 @@ def table_simple_info(self) -> Iterable[str]:
 
             results.append(f"{table_name}({','.join(table_colums)});")
         return results
-
-
-if __name__ == "__main__":
-    engine = create_engine(
-        "duckdb:////Users/tuyang.yhj/Code/PycharmProjects/DB-GPT/pilot/mock_datas/db-gpt-test.db"
-    )
-    metadata = MetaData(engine)
-
-    results = (
-        engine.connect()
-        .execute("SELECT name FROM sqlite_master WHERE type='table'")
-        .fetchall()
-    )
-
-    print(str(results))
-
-    fields = []
-    results2 = engine.connect().execute(f"""PRAGMA  table_info(user)""").fetchall()
-    for row_col in results2:
-        field_info = list(row_col)
-        fields.append(field_info[1])
-    print(str(fields))

pilot/connections/rdbms/conn_postgresql.py

@@ -1,6 +1,7 @@
 from typing import Iterable, Optional, Any
 from sqlalchemy import text
 from urllib.parse import quote
+from urllib.parse import quote_plus as urlquote
 from pilot.connections.rdbms.base import RDBMSDatabase
 
 
@@ -21,17 +22,7 @@ def from_uri_db(
         **kwargs: Any,
     ) -> RDBMSDatabase:
         db_url: str = (
-            cls.driver
-            + "://"
-            + quote(user)
-            + ":"
-            + quote(pwd)
-            + "@"
-            + host
-            + ":"
-            + str(port)
-            + "/"
-            + db_name
+            f"{cls.driver}://{quote(user)}:{urlquote(pwd)}@{host}:{str(port)}/{db_name}"
         )
         return cls.from_uri(db_url, engine_args, **kwargs)
 

pilot/connections/rdbms/conn_starrocks.py

@@ -1,7 +1,7 @@
 from typing import Iterable, Optional, Any
 from sqlalchemy import text
 from urllib.parse import quote
-import re
+from urllib.parse import quote_plus as urlquote
 from pilot.connections.rdbms.base import RDBMSDatabase
 from pilot.connections.rdbms.dialect.starrocks.sqlalchemy import *
 
@@ -23,7 +23,7 @@ def from_uri_db(
         **kwargs: Any,
     ) -> RDBMSDatabase:
         db_url: str = (
-            f"{cls.driver}://{quote(user)}:{quote(pwd)}@{host}:{str(port)}/{db_name}"
+            f"{cls.driver}://{quote(user)}:{urlquote(pwd)}@{host}:{str(port)}/{db_name}"
         )
         return cls.from_uri(db_url, engine_args, **kwargs)