package com.bjsxt;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ResourceBundle;
/**
* jdbc工具类
* @author Administrator
*
*/
public class JdbcUtil2 {
private static String driver;
private static String jdbcUrl;
private static String username;
private static String userpassword;
static{
//读取Properties文件
ResourceBundle bundle = ResourceBundle.getBundle("jdbc");
driver = bundle.getString("driver");
jdbcUrl= bundle.getString("jdbcUrl");
username = bundle.getString("username");
userpassword = bundle.getString("userpassword");
try {
Class.forName(driver);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
//获取Connection对象
public static Connection getConnection(){
Connection conn = null;
try {
conn = DriverManager.getConnection(jdbcUrl, username, userpassword);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return conn;
}
//关闭Statement
public static void closeStatement(Statement state){
try {
if(state != null){
state.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
//关闭Connection
public static void closeConnection(Connection conn){
try {
if(conn != null){
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
//關閉資源
public static void closeResource(Statement state,Connection conn,ResultSet rs){
closeStatement(state);
closeConnection(conn);
closeResultSet(rs);
}
//关闭ResultSet连接
public static void closeResultSet(ResultSet rs){
try {
if(rs != null){
rs.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}package com.bjsxt;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class JdbcTest2 {
//向Department表中添加一条数据
public void insertDepartments(String department_name,int location_id) {
Connection conn = null;
Statement state = null;
try {
conn = JdbcUtil2.getConnection();
String sql="insert into departments values(default,'"+department_name+"',"+location_id+")";
state = conn.createStatement();
int flag = state.executeUpdate(sql);
System.out.println(flag);
} catch (Exception e) {
e.printStackTrace();
}finally {
JdbcUtil2.closeResource(state, conn,null);
}
}
//更新departments表中的deoartment_id为5的数据，将部门名称修改为教学部，location_id修改为5
public void updateDempartments(String department_name,int location_id,int department_id) {
Connection conn = null;
Statement state = null;
try {
conn = JdbcUtil2.getConnection();
state = conn.createStatement();
String sql = "update departments d set d.department_name = '"+department_name+"',d.location_id = "+location_id+" where d.department_id = "+department_id;
int flag = state.executeUpdate(sql);
System.out.println(flag);
}catch(Exception e) {
e.printStackTrace();
}finally{
JdbcUtil2.closeResource(state,conn,null);
}
}
//查询Departments表中部门ID为6的部门信息
public void selectDepartmentsById(int departmentId) {
Connection conn = null;
Statement state = null;
ResultSet rs = null;
try {
conn = JdbcUtil2.getConnection();
state = conn.createStatement();
String sql = "select * from departments d where d.department_id = "+departmentId;
//执行查询返回结果
rs=state.executeQuery(sql);
while(rs.next()) {
System.out.println(rs.getInt("department_id")+" "+rs.getString("department_name")+" "+rs.getInt(3));
}
}catch(Exception e) {
e.printStackTrace();
}finally {
JdbcUtil2.closeResource(state,conn,rs);
}
}
public static void main(String[] args) {
JdbcTest2 test2 = new JdbcTest2();
//test2.insertDepartments("教学部",9);
//test2.updateDempartments("工程部",7,5);
test2.selectDepartmentsById(6);
}
}
麻烦老师帮忙看一下这个是什么问题
京公网安备 11011402011233号