package com.vk;

import java.sql.*;

public class ClassDB {
    private Connection conn;
    private Statement statmt;
    private ResultSet resSet;

    public void Conn() throws ClassNotFoundException, SQLException {
        conn = null;
        try{
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/vk_likes", "root", "root");
            statmt = conn.createStatement();
            System.out.println("База подключена!");
        }
        catch(SQLException e){
            System.out.println("Ошибка подключения базы!");
        }
    }

    public void setAutoCommit(boolean b) throws SQLException {
        conn.setAutoCommit(b);
    }

    public void WriteVkID(int val_vk_id) throws SQLException {
        statmt.addBatch("INSERT IGNORE ids (vk_id) VALUES ('" + val_vk_id + "');");
    }

    public void WriteVk() throws SQLException {
        int [] count = statmt.executeBatch();
        conn.commit();
    }

    public void CloseDB() throws ClassNotFoundException, SQLException {
        resSet.close();
        statmt.close();
        conn.close();

        System.out.println("Соединения закрыты");
    }
}