HomeProperty.java

import java.sql.*;
import java.util.Scanner;

public class HomeProperty implements Entity {

    public void listAll() {
        System.out.println("================================= Properties =======================================");
        printHomeProperties();
        System.out.println("====================================================================================");
    }

    public void displayDetails(int id) {
        System.out.println("========================================== Property Details ======================================");
        printPropertyDetails(id);
        System.out.println("===================================================================================================");
    }

    public void addNew() {
        Scanner scanner = new Scanner(System.in);

        System.out.print("Enter Street Address:");
        String street = scanner.nextLine();

        System.out.print("Enter City:");
        String city = scanner.nextLine();

        System.out.print("Enter State acronym:");
        String state = scanner.nextLine();

        System.out.print("Enter Zip Code:");
        String zipcode = scanner.nextLine();

        try {
            HomeProperty.insert(street, city, state, zipcode);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public void update(int id) {

    }

    public void delete(int id) {
        String sql = "delete from property where propertyId = ?";

        try (Connection conn = Connect.getConnection()) {
            PreparedStatement statement = conn.prepareStatement(sql);
            statement.setInt(1, id);

            int rowsAffected = statement.executeUpdate();
            if (rowsAffected == 1) {
                System.out.println("Successfully deleted Property!");
            }
        } catch (SQLException e) {
            System.out.println("Error Occurred!");
            System.out.println(e.getMessage());
        }
    }

    private static void printHomeProperties() {
        String sql = "select propertyId, street, city, state, zipCode from property";

        try (Connection conn = Connect.getConnection()) {
            if (conn == null) return;
            Statement statement = conn.createStatement();
            ResultSet result = statement.executeQuery(sql);
            String displayFormat = "%-3s%-25s%-20s%-20s%-20s";
            System.out.println(String.format(displayFormat, "Id", "Street", "City", "State", "Zip Code"));
            while (result.next()) {
                int id = result.getInt("propertyId");
                String street = result.getString("street");
                String city = result.getString("city");
                String state = result.getString("state");
                String zip = result.getString("zipCode");
                System.out.println(String.format(displayFormat, id, street, city, state, zip));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private static void printPropertyDetails(int id) {
        String sql = "select street, city, state, zipCode from property where propertyId = ?";

        try (Connection conn = Connect.getConnection()) {
            if (conn == null) return;
            PreparedStatement statement = conn.prepareStatement(sql);
            statement.setInt(1, id);
            ResultSet result = statement.executeQuery();
            if (result.next()) {
                String street = result.getString("street");
                System.out.printf("Street:%s", street);
                String city = result.getString("city");
                System.out.printf("\tCity:%s", city);
                String state = result.getString("state");
                System.out.printf("\tState:%s", state);
                String zip = result.getString("zipCode");
                System.out.printf("\tZip Code:%s%n", zip);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private static void insert
            (String street, String city, String state, String zipcode)
            throws SQLException {
        String sql = "insert Property (street, city, state, zipcode) "
                + "values (?, ?, ?, ?)";

        Connection conn = Connect.getConnection();
        PreparedStatement statement = conn.prepareStatement(sql);
        statement.setString(1, street);
        statement.setString(2, city);
        statement.setString(3, state);
        statement.setString(4, zipcode);

        int rowsAffected = statement.executeUpdate();
        if (rowsAffected == 1) {
            System.out.println("Successfully added new owner!");
        } else {
            System.out.println("Error Occurred!");
        }
    }
}