DAO 对象中的关闭连接[重复]

Question

我的 DAO 对象

package com.myselect;

import java.sql.*;
import java.sql.DriverManager;

import java.util.logging.Level;
import java.util.logging.Logger;

public class DataAccess {

    Connection conn;
    PreparedStatement pst;
    ResultSet rs;

    public DataAccess() {
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = (Connection) DriverManager.getConnection("jdbc:mysql://localhost/db", "root", "root");
        } catch (ClassNotFoundException ex) {
            Logger.getLogger(DataAccess.class.getName()).log(Level.SEVERE, null, ex);
        } catch (SQLException ex) {
            Logger.getLogger(DataAccess.class.getName()).log(Level.SEVERE, null, ex);
        }

    }

    public String getAge(String name) {
        String userage = null;
        try {
            pst = conn.prepareStatement("select age from mydb where name= ?");
            pst.setString(1, name);

            rs = pst.executeQuery();

            while (rs.next()) {
                userage = rs.getString("age");
                System.out.println(userage);
            }

        } catch (Exception ex) {
            Logger.getLogger(DataAccess.class.getName()).log(Level.SEVERE, null, ex);
        }

        return userage;
    }

    public int insertRecord(String name, int addage) {
        int b = 0;
        try {
            pst = conn.prepareStatement("insert into mydb values(?,?)");
            pst.setString(1, name);
            pst.setInt(2, addage);
            b = pst.executeUpdate();

        } catch (Exception ex) {
            Logger.getLogger(DataAccess.class.getName()).log(Level.SEVERE, null, ex);
        }

        return b;
    }


}

我想关闭连接。我有几个调用insertRecord 和getAge 方法的servlet。关闭连接的最佳方法是什么？创建另一个方法并从insertRecord 和getAge 方法或构造函数中调用？

Answer 1

在考虑连接之前，您还应该始终在每次使用 ResultSet 和 Statement 对象时关闭它们。不要将它们作为状态保留在您的 DataAccess 对象中。将它们作为局部变量并在使用后关闭它们：

public String getAge(String name) {
    PreparedStatement pst = null;
    ResultSet rs = null;
    String userage = null;
    try {
        pst = conn.prepareStatement("select age from mydb where name= ?");
        pst.setString(1, name);

        rs = pst.executeQuery();

        while (rs.next()) {
            userage = rs.getString("age");
            System.out.println(userage);
        }

    } catch (Exception ex) {
        Logger.getLogger(DataAccess.class.getName()).log(Level.SEVERE, null, ex);
    } finally {
       // closing JDBC resources
       if(rs != null) {
          rs.close();
       }

      if(pst != null) {
          pst.close();
       }

    return userage;
}

连接也是如此：理想情况下，每个方法都应该创建一个Connection 对象并在使用后关闭它。根据您在方法中打开和关闭连接的频率，您可能希望使用连接池来共享打开的连接以提高效率。

要关闭连接及其资源，您可以创建一个方法来执行此操作：

public void closeConnection(Connection connection, Statement statement, ResultSet resultSet) {
     ... // close resources here   
}

Answer 2

应在需要时打开和关闭连接。在您的情况下，您在一个点打开一个连接，然后在另一个点使用它。这意味着您打开了一个连接并且可能有一段时间不使用它。

您需要做的是使方法自包含，这意味着方法应该打开连接，完成后关闭它。关闭部分应该在 finally 块内完成，这将确保无论发生什么，集合都将始终关闭。

类似这样的：

public String getAge(String name) {
        String userage = null;
        Connection conn = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = (Connection) DriverManager.getConnection("jdbc:mysql://localhost/db", "root", "root");

            PreparedStatement pst = conn.prepareStatement("select age from mydb where name= ?");
            pst.setString(1, name);

            rs = pst.executeQuery();

            while (rs.next()) {
                userage = rs.getString("age");
                System.out.println(userage);
            }

        } catch (Exception ex) {
            Logger.getLogger(DataAccess.class.getName()).log(Level.SEVERE, null, ex);
        }
        finally {
            if(conn != null) {
                conn.close();
            }

            if(pst != null) {
                pst.close();
            }

            if(rs != null) {
                rs.close();
            }
        }

        return userage;
    }

编辑：根据@virtualpathum 的建议，您还可以查看 3rd 方框架，它们为您提供管理连接池的方法，通常通过实现单例编程模式。