package poe.indexer;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class MySQLThread extends Thread{
    private Connection con;
    private String MySQLHost;
    private String MySQLUser;
    private String MySQLPassword;

    public MySQLThread(Runnable r, String host, String user, String password ){
        super(r);
        MySQLHost = host;
        MySQLUser = user;
        MySQLPassword = password;
    }

    public MySQLThread(String host, String user, String password ){
        MySQLHost = host;
        MySQLUser = user;
        MySQLPassword = password;
    }

    public void closeConnection() {
        try { con.close(); } catch (SQLException e) { }
    }

    public Connection getConnection(){
        return con;
    }

    public void run() {
        try{
            con = DriverManager.getConnection(MySQLHost, MySQLUser, MySQLPassword);
        }catch(Exception e) {}
    }
}