update api

battery_voltage_events.py

@@ -86,8 +86,7 @@ def read_data(url, access_token, repeat_count=5):
         time.sleep(300)
 
 # Functie voor het bijwerken van gegevens in de database
-# Functie voor het bijwerken van gegevens in de database
+def update_data(record_id):
-def update_data(record_id, new_value):
     try:
         mydb = database_connect()
 
@@ -102,19 +101,24 @@ def update_data(record_id, new_value):
                 print(f"Record with ID {record_id} not found. Update operation aborted.")
                 return
 
+            # Vraag de gebruiker om nieuwe waarden voor de andere velden
+            new_timestamp = input("Enter new timestamp: ")
+            new_gateway_receive_time = input("Enter new gateway_receive_time: ")
+            new_device = input("Enter new device: ")
+            new_value = input("Enter new value: ")
+
             # Hier moet je de juiste kolomnamen aanpassen op basis van de structuur van je database
             update_query = """
             UPDATE goodgarden.battery_voltage_events
-            SET value = %s
+            SET timestamp = %s, gateway_receive_time = %s, device = %s, value = %s
             WHERE id = %s
             """
 
-            # Voer de query uit
             # Voer de query uit
             print(f"Executing update query: {update_query}")
-            print(f"Updating record with ID {record_id} to new value: {new_value}")
+            print(f"Updating record with ID {record_id} to new values - timestamp: {new_timestamp}, gateway_receive_time: {new_gateway_receive_time}, device: {new_device}, value: {new_value}")
 
-            mycursor.execute(update_query, (new_value, record_id))  # Provide the tuple with values here
+            mycursor.execute(update_query, (new_timestamp, new_gateway_receive_time, new_device, new_value, record_id))
 
             # Bevestig de wijzigingen
             mydb.commit()
@@ -174,8 +178,8 @@ if __name__ == "__main__":
     elif operation_choice == "U":
         # Update gegevens
         record_id = int(input("Enter record ID to update: "))
-        new_value = input("Enter new value: ")
+        # Call the update_data function without additional arguments
-        update_data(record_id, new_value)
+        update_data(record_id)
     elif operation_choice == "D":
         # Verwijder gegevens
         record_id = int(input("Enter record ID to delete: "))

fetch.py

@@ -1,97 +0,0 @@
-import mysql.connector
-import requests
-import time
-
-def database_connect():
-    return mysql.connector.connect(
-        host="localhost",
-        user="root",
-        password="",
-        database="goodgarden"
-    )
-
-def fetch_and_display_all(urls, access_token):
-    for url in urls:
-        try:
-            headers = {
-                "Authorization": f"Token {access_token}"
-            }
-            response = requests.get(url, headers=headers)
-            response.raise_for_status()
-
-            data = response.json()
-            print(f"Data from {url}:")
-            print(data)
-            load_data(data)
-
-        except requests.exceptions.RequestException as e:
-            print(f"Error fetching data from {url}: {e}")
-
-        # Wait for a certain time (e.g., 60 seconds) before making the next call
-        print("Waiting for the next retrieval action...")
-        time.sleep(10)  # Time here is in seconds.
-
-def load_data(data):
-    mydb = database_connect()
-    if mydb.is_connected():
-        mycursor = mydb.cursor()
-
-        # Here you need to adjust the correct column names and data formats based on the API response
-        insert_query = """
-        INSERT INTO goodgarden.fetch (timestamp, gateway_receive_time, device, value)
-        VALUES (%s, %s, %s, %s)
-        """
-        for record in data['results']:  # Adjust this based on the actual structure of the JSON
-            timestamp = record.get('timestamp', '')
-            gateway_receive_time = record.get('gateway_receive_time', '')
-            device = record.get('device', '')
-            value = record.get('value', '')
-
-            print(f"Inserting data: timestamp={timestamp}, gateway_receive_time={gateway_receive_time}, device={device}, value={value}")  # Print the data being inserted
-
-            # Execute the query
-            mycursor.execute(insert_query, (timestamp, gateway_receive_time, device, value))
-
-        # insert_query = """ Voor deze code werktengird te krijgen moet je in de datebase een ''id, serial_number, name, label, last_seen, last_battery_voltage)' aanmaken en dan werkt het.
-        # INSERT INTO goodgarden.fetch (id, serial_number, name, label, last_seen, last_battery_voltage) Hier de tabel naam veranderen
-        # VALUES (%s, %s, %s, %s, %s, %s)
-        # """
-        # for record in data['results']:  # Adjust this based on the actual structure of the JSON
-        #     id = record.get('id', '')
-        #     serial_number = record.get('serial_number', '')
-        #     name = record.get('name', '')
-        #     label = record.get('label', '')
-        #     last_seen = record.get('last_seen', '')
-        #     last_battery_voltage = record.get('last_battery_voltage', '')
-
-        #     print(f"Inserting data: id={id}, serial_number={serial_number}, name={name}, label={label}, last_seen={last_seen}, last_battery_voltage={last_battery_voltage}")  # Print the data being inserted
-
-        #     # Execute the query
-        #     mycursor.execute(insert_query, (id, serial_number, name, label, last_seen, last_battery_voltage))
-
-
-
-
-        # Commit the changes
-        mydb.commit()
-
-        # Close cursor and connection
-        mycursor.close()
-        mydb.close()
-
-        print("Data inserted into the database.")
-
-if __name__ == "__main__":
-    urls = [
-        "https://garden.inajar.nl/api/battery_voltage_events/?format=json",
-        "https://garden.inajar.nl/api/devices/?format=json",
-        "https://garden.inajar.nl/api/par_events/?format=json",
-        "https://garden.inajar.nl/api/relative_humidity_events/?format=json",
-        "https://garden.inajar.nl/api/soil_electric_conductivity_events/?format=json",
-        "https://garden.inajar.nl/api/soil_relative_permittivity_events/?format=json",
-        "https://garden.inajar.nl/api/soil_temperature_events/?format=json"
-    ]
-    
-    access_token = "33bb3b42452306c58ecedc3c86cfae28ba22329c"  # Vervang dit met jouw echte toegangstoken
-    
-    fetch_and_display_all(urls, access_token)