Transaction.java

package LMS.com;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Scanner;

public class Transaction {

    private Scanner sc = new Scanner(System.in);

    // Insert Transaction
    void insert(Connection connection) throws SQLException {

        String query = """
                INSERT INTO transactions
                (transaction_id, member_id, book_id, issue_date, return_date)
                VALUES (?, ?, ?, ?, ?)
                """;

        try (PreparedStatement prestmt = connection.prepareStatement(query)) {

            System.out.print("Enter Transaction ID: ");
            int transactionId = sc.nextInt();

            System.out.print("Enter Member ID: ");
            int memberId = sc.nextInt();

            System.out.print("Enter Book ID: ");
            int bookId = sc.nextInt();

            System.out.print("Enter Issue Date (YYYY-MM-DD): ");
            String issueDate = sc.next();

            System.out.print("Enter Return Date (YYYY-MM-DD): ");
            String returnDate = sc.next();

            prestmt.setInt(1, transactionId);
            prestmt.setInt(2, memberId);
            prestmt.setInt(3, bookId);
            prestmt.setString(4, issueDate);
            prestmt.setString(5, returnDate);

            int rows = prestmt.executeUpdate();

            if (rows > 0) {
                System.out.println("✅ Transaction Inserted Successfully!");
            } else {
                System.out.println("❌ Transaction Insert Failed!");
            }
        }
    }

    // Delete Transaction
    void delete(Connection connection) throws SQLException {

        String query = "DELETE FROM transactions WHERE transaction_id = ?";

        try (PreparedStatement prestmt = connection.prepareStatement(query)) {

            System.out.print("Enter Transaction ID to Delete: ");
            int transactionId = sc.nextInt();

            prestmt.setInt(1, transactionId);

            int rows = prestmt.executeUpdate();

            if (rows > 0) {
                System.out.println("🗑 Transaction Deleted Successfully!");
            } else {
                System.out.println("❌ Transaction ID Not Found!");
            }
        }
    }

    // Update Transaction
    void update(Connection connection) throws SQLException {

        String query = "UPDATE transactions SET return_date = ? WHERE transaction_id = ?";

        try (PreparedStatement prestmt = connection.prepareStatement(query)) {

            System.out.print("Enter Transaction ID to Update: ");
            int transactionId = sc.nextInt();

            System.out.print("Enter New Return Date (YYYY-MM-DD): ");
            String returnDate = sc.next();

            prestmt.setString(1, returnDate);
            prestmt.setInt(2, transactionId);

            int rows = prestmt.executeUpdate();

            if (rows > 0) {
                System.out.println("✏ Transaction Updated Successfully!");
            } else {
                System.out.println("❌ Transaction ID Not Found!");
            }
        }
    }

    // Get All Transactions
    void getAll(Connection connection) throws SQLException {

        String query = "SELECT * FROM transactions";

        try (PreparedStatement prestmt = connection.prepareStatement(query);
             ResultSet rs = prestmt.executeQuery()) {

            System.out.println("\n===== 📑 Transactions List =====");

            boolean found = false;
            while (rs.next()) {
                found = true;
                System.out.println(
                        "Transaction ID: " + rs.getInt("transaction_id") +
                        " | Member ID: " + rs.getInt("member_id") +
                        " | Book ID: " + rs.getInt("book_id") +
                        " | Issue Date: " + rs.getDate("issue_date") +
                        " | Return Date: " + rs.getDate("return_date")
                );
            }

            if (!found) {
                System.out.println("No transactions found.");
            }
        }
    }
}