网站建设知识
使用JDBC连接MySQL数据库--典型案例分析(二)--封装数据库的连接与关闭
2025-07-22 09:52  点击:0

在第一节中,我们已经基本实现了使用Myeclipse和Mysql数据库的连接,并且查询了员工的一些信息。但是上次的实现多多少少有不完美之处,这次进行进一步优化。

这次:将数据库的连接获取和关闭封装到DBUtility类中,并重构之前的案例,使用DBUtility类获取和关闭连接。

步骤

封装数据库连接的获取和关闭的过程如下:

1.创建属性db.properties,在该文件中以键值对的形式来存储连接数据库的相关信息。该文件的内容如下:

jdbc.driver=com.mysql.jdbc.Driver

jdbc.url=jdbc:mysql://127.0.0.1:3306/emp

jdbc.user=wonderq

jdbc.password=root

这样做的目的是当需要修改连接数据的信息时,只需修改该文件集合,降低了连接数据库的信息与使用类之间的耦合。

2.创建DBUtility类,使用static块,初始化连接数据的信息,代码如下:

static {try{//加载配置文件properties.load(DBUtility.class.getClassLoader().getResourceAsStream("Emp/src/dao/db.properties"));driver=properties.getProperty("jdbc.driver");url=properties.getProperty("jdbc.url");user=properties.getProperty("jdbc.user");pwd=properties.getProperty("jdbc.password");Class.forName(driver);//加载驱动类}catch (Exception e) {e.printStackTrace();throw new RuntimeException(e);}}
其中,
"Emp/src/dao/db.properties"
表示文件db.properties所在的包路径,可以按照你自己工程的包路径来写代码。

3.创建打开和关闭连接数据库的方法,代码如下:

public static Connection openConnection() throws SQLException{return DriverManager.getConnection(url,user,pwd);}public static void closeConnection(Connection con){if(con!=null){try {con.close();} catch (SQLException e) {System.out.println("关闭数据库时发生异常!");}}}
4.重构EmpDAO类,使用DBUtility类获取连接和关闭连接。
重构EmpDAO类,在该类中使用DBUtility类的openconnection获取连接,使用closeConnection方法关闭连接,代码如下所示:
package dao;import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;public class EmpDAO {public static void main(String [] args){EmpDAO dao=new EmpDAO();dao.findAll();}public void findAll(){Connection con=null;Statement stmt=null;ResultSet rs=null;try {con=DBUtility.openConnection();stmt=con.createStatement();rs=stmt.executeQuery("select empno,ename,sal,hiredate from emp;");while(rs.next()){System.out.println(rs.getInt("empno")+","+rs.getString("ename")+","+rs.getDouble("sal")+","+rs.getDate("hiredate"));}} catch (SQLException e) {System.out.println("数据库访问异常!");throw new RuntimeException(e);}finally{try {if(rs!=null){rs.close();}if(stmt!=null){stmt.close();}} catch (SQLException e) {System.out.println("释放资源时发生异常!");}DBUtility.closeConnection(con);}}}

运行类EmpDAO,输出结果与之前相同: