JPA dynamic query statement (detailed code explanation)
- 烟雨青岚forward
- 2020-06-18 13:13:173634browse
JPA动态查询语句 （代码详解）
我们现在在做一个OA系统，将新增的那些数据都写到数据库的时候是采用jpa规范的，（不太理解jpa的相关知识点，今天看下相关知识，然后再补充jpa的知识点），现在记录jpa中的动态查询语句，其实这些语句都是可以用sql语句写的，但是sql语句写得查询，删除，插入数据等操作不安全，所以采用jpa的语句。我们的项目是分为三层结构，第一层是实体层，在该层中专门定义某一实体的相关字段，它的set()，get()方法。第二层是服务层，将service和dao都放在一个组件中,在dao层中定义和数据库相关的操作方法，在service层中定义相关的业务逻辑层要调用的方法。第三层是restful层，在这层定义的是和前端交互的组件。
首先讲讲第一层：实体层
定义一个实体
/**
* 邮件实体
*
*/
@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;
}
}定义查询实体：
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层：定义和数据库相关操作的方法
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);
}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的小于给定值的数据
第一种写法：（安全，推荐使用这种）
/**
* 查询某一级别以上的用户
*/
@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();
}第二种写法：(不太安全，)
/**
* 查询某一级别以上的用户
*/
@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;
}第二种删除数据（有时候会由于某实体和另一实体设置了一对一或者多对一，或者多对多的关系而导致不能正常删除数据），解决方法：
/**
* 删除登记信息
*
* @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层：接口
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层:实现类
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);
}
}在服务层中定义相关的服务配置
<?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. --> <!-- dao --> <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 --> <bean id="mailService" class="com.gzydt.oa.service.impl.InnerMailServiceImpl"> <property name="mailDao" ref="mailDao" /> </bean> <!--新增结束 --> <!-- service --> <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层
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);
}实现类：
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层的配置文件：
<?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> <!-- implements OAuthDataProvider --> <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> <!-- <cxf:bus> <cxf:features> <cxf:logging /> </cxf:features> </cxf:bus> --> <!-- 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 --> <bean id="mailRestService" class="com.gzydt.oa.resource.impl.InnerMailsResourceImpl"> <property name="emailService" ref="emailService" /> <property name="appendFileService" ref="appendFileService" /> </bean> <!--添加bean结束 --> <reference id="emailService" interface="com.gzydt.oa.service.InnerMailService" /> <!--添加reference结束 --> </blueprint>
解析前端传来的参数：
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();
}
}
}内部邮件的测试类：
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);
}
}在添加一个正常的测试新增的方法：
@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();
}
}感谢大家的阅读，希望大家收益多多。
本文转自： http://community.itbbs.cn/thread/758207/
推荐教程：《java视频教程》
The above is the detailed content of JPA dynamic query statement (detailed code explanation). For more information, please follow other related articles on the PHP Chinese website!
Statement：
This article is reproduced at:itbbs.cn. If there is any infringement, please contact admin@php.cn delete
Previous article：Introduction to Java callback mechanismNext article：Introduction to Java callback mechanism