Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import cx_Oracle
- import pymysql.cursors
- 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, " \
- "nieruchomosc.idmieszkanie, nieruchomosc.liczbaPokoi, nieruchomosc.powierzchnia, nieruchomosc.piwnica, nieruchomosc.balkon, nieruchomosc.rokBudowy, nieruchomosc.pietro " \
- "dzielnica.iddzielnica, dzielnica.odlegloscOdCentrum, " \
- "miasto.idmiasto, miasto.nazwa " \
- "klient.idklient, klient.stanCywilny, klient.wiek, " \
- "osoba.plec " \
- "FROM biuro.sprzedaz " \
- "INNER JOIN biuro.nieruchomosc ON sprzedaz.idmieszkanie = nieruchomosc.idnieruchomosc " \
- "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']
- state_floor = row['pietro']
- state_year = row['rokBudowy']
- 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'
- 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 = state_year, local_id = locale_id, floor = state_floor))
- 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 = sale_date,
- klient_id_klient = client_id, nieruchomosc_idnieruchomosc = state_id ))
- conn_oracle.commit()
- conn_oracle.close()
- conn_mysql.close()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement