import sys import os import asyncio import codecs from sqlor.dbpools import DBPools async def exesqls(sqllines): sqls = sqllines.split(';') async with DBPools().sqlorContext('db') as sor: for sql in sqls: await sor.sqlExe(sql, {}) async def main(): with codecs.open(sys.argv[2],'r', 'utf-8') as f: txt = f.read() await exesqls(txt) if __name__ == '__main__': if len(sys.argv) < 3: print(f'Usage:{sys.argv[0]} sqlite3_db_file sqlfile') sys.exit(1) dbs = { "db":{ "driver":"aiosqlite", "kwargs":{ "dbname":sys.argv[1] } } } DBPools(dbs) loop = asyncio.get_event_loop() loop.run_until_complete(main())