日期:2014-05-17 浏览次数:20976 次
public class Db {
/**
* @param args
*/
//dbUrl数据库连接串信息,其中“1521”为端口,“ora9”为sid
private String dbUrl = "jdbc:oracle:thin:@192.168.86.204:1521:qc";
//theUser为数据库用户名
private String usr = "god";
//thePw为数据库密码
private String psw = "onmygod";
//几个数据库变量
private Connection con = null;
private Statement sta = null;
private ResultSet rs = null;
//初始化连接
public void dbconn() {
try {
Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
//与url指定的数据源建立连接
con = DriverManager.getConnection(dbUrl, usr, psw);
//采用Statement进行查询
sta = con.createStatement();
} catch (Exception e) {
e.printStackTrace();
}
}
//执行查询
public ResultSet select(String sql)
{
dbconn();
try {
rs=sta.executeQuery(sql); //Statement的executeQuery()方法则是用于SELECT等查询数据库的SQL,executeUpdate()方法会返回int结果,表示记录变动的数目,executeQuery()方法会返回java.sql.ResultSet对象
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
return rs;
}
//执行增删改
public int change(String sql)
{
dbconn();
int i=0;
try {
i=sta.executeUpdate(sql);
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
return i;
}
return i;
}
//关闭连接
public void close() {
try {
if (rs != null)
rs.close();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
if (sta != null)
sta.close();
} catch (SQLException e) {
e.printStackTrace();
} finally {
if (con != null)
try {
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
}
//执行增删改
public int change(String sql)
{
[color=#FF0000]dbconn();[/color] int i=0;
try {
i=sta.executeUpdate(sql);
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
return i;
}
return i;
}
------解决方案--------------------