Java 8 : how to use lambda expressions on JoinRowSets?

Question

我正在开发一项功能，该功能将在我公司的一些产品中使用，因此我无法拥有特定于产品的代码。

我有 2 个查询的结果存储在 2 个 JoinRowSet 对象上(我必须使用 JoinRowSet 因为我必须稍后将其他查询的结果与这些查询的结果连接起来) 。然后，我需要将这 2 个 JoinRowSet 相交，但我不知道它们“属于”哪个类(我不知道查询是否会返回人员、联系人、部门或任何其他内容) )。有人告诉我应该使用 lambda 表达式来执行此操作，但我发现了一些问题。

我已将其中一个 JoinRowSet 转换为集合(我不知道如何直接在 JoinRowSet 上使用 lambda 表达式)，然后我循环JoinRowSet 之一，对于该 JoinRowSet 的每一列，我想获取初始 Collection 上与该列具有相同值的记录。但是，由于我不知道数据的类，因此我无法执行诸如 u.getAge() 之类的操作，因为我没有属性名称。

这是我的方法:

public static void testLambdas() throws SQLException {

    ... //set the needed stuff to connect to database and query data 

    JoinRowSet jrs1 = ... //result from query 1
    JoinRowSet jrs2 = ... //result from query 2
    Collection<Row> jrs2Collection = (Collection<Row>) jrs2.getRowSets();//collection to use on lambda expression

    while (jrs1.next()) {

        ResultSetMetaData metadata = jrs1.getMetaData();
        for (int j = 1; j <= metadata.getColumnCount(); j++) {

            String dataType = metadata.getColumnTypeName(j);
            Object colValue = null;

            if (dataType.equals("NUMBER")) {
                colValue = jrs1.getBigDecimal(j);               
            } else if (dataType.equals("VARCHAR2")) {
                colValue = jrs1.getString(j);               
            } else if (dataType.equals("DATE")) {
                colValue = jrs1.getTimestamp(j);
            }
            System.out.println(metadata.getColumnName(j)+ " (" + dataType +"): "+ colValue);            

            Object o = jrs2Collection.stream()
                                     .filter(u -> {
                                         try { 
                                             return (u.getColumnObject(j).equals(colValue));
                                         } catch (Exception e) {
                                             e.printStackTrace();
                                             return false;
                                         }
                                     }) 
                                     .collect(Collectors.toCollection(TreeSet::new));

        }
    }
}

请忽略这样一个事实，即 lambda 表达式的使用是在一段时间之内，并且不会在每次迭代中重复使用。如果我能解决我现在遇到的问题，我会解决这个问题。

我必须将 try-catch 添加到过滤器，因为它返回未处理的异常类型 SQLException。添加此 try-catch 后，我在 u.getColumnObject(j) 上得到一个在封闭范围中定义的局部变量 j 必须是最终的或有效最终的.

我不知道我正在做的事情是否是最好的方法，或者我是否做错了什么(我的两个同事看过我的代码，也不知道如何解决这个问题)。

请对此提供任何意见，我将不胜感激。

Answer 1

当您在循环内创建集合而不使用它们时，不清楚您要做什么。所以我无法告诉你是否有更好的解决方案。

关于错误，错误消息非常清楚。您不能在 lambda 中使用可变局部变量。不过，解决方案非常简单:您可以将可变变量的内容分配给不可变变量:

    for (int j = 1; j <= metadata.getColumnCount(); j++) {
        // …
        int currentJ = j;
        Object currentColValue = colValue;
        Object o = jrs2Collection.stream()
          .filter(u -> {
                try { 
                    return (u.getColumnObject(currentJ).equals(currentColValue)); 
                } catch (Exception e) {
                    e.printStackTrace();
                    return false;
                }
            }
        ) 
        .collect(Collectors.toCollection(TreeSet::new));
    }

请注意，currentJ 和 currentColValue 是有效的最终，这意味着您可以向它们添加 final 修饰符，而无需改变程序。要求您在 lambda 表达式中使用的局部变量必须是 final 或有效的final。

<小时/>

顺便说一句，不要考虑“在迭代之间重用 lambda”。在大多数情况下，JRE 将尽可能重用为 lambda 表达式创建的实例。而且 JDBC 操作无论如何都超过了为 lambda 表达式创建的临时对象所带来的任何开销。