import cx_Oracle
import pymysql.cursors
from random import randint
import datetime

dsn_tns = cx_Oracle.makedsn('localhost', '1521', 'xe')
conn_oracle = cx_Oracle.connect(user='login', password='password', dsn=dsn_tns)
cur_oracle = conn_oracle.cursor()

conn_mysql = pymysql.connect(host='localhost', user='user', password='password', db='biuro',
                             cursorclass=pymysql.cursors.DictCursor)
cur_mysql = conn_mysql.cursor()
conn_mysql.autocommit(True)

sql_insert_client = "INSERT INTO klient(idklient, plec, stancywilny, wiek)" \
                    " VALUES ({id}, '{gender}', '{civil}', {age})"
sql_insert_sale = "INSERT INTO sprzedaz(idsprzedaz, cena, data, klient_id_klient, nieruchomosc_idnieruchomosc)" \
                  " VALUES ({id}, '{price}', '{date}', {client_id}, {state_id})"
sql_insert_state = "INSERT INTO nieruchomosc(idnieruchomosc, liczbapokoi, powierzchnia, piwnica, balkon, rokbudowy, lokalizacja_idlokalizacja, pietro)" \
                   " VALUES ({id}, {rooms}, {metres}, '{basement}','balcony','year' {local_id}, {floor})"
sql_insert_local = "INSERT INTO lokalizacja(idlokalizacja, miasto, odlegloscodcentrum)" \
                   " VALUES ({id}, '{city}', {from_city_center})"

sql_retrieve_sale_and_client = "SELECT sprzedaz.idsprzedaz, sprzedaz.data, sprzedaz.cena,  " \
                               "mieszkanie.idmieszkanie, mieszkanie.liczbaPokoi, mieszkanie.powierzchnia, mieszkanie.piwnica, mieszkanie.balkon, mieszkanie.winda, " \
                               "dzielnica.iddzielnica, dzielnica.odlegloscOdCentrum, " \
                               "miasto.idmiasto, miasto.nazwa " \
                               "klient.idklient, klient.stanCywilny, klient.wiek, " \
                               "osoba.plec " \
                               "FROM biuro.sprzedaz " \
                               "INNER JOIN biuro.mieszkanie ON sprzedaz.idmieszkanie = mieszkanie.idmieszkanie " \
                               "INNER JOIN biuro.dzielnica ON mieszkanie.idDzielnica = dzielnica.iddzielnica " \
                               "INNER JOIN biuro.miasto ON dzielnica.idmiasto = miasto.idmiasto" \
                               "INNER JOIN biuro.klient ON sprzedaz.idklient = klient.idklient " \
                               "INNER JOIN biuro.osoba ON klient.idosoba = osoba.idosoba;"

cur_mysql.execute(sql_retrieve_sale_and_client)
all = cur_mysql.fetchall()

i = 0
for row in all:

    sale_id = row['idsprzedaz']
    sale_date = row['data']
    sale_price = row['cena']

    client_id = row['idklient']
    client_civil = row['stanCywilny']
    client_age = row['wiek']
    client_gender = row['plec']

    state_id = row['idmieszkanie']
    state_rooms = row['liczbaPokoi']
    state_metres = row['powierzchnia']
    state_basement = row['piwnica']
    state_balcony = row['balkon']

    i = i + 1
    locale_id = i
    locale_city = ['miasto']
    locale_from_city_center = ['odlegloscOdCentrum']

    if client_gender == 'mezczyzna':
        client_gender = 'm'
    else:
        client_gender = 'f'
    if client_civil == 'zajety':
        client_civil = 'married'
    else:
        client_civil = 'single'

    if state_basement == 1:
        state_basement = 't'
    else:
        state_basement = 'f'
    if state_balcony == 1:
        state_balcony = 't'
    else:
        state_balcony = 'f'

    start = datetime.datetime.strptime("1995-06-21", "%Y-%m-%d")
    end = datetime.datetime.strptime("2018-06-21", "%Y-%m-%d")
    date_generated = [start + datetime.timedelta(days=x) for x in range(0, (end - start).days)]

    cur_oracle.execute(
        sql_insert_local.format(id = locale_id, city = locale_city, from_city_center = locale_from_city_center))

    cur_oracle.execute(sql_insert_state.format(id = state_id, rooms=state_rooms, metres=state_metres,
                                               basement = state_basement, balcony = state_balcony,
                                               year = randint(1930, 2018), local_id = locale_id, floor = randint(1, 15)))
    cur_oracle.execute(sql_insert_client.format(id = client_id, gender = client_gender, civil = client_civil, age = client_age))

    cur_oracle.execute(sql_insert_sale.format(id = sale_id, price = sale_price, date = date_generated.strftime("%Y-%m-%d"),
                                              klient_id_klient = client_id, nieruchomosc_idnieruchomosc = state_id ))

conn_oracle.commit()
conn_oracle.close()
conn_mysql.close()