import psycopg2
import sys
import os

f = open('<data_set>', 'r')
readf = f.readlines()


conn = psycopg2.connect('cockroach cluster link')

conn.set_session(autocommit=True)
cur = conn.cursor()
for line in readf:
    cur.execute(
        "SQL QUERIES"
    )   
    
rfetch = cur.fetchall()
print('ID added:')
for rows in rfetch:
    print([str(cell) for cell in rows])
cur.close()
conn.close()

c3bf370e71ef7d62b717d2c08ca0983763cbeca7
<mask token>

<mask token>
conn.set_session(autocommit=True)
<mask token>
for line in readf:
    cur.execute('SQL QUERIES')
<mask token>
print('ID added:')
for rows in rfetch:
    print([str(cell) for cell in rows])
cur.close()
conn.close()

<mask token>
f = open('<data_set>', 'r')
readf = f.readlines()
conn = psycopg2.connect('cockroach cluster link')
conn.set_session(autocommit=True)
cur = conn.cursor()
for line in readf:
    cur.execute('SQL QUERIES')
rfetch = cur.fetchall()
print('ID added:')
for rows in rfetch:
    print([str(cell) for cell in rows])
cur.close()
conn.close()

import psycopg2
import sys
import os
f = open('<data_set>', 'r')
readf = f.readlines()
conn = psycopg2.connect('cockroach cluster link')
conn.set_session(autocommit=True)
cur = conn.cursor()
for line in readf:
    cur.execute('SQL QUERIES')
rfetch = cur.fetchall()
print('ID added:')
for rows in rfetch:
    print([str(cell) for cell in rows])
cur.close()
conn.close()

import psycopg2
import sys
import os

f = open('<data_set>', 'r')
readf = f.readlines()


conn = psycopg2.connect('cockroach cluster link')

conn.set_session(autocommit=True)
cur = conn.cursor()
for line in readf:
    cur.execute(
        "SQL QUERIES"
    )   
    
rfetch = cur.fetchall()
print('ID added:')
for rows in rfetch:
    print([str(cell) for cell in rows])
cur.close()
conn.close()
