package com;

import java.sql.*;

public class TestPStatement implements Runnable {

    private final String DB_URL  = "jdbc:mysql://localhost:3306/test";
    private final String DB_USER = "root";
    private final String DB_PASS = "root";

    private final String[] fNames = {"Peter", "Ivan", "Peter", "Ivan"};
    private final String[] lNames = {"Ivanov", "Petrov", "Petrov", "Ivanov"};

    public static void main(String[] args) {
        new TestPStatement().run();
    }

    public void run() {
        Connection connection = null;
        try {
            connection = DriverManager.getConnection(DB_URL, DB_USER, DB_PASS);

            Statement statement = connection.createStatement();
            statement.addBatch("DROP TABLE IF EXISTS users");
            statement.addBatch("CREATE TABLE users (id int PRIMARY KEY, firstName varchar(30), lastName varchar(30))");
            statement.executeBatch();

            PreparedStatement addUser = connection.prepareStatement("INSERT INTO users (id, firstName, LastName) VALUES (?, ?, ?)");
            for (int i = 0; i < fNames.length; i++) {
                addUser.setLong(1, i);
                addUser.setString(2, fNames[i]);
                addUser.setString(3, lNames[i]);
                addUser.addBatch();
            }
            addUser.executeBatch();

            PreparedStatement showUsers = connection.prepareStatement("select * from users where firstName like ?");
            showUsers.setString(1, "P%");
            showUsers.execute();

            ResultSet rs = showUsers.getResultSet();
            while (rs.next()) {
                System.out.print(rs.getString("firstName"));
                System.out.print(" ");
                System.out.println(rs.getString("lastName"));
            }

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}