import java.math.BigInteger;
import java.sql.*;
import java.util.Vector;

/**
 *
 * @author Joseph
 */
public class DBWrapper {
    static Connection con = null;
    String ip2;
    String port2;
    String tab2;
    public DBWrapper(String user, String pass, String ip, String port, String tabname){
        try {
            Class.forName("com.mysql.jdbc.Driver").newInstance();
            if(user!=null & pass!=null){
                //////////////////////////////
                if(ip!=null){
                    ip2=ip;
                }
                else{
                   ip2="";
                }
                //////////////////////////////

                //////////////////////////////
                if(port!=null){
                    port2=port;
                }
                else{
                    port2="3306";
                }
                port2 = ":"+port2;
                //////////////////////////////

                //////////////////////////////
                if(tabname!=null){
                    tab2=tabname;
                }
                else{
                    tab2="test";
                }
                //////////////////////////////
            }
            con = DriverManager.getConnection("jdbc:mysql://"+ip2+port2+"/"+tab2, user, pass);

            if(!con.isClosed()){
                System.out.println("Successfully connected to MySQL server...");
            }

        } catch(Exception e) {
            System.err.println("Fail: " + e.getMessage() + " Table: " + tabname);
        }
    }
    public void Exec(String query){
        Statement state;
        try{
            state = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
            state.executeUpdate(query);
        } catch(SQLException e){
            System.err.println("Fail: " + e.getMessage() + "Query: "+query);
        } catch(NullPointerException e){
            System.err.println("Could not connect to the server, or some other error. Error: "+e.getMessage());
        }
    }

    public Vector Query(String query){
        Statement state;
        ResultSet rs = null;
        Vector returner = new Vector();
        try{
            state = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
            rs = state.executeQuery(query);
            ResultSetMetaData rsmd = rs.getMetaData();
            int colNo = rsmd.getColumnCount();
            while (rs.next()) {
                Vector newvec = new Vector();
                for (int i = 0; i < colNo; i++) {
                    newvec.add(i, rs.getObject(i + 1));
                }
                returner.add(newvec);
            }
        } catch(SQLException e){
            System.err.println("Fail: " + e.getMessage() + "Query: "+query);
        }
        return returner;
    }
    public BigInteger Next_AutoInc(String tabname) {
        BigInteger str = null;
        try {
            Statement state = con.createStatement();
            Vector thing = new Vector();
            thing = this.Query("SHOW TABLE STATUS LIKE '" + tabname + "'");
            Vector thing2 = (Vector)thing.get(0);
            str = (BigInteger)thing2.get(10);
        } catch (SQLException e) {
            System.err.println("Fail: " + e.getMessage() + " Table: " + tabname);
        }
        BigInteger one = BigInteger.valueOf(-1);
        return str.add(one);
    }
}