winzer/elwig-misc
3
1
Fork 0
Code Pull Requests Activity

Add flush=True to wgexport.py

Browse Source
This commit is contained in:
Lorenz Stechauner
2023-02-09 18:47:04 +01:00
parent 5dd84b9229
commit 4b93653478
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
wgmaster/wgexport.py
View File

@ -38,25 +38,26 @@ if __name__ == '__main__':
pass pass
os.makedirs(args.output, exist_ok=True) os.makedirs(args.output, exist_ok=True)
print(f'Opening {args.wgdaten}...') print(f'Opening {args.wgdaten}...', flush=True)
pypyodbc.lowercase = False pypyodbc.lowercase = False
conn = pypyodbc.connect(f"Driver={{Microsoft Access Driver (*.mdb, *.accdb)}};Dbq={args.wgdaten};") conn = pypyodbc.connect(f"Driver={{Microsoft Access Driver (*.mdb, *.accdb)}};Dbq={args.wgdaten};")
cur = conn.cursor() cur = conn.cursor()
print(f'Opened {args.wgdaten}!') print(f'Opened {args.wgdaten}!', flush=True)
try: try:
print(f'Fetching tables...') print(f'Fetching tables...', flush=True)
tbls = cur.tables(tableType='TABLE') tbls = cur.tables(tableType='TABLE')
tbls = tbls.fetchall() tbls = tbls.fetchall()
print(f'Successfully fetched {len(tbls)} tables!') print(f'Successfully fetched {len(tbls)} tables!', flush=True)
for file, _, t_name, t_type, _ in tbls: for file, _, t_name, t_type, _ in tbls:
print(f'Exporting {t_name}...') print(f'Exporting {t_name}...', flush=True)
cur.execute(f"SELECT TOP 1 * FROM {t_name};") cur.execute(f"SELECT TOP 1 * FROM {t_name};")
desc = [(t[0], t[1]) for t in cur.description] desc = [(t[0], t[1]) for t in cur.description]
cur.fetchall() cur.fetchall()
print(desc) print(desc, flush=True)
cur.execute(f"SELECT * FROM {t_name} ORDER BY `{desc[0][0]}`;") cur.execute(f"SELECT * FROM {t_name} ORDER BY `{desc[0][0]}`;")
cols = [t[0] for t in cur.description] cols = [t[0] for t in cur.description]
@ -66,7 +67,7 @@ if __name__ == '__main__':
for row in cur: for row in cur:
f.write((';'.join([convert(t_name, n, a) for n, a in zip(cols, row)]) + '\n').encode('utf-8')) f.write((';'.join([convert(t_name, n, a) for n, a in zip(cols, row)]) + '\n').encode('utf-8'))
print(f'Exported {t_name} successfully!') print(f'Exported {t_name} successfully!', flush=True)
finally: finally:
cur.close() cur.close()
conn.close() conn.close()