JDBC 连接关闭

Question

有人可以告诉我在哪里以及如何关闭这里的连接吗？我是否必须在 Connection 类或 Controller 类中关闭 Connection？我已经尝试在连接类中的方法末尾添加以下内容：

if (conn != null) {
        try {
            conn.close();
        } catch (SQLException e) { /* ignored */}
    } 

但后来我得到：“声明关闭后不允许进行任何操作。”

这是我的代码：

public class DB_Connection {

String url = "XXX";

Statement statement;

public DB_Connection (){
       try {

           Connection con =  (Connection) DriverManager.getConnection(url);
           statement = (Statement) con.createStatement();

       }
       catch (SQLException ex){
           System.out.println("Failed connection");
       }
   }

public void addSubject(String subject) throws SQLException {

     try {
     statement.executeUpdate("INSERT INTO `Subject` VALUES ('" + subject + "')" );
     System.out.println("Added " + subject + "to database");
     } catch(SQLException e) {
         System.out.println("SQL Exception");
     }
 }
}

我从这里称呼它：

public class MenuController {

    @FXML
        public void SendSubject(ActionEvent e) throws IOException, SQLException {
            DB_Connection connection = new DB_Connection();
            connection.addSubject("English");

        }

    }

感谢您的帮助！

Answer 1

使用完毕后需要关闭连接。有很多方法可以解决这个问题，但我建议您这样做：

public class DBConnection implements AutoCloseable {
    private String url = ...
    private Connection con;
    private Statement statement;

    public DBConnection () throws SQLException {
        try {
             con = DriverManager.getConnection(url);
             statement = con.createStatement();
        } finally {
             // Avoid leak if an exception was thrown in createStatement
             if (statement == null) {
                 con.close();
             }
        }
    }

    public void addSubject(String subject) throws SQLException {
        statement.executeUpdate("INSERT INTO `Subject` VALUES ('" + 
                                subject + "')" );
    }

    public void close() throws SQLException {
        con.close();
    }
}

然后像这样使用它：

try (DBConnection connection = new DBConnection()) {
     connection.addSubject("English");
}

解释/评论：

1. 该方法是应用程序告诉类“我已经完成”close()的方式。DBConnection
2. 声明DBConnection为“AutoCloaseable”意味着我们可以使用 try-with-resources 来管理闭包……这更简单、更健壮。
3. 实例变量private符合良好的 OO 设计原则。
4. 类名根据 Java 约定进行更正。
5. 我们仍然需要小心，以确保如果构造函数本身发生异常，我们不会泄漏连接。
6. 我们允许SQLException传播给调用者。这些异常无法在类本身中正确处理DBConnection。

另一种方法是完全取消类DBConnection，并让调用代码自行处理连接对象和语句。当然，在这个小例子中，DBConnection抽象增加的价值很小。