package server.servlets;
import java.sql.*;
public class DatabaseReader {
private String driver = server.db.SqlBean.getDriver();
private String url = server.db.SqlBean.getUrl();
private Connection cn;
private Statement stmt;
private ResultSet rs;
private String user = server.db.SqlBean.getUserId();
private String password = server.db.SqlBean.getPassword();
public void setDriver(String _driver) {
driver = _driver;
}
public void setUrl(String _url) {
url = _url;
}
public void setConnection(String _cn) {
}
public void setUser(String _user, String _password) {
user = _user;
password = _password;
}
public void openDatabase() throws ClassNotFoundException,
Exception {
System.out.println("Connecting to Database in openDatabase Method");
System.out.println("URL is " + url + " Driver is " + driver);
try {
Class.forName(driver);
} catch (Exception E) {
System.out.println("Failed on the class name");
}
try {
cn = DriverManager.getConnection(url, user, password);
} catch (Exception E) {
System.out.println("Failed on the connection");
}
stmt = cn.createStatement();
}
public void closeDatabase() {
try {
stmt.close();
cn.close();
} catch (SQLException sqle) {
sqle.printStackTrace();
}
}
public boolean checkRecordExists(String sql) {
try {
openDatabase();
rs = stmt.executeQuery(sql);
closeDatabase();
return rs.next();
} catch (ClassNotFoundException cnf) {
System.out.println("\n ClassNotFound");
cnf.printStackTrace();
return false;
} catch (SQLException sqle) {
System.out.println("\n checkRecordExists Failure");
sqle.printStackTrace();
return false;
} catch (Exception e) {
System.out.println("\n Exception");
e.printStackTrace();
return false;
}
}
}