package dbcon;
import java.sql.*;
import java.io.*;
import java.util.*;
import javax.servlet.*;
import javax.servlet.http.*;
import javax.naming.*;
import javax.sql.*;public class mydb {String strUser="",strPassword="";
String strDbdriver="sun.jdbc.odbc.JdbcOdbcDriver";
String strConstring="jdbc:odbc:ibbs";Connection conn = null;
ResultSet rs = null;public mydb() {
try {//--read db info from config file-------------
Class.forName(strDbdriver);
}
catch(Exception e) {
System.err.println("mydb(): " + e.getMessage());
}
}//----query------------------
public ResultSet executeQuery(String sql)throws Exception {
rs = null;
conn = DriverManager.getConnection(strConstring,strUser,strPassword);
Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
rs = stmt.executeQuery(sql);
if(rs==null){System.exit(1);}
return rs;
}
//---Update-------------------
public void executeUpdate(String sql) {
try {
conn = DriverManager.getConnection(strConstring,strUser,strPassword);
Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_SCROLL_SENSITIVE,java.sql.ResultSet.CONCUR_UPDATABLE);
stmt.executeUpdate(sql);
stmt.close();
conn.close();
}
catch(SQLException ex) {
System.err.println("aq.executeUpdate: " + ex.getMessage());
}
}
}
import java.sql.*;
import java.io.*;
import java.util.*;
import javax.servlet.*;
import javax.servlet.http.*;
import javax.naming.*;
import javax.sql.*;public class mydb {String strUser="",strPassword="";
String strDbdriver="sun.jdbc.odbc.JdbcOdbcDriver";
String strConstring="jdbc:odbc:ibbs";Connection conn = null;
ResultSet rs = null;public mydb() {
try {//--read db info from config file-------------
Class.forName(strDbdriver);
}
catch(Exception e) {
System.err.println("mydb(): " + e.getMessage());
}
}//----query------------------
public ResultSet executeQuery(String sql)throws Exception {
rs = null;
conn = DriverManager.getConnection(strConstring,strUser,strPassword);
Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
rs = stmt.executeQuery(sql);
if(rs==null){System.exit(1);}
return rs;
}
//---Update-------------------
public void executeUpdate(String sql) {
try {
conn = DriverManager.getConnection(strConstring,strUser,strPassword);
Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_SCROLL_SENSITIVE,java.sql.ResultSet.CONCUR_UPDATABLE);
stmt.executeUpdate(sql);
stmt.close();
conn.close();
}
catch(SQLException ex) {
System.err.println("aq.executeUpdate: " + ex.getMessage());
}
}
}
import java.io.*;
import java.sql.*;/**
** <code>DBcon</code> is a user-defined class.
开发:张葵<br>
功能:数据库相关操作<br>
*/
public class DBcon
{
String DBDriver = "oracle.jdbc.driver.OracleDriver"; //driver address;
String ConnStr = "jdbc:oracle:thin:@dataserver:1521:oradb";
String User="test";//database user name
String Passwd="test";//user password Connection conn = null; //connection
Statement stmt = null; //statment
ResultSet rs = null; //resultset public void DBcon (){
try {
System.out.print("test");
Class.forName(DBDriver).newInstance();//load db driver
conn = DriverManager.getConnection(ConnStr,User,Passwd);//create connection;
}catch(java.lang.ClassNotFoundException e) {
System.err.println("DBcon (): " + e.getMessage());
}catch(SQLException ex) {
System.err.println("aq.executeQuery: " + ex.getMessage());
}catch (Exception e)
{
System.err.println("\n打开数据库时异常,错误信息为:\n" + e.getMessage());
}
} //执行查询,返回数据集;
public ResultSet query(String sql) { rs = null;
try {
Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);//create statment
rs = stmt.executeQuery(sql);
}catch(SQLException ex) {
System.err.println("aq.executeQuery: " + ex.getMessage());
}
return rs; }
//执行更新,返回操作状态;
public int update(String sql) {
int success_update=0;
try {
Statement stmt = conn.createStatement();//create statment
success_update=stmt.executeUpdate(sql);
}catch(SQLException ex) {
System.err.println("aq.executeQuery: " + ex.getMessage());
}
return success_update;
} //关闭连接;
public void conClose(){
try {
conn.close();
}catch(SQLException ex) {
System.err.println("aq.executeQuery: " + ex.getMessage());
}
}
}