本篇进行Spring-data-jpa的介绍，几乎涵盖该框架的所有方面，在日常的开发当中，基本上能满足所有需求。这里不讲解JPA和Spring-data-jpa单独使用，所有的内容都是在和Spring整合的环境中实现。如果需要了解该框架的入门，百度一下，很多入门的介绍。在这篇文章的接下来一篇，会有一个系列来讲解mybatis，这个系列从mybatis的入门开始，到基本使用，和spring整合，和第三方插件整合，缓存，插件，最后会持续到mybatis的架构，源码解释，重点会介绍几个重要的设计模式，这样一个体系。基本上讲完之后，mybatis在你面前就没有了秘密，你能解决mybatis的几乎所有问题，并且在开发过程中相当的方便，驾轻就熟。

这篇文章由于介绍的类容很全，因此很长，如果你需要，那么可以耐心的看完，本人经历了很长时间的学识，使用，研究的心血浓缩成为这么短短的一篇博客。

大致整理一个提纲：

　　1、Spring-data-jpa的基本介绍；

　　2、和Spring整合；

　　3、基本的使用方式；

　　4、复杂查询，包括多表关联，分页，排序等；

现在开始：

　　1、Spring-data-jpa的基本介绍：JPA诞生的缘由是为了整合第三方ORM框架，建立一种标准的方式，百度百科说是JDK为了实现ORM的天下归一，目前也是在按照这个方向发展，但是还没能完全实现。在ORM框架中，Hibernate是一支很大的部队，使用很广泛，也很方便，能力也很强，同时Hibernate也是和JPA整合的比较良好，我们可以认为JPA是标准，事实上也是，JPA几乎都是接口，实现都是Hibernate在做，宏观上面看，在JPA的统一之下Hibernate很良好的运行。

　　上面阐述了JPA和Hibernate的关系，那么Spring-data-jpa又是个什么东西呢？这地方需要稍微解释一下，我们做Java开发的都知道Spring的强大，到目前为止，企业级应用Spring几乎是无所不能，无所不在，已经是事实上的标准了，企业级应用不使用Spring的几乎没有，这样说没错吧。而Spring整合第三方框架的能力又很强，他要做的不仅仅是个最早的IOC容器这么简单一回事，现在Spring涉及的方面太广，主要是体现在和第三方工具的整合上。而在与第三方整合这方面，Spring做了持久化这一块的工作，我个人的感觉是Spring希望把持久化这块内容也拿下。于是就有了Spring-data-**这一系列包。包括，Spring-data-jpa,Spring-data-template,Spring-data-mongodb,Spring-data-redis，还有个民间产品，mybatis-spring，和前面类似，这是和mybatis整合的第三方包，这些都是干的持久化工具干的事儿。

　　这里介绍Spring-data-jpa，表示与jpa的整合。

　　2、我们都知道，在使用持久化工具的时候，一般都有一个对象来操作数据库，在原生的Hibernate中叫做Session，在JPA中叫做EntityManager，在MyBatis中叫做SqlSession，通过这个对象来操作数据库。我们一般按照三层结构来看的话，Service层做业务逻辑处理，Dao层和数据库打交道，在Dao中，就存在着上面的对象。那么ORM框架本身提供的功能有什么呢？答案是基本的CRUD，所有的基础CRUD框架都提供，我们使用起来感觉很方便，很给力，业务逻辑层面的处理ORM是没有提供的，如果使用原生的框架，业务逻辑代码我们一般会自定义，会自己去写SQL语句，然后执行。在这个时候，Spring-data-jpa的威力就体现出来了，ORM提供的能力他都提供，ORM框架没有提供的业务逻辑功能Spring-data-jpa也提供，全方位的解决用户的需求。使用Spring-data-jpa进行开发的过程中，常用的功能，我们几乎不需要写一条sql语句，至少在我看来，企业级应用基本上可以不用写任何一条sql，当然spring-data-jpa也提供自己写sql的方式，这个就看个人怎么选择，都可以。我觉得都行。

　　2.1与Spring整合我们从spring配置文件开始，为了节省篇幅，这里我只写出配置文件的结构。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context" xmlns:mongo="http://www.springframework.org/schema/data/mongo"xmlns:jpa="http://www.springframework.org/schema/data/jpa"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsdhttp://www.springframework.org/schema/aop     http://www.springframework.org/schema/aop/spring-aop-3.0.xsd   http://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx-3.0.xsdhttp://www.springframework.org/schema/context     http://www.springframework.org/schema/context/spring-context-3.0.xsdhttp://www.springframework.org/schema/data/mongohttp://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsdhttp://www.springframework.org/schema/data/jpa http://www.springframework.org/schema/data/jpa/spring-jpa.xsd"><!-- 数据库连接 --><context:property-placeholder location="classpath:your-config.properties" ignore-unresolvable="true" /><!-- service包 --><context:component-scan base-package="your service package" /><!-- 使用cglib进行动态代理 --><aop:aspectj-autoproxy proxy-target-class="true" /><!-- 支持注解方式声明式事务 --><tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true" /><!-- dao --><jpa:repositories base-package="your dao package" repository-impl-postfix="Impl" entity-manager-factory-ref="entityManagerFactory" transaction-manager-ref="transactionManager" /><!-- 实体管理器 --><bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"><property name="dataSource" ref="dataSource" /><property name="packagesToScan" value="your entity package" /><property name="persistenceProvider"><bean class="org.hibernate.ejb.HibernatePersistence" /></property><property name="jpaVendorAdapter"><bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"><property name="generateDdl" value="false" /><property name="database" value="MYSQL" /><property name="databasePlatform" value="org.hibernate.dialect.MySQL5InnoDBDialect" /><!-- <property name="showSql" value="true" /> --></bean></property><property name="jpaDialect"><bean class="org.springframework.orm.jpa.vendor.HibernateJpaDialect" /></property><property name="jpaPropertyMap"><map><entry key="hibernate.query.substitutions" value="true 1, false 0" /><entry key="hibernate.default_batch_fetch_size" value="16" /><entry key="hibernate.max_fetch_depth" value="2" /><entry key="hibernate.generate_statistics" value="true" /><entry key="hibernate.bytecode.use_reflection_optimizer" value="true" /><entry key="hibernate.cache.use_second_level_cache" value="false" /><entry key="hibernate.cache.use_query_cache" value="false" /></map></property></bean><!-- 事务管理器 --><bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager"><property name="entityManagerFactory" ref="entityManagerFactory"/></bean><!-- 数据源 --><bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"><property name="driverClassName" value="${driver}" /><property name="url" value="${url}" /><property name="username" value="${userName}" /><property name="password" value="${password}" /><property name="initialSize" value="${druid.initialSize}" /><property name="maxActive" value="${druid.maxActive}" /><property name="maxIdle" value="${druid.maxIdle}" /><property name="minIdle" value="${druid.minIdle}" /><property name="maxWait" value="${druid.maxWait}" /><property name="removeAbandoned" value="${druid.removeAbandoned}" /><property name="removeAbandonedTimeout" value="${druid.removeAbandonedTimeout}" /><property name="timeBetweenEvictionRunsMillis" value="${druid.timeBetweenEvictionRunsMillis}" /><property name="minEvictableIdleTimeMillis" value="${druid.minEvictableIdleTimeMillis}" /><property name="validationQuery" value="${druid.validationQuery}" /><property name="testWhileIdle" value="${druid.testWhileIdle}" /><property name="testOnBorrow" value="${druid.testOnBorrow}" /><property name="testOnReturn" value="${druid.testOnReturn}" /><property name="poolPreparedStatements" value="${druid.poolPreparedStatements}" /><property name="maxPoolPreparedStatementPerConnectionSize" value="${druid.maxPoolPreparedStatementPerConnectionSize}" /><property name="filters" value="${druid.filters}" /></bean><!-- 事务 --><tx:advice id="txAdvice" transaction-manager="transactionManager"><tx:attributes><tx:method name="*" /><tx:method name="get*" read-only="true" /><tx:method name="find*" read-only="true" /><tx:method name="select*" read-only="true" /><tx:method name="delete*" propagation="REQUIRED" /><tx:method name="update*" propagation="REQUIRED" /><tx:method name="add*" propagation="REQUIRED" /><tx:method name="insert*" propagation="REQUIRED" /></tx:attributes></tx:advice><!-- 事务入口 --><aop:config><aop:pointcut id="allServiceMethod" expression="execution(* your service implements package.*.*(..))" /><aop:advisor pointcut-ref="allServiceMethod" advice-ref="txAdvice" /></aop:config></beans>

　　2.2对上面的配置文件进行简单的解释，只对“实体管理器”和“dao”进行解释，其他的配置在任何地方都差不太多。

　　　　1.对“实体管理器”解释：我们知道原生的jpa的配置信息是必须放在META-INF目录下面的，并且名字必须叫做persistence.xml，这个叫做persistence-unit，就叫做持久化单元，放在这下面我们感觉不方便，不好，于是Spring提供了

org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean

这样一个类，可以让你的随心所欲的起这个配置文件的名字，也可以随心所欲的修改这个文件的位置，只需要在这里指向这个位置就行。然而更加方便的做法是，直接把配置信息就写在这里更好，于是就有了这实体管理器这个bean。使用

<property name="packagesToScan" value="your entity package" />

这个属性来加载我们的entity。

　　2.3 解释“dao”这个bean。这里衍生一下，进行一下名词解释，我们知道dao这个层叫做Data Access Object，数据库访问对象，这是一个广泛的词语，在jpa当中，我们还有一个词语叫做Repository，这里我们一般就用Repository结尾来表示这个dao，比如UserDao，这里我们使用UserRepository，当然名字无所谓，随意取，你可以意会一下我的意思，感受一下这里的含义和区别，同理，在mybatis中我们一般也不叫dao，mybatis由于使用xml映射文件（当然也提供注解，但是官方文档上面表示在有些地方，比如多表的复杂查询方面，注解还是无解，只能xml），我们一般使用mapper结尾，比如我们也不叫UserDao，而叫UserMapper。

　　上面拓展了一下关于dao的解释，那么这里的这个配置信息是什么意思呢？首先base-package属性，代表你的Repository接口的位置，repository-impl-postfix属性代表接口的实现类的后缀结尾字符，比如我们的UserRepository，那么他的实现类就叫做UserRepositoryImpl，和我们平时的使用习惯完全一致，于此同时，spring-data-jpa的习惯是接口和实现类都需要放在同一个包里面（不知道有没有其他方式能分开放，这不是重点，放在一起也无所谓，影响不大），再次的，这里我们的UserRepositoryImpl这个类的定义的时候我们不需要去指定实现UserRepository接口，根据spring-data-jpa自动就能判断二者的关系。

　　比如：我们的UserRepository和UserRepositoryImpl这两个类就像下面这样来写。

public interface UserRepository extends JpaRepository<User, Integer>{}
public class UserRepositoryImpl {}

　　那么这里为什么要这么做呢？原因是：spring-data-jpa提供基础的CRUD工作，同时也提供业务逻辑的功能（前面说了，这是该框架的威力所在），所以我们的Repository接口要做两项工作，继承spring-data-jpa提供的基础CRUD功能的接口，比如JpaRepository接口，同时自己还需要在UserRepository这个接口中定义自己的方法，那么导致的结局就是UserRepository这个接口中有很多的方法，那么如果我们的UserRepositoryImpl实现了UserRepository接口，导致的后果就是我们势必需要重写里面的所有方法，这是Java语法的规定，如此一来，悲剧就产生了，UserRepositoryImpl里面我们有很多的@Override方法，这显然是不行的，结论就是，这里我们不用去写implements部分。

　　spring-data-jpa实现了上面的能力，那他是怎么实现的呢？这里我们通过源代码的方式来呈现他的来龙去脉，这个过程中cglib发挥了杰出的作用。

　　在spring-data-jpa内部，有一个类，叫做

public class SimpleJpaRepository<T, ID extends Serializable> implements JpaRepository<T, ID>,JpaSpecificationExecutor<T>

我们可以看到这个类是实现了JpaRepository接口的，事实上如果我们按照上面的配置，在同一个包下面有UserRepository，但是没有UserRepositoryImpl这个类的话，在运行时期UserRepository这个接口的实现就是上面的SimpleJpaRepository这个接口。而如果有UserRepositoryImpl这个文件的话，那么UserRepository的实现类就是UserRepositoryImpl，而UserRepositoryImpl这个类又是SimpleJpaRepository的子类，如此一来就很好的解决了上面的这个不用写implements的问题。我们通过阅读这个类的源代码可以发现，里面包装了entityManager，底层的调用关系还是entityManager在进行CRUD。

　　3. 下面我们通过一个完整的项目来基本使用spring-data-jpa，然后我们在介绍他的高级用法。

　　a.数据库建表：user,主键自增

　　b.对应实体：User

@Entity
@Table(name = "user")
public class User {@Id@GeneratedValue(strategy = GenerationType.IDENTITY)private Integer id;private String name;private String password;private String birthday;// getter,setter
}

　　c.简历UserRepository接口

public interface UserRepository extends JpaRepository<User, Integer>{}

　　通过上面3步，所有的工作就做完了，User的基础CRUD都能做了，简约而不简单。

　　d.我们的测试类UserRepositoryTest

public class UserRepositoryTest {@Autowiredprivate UserRepository userRepository;@Testpublic void baseTest() throws Exception {User user = new User();user.setName("Jay");user.setPassword("123456");user.setBirthday("2008-08-08");userRepository.save(user);
//        userRepository.delete(user);
//        userRepository.findOne(1);
    }
}

　　测试通过。

　　说到这里，和spring已经完成。接下来第三点，基本使用。

4.前面把基础的东西说清楚了，接下来就是spring-data-jpa的正餐了，真正威力的地方。

　　4.1 我们的系统中一般都会有用户登录这个接口，在不使用spring-data-jpa的时候我们怎么做，首先在service层定义一个登录方法。如：

User login(String name, String password);

然后在serviceImpl中写该方法的实现，大致这样：

    @Overridepublic User login(String name, String password) {return userDao.login(name, password);}

接下来，UserDao大概是这么个样子：

User getUserByNameAndPassword(String name, String password);

然后在UserDaoImpl中大概是这么个样子：

    public User getUserByNameAndPassword(String name, String password) {Query query = em.createQuery("select * from User t where t.name = ?1 and t.password = ?2");query.setParameter(1, name);query.setParameter(2, password);return (User) query.getSingleResult();}

ok，这个代码运行良好，那么这样子大概有十来行代码，我们感觉这个功能实现了，很不错。然而这样子真正简捷么？如果这样子就满足了，那么spring-data-jpa就没有必要存在了，前面提到spring-data-jpa能够帮助你完成业务逻辑代码的处理，那他是怎么处理的呢？这里我们根本不需要UserDaoImpl这个类，只需要在UserRepository接口中定义一个方法

User findByNameAndPassword(String name, String password);

然后在service中调用这个方法就完事了，所有的逻辑只需要这么一行代码，一个没有实现的接口方法。通过debug信息，我们看到输出的sql语句是

select * from user where name = ? and password = ?

跟上面的传统方式一模一样的结果。这简单到令人发指的程度，那么这一能力是如何实现的呢？原理是：spring-data-jpa会根据方法的名字来自动生成sql语句，我们只需要按照方法定义的规则即可，上面的方法findByNameAndPassword，spring-data-jpa规定，方法都以findBy开头，sql的where部分就是NameAndPassword，被spring-data-jpa翻译之后就编程了下面这种形态：

where name = ? and password = ?

在举个例，如果是其他的操作符呢，比如like，前端模糊查询很多都是以like的方式来查询。比如根据名字查询用户，sql就是

select * from user where name like = ?

这里spring-data-jpa规定，在属性后面接关键字，比如根据名字查询用户就成了

User findByNameLike(String name);

被翻译之后的sql就是

select * from user where name like = ?

这也是简单到令人发指，spring-data-jpa所有的语法规定如下图：

通过上面，基本CRUD和基本的业务逻辑操作都得到了解决，我们要做的工作少到仅仅需要在UserRepository接口中定义几个方法，其他所有的工作都由spring-data-jpa来完成。

接下来：就是比较复杂的操作了，比如动态查询，分页，下面详细介绍spring-data-jpa的第二大杀手锏，强大的动态查询能力。

在上面的介绍中，对于我们传统的企业级应用的基本操作已经能够基本上全部实现，企业级应用一般都会有一个模糊查询的功能，并且是多条的查询，在有查询条件的时候我们需要在where后面接上一个 xxx = yyy 或者 xxx like '% + yyy + %'类似这样的sql。那么我们传统的JDBC的做法是使用很多的if语句根据传过来的查询条件来拼sql，mybatis的做法也类似，由于mybatis有强大的动态xml文件的标签，在处理这种问题的时候显得非常的好，但是二者的原理都一致，那spring-data-jpa的原理也同样很类似，这个道理也就说明了解决多表关联动态查询根儿上也就是这么回事。

　　那么spring-data-jpa的做法是怎么的呢？有两种方式。可以选择其中一种，也可以结合使用，在一般的查询中使用其中一种就够了，就是第二种，但是有一类查询比较棘手，比如报表相关的，报表查询由于涉及的表很多，这些表不一定就是两两之间有关系，比如字典表，就很独立，在这种情况之下，使用拼接sql的方式要容易一些。下面分别介绍这两种方式。

　　a.使用JPQL,和Hibernate的HQL很类似。

　　　前面说道了在UserRepository接口的同一个包下面建立一个普通类UserRepositoryImpl来表示该类的实现类，同时前面也介绍了完全不需要这个类的存在，但是如果使用JPQL的方式就必须要有这个类。如下：

public class StudentRepositoryImpl {@PersistenceContextprivate EntityManager em;@SuppressWarnings("unchecked")public Page<Student> search(User user) {String dataSql = "select t from User t where 1 = 1";String countSql = "select count(t) from User t where 1 = 1";if(null != user && !StringUtils.isEmpty(user.getName())) {dataSql += " and t.name = ?1";countSql += " and t.name = ?1";}Query dataQuery = em.createQuery(dataSql);Query countQuery = em.createQuery(countSql);if(null != user && !StringUtils.isEmpty(user.getName())) {dataQuery.setParameter(1, user.getName());countQuery.setParameter(1, user.getName());}long totalSize = (long) countQuery.getSingleResult();Page<User> page = new Page();page.setTotalSize(totalSize);List<User> data = dataQuery.getResultList();page.setData(data);return page;}}

通过上面的方法，我们查询并且封装了一个User对象的分页信息。代码能够良好的运行。这种做法也是我们传统的经典做法。那么spring-data-jpa还有另外一种更好的方式，那就是所谓的类型检查的方式，上面我们的sql是字符串，没有进行类型检查，而下面的方式就使用了类型检查的方式。这个道理在mybatis中也有体现，mybatis可以使用字符串sql的方式，也可以使用接口的方式，而mybatis的官方推荐使用接口方式，因为有类型检查，会更安全。

　　b.使用JPA的动态接口，下面的接口我把注释删了，为了节省篇幅，注释也没什么用，看方法名字大概都能猜到是什么意思。

public interface JpaSpecificationExecutor<T> {
T findOne(Specification<T> spec);
List<T> findAll(Specification<T> spec);
Page<T> findAll(Specification<T> spec, Pageable pageable);
List<T> findAll(Specification<T> spec, Sort sort);
long count(Specification<T> spec);
}

上面说了，使用这种方式我们压根儿就不需要UserRepositoryImpl这个类，说到这里，仿佛我们就发现了spring-data-jpa为什么把Repository和RepositoryImpl文件放在同一个包下面，因为我们的应用很可能根本就一个Impl文件都不存在，那么在那个包下面就只有一堆接口，即使把Repository和RepositoryImpl都放在同一个包下面，也不会造成这个包下面有正常情况下2倍那么多的文件，根本原因：只有接口而没有实现类。

上面我们的UserRepository类继承了JpaRepository和JpaSpecificationExecutor类，而我们的UserRepository这个对象都会注入到UserService里面，于是如果使用这种方式，我们的逻辑直接就写在service里面了，下面的代码：一个学生Student类，一个班级Clazz类，Student里面有一个对象Clazz，在数据库中是clazz_id，这是典型的多对一的关系。我们在配置好entity里面的关系之后。就可以在StudentServiceImpl类中做Student的模糊查询，典型的前端grid的模糊查询。代码是这样子的：

@Service
public class StudentServiceImpl extends BaseServiceImpl<Student> implements StudentService {@Autowiredprivate StudentRepository studentRepository;@Overridepublic Student login(Student student) {return studentRepository.findByNameAndPassword(student.getName(), student.getPassword());}@Overridepublic Page<Student> search(final Student student, PageInfo page) {return studentRepository.findAll(new Specification<Student>() {@Overridepublic Predicate toPredicate(Root<Student> root, CriteriaQuery<?> query, CriteriaBuilder cb) {Predicate stuNameLike = null;if(null != student && !StringUtils.isEmpty(student.getName())) {　　　　　　　　　　　// 这里也可以root.get("name").as(String.class)这种方式来强转泛型类型stuNameLike = cb.like(root.<String> get("name"), "%" + student.getName() + "%");}Predicate clazzNameLike = null;if(null != student && null != student.getClazz() && !StringUtils.isEmpty(student.getClazz().getName())) {clazzNameLike = cb.like(root.<String> get("clazz").<String> get("name"), "%" + student.getClazz().getName() + "%");}if(null != stuNameLike) query.where(stuNameLike);if(null != clazzNameLike) query.where(clazzNameLike);return null;}}, new PageRequest(page.getPage() - 1, page.getLimit(), new Sort(Direction.DESC, page.getSortName())));}
}

先解释下这里的意思，然后我们在结合框架的源码来深入分析。

这里我们是2个表关联查询，查询条件包括Student表和Clazz表，类似的2个以上的表方式差不多，但是正如上面所说，这种做法适合所有的表都是两两能够关联上的，涉及的表太多，或者是有一些字典表，那就使用sql拼接的方式，简单一些。

先简单解释一下代码的含义，然后结合框架源码来详细分析。两个Predicate对象，Predicate按照中文意思是判断，断言的意思，那么放在我们的sql中就是where后面的东西，比如

name like '% + jay + %';

下面的PageRequest代表分页信息，PageRequest里面的Sort对象是排序信息。上面的代码事实上是在动态的组合最终的sql语句，这里使用了一个策略模式，或者callback，就是

studentRepository.findAll(一个接口)

studentRepository接口方法调用的参数是一个接口，而接口的实现类调用这个方法的时候，在内部，参数对象的实现类调用自己的toPredicate这个方法的实现内容，可以体会一下这里的思路，就是传一个接口，然后接口的实现自己来定义，这个思路在nettyJavaScript中体现的特别明显，特别是JavaScript的框架中大量的这种方式，JS框架很多的做法都是上来先闭包，和浏览器的命名空间分开，然后入口方法就是一个回调，比如ExtJS：

Ext.onReady(function() {// xxx
});

参数是一个function，其实在框架内部就调用了这个参数，于是这个这个方法执行了。这种模式还有一个JDK的排序集合上面也有体现，我们的netty框架也采用这种方式来实现异步IO的能力。

接下来结合框架源码来详细介绍这种机制，以及这种机制提供给我们的好处。

这里首先从JPA的动态查询开始说起，在JPA提供的API中，动态查询大概有这么一些方法，

从名字大概可以看出这些方法的意义，跟Hibernate或者一些其他的工具也都差不多，这里我们介绍参数为CriteriaQuery类型的这个方法，如果我们熟悉多种ORM框架的话，不难发现都有一个Criteria类似的东西，中文意思是“条件”的意思，这就是各个框架构建动态查询的主体，Hibernate甚至有两种，在线和离线两种Criteria，mybatis也能从Example中创建Criteria，并且添加查询条件。

那么第一步就需要构建出这个参数CriteriaQuery类型的参数，这里使用建造者模式，

CriteriaBuilder builder = em.getCriteriaBuilder();
CriteriaQuery<Student> query = builder.createQuery(Student.class);

接下来：

Root<Student> root = query.from(Student.class);

在这里，我们看方法名from，意思是获取Student的Root，其实也就是个Student的包装对象，就代表这条sql语句里面的主体。接下来：

        Predicate p1 = builder.like(root.<String> get("name"), "%" + student.getName() + "%");Predicate p2 = builder.equal(root.<String> get("password"), student.getPassword());

Predicate是判断的意思，放在sql语句中就是where后面 xxx = yyy, xxx like yyy这种，也就是查询条件，这里构造了2个查询条件，分别是根据student的name属性进行like查询和根据student的password进行“=”查询，在sql中就是

name like = ? and password = ?

这种形式，接下来

query.where(p1, p2);

这样子一个完整的动态查询就构建完成了，接下来调用getSingleResult或者getResultList返回结果，这里jpa的单个查询如果为空的话会报异常，这点感觉框架设计的不好，如果查询为空直接返回一个null或者一个空的List更好一点。

这是jpa原生的动态查询方式，过程大致就是，创建builder => 创建Query => 构造条件 => 查询。这么4个步骤，这里代码运行良好，如果不使用spring-data-jpa，我们就需要这么来做，但是spring-data-jpa帮我们做得更为彻底，从上面的4个步骤中，我们发现：所有的查询除了第三步不一样，其他几步都是一模一样的，不使用spring-data-jpa的情况下，我们要么4步骤写完，要么自己写个工具类，封装一下，这里spring-data-jpa就是帮我们完成的这样一个动作，那就是在JpaSpecification<T>这个接口中的

Page<T> findAll(Specification<T> spec, Pageable pageable);

这个方法，前面说了，这是个策略模式，参数spec是个接口，前面也说了框架内部对于这个接口有默认的实现类

@Repository
@Transactional(readOnly = true)
public class SimpleJpaRepository<T, ID extends Serializable> implements JpaRepository<T, ID>,JpaSpecificationExecutor<T> {}

，我们的Repository接口就是继承这个接口，而通过cglib的RepositoryImpl的代理类也是这个类的子类，默认也就实现了该方法。这个方法的方法体是这样的：

    /** (non-Javadoc)* @see org.springframework.data.jpa.repository.JpaSpecificationExecutor#findOne(org.springframework.data.jpa.domain.Specification)*/public T findOne(Specification<T> spec) {try {return getQuery(spec, (Sort) null).getSingleResult();} catch (NoResultException e) {return null;}}

这里的

getQuery(spec, (Sort) null)

返回类型是

TypedQuery<T>

进入这个getQuery方法：

    /*** Creates a {@link TypedQuery} for the given {@link Specification} and {@link Sort}.* * @param spec can be {@literal null}.* @param sort can be {@literal null}.* @return*/protected TypedQuery<T> getQuery(Specification<T> spec, Sort sort) {CriteriaBuilder builder = em.getCriteriaBuilder();CriteriaQuery<T> query = builder.createQuery(getDomainClass());Root<T> root = applySpecificationToCriteria(spec, query);query.select(root);if (sort != null) {query.orderBy(toOrders(sort, root, builder));}return applyRepositoryMethodMetadata(em.createQuery(query));}

一切玄机尽收眼底，这个方法的内容和我们前面使用原生jpa的api的过程是一样的，而再进入

Root<T> root = applySpecificationToCriteria(spec, query);

这个方法：

    /*** Applies the given {@link Specification} to the given {@link CriteriaQuery}.* * @param spec can be {@literal null}.* @param query must not be {@literal null}.* @return*/private <S> Root<T> applySpecificationToCriteria(Specification<T> spec, CriteriaQuery<S> query) {Assert.notNull(query);Root<T> root = query.from(getDomainClass());if (spec == null) {return root;}CriteriaBuilder builder = em.getCriteriaBuilder();Predicate predicate = spec.toPredicate(root, query, builder);if (predicate != null) {query.where(predicate);}return root;}

我们可以发现spec参数调用了toPredicate方法，也就是我们前面service里面匿名内部类的实现。

到这里spring-data-jpa的默认实现已经完全明了。总结一下使用动态查询：前面说的原生api需要4步，而使用spring-data-jpa只需要一步，那就是重写匿名内部类的toPredicate方法。在重复一下上面的Student和Clazz的查询代码，

 1     @Override
 2     public Page<Student> search(final Student student, PageInfo page) { 4         return studentRepository.findAll(new Specification<Student>() {
 5             @Override
 6             public Predicate toPredicate(Root<Student> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
 7
 8                 Predicate stuNameLike = null;
 9                 if(null != student && !StringUtils.isEmpty(student.getName())) {
10                     stuNameLike = cb.like(root.<String> get("name"), "%" + student.getName() + "%");
11                 }
12
13                 Predicate clazzNameLike = null;
14                 if(null != student && null != student.getClazz() && !StringUtils.isEmpty(student.getClazz().getName())) {
15                     clazzNameLike = cb.like(root.<String> get("clazz").<String> get("name"), "%" + student.getClazz().getName() + "%");
16                 }
17
18                 if(null != stuNameLike) query.where(stuNameLike);
19                 if(null != clazzNameLike) query.where(clazzNameLike);
20                 return null;
21             }
22         }, new PageRequest(page.getPage() - 1, page.getLimit(), new Sort(Direction.DESC, page.getSortName())));
23     }

到这里位置，spring-data-jpa的介绍基本上就完成了，涵盖了该框架使用的方方面面。接下来还有一块比较实用的东西，我们看到上面第15行位置的条件查询，这里使用了一个多级的get，这个是spring-data-jpa支持的，就是嵌套对象的属性，这种做法一般我们叫方法的级联调用，就是调用的时候返回自己本身，这个在处理xml的工具中比较常见，主要是为了代码的美观作用，没什么其他的用途。

最后还有一个小问题，我们上面说了使用动态查询和JPQL两种方式都可以，在我们使用JPQL的时候，他的语法和常规的sql有点不太一样，以Student、Clazz关系为例，比如：

select * from student t left join clazz tt on t.clazz_id = tt.id

这是一个很常规的sql，但是JPQL是这么写：

select t from Student t left join t.clazz tt

left join右边直接就是t的属性，并且也没有了on t.clazz_id == tt.id，然而并不会出现笛卡尔积，这里解释一下为什么没有这个条件，在我们的实体中配置了属性的映射关系，并且ORM框架的最核心的目的就是要让我们以面向对象的方式来操作数据库，显然我们在使用这些框架的时候就不需要关心数据库了，只需要关系对象，而t.clazz_id = tt.id这个是数据库的字段，由于配置了字段映射，框架内部自己就会去处理，所以不需要on t.clazz_id = tt.id就是合理的。

　　前面介绍了spring-data-jpa的使用，还有一点忘了，悲观所和乐观锁问题，这里的乐观锁比较简单，jpa有提供注解@Version，加上该注解，自动实现乐观锁，byId修改的时候sql自动变成：update ... set ... where id = ? and version = ?，比较方便。

in操作的查询：

　　在日常手动写sql的时候有in这种查询是比较多的，比如select * from user t where t.id in (1, 2, 3)；有人说in的效率不高，要少用，但是其实只要in是主键，或者说是带有索引的，效率是很高的，mysql中如果in是子查询貌似不会走索引，不过我个人经验，在我遇到的实际应用中，in(ids)这种是比较多的，所以一般来说是没有性能问题的。

　　那么，sql里面比较好写，但是如果使用spring-data-jpa的动态查询方式呢，就和前面的稍微有点区别。大致上是这么一个思路：

if(!CollectionUtils.isEmpty(ids)) {In<Long> in = cb.in(root.<Long> get("id"));for (Long id : parentIds) {in.value(id);}query.where(in);
}

　　cb创建一个in的Predicate,然后给这个in赋值，最后把in加到where条件中。

手动配置锁：

　　spring-data-jpa支持注解方式的sql，比如：@Query(xxx)，另外，关于锁的问题，在实体中的某个字段配置@Version是乐观锁，有时候为了使用一个悲观锁，或者手动配置一个乐观锁（如果实体中没有version字段），那么可以使用@Lock这个注解，它能够被解析成为相关的锁。

一对多、多对多查询（查询条件在关联对象中时）：

　　1、在JPA中，一个实体中如果存在多个关联对象，那么不能同时eager获取，只能有一个是eager获取，其他只能lazy；在Hibernate当中有几种独有的解决方法，在JPA当中有2中方法，i.就是前面的改成延时加载；ii.把关联对象的List改成Set（List允许重复，在多层抓去的时候无法完成映射，Hibernate默认抓去4层，在第三层的时候如果是List就无法完成映射）。

　　2、在多对多的查询中，我们可以使用JPQL，也可以使用原生SQL，同时还可以使用动态查询，这里介绍多对多的动态查询，这里有一个条件比较苛刻，那就是查询参数是关联对象的属性，一对多类似，多对一可以利用上面介绍的级联获取属性的方式。这里介绍这种方式的目的是为了更好的利用以面向对象的方式进行动态查询。

　　举例：2张表，分别是Employee(id, name)和Company(id, name)，二者是多对多的关系，那么当查询Employee的时候，条件是更具公司名称。那么做法如下：

    @Overridepublic List<Employee> findByCompanyName(final String companyName) {List<Employee> employeeList = employeeRepository.findAll(new Specification<Employee>() {public Predicate toPredicate(Root<Employee> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
//                ListJoin<Employee, Company> companyJoin = root.join(root.getModel().getList("companyList", Company.class), JoinType.LEFT);Join<Employee, Company> companyJoin = root.join("companyList", JoinType.LEFT);return cb.equal(companyJoin.get("name"), companyName);}});return employeeList;}

　　我们可以使用上面注释掉的方式，也可以使用下面这种比较简单的方式。因为我个人的习惯是尽量不去写DAO的实现类，除非查询特别复杂，万不得已的情况下采用，否则我个人比较偏向于这种方式。

　　上面的情况如果更为极端的话，关联多个对象，可以按照下面的方式：

    @Overridepublic List<Employee> findByCompanyName(final String companyName, final String wage) {List<Employee> employeeList = employeeRepository.findAll(new Specification<Employee>() {public Predicate toPredicate(Root<Employee> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
//                ListJoin<Employee, Company> companyJoin = root.join(root.getModel().getList("companyList", Company.class), JoinType.LEFT);Join<Employee, Company> companyJoin = root.join("companySet", JoinType.LEFT);Join<Employee, Wage> wageJoin = root.join("wageSet", JoinType.LEFT);Predicate p1 = cb.equal(companyJoin.get("name"), companyName);Predicate p2 = cb.equal(wageJoin.get("name"), wage);
//              return cb.and(p1, p2);根据spring-data-jpa的源码，可以返回一个Predicate，框架内部会自动做query.where(p)的操作，也可以直接在这里处理，然后返回null，///              也就是下面一段源码中的实现
                query.where(p1, p2);return null;}});return employeeList;}

    /*** Applies the given {@link Specification} to the given {@link CriteriaQuery}.* * @param spec can be {@literal null}.* @param query must not be {@literal null}.* @return*/private <S> Root<T> applySpecificationToCriteria(Specification<T> spec, CriteriaQuery<S> query) {Assert.notNull(query);Root<T> root = query.from(getDomainClass());if (spec == null) {return root;}CriteriaBuilder builder = em.getCriteriaBuilder();Predicate predicate = spec.toPredicate(root, query, builder);// 这里如果我们重写的toPredicate方法的返回值predicate不为空，那么调用query.where(predicate)if (predicate != null) {query.where(predicate);}return root;}

说明：虽然说JPA中这种方式查询会存在着多次级联查询的问题，对性能有所影响，但是在一般的企业级应用当中，为了开发的便捷，这种性能牺牲一般来说是可以接受的。

　　特别的：在一对多中或者多对一中，即便是fetch为eager，也会先查询主对象，再查询关联对象，但是在eager的情况下虽然是有多次查询问题，但是没有n+1问题，关联对象不会像n+1那样多查询n次，而仅仅是把关联对象一次性查询出来，因此，在企业级应用当中，访问量不大的情况下一般来说没什么问题。

　　补充一段题外话，关于Hibernate/JPA/Spring-Data-Jpa与MyBatis的区别联系，这种话题很多讨论，对于Hibernate/JPA/Spring-Data-Jpa，我个人而言基本上能够熟练使用，谈不上精通，对于mybatis，由于深入阅读过几次它的源码，对mybatis的设计思想以及细化到具体的方法，属性，参数算是比较熟悉，也开发过一些mybatis的相关插件。对于这两个持久化框架，总体来说的区别是，Hibernate系列的门槛相对较高，配置比较多，相对来说难度要大一些，主要体现在各种关系的问题上，据我所知，很多人的理解其实并不深刻，很多时候甚至配置得有一定的问题，但是优势也很明显，SQL自动生成，改数据库表结构仅仅需要调整几个注解就行了，在熟练使用的基础上相对来说要便捷一点。对于mybatis来说，门槛很低，真的很低，低到分分钟就能入门的程度，我个人最喜欢也是mybatis最吸引人的地方就是灵活，特别的灵活，但是修改数据库表结构之后需要调整的地方比较多，但是利用目前比较优秀的插件，对于单表操作也基本上能够达到和Hibernate差不多的境界（会稍微牺牲一点点性能），多表的情况下就要麻烦一点。性能方面的比较，由于我没做过测试，不太好比较，不过应该mybatis要稍微高一些，毕竟他的查询SQL可控一些（当然Hibernate也支持原生sql，但是对结果集的处理不够友好）。

　　之后更新：Root对象还有一批fetch方法，这个目前我很少用，后面有时间再来更新。

　　补充：单表分页可以传入分页对象，比如findByName(String name, new pageRequest(0, 10));

Spring Data JPA，一种动态条件查询的写法

我们在使用SpringData JPA框架时，进行条件查询，如果是固定条件的查询，我们可以使用符合框架规则的自定义方法以及@Query注解实现。

如果是查询条件是动态的，框架也提供了查询接口。

JpaSpecificationExecutor

和其他接口使用方式一样，只需要在你的Dao接口继承即可(官网代码)。

public interface CustomerRepository extends CrudRepository<Customer, Long>, JpaSpecificationExecutor {…
}

JpaSpecificationExecutor提供很多条件查询方法。

public interface JpaSpecificationExecutor<T> {T findOne(Specification<T> var1);List<T> findAll(Specification<T> var1);Page<T> findAll(Specification<T> var1, Pageable var2);List<T> findAll(Specification<T> var1, Sort var2);long count(Specification<T> var1);
}

比如方法:

List<T> findAll(Specification<T> var1);

就可以查找出符合条件的所有数据，如果你的框架使用的是前段分页的技术，那么这个方法就挺简便的。

那么这个方法该如何使用呢？我们看到它需要的参数是一个

org.springframework.data.jpa.domain.Specification

对象。那我们就创建这个对象先看看。

Specification specification = new Specification() {@Overridepublic Predicate toPredicate(Root root, CriteriaQuery criteriaQuery, CriteriaBuilder criteriaBuilder) {return null;}}

IDE自动生成了要重写的方法toPredicate。

root参数是我们用来对应实体的信息的。criteriaBuilder可以帮助我们制作查询信息。

/*** A root type in the from clause.* Query roots always reference entities.** @param <X> the entity type referenced by the root* @since Java Persistence 2.0*/
public interface Root<X> extends From<X, X> {...}

/*** Used to construct criteria queries, compound selections,* expressions, predicates, orderings.** <p> Note that <code>Predicate</code> is used instead of <code>Expression<Boolean></code>* in this API in order to work around the fact that Java* generics are not compatible with varags.** @since Java Persistence 2.0*/
public interface CriteriaBuilder {...}

CriteriaBuilder对象里有很多条件方法，比如制定条件:某条数据的创建日期小于今天。

criteriaBuilder.lessThan(root.get("createDate"), today)

该方法返回的对象类型是Predicate。正是toPredicate需要返回的值。

如果有多个条件，我们就可以创建一个Predicate集合，最后用CriteriaBuilder的and和or方法进行组合，得到最后的Predicate对象。

/*** Create a conjunction of the given restriction predicates.* A conjunction of zero predicates is true.** @param restrictions zero or more restriction predicates** @return and predicate*/Predicate and(Predicate... restrictions);

/*** Create a disjunction of the given restriction predicates.* A disjunction of zero predicates is false.** @param restrictions zero or more restriction predicates** @return or predicate*/Predicate or(Predicate... restrictions);

示例:

public List<WeChatGzUserInfoEntity> findByCondition(Date minDate, Date maxDate, String nickname){List<WeChatGzUserInfoEntity> resultList = null;Specification querySpecifi = new Specification<WeChatGzUserInfoEntity>() {@Overridepublic Predicate toPredicate(Root<WeChatGzUserInfoEntity> root, CriteriaQuery<?> criteriaQuery, CriteriaBuilder criteriaBuilder) {List<Predicate> predicates = new ArrayList<>();if(null != minDate){predicates.add(criteriaBuilder.greaterThan(root.get("subscribeTime"), minDate));}if(null != maxDate){predicates.add(criteriaBuilder.lessThan(root.get("subscribeTime"), maxDate));}if(null != nickname){predicates.add(criteriaBuilder.like(root.get("nickname"), "%"+nickname+"%"));}return criteriaBuilder.and(predicates.toArray(new Predicate[predicates.size()]));}};resultList =  this.weChatGzUserInfoRepository.findAll(querySpecifi);return resultList;}

and到一起的话所有条件就是且关系，or就是或关系了。

其实也是在Stack Overflow上看到的。

jpa动态查询语句

标签： jpa动态查询语句oa系统整理

2015-04-16 10:58 4781人阅读评论(0) 收藏举报

我们现在在做一个OA系统，将新增的那些数据都写到数据库的时候是采用jpa规范的，（不太理解jpa的相关知识点，今天看下相关知识，然后再补充jpa的知识点），现在记录jpa中的动态查询语句，其实这些语句都是可以用sql语句写的，但是sql语句写得查询，删除，插入数据等操作不安全，所以采用jpa的语句。我们的项目是分为三层结构，第一层是实体层，在该层中专门定义某一实体的相关字段，它的set()，get()方法。第二层是服务层，将service和dao都放在一个组件中,在dao层中定义和数据库相关的操作方法，在service层中定义相关的业务逻辑层要调用的方法。第三层是restful层，在这层定义的是和前端交互的组件。

首先讲讲第一层：实体层

定义一个实体

[java] view plaincopy

/**
* 邮件实体
*
*/
@Entity
@Table(name = "mail_tbl")
public class InnerMails implements Serializable {
private static final long serialVersionUID = 4999674279957375152L;
@Id
@GeneratedValue
private long id;
private String subject;// 主题
private String toMails;// 收件人格式：姓名<userId>;姓名<userId>
private String urgency;// 紧急程度
@Column(name = "sendDate")
@Temporal(TemporalType.TIMESTAMP)
private Date sendDate;// 发布日期
private String content;// 邮件内容
// 原文附件
@OneToMany(cascade={ CascadeType.MERGE,CascadeType.REMOVE})
@JoinColumn(name = "mail_id")
@OrderBy(value = "id DESC")//注释指明加载Attachment时按id的降序排序
private Set<AppendFile> appendFiles=new HashSet<AppendFile>();// 附件
private String mailUser;// 邮件拥有者格式：userId
private String sendMail;// 邮件发送者格式：姓名<userId>
private int type;// 状态标示：-1删除；0草稿；1发送；2未读收件，3已读收件
public long getId() {
return id;
}
public void setId(long id) {
this.id = id;
}
public String getSubject() {
return subject;
}
public void setSubject(String subject) {
this.subject = subject;
}
public String getToMails() {
return toMails;
}
public void setToMails(String toMails) {
this.toMails = toMails;
}
public String getUrgency() {
return urgency;
}
public void setUrgency(String urgency) {
this.urgency = urgency;
}
public Date getSendDate() {
return sendDate;
}
public void setSendDate(Date sendDate) {
this.sendDate = sendDate;
}
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
public String getMailUser() {
return mailUser;
}
public void setMailUser(String mailUser) {
this.mailUser = mailUser;
}
public Set<AppendFile> getAppendFiles() {
return appendFiles;
}
public void setAppendFiles(Set<AppendFile> appendFiles) {
this.appendFiles = appendFiles;
}
public String getSendMail() {
return sendMail;
}
public void setSendMail(String sendMail) {
this.sendMail = sendMail;
}
public int getType() {
return type;
}
public void setType(int type) {
this.type = type;
}
}

定义查询实体：

[java] view plaincopy

package com.gzydt.oa.commons;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* 分页查询参数
*
* @author huangzhenwei
* @since 2014-11-21
*
*/
public class QueryParam {
// 排序字段，以“+”、“-”符号连接排序字段名：“+key”表示按“key”字段升序，“-key”表示按“key”字段降序。
private List<String> sorts = new ArrayList<String>();
// 起始记录下标，从0开始计算
private int first = 0;
// 每页最大记录数
private int max = 10;
// 是否分页标志
private boolean isPage = true;
// 查询参数
private Map<String, String> param = new HashMap<String, String>();
public QueryParam() {
}
public int getFirst() {
return first;
}
public void setFirst(int first) {
this.first = first;
}
public int getMax() {
return max;
}
public void setMax(int max) {
this.max = max;
}
public Map<String, String> getParam() {
return param;
}
public void setParam(Map<String, String> param) {
this.param = param;
}
public boolean isPage() {
return isPage;
}
public void setPage(boolean isPage) {
this.isPage = isPage;
}
public List<String> getSorts() {
return sorts;
}
public void setSorts(List<String> sorts) {
this.sorts = sorts;
}
}

第二层：服务层

dao层：定义和数据库相关操作的方法

[java] view plaincopy

package com.gzydt.oa.dao;
import java.util.List;
import com.gzydt.oa.commons.QueryParam;
import com.gzydt.oa.entity.AppendFile;
import com.gzydt.oa.entity.InnerMails;
/**
* 邮件发送dao接口
*
*/
public interface InnerMailDao {
/**
* 保存邮件
* @param mail
* @return
*/
public InnerMails save(InnerMails mail);
/**
* 更新邮件
* @param mail
* @return
*/
public InnerMails update(InnerMails mail);
/**
* 删除邮件
* @param id
*/
public void delete(long id);
/**
* 查询邮件
* @param queryParam
* @return
*/
public List<InnerMails> getlist(QueryParam queryParam);
/**
* 获取单个邮件
* @param id
* @return
*/
public InnerMails get(long id);
/**
* 获取满足条件的邮件的总数
* @param queryParam
* @return
*/
public int getCount(QueryParam queryParam);
/**
* 新增附件
* @param id
* @param appendFile
*/
public void addAttach(long id,AppendFile appendFile);
}

[java] view plaincopy

package com.gzydt.oa.dao.impl;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import javax.persistence.EntityManager;
import javax.persistence.TypedQuery;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import com.gzydt.oa.commons.QueryParam;
import com.gzydt.oa.dao.InnerMailDao;
import com.gzydt.oa.entity.AppendFile;
import com.gzydt.oa.entity.InnerMails;
/**
* 邮件实现类
*/
public class InnerMailDaoImpl implements InnerMailDao{
private EntityManager entityManager;
public void setEntityManager(EntityManager entityManager) {
this.entityManager = entityManager;
}
/**
* 保存邮件
* @param mail
* @return
*/
@Override
public InnerMails save(InnerMails mail) {
try {
entityManager.persist(mail);
entityManager.flush();
return mail;
} catch ( Exception e ) {
e.printStackTrace();
return null;
}
}
/**
* 更新邮件
* @param mail
* @return
*/
@Override
public InnerMails update(InnerMails mail) {
try {
entityManager.merge(mail);
return mail;
} catch ( Exception e ) {
e.printStackTrace();
return null;
}
}
/**
* 删除邮件
* @param id
*/
@Override
public void delete(long id) {
entityManager.createQuery("delete from PhoneRecord e where e.id=:id").setParameter("id", id).executeUpdate();
}
/**
* 查询邮件
* @param queryParam
* @return
*/
@Override
public List<InnerMails> getlist(QueryParam queryParam) {
CriteriaBuilder cb = entityManager.getCriteriaBuilder();
CriteriaQuery<InnerMails> criteriaQuery = cb.createQuery(InnerMails.class);
Root<InnerMails> register = criteriaQuery.from(InnerMails.class);
// 过滤条件
Predicate[] predicates = createPredicate(queryParam, cb, register);
criteriaQuery.where(predicates);
int start = queryParam.getFirst();
int end = queryParam.getMax();
TypedQuery<InnerMails> typedQuery = entityManager.createQuery(criteriaQuery);
typedQuery.setFirstResult(start).setMaxResults(end);
return typedQuery.getResultList();
}
//设置查询条件
private Predicate[] createPredicate(QueryParam queryParam, CriteriaBuilder cb, Root<InnerMails> entity) {
List<Predicate> predicates=new ArrayList<Predicate>();
//取出查询条件
Map<String, String> param= queryParam.getParam();
for(Map.Entry entry:param.entrySet()){
String key=entry.getKey().toString();
String value=entry.getValue().toString();
if(key.equals("sendDate")){
Predicate conditionTime = createOperateTime(key,cb,value,entity);
if(null!=conditionTime){
predicates.add(conditionTime);
}
}else{
predicates.add(cb.like(entity.<String> get(key),"%"+value+"%"));
}
}
return predicates.toArray(new Predicate[0]);
}
/**
* 将时间作为查询条件的方法
* @param cb
* @param value
* @param entity
*/
private Predicate createOperateTime(String key,CriteriaBuilder cb, String value, Root<InnerMails> entity) {
if(null == value){
return null;
}
String[] operateTime=value.split("~");
if(operateTime.length!=2){
return null;
}
try {
DateFormat df=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//格式一定要写正确，
Date t1=df.parse(operateTime[0] + " 00:00:00");
Date t2=df.parse(operateTime[1] + " 23:59:59");
return cb.between(entity.<Date> get(key), t1, t2);
} catch ( Exception e ) {
e.printStackTrace();
}
return null;
}
/**
* 获取单个邮件
* @param id
* @return
*/
@Override
public InnerMails get(long id) {
InnerMails innersMails=entityManager.find(InnerMails.class, id);
Iterator<AppendFile> iterator=innersMails.getAppendFiles().iterator();
Set<AppendFile> attachs=new HashSet<AppendFile>();
while(iterator.hasNext()){
AppendFile appendFile=new AppendFile();
appendFile=iterator.next();
attachs.add(appendFile);
}
innersMails.setAppendFiles(attachs);
return innersMails;
}
/**
* 获取满足条件的邮件的总数
* @param queryParam
* @return
*/
@Override
public int getCount(QueryParam queryParam) {
CriteriaBuilder cb = entityManager.getCriteriaBuilder();
CriteriaQuery<Long> criteriaQuery = cb.createQuery(Long.class);
Root<InnerMails> mails = criteriaQuery.from(InnerMails.class);
criteriaQuery.select(cb.countDistinct(mails));
// 过滤条件
Predicate[] predeicates = createPredicate(queryParam, cb, mails);
criteriaQuery.where(predeicates);
TypedQuery<Long> typedQuery = entityManager.createQuery(criteriaQuery);
int count = 0;
try {
count = typedQuery.getSingleResult().intValue();
} catch ( Exception e ) {
e.printStackTrace();
}
return count;
}
/**
* 新增附件
* @param id
* @param appendFile
*/
@Override
public void addAttach(long id, AppendFile appendFile) {
InnerMails entity=this.get(id);
entity.getAppendFiles().add(appendFile);
entityManager.merge(entity);
}
}

动态查询语句的相关知识

1：查询User表中的字段adminlever的小于给定值的数据

第一种写法：（安全，推荐使用这种）

[java] view plaincopy

/**
* 查询某一级别以上的用户
*/
@Override
public List<User> getOnLeverUper(int lever) {
CriteriaBuilder cb =entityManager.getCriteriaBuilder();
CriteriaQuery<User> criterQuery=cb.createQuery(User.class);
Root<User> entity=criterQuery.from(User.class);
Path<Integer> adminLever=entity.<Integer> get("adminlever") ;
criterQuery.where(cb.lessThan(adminLever, lever));
TypedQuery<User> typedQuery=entityManager.createQuery(criterQuery);
return typedQuery.getResultList();
}

第二种写法：(不太安全，)

[java] view plaincopy

/**
* 查询某一级别以上的用户
*/
@Override
public List<User> getOnLeverUper(int lever) {
List<User> users=entityManager.createQuery("from User u where u.adminlever<:adminlever")
.setParameter("adminlever",lever).getResultList();
return users;
}

第二种删除数据（有时候会由于某实体和另一实体设置了一对一或者多对一，或者多对多的关系而导致不能正常删除数据），解决方法：

[java] view plaincopy

/**
* 删除登记信息
*
* @param id
* 登记编号
*/
@Override
public void handleDelete(long id) throws Exception {
ReceiptEntity entity = entityManager.find(ReceiptEntity.class, id);
entityManager.remove(entity);
//下面的的方法删除应为存在外键关联会删除失败
/*entityManager.createQuery("delete from ReceiptEntity e where e.id=:id").
setParameter("id", id).executeUpdate();*/
}

service层：接口

[java] view plaincopy

package com.gzydt.oa.service;
import java.util.List;
import com.gzydt.oa.commons.QueryParam;
import com.gzydt.oa.entity.AppendFile;
import com.gzydt.oa.entity.InnerMails;
/**
* 内部邮件接口
*
*/
public interface InnerMailService {
/**
* 保存邮件
* @param mail
* @return
*/
public InnerMails save(InnerMails mail);
/**
* 更新邮件
* @param mail
* @return
*/
public InnerMails update(InnerMails mail);
/**
* 删除邮件
* @param id
*/
public void delete(long id);
/**
* 查询邮件
* @param queryParam
* @return
*/
public List<InnerMails> getlist(QueryParam queryParam);
/**
* 获取单个邮件
* @param id
* @return
*/
public InnerMails get(long id);
/**
* 获取满足条件的邮件的总数
* @param queryParam
* @return
*/
public int getCount(QueryParam queryParam);
/**
* 发邮件
* @param content
*//*
public void sendMail(String content);*/
/**
* 新增附件
* @param id
* @param appendFile
*/
public void addAttach(long id,AppendFile appendFile);
}

service层:实现类

[java] view plaincopy

package com.gzydt.oa.service.impl;
import java.util.List;
import com.gzydt.oa.commons.QueryParam;
import com.gzydt.oa.dao.InnerMailDao;
import com.gzydt.oa.entity.AppendFile;
import com.gzydt.oa.entity.InnerMails;
import com.gzydt.oa.service.InnerMailService;
/**
* 内部邮件服务类
*
*/
public class InnerMailServiceImpl implements InnerMailService{
private InnerMailDao mailDao;
public void setMailDao(InnerMailDao mailDao) {
this.mailDao = mailDao;
}
/**
* 保存邮件
* @param mail
* @return
*/
@Override
public InnerMails save(InnerMails mail) {
return mailDao.save(mail);
}
@Override
public InnerMails update(InnerMails mail) {
return mailDao.update(mail);
}
/**
* 删除邮件
* @param id
*/
@Override
public void delete(long id) {
mailDao.delete(id);
}
/**
* 查询邮件
* @param queryParam
* @return
*/
@Override
public List<InnerMails> getlist(QueryParam queryParam) {
return mailDao.getlist(queryParam);
}
/**
* 获取单个邮件
* @param id
* @return
*/
@Override
public InnerMails get(long id) {
return mailDao.get(id);
}
/**
* 获取满足条件的邮件的总数
* @param queryParam
* @return
*/
@Override
public int getCount(QueryParam queryParam) {
return mailDao.getCount(queryParam);
}
/* @Override
public void sendMail(String content) {
}*/
/**
* 新增附件
* @param id
* @param appendFile
*/
@Override
public void addAttach(long id, AppendFile appendFile) {
mailDao.addAttach(id, appendFile);
}
}

在服务层中定义相关的服务配置

[java] view plaincopy

<?xml version="1.0" encoding="UTF-8"?>
<blueprint default-activation="eager"
xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:jpa="http://aries.apache.org/xmlns/jpa/v1.0.0" xmlns:tx="http://aries.apache.org/xmlns/transactions/v1.0.0"
xsi:schemaLocation="
http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
http://cxf.apache.org/blueprint/jaxrs http://cxf.apache.org/schemas/blueprint/jaxrs.xsd
http://cxf.apache.org/blueprint/core http://cxf.apache.org/schemas/blueprint/core.xsd">
<!-- This gets the container-managed EntityManager and injects it into the
ServiceImpl bean. -->
<bean id="mailDao" class="com.gzydt.oa.dao.impl.InnerMailDaoImpl">
<jpa:context unitname="com.gzydt.jpa.persistence"
property="entityManager" />
<tx:transaction method="*" value="Required" />
</bean>
<bean id="mailService" class="com.gzydt.oa.service.impl.InnerMailServiceImpl">
<property name="mailDao" ref="mailDao" />
</bean>
<service ref="mailService" interface="com.gzydt.oa.service.InnerMailService" />
<!-- This bundle makes use of Karaf commands to demonstrate core persistence
operations. Feel free to remove it. -->
<command-bundle xmlns="http://karaf.apache.org/xmlns/shell/v1.1.0">
<command name="msg/add">
<action class="com.gzydt.oa.command.AddMessage">
<property name="messageService" ref="messageService" />
</action>
</command>
<command name="msg/list">
<action class="com.gzydt.oa.command.GetMessage">
<property name="messageService" ref="messageService" />
</action>
</command>
<command name="msg/delete">
<action class="com.gzydt.oa.command.DeleteMessage">
<property name="messageService" ref="messageService" />
</action>
</command>
<command name="dept/add">
<action class="com.gzydt.oa.command.DeptAddCommand">
<property name="deptService" ref="deptService" />
</action>
</command>
<command name="dept/list">
<action class="com.gzydt.oa.command.DeptGetCommand">
<property name="deptService" ref="deptService" />
</action>
</command>
<command name="dept/delete">
<action class="com.gzydt.oa.command.DeptDeleteCommand">
<property name="deptService" ref="deptService" />
</action>
</command>
</command-bundle>
</blueprint>

第三层：restful层

[java] view plaincopy

package com.gzydt.oa.resource;
import java.text.ParseException;
import java.util.List;
import javax.ws.rs.Consumes;
import javax.ws.rs.DELETE;
import javax.ws.rs.GET;
import javax.ws.rs.HeaderParam;
import javax.ws.rs.POST;
import javax.ws.rs.PUT;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.QueryParam;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
import org.apache.cxf.jaxrs.ext.multipart.Attachment;
import org.apache.cxf.jaxrs.ext.multipart.Multipart;
/**
* 内部邮件的restful
*/
@Path("/mails")
public interface InnerMailsResource {
/**
* 新增邮件
* @param content
* @return
*/
@POST
@Path("/")
@Consumes("multipart/form-data")
public Response save(@Multipart("content") String content,
List<Attachment> attachments) throws ParseException ;
/**
* 更新邮件
* @param id
* @param content
* @return
*/
@PUT
@Path("/{id}")
@Consumes("multipart/form-data")
public Response update(@PathParam("id") long id,@Multipart("content") String content,
List<Attachment> attachments) throws ParseException;
/**
* 查询邮件
* @param id
* @return
*/
@GET
@Path("/{id}")
public Response get(@PathParam("id") long id);
/**
* 查询邮件列表
* @param range
* @param query
* @return
*/
@GET
@Path("/list")
public Response getList(@HeaderParam("range") String range,@QueryParam("query") String query);
/**
* 删除邮件
* @param id
* @return
*/
@DELETE
@Path("/{id}")
public Response delete(@PathParam("id") long id);
/**
* 发送邮件
* @param content
* @return 数据格式：{"data":{},"toMail":""}
*/
@POST
@Path("/sendMails/{id}")
public Response sendMail(@PathParam("id")long id) ;
/**
* 下载附件
* @param id(附件的id)
* @return
*/
@GET
@Path("/getAttach/{id}")
@Produces(MediaType.APPLICATION_OCTET_STREAM)
public Response downLoadAttach(@PathParam("id") long id);
}

实现类：

[java] view plaincopy

package com.gzydt.oa.resource.impl;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import javax.activation.DataHandler;
import javax.ws.rs.WebApplicationException;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
import javax.ws.rs.core.Response.Status;
import javax.ws.rs.core.StreamingOutput;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import net.sf.json.JsonConfig;
import org.apache.cxf.jaxrs.ext.multipart.Attachment;
/*import org.json.JSONArray;*/
import com.gzydt.oa.commons.QueryParam;
import com.gzydt.oa.entity.AppendFile;
import com.gzydt.oa.entity.InnerMails;
import com.gzydt.oa.resource.InnerMailsResource;
import com.gzydt.oa.service.AppendFileService;
import com.gzydt.oa.service.InnerMailService;
import com.gzydt.oa.util.Constant;
import com.gzydt.oa.util.QueryUtil;
public class InnerMailsResourceImpl implements InnerMailsResource {
private InnerMailService emailService;
public void setEmailService(InnerMailService emailService) {
this.emailService = emailService;
}
private AppendFileService appendFileService;
public void setAppendFileService(AppendFileService appendFileService) {
this.appendFileService = appendFileService;
}
private static final String PATH = "data/oa/upload/mails";
@Override
public Response save(String content, List<Attachment> attachments) throws ParseException {
//去掉懒加载字段
JsonConfig jsonConfig = Constant.jsonDateConfig;
jsonConfig.setExcludes(new String[] { "appendFiles"});
JSONObject preceInfo = JSONObject.fromObject(content);
JSONObject backInfo = new JSONObject();
InnerMails entity = new InnerMails();
Date sendDate = null;
if ( preceInfo.optString("sendDate") != null && preceInfo.optString("sendDate") != "" ) {
//这里的MM必须是要大写，若是写为mm,则是分钟，，格式一定要按照正规的来写<span class="con">yyyy-MM-dd HH:mm:ss</span>，
//该大写就大写，小写就小写，并且中间有空格等，都不能错误。不然时间会出错
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd");
sendDate = df.parse(preceInfo.optString("sendDate"));
}
preceInfo.put("sendDate", sendDate);
entity = (InnerMails) JSONObject.toBean(preceInfo, InnerMails.class);
if ( !preceInfo.has("type") ) {
entity.setType(0);
}
entity = emailService.save(entity);
// 新增附件到附件表中
Set<AppendFile> appfiles=addAttach(attachments, entity);
entity.setAppendFiles(appfiles);
entity=emailService.update(entity);
if ( null != entity ) {
backInfo = JSONObject.fromObject(entity);
return Response.ok(backInfo.toString(), MediaType.APPLICATION_JSON).build();
}
backInfo.put("message", "保存失败");
return Response.ok(backInfo.toString(), MediaType.APPLICATION_JSON).build();
}
// 保存并关联附件
private Set<AppendFile> addAttach(List<Attachment> attachments,InnerMails entity){
Set<AppendFile> appenFiles=new HashSet<AppendFile>();
for (Attachment attachment : attachments) {
if (attachment.getContentType().toString().startsWith("application/octet-stream")) {
DataHandler dh = attachment.getDataHandler();
long time = new Date().getTime();
String fileName = null;
try {
fileName = new String(dh.getName().getBytes("ISO-8859-1"), "UTF-8");
writeFile(dh, fileName);
} catch (Exception e) {
e.printStackTrace();
}
AppendFile file = new AppendFile();
file.setSerialNumber(time);// 唯一标识
file.setFileName(fileName);// 文件名
file.setExtension(fileName.substring(fileName.lastIndexOf(".") + 1));// 文件后缀
file.setType("email");// 文件类型
emailService.addAttach(entity.getId(), file);
AppendFile result = null;
result = appendFileService.getByNumber(time);
appenFiles.add(result);
}
}
return appenFiles;
}
// 写文件
private void writeFile(DataHandler dh, String fileName) throws IOException {
InputStream is = dh.getInputStream();
File file = new File(PATH);
if ( !file.exists() ) {
file.mkdirs();
}
// LOG.info("附件目录：" + file.getAbsolutePath());
writeToFile(is, PATH + fileName);
}
private void writeToFile(InputStream is, String path) throws IOException {
File file = new File(path);
OutputStream out = new FileOutputStream(file);
int len = 0;
byte[] bytes = new byte[1024];
while ( (len = is.read(bytes)) != -1 ) {
out.write(bytes, 0, len);
}
out.flush();
out.close();
}
@Override
public Response update(long id, String content, List<Attachment> attachments) throws ParseException {
InnerMails entity = emailService.get(id);
JSONObject preceInfo = JSONObject.fromObject(content);
JSONObject backInfo = new JSONObject();
if ( null != entity ) {
entity.setSubject(preceInfo.optString("subject"));
entity.setToMails(preceInfo.optString("toMails"));
entity.setUrgency(preceInfo.optString("urgency"));
Date sendDate = null;
if ( preceInfo.optString("sendDate") != null && preceInfo.optString("sendDate") != "" ) {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd");
sendDate = df.parse(preceInfo.optString("sendDate"));
}
//保存附件
Set<AppendFile> appfiles=addAttach(attachments, entity);
entity.setAppendFiles(appfiles);
entity.setSendDate(sendDate);
entity.setContent(preceInfo.optString("content"));
entity.setMailUser(preceInfo.optString("mailUser"));
entity.setSendMail(preceInfo.optString("sendMail"));
entity.setType(preceInfo.optInt("type"));
addAttach(attachments, entity);
entity = emailService.update(entity);
if ( entity != null ) {
backInfo = JSONObject.fromObject(entity);
return Response.ok(backInfo.toString(), MediaType.APPLICATION_JSON).build();
} else {
backInfo.put("message", "修改失败");
return Response.ok(backInfo.toString(), MediaType.APPLICATION_JSON).build();
}
}
backInfo.put("message", "没有找到指定的邮件");
return Response.ok(backInfo.toString(), MediaType.APPLICATION_JSON).build();
}
@Override
public Response get(long id) {
JSONObject backInfo = new JSONObject();
InnerMails entity = emailService.get(id);
JSONObject jo;
/*JsonConfig JSONConfig = Constant.jsonDateConfigWithHour;
JSONConfig.setExcludes(new String[] {"appendFiles"});*/
// 去掉延迟加载的字段
jo = JSONObject.fromObject(entity);
//修改状态为已读
entity.setType(3);
emailService.update(entity);
if ( null != entity ) {
backInfo = JSONObject.fromObject(jo);
return Response.ok(backInfo.toString(), MediaType.APPLICATION_JSON).build();
}
backInfo.put("message", "没有找到指定的内部邮件");
return Response.ok(backInfo.toString(), MediaType.APPLICATION_JSON).build();
}
@Override
public Response getList(String range, String query) {
QueryParam queryParam = new QueryParam();
int from = 0;
int to = 9;
try {
String[] ranges = range.replace("items=", "").split("-");
from = Integer.parseInt(ranges[0]);
to = Integer.parseInt(ranges[1]);
} catch ( Exception e ) {
e.printStackTrace();
}
queryParam.setFirst(from);
int max = to - from + 1;
if ( max > 0 ) {
queryParam.setMax(max);
}
if(null!=query){
QueryUtil.prepareQuery(query, queryParam);
}
int count=emailService.getCount(queryParam);
List<InnerMails> list=emailService.getlist(queryParam);
JsonConfig jsonconfig=Constant.jsonDateConfig;
jsonconfig.setExcludes(new String[] {"appendFiles"});
String contentRange=String.format("items %d-%d/%d", from,to,count);
JSONArray ja = JSONArray.fromObject(list,jsonconfig);
String entity = ja.toString();
return Response.ok(entity, MediaType.APPLICATION_JSON).header("Content-Range", contentRange).build();
}
@Override
public Response delete(long id) {
JSONObject backInfo=new JSONObject();
try {
emailService.delete(id);
backInfo.put("message", "删除成功");
return Response.ok(backInfo.toString(), MediaType.APPLICATION_JSON).build();
} catch ( Exception e ) {
backInfo.put("message","删除失败");
return Response.ok(backInfo.toString(),MediaType.APPLICATION_JSON).build();
}
}
@Override
public Response sendMail(/*String content,List<Attachment> attachments*/long id){
JSONObject backInfo=new JSONObject();
//通过id找到对应的邮件
InnerMails entity=emailService.get(id);
//将A的邮件mail状态改为发送
entity.setType(1);
entity=emailService.update(entity);
//找到收件人，根据收件人的个数来新增多条邮件
String toMail=entity.getToMails();
String[] toMails=toMail.split(",");
for(String tomail:toMails){
//新增邮件，修改mail1的拥有者，修改状态为未读
InnerMails newMails=new InnerMails();
newMails.setSubject(entity.getSubject());
newMails.setToMails(entity.getToMails());
newMails.setUrgency(entity.getUrgency());
newMails.setAppendFiles(entity.getAppendFiles());
newMails.setSendDate(entity.getSendDate());
newMails.setContent(entity.getContent());
newMails.setSendMail(entity.getSendMail());
newMails.setType(2);
newMails.setMailUser(getNoFromChar(tomail));
emailService.save(newMails);
}
backInfo.put("发送邮件的人数", toMails.length);
return Response.ok(backInfo.toString(), MediaType.APPLICATION_JSON).build();
}
//截取字符串中的数字
private String getNoFromChar(String params) {
String regex="[^0-9]";
Pattern p=Pattern.compile(regex);
Matcher m=p.matcher(params);
return m.replaceAll("").trim();
}
@Override
public Response downLoadAttach(long id) {
//根据附件名称去指定路径中找附件
AppendFile appendFile=appendFileService.get(id);
if ( null == appendFile ) {
return Response.status(Status.NOT_FOUND).entity("找不到文件").build();
}
final File file=new File(PATH, appendFile.getFileName());
JSONObject preceInfo=new JSONObject();
if(!file.exists()||!file.isFile()){
preceInfo.put("message","没有找到指定的文件");
return Response.status(Status.NOT_FOUND).entity("找不到文件："+file.getName()).build();
}
//下载附件
StreamingOutput entity=downLoad(file);
String fileName=file.getName().toLowerCase();
String type=MediaType.APPLICATION_OCTET_STREAM;
if(fileName.endsWith(".jpg")||fileName.endsWith(".png")){
type="image/jpeg";
}else if(fileName.endsWith(".doc")){
type="application/msword;charset=utf-8";
}else if(fileName.endsWith(".pdf")){
type="application/pdf;charset=utf-8";
}
try {
//结局中文名字乱码的问题
fileName=new String(file.getName().getBytes("UTF-8"),"ISO-8859-1");
} catch ( Exception e ) {
// TODO: handle exception
}
return Response.ok(entity, type).header("Content-disposition", "inline;filename="+fileName).build();
}
//下载附件方法
private StreamingOutput downLoad(final File file) {
StreamingOutput entity=new StreamingOutput() {
@Override
public void write(OutputStream output) throws IOException, WebApplicationException {
int len=0;
byte[] buffer=new byte[1024];
InputStream intpStream=new FileInputStream(file);
while((len = intpStream.read(buffer))>0){
output.write(buffer, 0,len);
}
intpStream.close();
output.flush();
output.close();
}
};
return entity;
}
}

restful层的配置文件：

[java] view plaincopy

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxrs="http://cxf.apache.org/blueprint/jaxrs"
xmlns:cxf="http://cxf.apache.org/blueprint/core"
xsi:schemaLocation="
http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
http://cxf.apache.org/blueprint/jaxrs http://cxf.apache.org/schemas/blueprint/jaxrs.xsd
http://cxf.apache.org/blueprint/core http://cxf.apache.org/schemas/blueprint/core.xsd">
<jaxrs:server id="OARestService" address="/oa">
<jaxrs:serviceBeans>
<ref component-id="mailRestService" />
</jaxrs:serviceBeans>
<jaxrs:providers>
<ref component-id="authFilter" />
</jaxrs:providers>
</jaxrs:server>
<bean id="oauthProvider" class="com.gzydt.oa.auth.OAuthManager" />
<bean id="authorizationService"
class="org.apache.cxf.rs.security.oauth2.services.AuthorizationCodeGrantService">
<property name="dataProvider" ref="oauthProvider" />
</bean>
<jaxrs:server id="appServer" address="/myapp">
<jaxrs:serviceBeans>
<ref component-id="authorizationService" />
</jaxrs:serviceBeans>
</jaxrs:server>
<!-- We are using the OSGi Blueprint XML syntax to define a bean that we
referred to in our JAX-RS server setup. This bean carries a set of JAX-RS
annotations that allow its methods to be mapped to incoming requests. -->
<bean id="authRestService" class="com.gzydt.oa.resource.impl.AuthResourceImpl">
<property name="userService" ref="userService" />
</bean>
<bean id="authFilter" class="com.gzydt.oa.auth.AuthenticationFilter">
</bean>
<bean id="backlogRestService" class="com.gzydt.oa.resource.impl.BacklogResourceImpl">
<property name="registerService" ref="registerService" />
</bean>
<bean id="securityResource" class="com.gzydt.oa.resource.impl.SecurityResourceImpl"
scope="singleton" init-method="init" destroy-method="destroy">
<property name="userService" ref="userService" />
<property name="deptService" ref="deptService" />
<property name="dutyUsersService" ref="dutyUsersService" />
<property name="unitService" ref="unitService" />
</bean>
<bean id="mailRestService" class="com.gzydt.oa.resource.impl.InnerMailsResourceImpl">
<property name="emailService" ref="emailService" />
<property name="appendFileService" ref="appendFileService" />
</bean>
<reference id="emailService" interface="com.gzydt.oa.service.InnerMailService" />
</blueprint>

解析前端传来的参数：

[java] view plaincopy

package com.gzydt.oa.util;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import net.sf.json.JSONObject;
import com.gzydt.oa.commons.QueryParam;
public class QueryUtil {
/**
* 解析url中的查询条件的参数
*
* @param query
* :查询标示
* @param queryParam
* :url中的查询参数
* @return 为空
*/
public static void prepareQuery(String query, QueryParam queryParam) {
try {
JSONObject jo = JSONObject.fromObject(query);
Map<String, String> param = new HashMap<String, String>();
List<String> sorts = new ArrayList<String>();
for ( @SuppressWarnings("unchecked")
Iterator<String> iterator = jo.keySet().iterator(); iterator.hasNext(); ) {
String key = iterator.next();
String value = jo.optString(key);
if ( !value.isEmpty() ) {
if ( "sort".equals(key) ) {
for ( String s : value.split(",") ) {
if ( null != s ) {
if ( s.startsWith("8") ) {// 前端无法传“+”
s = "+" + s.substring(1, s.length());
} else {
s = "-" + s.substring(1, s.length());
}
sorts.add(s);
}
}
} else {
param.put(key, value);
}
}
}
queryParam.setParam(param);
queryParam.setSorts(sorts);
} catch ( Exception e ) {
e.printStackTrace();
}
}
}

内部邮件的测试类：

[java] view plaincopy

package com.gzydt.oa.resource;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.List;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpException;
import org.apache.commons.httpclient.NameValuePair;
import org.apache.commons.httpclient.methods.DeleteMethod;
import org.apache.commons.httpclient.methods.GetMethod;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.methods.PutMethod;
import org.apache.commons.httpclient.methods.RequestEntity;
import org.apache.commons.httpclient.methods.StringRequestEntity;
import org.apache.commons.httpclient.methods.multipart.FilePart;
import org.apache.commons.httpclient.methods.multipart.MultipartRequestEntity;
import org.apache.commons.httpclient.methods.multipart.Part;
import org.apache.commons.httpclient.methods.multipart.StringPart;
import org.apache.commons.httpclient.params.HttpMethodParams;
import org.json.JSONObject;
import org.junit.Assert;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class MailTest extends Tester {
private static final String TEST_URL = "http://localhost:8181/cxf/oa/mails";
private static final Logger LOG = LoggerFactory.getLogger(MailTest.class);
/**
* 登记信息写邮件
*
* @throws FileNotFoundException
*/
@Test
public void uploadOrigText() throws FileNotFoundException {
/*
* JSONObject jo = new JSONObject(); jo.put("subject", "周末计划");// 主题
* jo.put("toMails", "aa<13>,bb<2>");// 收件人格式：姓名<userId>;姓名<userId>
* jo.put("urgency", "加急");// 紧急程度 jo.put("sendDate", "2015-4-11");//
* 发布日期 jo.put("content", "周末购物");// 邮件内容 jo.put("mailUser", "14");//
* 邮件拥有者格式：userId jo.put("sendMail", "cc<14>");// 邮件发送者
* 格式：姓名<userId>,若只是新建，则不需要改字段 jo.put("type", "0");//
* 状态标示：-1删除；0草稿；1发送；2未读收件，3已读收件 //新增不需要增加type
*/
// 要上传的文件
String path = "F:\\1.doc";
String path1 = "F:\\3.doc";
long start = System.currentTimeMillis();
File file = new File(path);
File fileText = new File(path1);
// 'type': '0',
String content = "{ 'content': '周末野炊','sendDate': '2015-04-11',
'toMails': 'aa<13>,bb<2>','mailUser': '14','subject': '周末计划','sendMail': '','urgency': '加急'}";
Part[] parts = { new FilePart("file", file, "application/octet-stream", "UTF-8"),
new FilePart("file", fileText, "application/octet-stream", "UTF-8"),
new StringPart("content", content, "UTF-8") };
PostMethod post = new PostMethod(TEST_URL);
post.setRequestEntity(new MultipartRequestEntity(parts, post.getParams()));
HttpClient httpclient = new HttpClient();
String res = "";
try {
int result = httpclient.executeMethod(post);
LOG.info("Response status code: " + result);
LOG.info("Response body: ");
res = getStringFromInputStream(post.getResponseBodyAsStream());
LOG.info(res);
} catch ( Exception e ) {
LOG.error("Error connecting to {}", TEST_URL);
Assert.fail("Connection error");
} finally {
// Release current connection to the connection pool once you
// are
// done
post.releaseConnection();
}
LOG.info("断言：验证成功返回【ok】响应！");
Assert.assertTrue("ok".equals(res));
long end = System.currentTimeMillis();
LOG.info("验证用时（毫秒）：" + (end - start));
}
/**
* 发邮件
* @throws Exception
* @throws FileNotFoundException
*/
@Test
public void sendEmail() throws Exception {
long id = 2l;
LOG.info("开始测试发送邮件");
PostMethod post = new PostMethod(TEST_URL +"/sendMails/"+ id);
post.addRequestHeader("Accept", "application/json");
post.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, "UTF-8");
/* JSONObject jo = new JSONObject();
jo.put("subject", "周末计划");// 主题
jo.put("toMails", "aa<13>,bb<2>");// 收件人格式：姓名<userId>;姓名<userId>
jo.put("urgency", "加急");// 紧急程度
jo.put("sendDate", "2015-4-11");// 发布日期
jo.put("content", "周末购物");// 邮件内容
jo.put("mailUser", "14");// 邮件拥有者格式：userId
jo.put("sendMail", "cc<14>");// 邮件发送者格式：姓名<userId>,若只是新建，则不需要改字段
*/ // LOG.debug("设置请求参数：" + jo.toString());
JSONObject jo = new JSONObject();
RequestEntity entity = new StringRequestEntity(jo.toString(), "application/json", "UTF-8");
post.setRequestEntity(entity);
HttpClient httpclient = new HttpClient();
String res = "";
LOG.info("发送post请求");
int result = httpclient.executeMethod(post);
LOG.info(" 响应状态：" + result);
res = this.getStringFromInputStream(post.getResponseBodyAsStream());
LOG.info("响应结果：：" + res);
LOG.info("断言：");
}
// 将邮件放进回收站，是将状态改为-1
@Test
public void updateTest() throws FileNotFoundException {
LOG.info("开始测试更新");
long id = 1;
PutMethod put = new PutMethod(TEST_URL + "/" + id);
// 要上传的文件
String path = "F:\\1.doc";
String path1 = "F:\\3.doc";
long start = System.currentTimeMillis();
File file = new File(path);
File fileText = new File(path1);
String content = "{ 'content': '周末加班','sendDate': '2015-4-11','toMails': 'aa<13>,bb<2>',
'mailUser': '14','subject': '周末计划','type': '0','sendMail': '','urgency': '加急'}";
Part[] parts = { new FilePart("file", file, "application/octet-stream", "UTF-8"),
new FilePart("file", fileText, "application/octet-stream", "UTF-8"),
new StringPart("content", content, "UTF-8") };
put.addRequestHeader("Accept", "application/json");
put.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, "UTF-8");
put.setRequestEntity(new MultipartRequestEntity(parts, put.getParams()));
HttpClient httpclient = new HttpClient();
String res = "";
try {
int result = httpclient.executeMethod(put);
LOG.info("Response status code: " + result);
LOG.info("Response body: ");
res = getStringFromInputStream(put.getResponseBodyAsStream());
LOG.info(res);
} catch ( Exception e ) {
LOG.error("Error connecting to {}", TEST_URL);
Assert.fail("Connection error");
} finally {
put.releaseConnection();
}
LOG.info("断言：验证成功返回【ok】响应！");
Assert.assertTrue("ok".equals(res));
long end = System.currentTimeMillis();
LOG.info("验证用时（毫秒）：" + (end - start));
}
/**
* 根据特定的id来找到值班人员的用户信息
*/
@Test
public void findTest() {
long id = 15L;
GetMethod get = new GetMethod(TEST_URL + "/" + id);
HttpClient client = new HttpClient();
String res = "";
try {
int retCode = client.executeMethod(get);
LOG.info("响应状态 " + retCode);
res = this.getStringFromInputStream(get.getResponseBodyAsStream());
LOG.info("响应结果" + res);
} catch ( Exception e ) {
LOG.error("该url路径出错，服务未开启，请检查", TEST_URL + "/" + id);
Assert.fail("连接失败.");
} finally {
get.releaseConnection();
}
}
@Test
public void queryTest() {
LOG.info("开始测试分页查询");
GetMethod get = new GetMethod(TEST_URL + "/list");
get.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, "UTF-8");
List<NameValuePair> params = new ArrayList<NameValuePair>();
// 设置分页有信息
get.setRequestHeader("Range", "items=0-9");
JSONObject jo = new JSONObject();
LOG.debug("请求参数：：" + jo.toString());
// jo.put("mailUser", "14");
jo.put("sendDate", "2015-01-10~2015-01-13");
/*
* jo.put("type", "0"); jo.put("content","周末");
*/
// jo.put("issueDate", "2015-01-10~2015-02-24");
// jo.put("sendFileDate", "2015-01-14~2015-02-04");
// jo.put("getFileDate", "2015-01-11~2015-02-04");
// jo.put("fromUnit", "Scgovernment");
/* jo.put("issueDate", "2015-3") */
// jo.put("number","Yfp");
// jo.put("refNumber", "a11111");
// jo.put("sendUnit", "Shengbangongting");
// jo.put("title","22222");
JSONObject jb = new JSONObject();
params.add(new NameValuePair("query", jo.toString()));// 从0开始的
get.setQueryString(params.toArray(new NameValuePair[0]));
HttpClient httpClient = new HttpClient();
String res = "";
try {
int result = httpClient.executeMethod(get);
LOG.info("响应状态 " + result);
res = this.getStringFromInputStream(get.getResponseBodyAsStream());
LOG.info("响应结果 " + res);
} catch ( Exception e ) {
LOG.error("该url路径出错，服务未开启，请检查", TEST_URL);
Assert.fail("连接失败.");
} finally {
get.releaseConnection();
}
}
/**
* 测试删除周知事项
*/
@Test
public void TestDelete() {
LOG.info("开始测试删除通知");
long id = 1L;
DeleteMethod delete = new DeleteMethod(TEST_URL + "/" + id);
HttpClient client = new HttpClient();
String res = "";
try {
LOG.info("发送delete请求删除通知");
int retCode = client.executeMethod(delete);
LOG.info("响应状态：" + retCode);
res = this.getStringFromInputStream(delete.getResponseBodyAsStream());
LOG.info("响应结果: " + res);
} catch ( Exception e ) {
LOG.error("测试错误", e);
Assert.fail("连接出错");
} finally {
/* 释放url的资源 */
delete.releaseConnection();
}
LOG.info(res);
}
}

在添加一个正常的测试新增的方法：

[java] view plaincopy

@Test
public void testAdd(){
LOG.info("开始测试增加");
PostMethod post = new PostMethod(TEST_URL);
post.addRequestHeader("Accept", "application/json");
post.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET,
"UTF-8");
try {
JSONObject jo = new JSONObject();
jo.put("day", "2015-4-10");
jo.put("type", "0");
jo.put("content", "gfdz参加了2014年广东省某某某某活动");
jo.put("mainLeaderIds", "2,3");
jo.put("relevantLeaderIds", "5,6");
// date
jo.put("goverEvent", true);
jo.put("ownEvent", false);
jo.put("ownerId", "2");
LOG.debug("设置请求参数：" + jo.toString());
RequestEntity entity = new StringRequestEntity(
jo.toString(), "application/json", "UTF-8");
post.setRequestEntity(entity);
HttpClient httpclient = new HttpClient();
String res = "";
LOG.info("发送post请求");
int result = httpclient.executeMethod(post);
LOG.info(" 响应状态：" + result);
res = this.getStringFromInputStream(post.getResponseBodyAsStream());
LOG.info("响应结果：：" + res);
Assert.assertTrue(res.contains("增加值班表"));
} catch (Exception e) {
LOG.error("测试错误", e);
Assert.fail("连接出错");
} finally {
post.releaseConnection();
}
}

Java动态拼接SQL--02--Jpa相关推荐

mysql存储过参数拼接_mysql 存储过程动态拼接sql并执行赋值
CREATE DEFINER = CURRENT_USER PROCEDURE `NewProc`(in _xnb varchar(50)) BEGIN ## 定义变量 DECLARE _num FL ...
BIRT 中如何根据参数动态拼接 SQL
BIRT可以使用sql query来创建数据集,通过在报表中设置参数(Parameter)来传递客户端的用户输入,同时可以设置Dataset参数并且与报表参数关联(这两个参数是不同的),这样可以将客户 ...
java 动态拼接sql_动态SQL拼接工具类
动态SQL拼接处理工具类,为了传动态参数sql语句拼接的灵活使用.具体源代码见: 下面简单介绍下使用Demo: public static void main(String[] args) throw ...
代码中(C#)支持动态拼接SQL的参数化查询
using System; using System.Collections.Generic; using System.Text; using System.Data; using System.D ...
java动态拼接String类sql
String sql = "SELECT * from em_earmarkboxinfo ac ";//定义一个list<string>类型的集合,用来放拼接的SQL ...
MyBatis动态拼接SQL
通过使用MyBatis提供的标签方法可以实现动态SQL拼接 1.if标签 <include refid="temp_sql"></include>这里代表s ...
java动态拼接请求_在JavaWeb项目中处理静态文件或动态链接拼接网站地址的最优处理方案...
在开发网站时候我们会遇到下面问题? - 在引用网页中引用js和css或者动态的Servlet的时候我们是写绝对路径还是相对路径? - 如果写相对路径吧,上线偶尔会报404,还要手动去拼接绝对路径 - ...
excel动态拼接sql语句
需求: 根据Excel中的一个字段的值作为条件,把对应行中的其他字段插入. 例子:表A根据id更新Name =C2&B2&D2&A2&E2 表示单元格根据值& ...
java 动态报表 sql,报表SQL
--子查询方式 select r.organno,r.organname,sum(r.vrc),sum(r.psatf),sum(r.vtf),(select a.rate from tb_accra ...

Java动态拼接SQL--02--Jpa

Spring Data JPA，一种动态条件查询的写法

jpa动态查询语句

Java动态拼接SQL--02--Jpa相关推荐

最新文章

热门文章