/**
 * JpaSpecificationExecutor 这是为了实现第二种查询方式
 * @author maxzhao
 * @date 2019-05-06
 */
@Repository(value = "appTableRepository")
public interface AppTableRepository extends JpaRepository<AppTable, String>, JpaSpecificationExecutor<AppTable> {

}

/**
 * 测试
 * @author maxzhao
 * @date 2019-06-06
 */
@RunWith(SpringRunner.class)
// BasicApplication 是启动类
@SpringBootTest(classes = BasicApplication.class)
public class AppColumnServiceTest {
    // 如果没有日志可以删掉
    private final static Logger logger = LoggerFactory.getLogger(AppTablesRepositoryTest.class);
    @Resource(name = "appTableRepository")
    private AppTableRepository appTableRepository;

    @Before
    public void startInit() {
        logger.info("---------------- {} -------------------", "AppColumnServiceTest");
    }

    @After
    public void endDestory() {    }

    @Test
    public void listTableTest() {
        //Sort.Direction是个枚举有ASC(升序)和DESC(降序)
        Sort.Direction sort = Sort.Direction.ASC;
        //PageRequest继承于AbstractPageRequest并且实现了Pageable
        //获取PageRequest对象 index:页码 从0开始  size每页容量 sort排序方式 "tab_name"->properties 以谁为准排序
        // 这里的tabName是实体的属性，不是数据库字段的名称
        Pageable pageable = PageRequest.of(0, 5, sort, "tabName");

        //region 查询条件设置方式一：
        //要匹配的实例对象
        AppTable appTable = new AppTable();
        appTable.setTabName("app_");
        //定义匹配规则 匹配"vendorId"这个属性 exact 精准匹配
        // 这里的tabName是实体的属性，不是数据库字段的名称
        ExampleMatcher exampleMatcher = ExampleMatcher
                .matching()
                .withMatcher("tabName", ExampleMatcher.GenericPropertyMatchers.contains());
        Example<AppTable> example = Example.of(appTable, exampleMatcher);
        //下面加断点，查询结果集
        Page<AppTable> page = appTableRepository.findAll(example, pageable);
        //获取总页数
        page.getTotalPages();
        //获取总元素个数
        page.getTotalElements();
        //获取该分页的列表
        page.getContent();
        page.getSize();
        //endregion

        //查询条件设置方式二：
        Specification<AppTable> specification = (Specification<AppTable>) (root, query, criteriaBuilder) -> {
            // 这里的tabName是实体的属性，不是数据库字段的名称
            Path<String> name = root.get("tabName");
			//Path<String> alias = root.get("alias");
            //查询条件1
            Predicate p1 = criteriaBuilder.like(name, "%" + "app_" + "%");
            //查询条件2
		//Predicate p2 = criteriaBuilder.lt(alias param.getAge());
            //查询条件1和2的关系
		//Predicate p = criteriaBuilder.and(p1, p2);
            return p1;
        };
        //下面加断点，查询结果集
        Page<AppTable> page2 = appTableRepository.findAll(specification,pageable);
        //endregion
    }
}

// Root<User> root, CriteriaQuery<?> criteriaQuery, CriteriaBuilder cb
List<Predicate> predicates = new ArrayList<>();
if (user.getUserId() != null && !user.getUserId().equals("")) {
	predicates.add(cb.like(root.get("userId").as(String.class), "%" + user.getUserId() + "%"));
}
if (user.getUserName() != null && !user.getUserName().equals("")) {
	predicates.add(cb.like(root.get("userName").as(String.class), "%" + user.getUserName() + "%"));
}
if (user.getGender() != null && !user.getGender().equals("")) {
	predicates.add(cb.like(root.get("gender").as(String.class), "%" + user.getGender() + "%"));
}
if (user.getAge() != null && !user.getAge().equals("")) {
	predicates.add(cb.like(root.get("age").as(String.class), "%" + user.getAge() + "%"));
}
Predicate[] pre = new Predicate[predicates.size()];
criteriaQuery.where(predicates.toArray(pre));
return cb.and(predicates.toArray(pre));

// (Root<User> root, CriteriaQuery<?> criteriaQuery, CriteriaBuilder cb)
List<Predicate> list = new ArrayList<>();
                //根据userId 查询user
if (StringUtils.isNotBlank(params.getUserId())) {
	list.add(cb.equal(root.get("userId").as(String.class), params.getUserId()));
}
                //根据userName 模糊查询user
if (StringUtils.isNotBlank(params.getUserName())) {
 	list.add(cb.like(root.get("userName").as(String.class), "%" + params.getUserName() + "%"));
}
                //根据gender 查询user
if (StringUtils.isNotBlank(params.getGender())) {
 	list.add(cb.equal(root.get("gender").as(String.class), params.getGender()));
}
                //根据age>? 查询user
if (StringUtils.isNotBlank(params.getAge())) {
 	list.add(cb.gt(root.get("age").as(Integer.class), Integer.valueOf(params.getAge())));
}
                //根据gradeName 查询user
if (StringUtils.isNotBlank(params.getGradeName())) {
	Join<Grade, User> join = root.join("grade", JoinType.LEFT);
	list.add(cb.equal(join.get("gradeName"), params.getGradeName()));
}
                //根据schoolName 查询user
if (StringUtils.isNotBlank(params.getSchoolName())) {
	Join<School, User> join = root.join("grade", JoinType.LEFT);
	list.add(cb.equal(join.get("school").get("schoolName"), params.getSchoolName()));
}
Predicate[] pre = new Predicate[list.size()];
criteriaQuery.where(list.toArray(pre));
return cb.and(list.toArray(pre));

Path<String> path = root.get("tabName");
CriteriaBuilder.In<String> in = criteriaBuilder.in(path);
in.value("app_table");
in.value("app_column");
criteriaBuilder.and(in);
return criteriaBuilder.and(p1, in);

   @PersistenceContext
   private EntityManager entityManager;
// 查询
entityManager.find(AppTable.class, id);
// 查询列表
entityManager.createQuery(hql).getResultList();
// 查询列表数量,有参数
entityManager.createQuery(hql)
               .setParameter(0, tabName)
               .setParameter(1, alias).getResultList().size();
// 	更新
AppTable appTable = entityManager.find(AppTable.class, id);
appTable.setTabName("X");
   entityManager.flush();
// 删除
entityManager.remove(entityManager.find(AppTable.class, id));