hiplab/data-transport
hiplab
/
data-transport
mirror of https://github.com/lnyemba/data-transport
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

bug fix: versions of sqlalchemy for meta data

This commit is contained in:
Steve Nyemba 2023-06-16 17:39:02 -05:00
parent 18cd1d8b11
commit aaaf64db33
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
transport/sql.py
View File

@ -106,8 +106,13 @@ class SQLRW :
try: try:
if self._engine : if self._engine :
table = _args['table'] if 'table' in _args else self.table table = _args['table'] if 'table' in _args else self.table
if sqlalchemy.__version__.startswith('1.') :
_m = sqlalchemy.MetaData(bind=self._engine) _m = sqlalchemy.MetaData(bind=self._engine)
_m.reflect() _m.reflect()
else:
_m = sqlalchemy.MetaData()
_m.reflect(bind=self._engine)
schema = [{"name":_attr.name,"type":str(_attr.type)} for _attr in _m.tables[table].columns] schema = [{"name":_attr.name,"type":str(_attr.type)} for _attr in _m.tables[table].columns]
# #
# Some house keeping work # Some house keeping work
@ -117,6 +122,7 @@ class SQLRW :
_item['type'] = _m[_item['type']] _item['type'] = _m[_item['type']]
except Exception as e: except Exception as e:
print (e)
pass pass
return schema return schema
def _tablename(self,name) : def _tablename(self,name) :