我的问题是有关Jinq的,并且我使用的是当前最新的版本1.8.9。
我正在尝试使用Jinq通过Java 8 lambda(功能接口)谓词作为方法参数来实现通用的可重用JPA(Java Persistence API)类型安全查询方法。
不幸的是,我无法使其与Java 8谓词一起使用,但我可以使用类似的谓词类型(由Jinq提供)作为方法参数,但希望避免方法签名中对Jinq的依赖,因此更喜欢Java 8如果可能的话?
Jinq提供功能接口“ Where”:
package org.jinq.orm.stream;
public interface JinqStream<T> extends Stream<T> {
@FunctionalInterface
public static interface Where<U, E extends Exception> extends Serializable {
public boolean where(U obj) throws E;
}
我可以通过在方法签名中使用上述接口来实现所需的查询方法(但具有不希望的耦合),如下所示:
public List<T> select(JinqStream.Where<T, Exception> wherePredicate)
除了使用方法签名中的上述与Jinq的耦合之外,我想使用如下的标准谓词:
public List<T> select(java.util.function.Predicate<T> wherePredicate) {
标准谓词的定义如下:
@FunctionalInterface
public interface Predicate<T> {
public boolean test(T t);
}
因此,我认为使用以下代码创建Jinq接口的lambda实现,可以实现所需的select方法:
public List<T> select(java.util.function.Predicate<T> predicate) {
org.jinq.orm.stream.JinqStream.Where<T, Exception> wherePredicate = u -> predicate.test(u);
...
但是,它不起作用,但会导致IllegalArgumentException(请参见下面进一步粘贴的stacktrace)
以下是一些其他代码,它们说明了我要执行的操作。
我试图说明的问题是,我想在下面的方法“ DataMapperBase.select2”中使用Predicate参数,而不是在下面的方法“ DataMapperBase.select”中使用Jinq特定的Where参数。
public abstract class DataMapperBase<T> {
...
private EntityManagerFactory entityManagerFactory;
private EntityManager entityManager;
private final Class clazz;// initialized using below method getClazz()
private Class getClazz() throws ClassNotFoundException {
Type genericSuperclass = getClass().getGenericSuperclass();
Type actualTypeArgument = ((ParameterizedType)genericSuperclass).getActualTypeArguments()[0];
return Class.forName(actualTypeArgument.getTypeName());
}
// This method works but has an undesirable dependency to Jinq in method signature.
public List<T> select(org.jinq.orm.stream.JinqStream.Where<T, RuntimeException> wherePredicate) {
JinqJPAStreamProvider streams = new JinqJPAStreamProvider(entityManagerFactory);
List<T> result = streams
.streamAll(entityManager, clazz)
.where( wherePredicate )
.toList();
return result;
}
// Instead of the above select method I want to use the below method (currently named "select2")
// The code below compiles but does not work in runtime.This is the method signature I would like to use.
public List<T> select2(java.util.function.Predicate<T> predicate) {
org.jinq.orm.stream.JinqStream.Where<T, RuntimeException> wherePredicate = u -> predicate.test(u);
JinqJPAStreamProvider streams = new JinqJPAStreamProvider(entityManagerFactory);
List<T> result = streams
.streamAll(entityManager, clazz)
.where( wherePredicate )
.toList();
return result;
}
...
public class PersonDataMapper extends DataMapperBase<Person> { ...
...
@Entity
@Access(AccessType.PROPERTY)
@Table(name="person")
public class Person implements Serializable {
...
private int age;
@Column(name = "Age")
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
...
...
// The invocations below can be used e.g. from a test class
List<Person> persons = personDataMapper.select( p -> p.getAge() > 20 );
List<Person> persons2 = personDataMapper.select2( p -> p.getAge() > 20 );
上面的两个方法(select和select2)都可以编译,但是第二个方法在运行时失败,但以下情况除外:
java.lang.IllegalArgumentException: Could not extract code from lambda. This error sometimes occurs because your lambda references objects that aren't Serializable.
at org.jinq.jpa.transform.LambdaInfo.analyze(LambdaInfo.java:33)
at org.jinq.jpa.transform.LambdaAnalysisFactory.extractSurfaceInfo(LambdaAnalysisFactory.java:7)
at org.jinq.jpa.JPAQueryComposer.applyTransformWithLambda(JPAQueryComposer.java:269)
at org.jinq.jpa.JPAQueryComposer.where(JPAQueryComposer.java:365)
at org.jinq.jpa.JPAQueryComposer.where(JPAQueryComposer.java:1)
at org.jinq.orm.stream.QueryJinqStream.where(QueryJinqStream.java:45)
at org.jinq.jpa.QueryJPAJinqStream.where(QueryJPAJinqStream.java:86)
错误消息指示java.util.function.Predicate可能未实现Serializable出现问题。
(由于本例中的Person实现了Serializable)
不过,然后我尝试了另一个类似这样的接口:
public interface Predicate2<T> extends java.util.function.Predicate<T> , Serializable {}
当我改用它时,出现以下异常:
java.lang.IllegalArgumentException: Could not analyze lambda code
at org.jinq.jpa.transform.LambdaAnalysis.fullyAnalyzeLambda(LambdaAnalysis.java:197)
at org.jinq.jpa.transform.LambdaInfo.fullyAnalyze(LambdaInfo.java:116)
at org.jinq.jpa.JPAQueryComposer.applyTransformWithLambda(JPAQueryComposer.java:278)
at org.jinq.jpa.JPAQueryComposer.where(JPAQueryComposer.java:365)
at org.jinq.jpa.JPAQueryComposer.where(JPAQueryComposer.java:1)
at org.jinq.orm.stream.QueryJinqStream.where(QueryJinqStream.java:45)
at org.jinq.jpa.QueryJPAJinqStream.where(QueryJPAJinqStream.java:86)
因此,我的问题是,是否有人可以提供上述方法“ DataMapperBase.select2”的有效实现,即使用参数java.util.function.Predicate的方法?
最佳答案
由于Java 8的lambdas实现的限制,Jinq要求使用Serializable
lambdas。不幸的是,Java 8中的默认Predicate
无法序列化,因此Jinq无法对其进行分析。
我在去年的JVM语言峰会上就Jinq的工作方式进行了演讲。 Jinq无法使用默认Java 8 Predicate
的部分在17:16左右进行了讨论:
https://youtu.be/JqCnZFzTR2I?t=17m16s
当前的Jinq字节码分析当前主要设计为与Jinq查询样式一起使用,因此,如果您尝试填充任意lambda,则Jinq的分析可能会失败。视频中其他地方也对此进行了讨论。