如何在JavaFX中对接PostgreSQL，解决运行SQL查询时空连接报错问题

你遇到的空连接错误核心原因是ConnectionClass类的getConnection()方法未正确获取数据库连接，返回了null值，后续调用connection.createStatement()时触发空指针。同时现有代码还存在SQL执行逻辑错误、结果展示不全、资源未释放等问题，修复方案如下： #

1. 修复数据库连接类 #

请按照以下示例修改你的ConnectionClass实现，替换为你自己的数据库配置：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class ConnectionClass {
    // 替换为你的实际数据库配置
    private static final String DB_URL = "jdbc:postgresql://localhost:5432/你的数据库名称";
    private static final String DB_USER = "你的数据库用户名";
    private static final String DB_PWD = "你的数据库密码";

    public Connection getConnection() {
        Connection conn = null;
        try {
            // 加载PostgreSQL驱动
            Class.forName("org.postgresql.Driver");
            conn = DriverManager.getConnection(DB_URL, DB_USER, DB_PWD);
        } catch (ClassNotFoundException e) {
            System.out.println("驱动加载失败：" + e.getMessage());
        } catch (SQLException e) {
            System.out.println("连接失败：" + e.getMessage());
        }
        return conn;
    }
}

2. 修复Controller逻辑 #

原代码中同一条SQL先后调用executeUpdate和executeQuery属于逻辑错误，同时缺少空值校验、结果展示逻辑不完善、没有资源释放步骤，修复后代码如下：

import javafx.event.ActionEvent;
import javafx.fxml.FXML;
import javafx.scene.control.Label;
import javafx.scene.control.TextField;
import java.sql.*;

public class ListController {

    @FXML
    public TextField sqlTextField;
    @FXML
    public Label textLabel;

    public void handleSaveButton(ActionEvent actionEvent) {
    }

    public void handleRunButton(ActionEvent actionEvent1) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            ConnectionClass connectionClass = new ConnectionClass();
            conn = connectionClass.getConnection();
            // 连接空值校验
            if (conn == null) {
                textLabel.setText("错误：数据库连接失败，请检查配置");
                return;
            }
            String inputSql = sqlTextField.getText().trim();
            // 输入内容校验
            if (inputSql.isEmpty()) {
                textLabel.setText("错误：请输入SQL命令");
                return;
            }
            String sql = inputSql.endsWith(";") ? inputSql : inputSql + ";";
            stmt = conn.createStatement();
            boolean hasResultSet = stmt.execute(sql);
            if (hasResultSet) {
                // 处理查询类SQL的结果集
                rs = stmt.getResultSet();
                StringBuilder resultBuilder = new StringBuilder();
                ResultSetMetaData metaData = rs.getMetaData();
                int columnCount = metaData.getColumnCount();
                // 拼接列名
                for (int i = 1; i <= columnCount; i++) {
                    resultBuilder.append(metaData.getColumnName(i)).append("\t");
                }
                resultBuilder.append("\n--------------------------\n");
                // 拼接每行数据
                while (rs.next()) {
                    for (int i = 1; i <= columnCount; i++) {
                        resultBuilder.append(rs.getString(i)).append("\t");
                    }
                    resultBuilder.append("\n");
                }
                textLabel.setText(resultBuilder.toString());
            } else {
                // 处理增删改类SQL
                int affectRows = stmt.getUpdateCount();
                textLabel.setText("执行成功，影响行数：" + affectRows);
            }
        } catch (SQLException e) {
            textLabel.setText("执行错误：" + e.getMessage());
        } finally {
            // 释放资源避免连接泄露
            try {
                if (rs != null) rs.close();
                if (stmt != null) stmt.close();
                if (conn != null) conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

3. 前置检查项 #

• 确认项目已引入PostgreSQL JDBC驱动包
• 确认PostgreSQL服务正常运行，配置的IP、端口、库名、账号密码正确
• 如果需要展示更规整的多列多行结果，建议将Label替换为JavaFX的TableView组件
• 生产环境禁止开放用户原生SQL输入权限，避免SQL注入风险
  你对应的UI界面如下：
  

内容的提问来源于stack exchange，提问作者Azad