Camunda Java Delegate执行多数据库查询失败问题求助

环境配置 #

• JDK：Liberica 11.0.22
• Camunda版本：7.17.0
• 已在Tomcat的context.xml和Camunda应用的web.xml中配置名为jdbc/tstECOM的MySQL数据源

问题描述 #

编写Java Delegate用于创建Store对象并填充数据，但仅第一个方法能正常执行；添加其他方法后，Camunda抛出流程实例初始化错误：无法实例化流程定义，持久层发生异常。尝试将Stock相关方法放入构造函数、按顺序调用，均未解决问题，怀疑getStocksForStore()方法的数据库连接环节存在问题。

核心问题诊断 #

1. 静态Connection变量引发线程安全问题：Store类中使用static java.sql.Connection ECOM，多线程环境下会导致连接被共享、覆盖，引发连接状态异常。
2. 异常处理缺失：所有SQL异常仅调用e.getMessage()而不抛出或记录，错误被隐藏，无法定位具体问题。
3. Hub类递归构造死循环：Hub继承自Store，其无参构造调用super(ECOM)，会触发Store的构造逻辑，进而可能调用getHubForThisStore()创建Hub实例，形成递归死循环。
4. JDBC资源未正确关闭：Statement、PreparedStatement、ResultSet等资源未在finally块中关闭，可能导致连接泄漏。
5. SQL语句格式错误：代码中SQL字符串拼接存在换行导致的语法问题。

解决方案 #

1. 移除静态Connection变量，改为实例变量 #

消除线程共享风险，将Store类中的静态连接改为实例变量：

public class Store {
    String ID;
    Stock stock = new Stock(); // 变量名遵循小写开头规范
    private HashMap<String, List<Hub>> hubMap = new HashMap<>(); // 重命名避免与类名冲突
    private Connection ecomConn; // 改为实例变量

    public Store(Connection ecomConn) throws SQLException {
        this.ecomConn = ecomConn;
        getStoreFromECOM();
        getStocksForStore();
    }
    // ... 其他方法
}

2. 重构Hub类，消除递归继承 #

Hub无需继承Store，改为独立类避免递归构造：

public class Hub {
    private String id;
    private Stock stock;

    public Hub(String id, Connection conn) throws SQLException {
        this.id = id;
        this.stock = new Stock();
        this.stock.setOwner(id);
        this.stock.getStocksForThisStore(conn);
    }

    // 添加必要的getter/setter
    public String getId() { return id; }
    public Stock getStock() { return stock; }
}

3. 完善异常处理与资源关闭 #

在所有JDBC操作中，正确捕获并抛出异常，同时关闭资源：

public void getStoreFromECOM() throws SQLException {
    List<String> storeIds = new ArrayList<>();
    Statement stmt = null;
    ResultSet rs = null;
    try {
        stmt = ecomConn.createStatement();
        String sql = "SELECT s.store_id, hts.hub_store_id, hts.level_id " +
                     "FROM stores s " +
                     "INNER JOIN hub_to_stores hts ON s.store_id = hts.hub_store_id " +
                     "WHERE hts.level_id IN (0,1,2) " +
                     "GROUP BY hub_store_id, level_id";
        rs = stmt.executeQuery(sql);
        while (rs.next()) {
            storeIds.add(rs.getString("store_id"));
        }
    } catch (SQLException e) {
        throw new SQLException("获取Store列表失败", e);
    } finally {
        // 安全关闭资源
        if (rs != null) try { rs.close(); } catch (SQLException ignored) {}
        if (stmt != null) try { stmt.close(); } catch (SQLException ignored) {}
    }
    if (storeIds.isEmpty()) {
        throw new IllegalStateException("未找到符合条件的Store");
    }
    this.ID = storeIds.get(new Random().nextInt(storeIds.size()));
}

4. 修复getHubForThisStore方法逻辑错误 #

原方法中每次循环创建新List导致数据丢失，同时调整Hub实例创建方式：

public void getHubForThisStore() throws SQLException {
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try {
        String query = "SELECT hub_store_id, level_id FROM hub_to_stores WHERE store_id = ?";
        pstmt = ecomConn.prepareStatement(query);
        pstmt.setString(1, this.ID);
        rs = pstmt.executeQuery();
        while (rs.next()) {
            String levelId = rs.getString("level_id");
            String hubId = rs.getString("hub_store_id");
            // 获取或创建对应层级的Hub列表
            List<Hub> hubList = hubMap.getOrDefault(levelId, new ArrayList<>());
            Hub hub = new Hub(hubId, ecomConn);
            hubList.add(hub);
            hubMap.put(levelId, hubList);
        }
    } catch (SQLException e) {
        throw new SQLException("获取Hub信息失败", e);
    } finally {
        if (rs != null) try { rs.close(); } catch (SQLException ignored) {}
        if (pstmt != null) try { pstmt.close(); } catch (SQLException ignored) {}
    }
}

5. 修正Stock类SQL语句格式与资源管理 #

public void getStocksForThisStore(Connection connection) throws SQLException {
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try {
        String query = "SELECT good_id, quantity, reserve_quantity, available_quantity " +
                       "FROM original_stock WHERE store_id = ?";
        pstmt = connection.prepareStatement(query);
        pstmt.setString(1, this.getOwner()); // 使用getter方法
        rs = pstmt.executeQuery();
        while (rs.next()) {
            SKU sku = new SKU();
            sku.setGoodID(rs.getInt("good_id"));
            sku.setQuantity(rs.getFloat("quantity"));
            sku.setReserve(rs.getFloat("reserve_quantity"));
            sku.setAvailable(rs.getFloat("available_quantity"));
            this.getSKU().add(sku);
        }
    } catch (SQLException e) {
        throw new SQLException("获取Stock信息失败", e);
    } finally {
        if (rs != null) try { rs.close(); } catch (SQLException ignored) {}
        if (pstmt != null) try { pstmt.close(); } catch (SQLException ignored) {}
    }
}

6. 优化Delegate类代码 #

调整异常捕获顺序，确保连接关闭前完成所有操作：

public class GetStore implements JavaDelegate { // 类名遵循首字母大写规范
    @Override
    public void execute(DelegateExecution execution) throws Exception {
        InitialContext ctx = new InitialContext();
        DataSource ds = (DataSource) ctx.lookup("java:comp/env/jdbc/tstECOM");
        try (Connection connection = ds.getConnection()) {
            Store store = new Store(connection);
            store.getHubForThisStore(); // 调用Hub数据填充方法
            execution.setVariable("store", store.serializeStore());
        } catch (SQLException e) {
            throw new BpmnError("cantGetStoreFromECOM", "无法连接到ECOM数据库: " + e.getMessage());
        } catch (Exception e) {
            throw new BpmnError("cantCreateInstanceOfStore", "创建Store对象失败: " + e.getMessage());
        }
    }
}

额外建议 #

• 严格遵循Java命名规范：类名首字母大写，变量名小写开头，避免与类名冲突。
• 使用SLF4J等日志框架记录异常详细堆栈信息，便于排查问题。
• 考虑引入MyBatis等ORM框架简化JDBC操作，减少手动资源管理错误。

内容的提问来源于stack exchange，提问作者Николай Минаев