product-add-ajax.php

<?php
function productCreated(){
    if($_POST['action'] == 'productCreated' ){
        $productName     = $_POST['productName'] ?? null;
        $productCategory = $_POST['category'] ?? null;
        $productPrice    = $_POST['cost'] ?? null;
        $error           = false;
        
        if( empty($productName) ){
            $error = true;
            $response['error'] = true;
            $response['productName'] = 'Product name is required!';
        }

        if( empty($productCategory) ){
            $error = true;
            $response['error'] = true;
            $response['category'] = 'Product category is required!';
        }

        if( empty($productPrice) ){
            $error = true;
            $response['error'] = true;
            $response['cost'] = 'Product price is required!';
        }

        if($error){
            echo json_encode($response);
            exit;
        }

        include_once 'databaseConnection.php'; 
        $db = new \DB\DBConnection(); // Use namespace
        $mysqli = $db->dbConnect();
        $data = [];

        $stmt = $mysqli->prepare("INSERT INTO products(product_name,category, product_price) VALUES (?, ?, ?)");
        $stmt->bind_param("ssd", $productName, $productCategory, $productPrice);

        // Execute the statement
        $saveProduct = $stmt->execute();
        $allProducts = $mysqli->query("SELECT * FROM products");
        if ($allProducts->num_rows > 0) {
            while($row = $allProducts->fetch_assoc()) {
                $data[] = $row;
            }
        }

        // Close the statement
        $stmt->close();
        echo json_encode([
            'message' => 'Successfully added.',
            'response' => $data,
            'status'  => true,
            'error'   => false,
        ]);

    }

    if($_POST['action'] == 'productUpdated' ){
        $productId       = $_POST['product_id'] ?? null;
        $productName     = $_POST['productName'] ?? null;
        $productCategory = $_POST['category'] ?? null;
        $productPrice    = $_POST['cost'] ?? null;
        $error           = false;
        
        if( empty($productName) ){
            $error = true;
            $response['error'] = true;
            $response['productName'] = 'Product name is required!';
        }

        if( empty($productCategory) ){
            $error = true;
            $response['error'] = true;
            $response['category'] = 'Product category is required!';
        }

        if( empty($productPrice) ){
            $error = true;
            $response['error'] = true;
            $response['cost'] = 'Product price is required!';
        }

        if($error){
            echo json_encode($response);
            exit;
        }

        include_once 'databaseConnection.php'; 
        $db     = new \DB\DBConnection(); // Use namespace
        $mysqli = $db->dbConnect();
        $data   = [];

        $stmt = $mysqli->prepare("UPDATE products SET product_name = ?, category = ?, product_price = ? WHERE product_id = ?");
        $stmt->bind_param("ssdi", $productName, $productCategory, $productPrice, $productId);

        // Execute the statement
        $saveProduct = $stmt->execute();
        $allProducts = $mysqli->query("SELECT * FROM products");
        if ($allProducts->num_rows > 0) {
            while($row = $allProducts->fetch_assoc()) {
                $data[] = $row;
            }
        }

        // Close the statement
        $stmt->close();
        echo json_encode([
            'message' => 'Successfully added.',
            'response' => $data,
            'status'  => true,
            'error'   => false,
        ]);

    }
}
productCreated();