This commit is contained in:
dataeaseShu
2025-07-22 16:54:34 +08:00
2 changed files with 8 additions and 3 deletions
+2 -2
View File
@@ -99,7 +99,7 @@ class DatasourceConf(BaseModel):
class TableSchema:
def __init__(self, attr1, attr2):
self.tableName = attr1
self.tableComment = attr2
self.tableComment = attr2 if isinstance(attr2, str) else attr2.decode("utf-8")
tableName: str
tableComment: str
@@ -109,7 +109,7 @@ class ColumnSchema:
def __init__(self, attr1, attr2, attr3):
self.fieldName = attr1
self.fieldType = attr2
self.fieldComment = attr3
self.fieldComment = attr3 if isinstance(attr3, str) else attr3.decode("utf-8")
fieldName: str
fieldType: str
+6 -1
View File
@@ -61,10 +61,15 @@ def get_engine(ds: CoreDatasource) -> Engine:
connect_args={"options": f"-c search_path={conf.dbSchema}",
"connect_timeout": conf.timeout},
pool_timeout=conf.timeout, pool_size=20, max_overflow=10)
elif ds.type == 'oracle' or ds.type == 'sqlServer':
elif ds.type == 'sqlServer':
engine = create_engine(get_uri(ds), pool_timeout=conf.timeout,
pool_size=20,
max_overflow=10)
elif ds.type == 'oracle':
engine = create_engine(get_uri(ds),
pool_timeout=conf.timeout,
pool_size=20,
max_overflow=10)
else:
engine = create_engine(get_uri(ds), connect_args={"connect_timeout": conf.timeout}, pool_timeout=conf.timeout,
pool_size=20,