app.py

from flask import Flask, render_template, request, redirect, url_for
import mysql.connector

app = Flask(__name__)


def get_db_connection():
    connection = mysql.connector.connect(
        host='localhost',
        user='root',
        password='Reabetsweneo03#',  
        database='blog'  
    )
    return connection


@app.route('/')
def index():
    connection = get_db_connection()
    cursor = connection.cursor(dictionary=True)
    cursor.execute('SELECT * FROM comments ORDER BY created_at DESC')
    comments = cursor.fetchall()
    cursor.close()
    connection.close()
    return render_template('index.html', comments=comments)


@app.route('/submit_comment', methods=['POST'])
def submit_comment():
    if request.method == 'POST':
        name = request.form.get('name')
        comment = request.form.get('comment')
        post_id = request.form.get('post_id')

        connection = get_db_connection()
        cursor = connection.cursor()
        cursor.execute('INSERT INTO comments (name, comment, post_id) VALUES (%s, %s, %s)', 
                       (name, comment, post_id))
        connection.commit()
        cursor.close()
        connection.close()

        return redirect('/')


@app.route('/edit_comment/<int:id>', methods=['GET'])
def edit_comment(id):
    connection = get_db_connection()
    cursor = connection.cursor(dictionary=True)
    cursor.execute('SELECT * FROM comments WHERE id = %s', (id,))
    comment = cursor.fetchone()
    cursor.close()
    connection.close()
    return render_template('edit_comment.html', comment=comment)


@app.route('/update_comment/<int:id>', methods=['POST'])
def update_comment(id):
    name = request.form.get('name')
    comment = request.form.get('comment')

    connection = get_db_connection()
    cursor = connection.cursor()
    cursor.execute('UPDATE comments SET name = %s, comment = %s WHERE id = %s',
                   (name, comment, id))
    connection.commit()
    cursor.close()
    connection.close()

    return redirect('/')


@app.route('/delete_comment/<int:id>', methods=['GET'])
def delete_comment(id):
    connection = get_db_connection()
    cursor = connection.cursor()
    cursor.execute('DELETE FROM comments WHERE id = %s', (id,))
    connection.commit()
    cursor.close()
    connection.close()

    return redirect('/')

if __name__ == '__main__':
    app.run(debug=True)