子选择以使用 CriteriaBuilder (JPA) 检索语句的右侧

Question

我正在玩 JPA 和其他 Java EE 6 的东西，但现在我在使用标准 Builder 进行类型查询时遇到了一些问题。 我的 poc 的商业案例是一个 twitter 克隆，所以我的用户有一个订阅者和订阅列表，我得到了推文。

@Entity
public class Tweet {
    @Id @GeneratedValue(strategy=GenerationType.AUTO)
    private Long id;

    @ManyToOne
    private TwitterUser author;

    @ManyToOne
    private TwitterUser receiver;

    @Temporal(TemporalType.TIMESTAMP) 
    private Date datetime; 

    private String message;
}


@Entity
public class TwitterUser {
    @Id @GeneratedValue(strategy=GenerationType.AUTO)
    private Long id;

    private String username;

    private String displayname;

    private String password;

    private String email;

    @Temporal(TemporalType.TIMESTAMP)
    private Date since;

    @ManyToMany(cascade=CascadeType.ALL)
    private List<TwitterUser> subscriptions;

    @ManyToMany(mappedBy = "subscriptions")
    private List<TwitterUser> subscribers;
}

JPA 生成的数据模型由 3 个表组成：Tweet、TwitterUser 和 TwitterUser_TwitterUser。到目前为止一切都很好。基本查询效果很好。

现在我想为时间线选择所有推文，这意味着所有用户的推文，他们在当前登录用户的订阅列表中。我想到了一个使用子选择的解决方案，所以我的 sql 看起来像：

select * from TWEET where author_id in (
    select subscriptions_ID from TWITTERUSER_TWITTERUSER where subscribers_ID = ?loggedInUserId);

此查询运行良好，但我不知道如何使用 CriteriaBuilder 和泛型将其写下来。我什至没有得到一段可能在其他时候失败的可编译代码，因为我不确定子查询的类型应该是什么。 我现在正在搜索很多示例，但它们大多只是使用原始类型或使用子查询来检索 in-clause 左侧的元素。

也许我只见树木不见森林，但我真的很困惑。 :(

Answer 1

在 JPQL 中，一种表达方式类似于以下内容：

SELECT
    tweet
FROM
    Tweet tweet JOIN tweet.author author
WHERE
    EXISTS (
        SELECT 
               user 
         FROM 
                TwitterUser user JOIN user.subscriptions subscriber
         WHERE 
                user = :loggedinUser AND
                subscriber = author
    )

作为几乎直接遵循 JPQL 模型的标准，也许这可以帮助您入门。

Answer 2

再次感谢你们帮助我。我终于设法根据您的输入找到了解决方案，它看起来如下：

public List<Tweet> findAllForSubscriber(TwitterUser user) {
    // Select tweets
    CriteriaBuilder cb = em.getCriteriaBuilder();
    CriteriaQuery<Tweet> cq = cb.createQuery(Tweet.class);
    Root<Tweet> tweet = cq.from(Tweet.class);
    cq.select(Tweet);

    // Select subscribers of user
    Subquery<Long> sq = cq.subquery(Long.class);
    Root<TwitterUser> twitterUser = sq.from(TwitterUser.class);
    Join<TwitterUser, TwitterUser> subscriptions = twitterUser.join(TwitterUser_.subscriptions);
    sq.select(subscriptions.get(TwitterUser_.id));
    sq.where(cb.equal(twitterUser, user));

    // Where authorId in list of subscribers
    cq.where(cb.in(tweet.get(Tweet_.author).get(TwitterUser_.id)).value(sq));

    //
    return em.createQuery(cq).getResultList();
}

我的缺点是：

• Criteria API 只是能够 比较一个对象中的对象 equal() 但不在 in() 内 陈述。但我没有得到 有帮助的例外，所有这些都是 生成的是一个错误的查询（eclipselink & derby）:(
• in() 语句 取 in 的左侧 声明，价值声明采取 可能性清单， 措辞让我很困惑。
• 我不能简单地访问 ID 在所有订阅中，我必须使用 加入。如果你认为这很清楚 关于表结构，但我 只是想着就错过了 我的对象。

P.S.：我的解决方案完全没有选择用户自己的推文！ ^^

Answer 3

这里有一个类似的Criteria查询示例，

http://en.wikibooks.org/wiki/Java_Persistence/Querying#Subselect.2C_querying_all_of_a_ManyToMany_relationship