package DatabaseConnection;
 
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
 
public class JDBCConnector {
	String dbDriver = "your_db_connection";
	String userId="db_userId";   // individual user id
        String password="db_password"; // individual password
	String dbURL =
	"db_location"+userId+"&password="+password;
 
	private Connection dbCon;
	private DatabaseMetaData dbMetaData;
	private Statement stmt;
 
	public JDBCConnector() {
		super();
	}
 
	public boolean connect()
		throws
			ClassNotFoundException,
			SQLException,
			InstantiationException,
			IllegalAccessException {
 
				Class.forName(this.getDbDriver()).newInstance();
				dbCon = DriverManager.getConnection(this.getDbURL());
				return true;
	}
 
	public void close() throws SQLException {
		dbCon.close();
	}
 
	public void commit() throws SQLException {
		dbCon.commit();
	}
 
	public void setAutoCommit(boolean autocommit) throws SQLException {
		dbCon.setAutoCommit(autocommit);
	}
 
	public void rollback() throws SQLException {
		dbCon.rollback();
	}
 
	public PreparedStatement prepareStatement(String sql) throws SQLException {
		PreparedStatement s = dbCon.prepareStatement(sql);
		return s;
	}
 
	public Statement createStatement() throws SQLException {
		Statement s = dbCon.createStatement();
		return s;
	}
 
	public int executeUpdate(String s) throws SQLException {
		int count = stmt.executeUpdate(s);
		return count;
	}
 
	public ResultSet execSQL(StringBuffer sqlBuf) throws SQLException {
		Statement s = dbCon.createStatement();
		String sql = sqlBuf.toString();
		ResultSet rs = s.executeQuery(sql);
		return (rs == null) ? null : rs;
	}
 
	public String getDbDriver() {
		return this.dbDriver;
	}
 
	public void setDbDriver(String newValue) {
		this.dbDriver = newValue;
	}
 
	public String getDbURL() {
		return this.dbURL;
	}
 
	public void setDbURL(String newValue) {
		this.dbURL = newValue;
	}
 
	public ResultSet doQuery(StringBuffer qry) {
		Connection con = null;
		Statement stmt = null;
 
		// set variables to take in resultset values
		String returnedUserName = null;
		String returnedPassword = null;
		ResultSet rs = null;
 
		try {
			connect();
			rs = execSQL(qry);
 
		} catch (ClassNotFoundException e) {
			System.out.println("ClassNotFound: " + e.getMessage());
		} catch (SQLException e) {
			System.out.println("SQLException: " + e.getMessage());
		} catch (InstantiationException e) {
			System.out.println("InstantiationException: " + e.getMessage());
		} catch (IllegalAccessException e) {
			System.out.println("IllegalAccessException: " + e.getMessage());
		}
		return rs;
	}
 
}

ResultSet rs = s.executeQuery(sql);
return (rs == null) ? null : rs;

public void close() throws SQLException {
		dbCon.close();
	}

public int executeUpdate(String s) throws SQLException {
int count = stmt.executeUpdate(s);
return count;
}