ReturnBook.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 ReturnBook {

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

    // Insert Return record
    void insert(Connection connection) throws SQLException {

        String query = """
                INSERT INTO return_book
                (return_id, issue_id, member_id, book_id, return_date)
                VALUES (?, ?, ?, ?, ?)
                """;

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

            System.out.print("Enter Return ID: ");
            int returnId = sc.nextInt();

            System.out.print("Enter Issue ID: ");
            int issueId = 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 Return Date (YYYY-MM-DD): ");
            String returnDate = sc.next();

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

            int rows = prestmt.executeUpdate();

            if (rows > 0) {
                System.out.println("✅ Book Returned Successfully!");
            } else {
                System.out.println("❌ Return Failed!");
            }
        }
    }

    // Delete Return record
    void delete(Connection connection) throws SQLException {

        String query = "DELETE FROM return_book WHERE return_id = ?";

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

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

            prestmt.setInt(1, returnId);

            int rows = prestmt.executeUpdate();

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

    // Update Return record
    void update(Connection connection) throws SQLException {

        String query = "UPDATE return_book SET return_date = ? WHERE return_id = ?";

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

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

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

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

            int rows = prestmt.executeUpdate();

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

    // Get all Return records
    void getAll(Connection connection) throws SQLException {

        String query = "SELECT * FROM return_book";

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

            System.out.println("\n===== 🔄 Returned Books =====");

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

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