from flask import Flask, request, jsonify

from flask_cors import CORS

import mysql.connector

app = Flask(__name__)

CORS(app) # ✅ Enables frontend-to-backend access

# Database Configuration

db_config = {

'host': 'database-1.c58m86oy0fvp.us-east-1.rds.amazonaws.com',

'user': 'admin',

'password': 'admin@123456',

'database': 'dev'

}

def get_db_connection():

return mysql.connector.connect(**db_config)

# Get all users

@app.route('/users', methods=['GET'])

def get_users():

conn = get_db_connection()

cursor = conn.cursor(dictionary=True)

cursor.execute("SELECT * FROM users")

users = cursor.fetchall()

cursor.close()

conn.close()

return jsonify(users)

# Get single user by ID

@app.route('/users/<int:user_id>', methods=['GET'])

def get_user(user_id):

conn = get_db_connection()

cursor = conn.cursor(dictionary=True)

cursor.execute("SELECT * FROM users WHERE id = %s", (user_id,))

user = cursor.fetchone()

cursor.close()

conn.close()

if user:

return jsonify(user)

return jsonify({'error': 'User not found'}), 404

# Add user

@app.route('/users/add', methods=['POST'])

def add_user():

data = request.get_json()

name = data.get('name')

email = data.get('email')

if not name or not email:

return jsonify({'error': 'Name and Email required'}), 400

conn = get_db_connection()

cursor = conn.cursor()

try:

cursor.execute("INSERT INTO users (name, email) VALUES (%s, %s)", (name, email))

conn.commit()

return jsonify({'message': 'User added successfully'})

except mysql.connector.Error as err:

return jsonify({'error': str(err)}), 500

finally:

cursor.close()

conn.close()

# Update user

@app.route('/users/update/<int:user_id>', methods=['PUT'])

def update_user(user_id):

data = request.get_json()

name = data.get('name')

email = data.get('email')

if not name or not email:

return jsonify({'error': 'Name and Email required'}), 400

conn = get_db_connection()

cursor = conn.cursor()

cursor.execute("SELECT * FROM users WHERE id = %s", (user_id,))

if not cursor.fetchone():

return jsonify({'error': 'User not found'}), 404

cursor.execute("UPDATE users SET name = %s, email = %s WHERE id = %s", (name, email, user_id))

conn.commit()

cursor.close()

conn.close()

return jsonify({'message': 'User updated successfully'})

# Delete user

@app.route('/users/delete/<int:user_id>', methods=['DELETE'])

def delete_user(user_id):

conn = get_db_connection()

cursor = conn.cursor()

cursor.execute("SELECT * FROM users WHERE id = %s", (user_id,))

if not cursor.fetchone():

return jsonify({'error': 'User not found'}), 404

cursor.execute("DELETE FROM users WHERE id = %s", (user_id,))

conn.commit()

cursor.close()

conn.close()

return jsonify({'message': 'User deleted successfully'})

@app.route('/sql')

def sql():

return """

<pre>

CREATE TABLE users (

id INT AUTO_INCREMENT PRIMARY KEY,

name VARCHAR(100),

email VARCHAR(100) UNIQUE

);

</pre>

"""

if __name__ == '__main__':

app.run(host='0.0.0.0', port=5000)