cet.py 1.3 KB

1234567891011121314151617181920212223242526272829303132333435363738
  1. import plac
  2. import pyodbc
  3. @plac.pos('query', 'SQL Query', type=str)
  4. @plac.pos('mode', '', choices=['in', 'out', 'queryout'])
  5. @plac.pos('csv_file', '', type=str)
  6. @plac.opt('Server', 'Hostname or DSN', type=str)
  7. @plac.opt('database', '', type=str)
  8. @plac.opt('User', '', type=str)
  9. @plac.opt('Password', '', type=str)
  10. @plac.flg('charset', '')
  11. @plac.opt('Codepage', '', type=str)
  12. @plac.opt('errorlog', '', type=str)
  13. def run(query, mode, csv_file, Server='localhost\\GLOBALCUBE', database='master', User='sa', Password='Mffu3011#', charset=False, Codepage='65001', errorlog='error.log'):
  14. dsn = f"dsn={Server};uid={User};pwd={Password}"
  15. if Codepage.isnumeric():
  16. Codepage = 'cp' + Codepage
  17. if mode == 'queryout':
  18. queryout(dsn, query, csv_file, Codepage, errorlog)
  19. return
  20. print('This is madness')
  21. def queryout(dsn, query, csv_file, codepage, errorlog):
  22. try:
  23. conn = pyodbc.connect(dsn)
  24. cursor = conn.cursor()
  25. cursor.execute(query)
  26. with open(csv_file, 'w', encoding=codepage) as fwh:
  27. while row := cursor.fetchone():
  28. fwh.write('\t'.join(map(str, row)).replace('None', '').replace('False', '0').replace('True', '1') + '\n')
  29. except pyodbc.InterfaceError as e:
  30. print(e.args[1])
  31. if __name__ == '__main__':
  32. plac.call(run)