sql_uploader.py

import mysql.connector

class SQLUploader:
    def __init__(self):
        self.db_config = {
            'host': 'localhost',
            'user': 'root',
            'password': 'iamrahul',  # Add your password if needed
            'database': 'health_project'
        }
        self.conn = None
        self.cursor = None

    def connect(self):
        try:
            self.conn = mysql.connector.connect(**self.db_config)
            self.cursor = self.conn.cursor()
            print("Successfully connected to MySQL.")
            return True
        except mysql.connector.Error as err:
            print(f"MySQL Connection Error: {err}")
            return False

    def insert_data(self, bpm, spo2):
        if self.conn and self.conn.is_connected():
            try:
                sql = "INSERT INTO pulse_data (bpm, spo2) VALUES (%s, %s)"
                self.cursor.execute(sql, (bpm, spo2))
                self.conn.commit()
                return True
            except mysql.connector.Error as err:
                print(f"Insert Failed: {err}")
        return False

    def close(self):
        if self.conn and self.conn.is_connected():
            self.cursor.close()
            self.conn.close()