Skip to content

B
bcom-tp-etl-transformation-pipelines
Commit 5fe4a975 authored by Cristian Aguirre's avatar Cristian Aguirre
Browse files
Options

Update 26-07-23. Issue 354

parent 82505e1b
Show whitespace changes
Inline Side-by-side
Showing with 10 additions and 2 deletions
dags/components/Databases/Mysql.py
View file @ 5fe4a975
......@@ -57,7 +57,11 @@ class Mysql:
size = int(field[2] / 4)
try:
if not isinstance(field[3], type(None)) and field[3] > 0:
data_type = MysqlDataTypeORMEnum[MysqlDataTypeEnum(field[1]).name].value(precision=field[2], scale=field[3])
precision, scale = field[2], field[3]
if scale > precision:
precision = field[3]
scale = field[2]
data_type = MysqlDataTypeORMEnum[MysqlDataTypeEnum(field[1]).name].value(precision=precision, scale=scale)
else:
data_type = MysqlDataTypeORMEnum[MysqlDataTypeEnum(field[1]).name].value(size)
except TypeError:
......
dags/components/Databases/Postgres.py
View file @ 5fe4a975
......@@ -59,7 +59,11 @@ class Postgres:
if field[2] != -1:
try:
if not isinstance(field[3], type(None)) and field[3] > 0:
data_type = PostgresDataTypeORMEnum[PostgresDataTypeEnum(field[1]).name].value(precision=field[2], scale=field[3])
precision, scale = field[2], field[3]
if scale > precision:
precision = field[3]
scale = field[2]
data_type = PostgresDataTypeORMEnum[PostgresDataTypeEnum(field[1]).name].value(precision=precision, scale=scale)
else:
data_type = PostgresDataTypeORMEnum[PostgresDataTypeEnum(field[1]).name].value(field[2])
except TypeError:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment