sQVk0YF8

1import sqlite3
2import csv
3import heapq as heap
4
5
6connection = sqlite3.connect(':memory:')
7c = connection.cursor()
8
9c.execute(""" CREATE TABLE IF NOT EXISTS customers2(col1 varchar(110),
10col2 varchar(110), col3 varchar(110), col4 varchar(110))""")
11connection.commit()
12
13with open('data.csv', 'r') as data_csv:
14    data_reader = csv.reader(data_csv)
15    next(data_reader)
16    for r in data_reader:
17        c.execute(f"INSERT INTO customers2 (col1, col2, col3, col4) VALUES('{r[0]}', '{r[1]}', '{r[2]}', '{r[3]}')")
18    connection.commit()
19    
20c.execute("SELECT * FROM customers2;")
21
22for r in c.fetchall():
23    print(r)
24  
25
26with open ('test.bin', 'wb') as f:
27    with open ('data.csv', 'r') as data_csv:
28       data_reader = csv.reader(data_csv)
29       next(data_reader)
30       for r in data_reader:
31          header1 = str.encode(r[0] + r[1] + r[2] + r[3])
32          f.write(header1 + b"n")
33
34
35with open ('test.bin', 'rb') as f:
36     data = f.read()
37     text = data.decode('utf-8')
38     print(text)
39
40
41
42with open ('test2.bin', 'wb') as f:
43    with open ('data.csv', 'r') as data_csv:
44       data_reader = csv.reader(data_csv)
45       next(data_reader)
46       for r in data_reader:
47           heap.heapify(r)
48          header1 = str.encode(list.r[])
49          f.write(header1 + b"n")