89 lines
3.3 KiB
Python
89 lines
3.3 KiB
Python
# copy_to_energy_prices.py
|
|
import mysql.connector
|
|
import sys
|
|
from mysql.connector import Error
|
|
|
|
def copy_data():
|
|
source_conn = None
|
|
dest_conn = None
|
|
|
|
# ---- Gegevens voor de BRON-database (alfen) ----
|
|
source_db_config = {
|
|
'host': '127.0.0.1',
|
|
'database': 'alfen',
|
|
'user': 'alfen_user',
|
|
'password': '5uVgr%f%s2P5GR@3q!',
|
|
'port': 3307
|
|
}
|
|
|
|
# ---- Gegevens voor de DOEL-database (energy_prices) ----
|
|
# VUL DEZE GEGEVENS ZELF IN
|
|
dest_db_config = {
|
|
'host': '127.0.0.1',
|
|
'database': 'energy_prices',
|
|
'user': 'energy_prices_user',
|
|
'password': 'kS9R*xp17ZwCD@CV&E^N',
|
|
'port': 3307
|
|
}
|
|
|
|
try:
|
|
# 1. Maak verbinding met de bron-database (alfen)
|
|
source_conn = mysql.connector.connect(**source_db_config)
|
|
|
|
# 2. Maak verbinding met de doel-database (energy_prices)
|
|
dest_conn = mysql.connector.connect(**dest_db_config)
|
|
|
|
if source_conn.is_connected() and dest_conn.is_connected():
|
|
source_cursor = source_conn.cursor(dictionary=True) # dictionary=True maakt 'row['column_name']' mogelijk
|
|
dest_cursor = dest_conn.cursor()
|
|
|
|
# 3. Selecteer de data van VANDAAG uit de 'alfen' database
|
|
# We gaan ervan uit dat de API (stroomprijs_vandaag) data voor vandaag levert
|
|
print("Data selecteren uit 'alfen' database...")
|
|
select_query = "SELECT datetime, provider_code, price FROM dynamic_price_data WHERE DATE(datetime) = CURDATE()"
|
|
source_cursor.execute(select_query)
|
|
|
|
rows_to_copy = source_cursor.fetchall()
|
|
|
|
if not rows_to_copy:
|
|
print("Geen data van vandaag gevonden in 'alfen' om te kopiëren.")
|
|
return
|
|
|
|
print(f"{len(rows_to_copy)} rijen gevonden om te kopiëren.")
|
|
|
|
# 4. Voer de data in in de 'energy_prices' database
|
|
insert_query = """
|
|
INSERT INTO dynamic_price_data (datetime, provider_code, price)
|
|
VALUES (%s, %s, %s)
|
|
ON DUPLICATE KEY UPDATE price = %s
|
|
"""
|
|
|
|
copied_count = 0
|
|
for row in rows_to_copy:
|
|
try:
|
|
data_tuple = (row['datetime'], row['provider_code'], row['price'], row['price'])
|
|
dest_cursor.execute(insert_query, data_tuple)
|
|
copied_count += 1
|
|
except Error as e:
|
|
print(f"Fout bij invoeren rij {row}: {e}")
|
|
|
|
# Commit de transactie naar de doel-database
|
|
dest_conn.commit()
|
|
print(f"Succesvol {copied_count} rijen gekopieerd naar 'energy_prices'.")
|
|
|
|
except Error as e:
|
|
# Stuur de foutmelding naar stderr zodat het hoofdscript dit kan opvangen
|
|
print(f"Fout tijdens kopieerproces: {e}", file=sys.stderr)
|
|
sys.exit(1) # Sluit af met een foutcode
|
|
|
|
finally:
|
|
# Sluit alle verbindingen en cursors
|
|
if source_conn and source_conn.is_connected():
|
|
source_cursor.close()
|
|
source_conn.close()
|
|
if dest_conn and dest_conn.is_connected():
|
|
dest_cursor.close()
|
|
dest_conn.close()
|
|
|
|
if __name__ == "__main__":
|
|
copy_data() |