jpa EntityManager 复杂查询实例

jpa EntityManager 复杂查询实例

目录jpa EntityManager复杂查询概念1. 注入entitymanager2. 建立连接，执行查询操作拓展基于EntityManager的使用1、最基础的查询2、spring data jpa的toPredicate方法

jpa EntityManager复杂查询

概念

EntityManager：EntityManager是JPA中用于增删改查的接口，它的作用相当于一座桥梁，连接内存中的java对象和数据库的数据存储。可以用getCriteriaBuilder()的方式获取CriteriaBuilder对象。

CriteriaBuilder接口：用于构造标准查询、复合条件、表达式、排序等。可以通过createQuery的方式获取CriteriaQuery实例。

CriteriaQuery接口：代表一个specific的顶层查询对象，它包含着查询的各个部分，比如：select 、from、where、grouhttp://p by、order by。

root接口：代表Criteria查询的根对象，定义了实体类型，能为将来导航获得想要的结果，它与SQL查询中的FROM子句类似

接下来上代码啦！

1. 注入entitymanager

@PersistenceContext

private EntityManager em;

2. 建立连接，执行查询操作

CriteriaBuilder cb = em.getCriteriaBuilder();

CriteriaQuery q = cb.createQuery(ADTO.class);

Root root = q.from(A.class);

/*********************表连接**************************/

Join b = root.join("b", JoinType.LEFT);

Join c = root.join("c", JoinType.LEFT);

Join d = root.join("d", JoinType.LEFT);

Join e = root.join("e", JoinType.LEFT);

Join f = root.join("f", JoinType.LEFT);

q.multiselect(//备注：ADTO要有对应构造函数哦

root.get("id"),

root.get("version"),

root.get("code"),

root.get("name"),

root.get("isAlterable"),

root.get("mustCharge"),

root.get("isConsignment"),

root.get("memo"),

b.get("id"),

b.get("name"),

c.get("id"),

c.get("description"),

d.get("id"),

d.get("name"),

e.get("id"),

e.get("name"),

f.get("id"),

f.get("name"),

root.get("standardPrice"),

root.get("upperPrice"),

root.get("lowerPrice"),

root.get("isActive")

);//还可以进行where.order by等操作哦

List rs = em.createQuery(q).getResultList();

到此就完成啦！！！

拓展

where条件

List predicates = new ArrayList<>();

CriteriaBuilder.In in = cb.in(root.get("code").as(String.class));

for (String code: codes) {

in.value(code);

}

predicates.add(in);

if (startDate != null && !"".equals(startDate)) {

predicateList.add(cb.greaterThan(birthdayPath, startDate));

}

Predicate[] pre = new Predicate[predicates.size()];

q.where(predicates.toArray(pre));

or 条件拼接

public List getOrSearchPredicates(CriteriaBuilder cb, Root root, String keywords){

List predicates = new ArrayList<>();

Predicate predicate = null;

Predicate predicate1 = null;

try {

UUID uuid = UUID.fromString(keywords);

predicate1 = cb.equal(root.get("id"), uuid);

}catch (Exception e){

log.info(e.getMessage());

}finally {

Predicate predicate2 = cb.like(root.get("code"), "%"+keywords+"%");

Predicate predicate3 = cb.like(root.get("name"), "%"+keywords+"%");

if (predicate1 != null){

predicate = cb.or(predicate1, cb.or(predicate2,predicate3));

} else {

predicate = cb.or(predicate2, predicate3);

}

}

predicates.add(predicate);

return predicates;

}

JPA 动态更新

CriteriaBuilder cb=entityManager.getCriteriaBuilder();

CriteriaUpdate op=cb.createCriteriaUpdate(clazz);

Root root=op.from(clazz);

op.set(fieldName, value);

op.where(cb.equal(root.get(keyName), delta.get(keyName)));

entityManager.createQuery(op).executeUpdate();

基于EntityManager的使用

1、最基础的查询

CriteriaBuilder cb = entityManager.getCriteriaBuilder();

CriteriaQuery cq = cb.createQuery(User.class);

Root root = cq.from(User.class); //from User

cq.select(root); //select * from User

javax.persistence.criteria.Predicate pre = cb.equal(root.get("id").as(Integer.class),id);//id=1

cq.where(pre);//where id=1

Query query = entityManager.createQuery(cq);//select u from User u where u.id = 1

System.out.println(query.getResultList());

2、spring data jpa的toPredicate方法

public Predicate toPredicate(Root root, CriteriaQuery> query, CriteriaBuilder cb) {

List list = new ArrayList();

list.add(cb.equal(root.get("dr").as(Integer.class), delete));

if (StringUtils.isNotBlank(searchParam)) {/*searchParam 为传递参数*/

list.add(cb.or(cb.like(root.get("roleName").as(String.class), cb.literal("%" + searchParam + "%")), cb.like(root.get("roleCode").as(String.class), cb.literal("%" + searchParam + "%"))));

}

// 角色id

if (roleId != null && !("".equals(roleId.trim()))) {

list.add(cb.equal(root.get("id").as(String.class), roleId));

}

// 管理员角色标识

if (category != null && category > 0) {

list.add(cb.equal(root.get("category").as(Integer.class), category));

}

//多角色Id

if (roleids != null && roleids.size() > 0) {

list.add(root.get("id").as(String.class).in(roleids));

}

Predicate[] predicates = new Predicate[list.size()];

query.where(list.toArray(predicates));

query.orderBy(cb.asc(root.get("roleType").as(String.class)), cb.asc(root.get("roleProperty").as(String.class)), cb.asc(root.get("roleCode").as(String.class)));

return query.getRestriction();

}

参考 org.springframework.data.jpa.repository.support.SimpleJpaRepository 的 findAll方法，如下

public List findAll(Specification spec) {

return getQuery(spec, (Sort) null).getResultList();

}

protected TypedQuery getQuery(Specification spec, Sort sort) {

CriteriaBuilder builder = em.getCriteriaBuilder();

CriteriaQuery query = builder.createQuery(getDomainClass());

Root root = applySpecificationToCriteria(spec, query);

query.select(root);

if (sort != null) {

query.orderBy(toOrders(sort, root, builder));

}

return applyRepositoryMethodMetadata(em.createQuery(query));

}

private TypedQuery applyRepositoryMethodMetadata(TypedQuery query) {

if (metadata == null) {

rethttp://urn query;

}

LockModeType type = metadata.getLockModeType();

TypedQuery toReturn = type == null ? query : query.setLockMode(type);

applyQueryHints(toReturn);

return toReturn;

}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。