/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package testdb;

import java.sql.*;

public class DataBaseUtil {

    // метод для получения соединения !!!
    // Connection - интерфейс для получения соединения с БД
    public static Connection getConn() throws SQLException {
        String connectionString = "jdbc:mariadb://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&user=root&password=";
        final Connection connection = DriverManager.getConnection(connectionString);
        return connection;
    }

    // select * from test.t2 t
    public static void printTableData() {
        // try-with-resources
        String sql = "select * from test.t2 t";
        try (Connection c = getConn();
                Statement s = c.createStatement();
                ResultSet rs = s.executeQuery(sql)) {
            // ResultSet - интерфейс для получения данных в виде набора записей (строк)
            // проверка есть ли записи в ResultSet и переход на следущую запись
            while (rs.next()) {
                // используем getString с параметр (название колонки или порядковый номер)
                String id = rs.getString("id"); // rs.getString(1);
                String name = rs.getString("name");
                System.out.println("printTableData.id=" + id);
                System.out.println("printTableData.name=" + name);
            }
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }

    // INSERT INTO test.t2 (name) VALUES('product2');
    public static void createRecord(String name) { // имя продукта в таблице t2
        // параметризованный запрос (запрос содердит символ: ?)
        String sql = "INSERT INTO test.t2 (name) VALUES(?)";
        try (Connection c = getConn(); PreparedStatement s = c.prepareStatement(sql)) {
             // устанавливаем значения параметров запроса - используем метод setString
             s.setString(1, name);
             // выполняем запрос - используем метод executeUpdate
             int rowCount = s.executeUpdate();
             System.out.println("createRecord.rowCount=" + rowCount + " created!");
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
}