package randomdataset;

import java.sql.*;
import java.util.logging.Level;
import java.util.logging.Logger;

public class InsertMySQL {

    private String url = " ";
    private String user = "root";
    private String password = "2916";
    private String filePath;

    public InsertMySQL(String url, String filePath) {
        this.url = url;
        this.filePath = filePath;
        //pass database address (url) and text file path (filePath)
    }

    public void connect() {
        try (Connection con = DriverManager.getConnection(url, user, password)) {
            Class.forName("");

            if (con != null) {
                System.out.println("Connection to database successful");
            }
        } catch (ClassNotFoundException e) {
            System.out.println("Database driver class not found");
            e.printStackTrace();
        } catch (SQLException e) {
            System.out.println("Error with SQL");
            e.printStackTrace();
        }
    }

    public void insert() {
        try {
            try (Connection con = DriverManager.getConnection(url, user, password)) {
                String querySetLimit = "SET GLOBAL max_allowed_packet=104857600;";  // 10 MB
                Statement stSetLimit = con.createStatement();
                stSetLimit.execute(querySetLimit);

                String sql = "INSERT INTO patient(ID, sex, age) values (LOAD_FILE(?))";
                PreparedStatement statement = con.prepareStatement(sql);

                statement.setString(1, filePath);

                int tuple = statement.executeUpdate();

                if (tuple > 0) {
                    System.out.println("A patient was inserted");
                }
            }
        } catch (SQLException ex) {
            Logger.getLogger(InsertMySQL.class.getName()).log(Level.SEVERE, null, ex);
        }