async with pool.acquire() as conn:
cur = await conn.cursor()
for course in courses:
if course['subject_id'] not in inserted:
await cur.execute(
'INSERT INTO subjects (subject_id, subject_name) VALUES ({}, \'{}\')'.format(
course['subject_id'], course['subject']))
await cur.commit()
inserted.append(course['subject_id'])
await cur.close()
await conn.close()
pool.close()
await pool.wait_closed()
dsn = 'Driver={SQLite3 Driver};Database=../dbs/storage.db;'
pool = await aioodbc.create_pool(dsn=dsn, loop=loop)
[(31, '\x10=3;89A:89 O7K:'), (19, '\x118>;>38O'), (24, '\x1287C0;L=>5 ?@>3@0<<8@>20=85'), (20, '\x135>3@0D8O'), (41, '\x187>1@078B5;L=>5 8A:CAAB2>').....