Skip to content

Commit 2bbcaf4

Browse files
committed
fix(datasource): fix decimal to float
1 parent 7cd0f91 commit 2bbcaf4

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

backend/apps/db/db.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99
from apps.datasource.models.datasource import DatasourceConf, CoreDatasource, TableSchema, ColumnSchema
1010
from apps.datasource.utils.utils import aes_decrypt
1111
from apps.db.engine import get_engine_config
12+
from decimal import Decimal
1213

1314

1415
def get_uri(ds: CoreDatasource):
@@ -238,7 +239,7 @@ def exec_sql(ds: CoreDatasource, sql: str):
238239
columns = result.keys()._keys
239240
res = result.fetchall()
240241
result_list = [
241-
{columns[i]: value for i, value in enumerate(tuple_item)}
242+
{columns[i]: float(value) if isinstance(value, Decimal) else value for i, value in enumerate(tuple_item)}
242243
for tuple_item in res
243244
]
244245
return {"fields": columns, "data": result_list, "sql": bytes.decode(base64.b64encode(bytes(sql, 'utf-8')))}

0 commit comments

Comments
 (0)