JDBC四(web基础学习笔记十)

一、增加 、修改、删除、查询

package pb.base;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import pb.until.ConfigManager;

public class Base {
public Connection conn;
public PreparedStatement pstmt;
public Statement stmt;
public ResultSet rs;

//建立连接
public boolean getConnection(){
// 获取DRIVER，url,用户名密码
String driver = ConfigManager.getintance().getvalue("jdbc.driver");
String url = ConfigManager.getintance().getvalue("jdbc.url");
String uname = ConfigManager.getintance().getvalue("jdbc.uname");
String pwd = ConfigManager.getintance().getvalue("jdbc.upwd");
// (1)使用Class.forName()加载驱动
try {
Class.forName(driver);
// (2)DriverManager.getConnection(URL,用户名，密码)获取数据库的连接Connection
// Oracle连接方式jdbc:oracle:thin:@localhost:1521:orcl
conn = DriverManager.getConnection(url, uname, pwd);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return false;
}catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return false;
}
return true;
}

//增加，修改，删除
public int  executeUpdate(String sql,Object [] pararm){

int UpdateRow=0;
getConnection();
try {
pstmt=conn.prepareStatement(sql);
//遍历数组设置每个值
for(int i=0;i<pararm.length;i++){
pstmt.setObject(i+1, pararm[i]);
}
UpdateRow = pstmt.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return UpdateRow;
}

//查询
public ResultSet executeSQL(String sql,Object [] pararm){
getConnection();
try {
pstmt=conn.prepareStatement(sql);
//遍历数组设置每个值
for(int i=0;i<pararm.length;i++){
pstmt.setObject(i+1, pararm[i]);
}
rs = pstmt.executeQuery();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return rs;
}

//关闭数据库连接
public boolean CloseConnection(){
try {
if(rs!=null){
rs.close();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return false;
}

try {
if(stmt!=null){
stmt.close();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return false;
}
try {
if(pstmt!=null){
pstmt.close();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return false;
}
try {
if(conn!=null){
conn.close();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return false;
}
return true;

}
}