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 fixes: sqlite writer with sqlalchemy

This commit is contained in:
Steve Nyemba 2024-02-02 18:16:34 -06:00
parent e4faac7d6e
commit 9270695c95
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
transport/disk.py
View File

@ -113,8 +113,6 @@ class SQLite :
self.conn = sqlite3.connect(self.path,isolation_level="IMMEDIATE") self.conn = sqlite3.connect(self.path,isolation_level="IMMEDIATE")
self.conn.row_factory = sqlite3.Row self.conn.row_factory = sqlite3.Row
self.fields = _args['fields'] if 'fields' in _args else [] self.fields = _args['fields'] if 'fields' in _args else []
path = self._path
self._engine = create_engine(f'sqlite://{path}')
def has (self,**_args): def has (self,**_args):
found = False found = False
try: try:
@ -178,6 +176,8 @@ class SQLiteWriter(SQLite,DiskWriter) :
# DiskWriter.__init__(self,**args) # DiskWriter.__init__(self,**args)
super().__init__(**args) super().__init__(**args)
self.table = args['table'] if 'table' in args else None self.table = args['table'] if 'table' in args else None
path = self.path
self._engine = create_engine(f'sqlite://{path}')
# self.conn = sqlite3.connect(self.path,isolation_level="IMMEDIATE") # self.conn = sqlite3.connect(self.path,isolation_level="IMMEDIATE")
# self.conn.row_factory = sqlite3.Row # self.conn.row_factory = sqlite3.Row