# Setting up the db connections
import psycopg2
import cx_Oracle

oracle = cx_Oracle.connect("username", "password", "url/db")
psql = psycopg2.connect("dbname='dbname' user='username' host='url' password='password'")


# Actual usage
from sql2sql.objects import ETL

extract = "SELECT col1, col2 FROM some_table"
def transform(each_row):
    print(each_row[0], each_row[1])
    each_row = (each_row[0] + 1, each_row[1] + 2)
    return each_row
load = "INSERT INTO new_table(col1, col2) VALUES (%s, %S)"

ETL().from_conn(oracle).to_conn(psql).extract(extract).transform(transform).load(load).execute()