import sqlite3
import csv
import heapq as heap


connection = sqlite3.connect(':memory:')
c = connection.cursor()

c.execute(""" CREATE TABLE IF NOT EXISTS customers2(col1 varchar(110),
col2 varchar(110), col3 varchar(110), col4 varchar(110))""")
connection.commit()

with open('data.csv', 'r') as data_csv:
    data_reader = csv.reader(data_csv)
    next(data_reader)
    for r in data_reader:
        c.execute(f"INSERT INTO customers2 (col1, col2, col3, col4) VALUES('{r[0]}', '{r[1]}', '{r[2]}', '{r[3]}')")
    connection.commit()

c.execute("SELECT * FROM customers2;")

for r in c.fetchall():
    print(r)


with open ('test.bin', 'wb') as f:
    with open ('data.csv', 'r') as data_csv:
       data_reader = csv.reader(data_csv)
       next(data_reader)
       for r in data_reader:
          header1 = str.encode(r[0] + r[1] + r[2] + r[3])
          f.write(header1 + b"n")


with open ('test.bin', 'rb') as f:
     data = f.read()
     text = data.decode('utf-8')
     print(text)



with open ('test2.bin', 'wb') as f:
    with open ('data.csv', 'r') as data_csv:
       data_reader = csv.reader(data_csv)
       next(data_reader)
       for r in data_reader:
           heap.heapify(r)
          header1 = str.encode(list.r[])
          f.write(header1 + b"n")