学步园

EMF.java

/**<br /> *<br /> */<br /> package com.mwdoor.common.jpa;<br /> import javax.persistence.EntityManagerFactory;<br /> import javax.persistence.Persistence;<br /> /**<br /> * @author scott.Cgi<br /> * @since 2009-5-31<br /> * 实体管理类工厂,手动利用这个静态类获得entityManagerFactory当要自己管理事务<br /> */<br /> public final class EMF {<br /> private static final EntityManagerFactory emfInstance =<br /> Persistence.createEntityManagerFactory("transactions-optional");<br /> private EMF() {}<br /> public static EntityManagerFactory get() {<br /> return emfInstance;<br /> }<br /> }<br />

IJpaDao.java

/**<br /> *<br /> */<br /> package com.mwdoor.common.jpa;<br /> import java.util.List;<br /> import javax.persistence.EntityManager;<br /> /**<br /> * @author scott.Cgi<br /> * @since 2009-6-1<br /> */<br /> public interface IJpaDao {</p> <p> /**<br /> * 新实体转换为受控状态,事务提交时候同步数据库<br /> * @param entity<br /> */<br /> void persist(Object entity);</p> <p> /**<br /> * 批量持久化实体<br /> * @param entitys<br /> */<br /> void batchPersist(List<Object> entitys);</p> <p> /**<br /> * 删除受控(拥有持久化主键和上下文)实体<br /> * @param entity<br /> */<br /> void remove(Object entity);</p> <p> /**<br /> * 批量删除<br /> * @param entitys<br /> */<br /> void batchRemove(List<Object> entitys);</p> <p> /**<br /> * 游离态(拥有持久化主键没有上下文)实体同步数据库<br /> * @param <T><br /> * @param entity<br /> * @return<br /> */<br /> <T> T merge(T entity);</p> <p> /**<br /> * 以主键值查找实体<br /> * @param <T><br /> * @param entityClass<br /> * @param pk 主键<br /> * @return<br /> */<br /> <T> T findById(Class<T> entityClass,Object pk);</p> <p> /**<br /> * 根据主键删除数据<br /> * @param <T><br /> * @param entityClass<br /> * @param pk 主键<br /> */<br /> <T> void removeById(Class<T> entityClass,Object pk);</p> <p> /**<br /> * @param <T><br /> * @param query JPA查询语句(注意google app的限制)<br /> * @return<br /> */<br /> <T> List<T> find(String query);</p> <p> /**<br /> * 计算行数<br /> * @param sql<br /> * @return<br /> */<br /> int countRows(String countSql);</p> <p> /**<br /> * 新增或删除或更新<br /> * @param updateSql<br /> * @return 影响行数<br /> */<br /> int executeUpdate(String updateSql);</p> <p> /**<br /> * @param <T><br /> * @param countSql 查询函数的count查询语句<br /> * @param sql 查询语句<br /> * @param pageNo 页面号(从1开始)<br /> * @param pageSize (分页大小)<br /> * @return<br /> */<br /> public <T> Page<T> pageQuery(String countSql,String sql,int pageNo,int pageSize);</p> <p> public EntityManager getEM();</p> <p>}<br />

JpaDao.java

/**<br /> *<br /> */<br /> package com.mwdoor.common.jpa;<br /> import java.util.List;<br /> import javax.persistence.EntityManager;<br /> import javax.persistence.Query;<br /> /**<br /> * @author scott.Cgi<br /> * @since 2009-5-31<br /> */<br /> public class JpaDao implements IJpaDao{</p> <p> public <T> T findById(Class<T> entityClass, Object pk) {<br /> EntityManager em = this.getEM();<br /> try{<br /> return em.find(entityClass, pk);<br /> }finally{<br /> em.close();<br /> }</p> <p> }<br /> public <T> T merge(T entity) {<br /> EntityManager em = this.getEM();<br /> try{<br /> return em.merge(entity);<br /> }finally{<br /> em.close();<br /> }<br /> }<br /> public void persist(Object entity) {<br /> EntityManager em = this.getEM();<br /> try{<br /> em.persist(entity);<br /> }finally{<br /> em.close();<br /> }</p> <p> }<br /> public void remove(Object entity) {<br /> EntityManager em = this.getEM();<br /> try{<br /> em.remove(entity);<br /> }finally{<br /> em.close();<br /> }</p> <p> }</p> <p> /**<br /> * 通过EMF获得entityManager实例<br /> * @return<br /> */<br /> public EntityManager getEM(){<br /> return EMF.get().createEntityManager();<br /> }<br /> @Override<br /> public <T> void removeById(Class<T> entityClass, Object pk) {<br /> EntityManager em = this.getEM();<br /> try{<br /> T t = em.find(entityClass, pk);<br /> em.remove(t);<br /> }finally{<br /> em.close();<br /> }<br /> }<br /> @SuppressWarnings("unchecked")<br /> @Override<br /> public <T> List<T> find(String query) {<br /> EntityManager em = this.getEM();<br /> try{<br /> List<T> l = em.createQuery(query).getResultList();<br /> //强制获取所有对象在em close前<br /> l.size();<br /> return l;<br /> }finally{<br /> em.close();<br /> }<br /> }</p> <p> @Override<br /> public int countRows(String countSql) {<br /> EntityManager em = this.getEM();<br /> try{<br /> return (Integer)em.createQuery(countSql).getSingleResult();<br /> }finally{<br /> em.close();<br /> }<br /> }<br /> @Override<br /> public void batchPersist(List<Object> entitys) {<br /> EntityManager em = this.getEM();<br /> try{<br /> for(Object o : entitys)<br /> this.persist(o);<br /> }finally{<br /> em.close();<br /> }</p> <p> }<br /> @Override<br /> public void batchRemove(List<Object> entitys) {<br /> EntityManager em = this.getEM();<br /> try{<br /> for(Object o : entitys)<br /> this.remove(o);<br /> }finally{<br /> em.close();<br /> }<br /> }<br /> @Override<br /> public int executeUpdate(String updateSql) {<br /> EntityManager em = this.getEM();<br /> try{<br /> return em.createQuery(updateSql).executeUpdate();<br /> }finally{<br /> em.close();<br /> }<br /> }<br /> @SuppressWarnings("unchecked")<br /> @Override</p> <p> public <T> Page<T> pageQuery(String countSql,String sql, int pageNo, int pageSize) {<br /> EntityManager em = this.getEM();<br /> try{<br /> int totalCount = this.countRows(countSql);</p> <p> //没有数据返回空page<br /> if (totalCount < 1)<br /> return new Page<T>();<br /> // 当前页的开始数据索引<br /> Long startIndex = Page.getStartOfPage(pageNo, pageSize);</p> <p> Query query = em.createQuery(sql);<br /> List<T> l = query.setFirstResult(startIndex.intValue()).setMaxResults(pageSize).getResultList();<br /> l.size();</p> <p> return new Page(startIndex,totalCount,pageSize,l);<br /> }finally{<br /> em.close();<br /> }<br /> }<br /> }<br />

Page.java

package com.mwdoor.common.jpa;<br /> import java.io.Serializable;<br /> import java.util.Collections;<br /> import java.util.List;<br /> /**<br /> * 分页对象.包含当前页数据及分页信息如总记录数.<br /> *<br /> * @author scott.Cgi<br /> * @since 2008-6-29<br /> */<br /> public class Page<T> implements Serializable {<br /> private static final long serialVersionUID = -5624189033006412710L;<br /> private static long DEFAULT_PAGE_SIZE = 20;<br /> private long pageSize = DEFAULT_PAGE_SIZE; // 每页的记录数<br /> private long start; // 当前页第一条数据在List中的位置,从0开始<br /> private List<T> data = Collections.emptyList(); // 当前页中存放的记录<br /> private long totalCount = 0; // 总记录数<br /> /**<br /> * 构造方法，只构造空页.<br /> */<br /> public Page() {<br /> this(0l, 0l, DEFAULT_PAGE_SIZE, Collections.<T>emptyList());<br /> }<br /> /**<br /> * 默认构造方法.<br /> *<br /> * @param start 本页数据在数据库中的起始位置<br /> * @param totalSize 数据库中总记录条数<br /> * @param pageSize 本页容量<br /> * @param data 本页包含的数据<br /> */<br /> public Page(long start, long totalSize, long pageSize, List<T> data) {<br /> this.pageSize = pageSize;<br /> this.start = start;<br /> this.totalCount = totalSize;<br /> this.data = data;<br /> }<br /> /**<br /> * 取总记录数.<br /> */<br /> public long getTotalCount() {<br /> return this.totalCount;<br /> }<br /> /**<br /> * 取总页数.<br /> */<br /> public long getTotalPageCount() {<br /> if (totalCount % pageSize == 0)<br /> return totalCount / pageSize;<br /> else<br /> return totalCount / pageSize + 1;<br /> }<br /> /**<br /> * 取每页数据容量.<br /> */<br /> public Long getPageSize() {<br /> return pageSize;<br /> }<br /> /**<br /> * 取当前页中的记录.<br /> */<br /> public List<T> getResult() {<br /> return data;<br /> }<br /> /**<br /> * 取该页当前页码,页码从1开始.<br /> */<br /> public long getCurrentPageNo() {<br /> return start / pageSize + 1;<br /> }<br /> /**<br /> * 该页是否有下一页.<br /> */<br /> public boolean hasNextPage() {<br /> return this.getCurrentPageNo() < this.getTotalPageCount();<br /> }<br /> /**<br /> * 该页是否有上一页.<br /> */<br /> public boolean hasPreviousPage() {<br /> return this.getCurrentPageNo() > 1;<br /> }<br /> /**<br /> * 获取任一页第一条数据在数据集的位置，每页条数使用默认值.<br /> *<br /> */<br /> protected static long getStartOfPage(long pageNo) {<br /> return getStartOfPage(pageNo, DEFAULT_PAGE_SIZE);<br /> }<br /> /**<br /> * 获取任一页第一条数据在数据集的位置.<br /> *<br /> * @param pageNo 从1开始的页号<br /> * @param pageSize 每页记录条数<br /> * @return 该页第一条数据<br /> */<br /> public static long getStartOfPage(long pageNo, long pageSize) {<br /> return (pageNo - 1) * pageSize;<br /> }<br /> }

我用这个dao做的一个google app的小测试，感觉google app速度就是不照。

http://mwdoor.appspot.com