首页 > 代码库 > 【Java 新建项目】使用程序对新项目的各个实体 创建Dao、DaoImpl、Service、ServiceImpl层的文件
【Java 新建项目】使用程序对新项目的各个实体 创建Dao、DaoImpl、Service、ServiceImpl层的文件
首先给出基本Dao层代码：
GenericDao.java
1 package com.agen.dao; 2 3 import java.io.Serializable; 4 import java.util.Collection; 5 import java.util.List; 6 import java.util.Map; 7 8 import org.hibernate.Criteria; 9 import org.hibernate.criterion.Criterion; 10 import org.hibernate.criterion.DetachedCriteria; 11 12 import com.github.pagehelper.PageInfo; 13 14 15 public interface GenericDao<T, PK extends Serializable> { 16 /** 17 * 查询全部，可以排序 18 * @param orderBy 19 * @param isAsc 20 * @return List<T> 21 */ 22 public List<T> list(Criteria criteria); 23 24 /** 25 * 查询全部，可以排序 26 * @param orderBy 27 * @param isAsc 28 * @return List<T> 29 */ 30 public List<T> list(String orderBy, boolean isAsc); 31 32 /** 33 * 离线查询 34 * @param criteria 35 * @return List<T> 36 */ 37 public List<T> list(DetachedCriteria criteria); 38 39 /** 40 * 根据Criteria查询条件，获取总数 41 * @param criteria 42 * @return int 43 * @throws SecurityException 44 * @throws NoSuchFieldException 45 * @throws IllegalAccessException 46 * @throws IllegalArgumentException 47 */ 48 public int countAll(Criteria criteria); 49 50 /** 51 * 获取总数(默认为entityClass) 即查询总条数 52 * @return int 53 */ 54 public int countAll(); 55 56 /** 57 * 根据I判断是否存在 58 * @param id 59 * @return boolean 60 */ 61 public boolean exists(PK id); 62 63 /** 64 * 保存实体 65 * @param t 实体参数 66 */ 67 public void save(T t); 68 69 /** 70 * 保存或者更新实体 71 * @param t 实体 72 */ 73 public void saveOrUpdate(T t); 74 75 /** 76 * 加载实体的通过load方法 77 * @param id 实体的id 78 * @return 查询出来的实体 79 */ 80 public T load(PK id); 81 82 /** 83 * 合并实体 84 * @param entity 85 */ 86 public void merge(T entity); 87 88 /** 89 * 查找全部 90 */ 91 public List<T> findAll(); 92 93 /** 94 * 通过get方法加载实体的 95 * @param id 实体的id 96 * @return 查询出来的实体 97 */ 98 public T get(PK id); 99 100 /** 101 * contains 102 * @param t 实体 103 * @return 是否包含 104 */ 105 public boolean contains(T t); 106 107 /** 108 * delete 109 * @param t 110 * 删除实体 111 */ 112 public void delete(T t); 113 114 /** 115 * 根据ID删除数据 116 * @param Id 实体id 117 * @return 是否删除成功 118 */ 119 public boolean deleteById(PK Id); 120 121 /** 122 * 删除所有 123 * @param entities 实体的Collection集合 124 */ 125 public void deleteAll(Collection<T> entities); 126 127 /** 128 * 执行Hql语句 要求 hql中参数顺序与可变参数 中参数顺序相一致 129 * @param hqlString hql 130 * @param values 不定参数数组 131 */ 132 public void queryHql(String hqlString, Object... values); 133 134 /** 135 * 执行Sql语句(不建议用，影响扩展) 136 * @param sqlString sql 137 * @param values 不定参数数组 138 */ 139 public void querySql(String sqlString, Object... values); 140 141 /** 142 * 根据HQL语句查找唯一实体 143 * 144 * @param hqlString HQL语句 145 * @param values 不定参数的Object数组 146 * @return 查询实体 147 */ 148 public T getByHQL(String hqlString, Object... values); 149 150 /** 151 * 根据SQL语句查找唯一实体（不建议用，影响扩展） 152 * @param sqlString SQL语句 153 * @param values 不定参数的Object数组 154 * @return 查询实体 155 */ 156 157 /** 158 * 根据HQL语句，得到对应的list 159 * @param hqlString HQL语句 160 * @param values 不定参数的Object数组 161 * @return 查询多个实体的List集合 162 */ 163 public List<T> getListByHQL(String hqlString, Object... values); 164 165 /** 166 * 根据SQL语句，得到对应的list（不建议用，影响扩展） 167 * @param sqlString HQL语句 168 * @param values 不定参数的Object数组 169 * @return 查询多个实体的List集合 170 */ 171 public List<T> getListBySQL(String sqlString, Object... values); 172 173 /** 174 * refresh 刷新实体，强制与数据库两步 refresh方法应该是数据库的数据更新到本地的person实体中，而不是本地person更新数据到数据库中 也就是执行refresh方法是更新了java代码中变量的数据值 175 * @param t 实体 176 */ 177 public void refresh(T t); 178 179 /** 180 * update 181 * @param t 182 * 更新的是数据库中的数据 183 */ 184 public void update(T t); 185 186 /** 187 * 根据HQL得到记录数 188 * @param hql HQL语句 189 * @param values 不定参数的Object数组 190 * @return 记录总数 191 */ 192 public Long countByHql(String hql, Object... values); 193 194 /** 195 * HQL分页查询 196 * 197 * @param hql HQL语句 198 * @param countHql 查询记录条数的HQL语句 199 * @param pageNo 下一页 200 * @param pageSize 一页总条数 201 * @param values 不定Object数组参数 202 * @return PageResults的封装类，里面包含了页码的信息以及查询的数据List集合 203 */ 204 public PageInfo<T> findPageByHql(String hql, String countHql, int pageNo, int pageSize, Object... values); 205 206 /** 207 * 按属性查找对象列表，匹配方式为相等 208 * @param propertyName 209 * @param value 210 * @return List<T> 211 */ 212 public List<T> list(String propertyName, Object value); 213 214 /** 215 * 根据criterion查询条件获取数据列表 216 * @param criterion 217 * @return List<T> 218 */ 219 public List<T> list(Criterion criterion); 220 221 /** 222 * 按Criteria查询对象列表 223 * @param criterions 224 * @return List<T> 225 */ 226 public List<T> list(Criterion... criterions); 227 228 /** 229 * 按属性查找唯一对象，匹配方式为相等 230 * @param propertyName 231 * @param value 232 * @return T 233 */ 234 public T uniqueResult(String propertyName, Object value); 235 236 /** 237 * 按Criteria查询唯一对象 238 * @param criterions 239 * @return T 240 */ 241 public T uniqueResult(Criterion... criterions); 242 243 /** 244 * 按Criteria查询唯一对象 245 * @param criteria 246 * @return T 247 */ 248 public T uniqueResult(Criteria criteria); 249 250 /** 251 * 按criteria查询某个Integer类型的字段 252 * @param criteria 253 * @return 254 */ 255 public Integer uniqueResultInt(Criteria criteria); 256 257 /** 258 * 为Criteria添加distinct transformer 259 * @param criteria 260 * @return Criteria 261 */ 262 public Criteria distinct(Criteria criteria); 263 264 /** 265 * 刷新session 266 */ 267 public void flush(); 268 269 /** 270 * 清空session 271 */ 272 public void clear(); 273 274 /** 275 * 创建Criteria实例 276 */ 277 public Criteria createCriteria(); 278 279 /** 280 * 根据Criterion条件创建Criteria 281 * @param criterions 282 * @return Criteria 283 */ 284 public Criteria createCriteria(Criterion... criterions); 285 286 /** 287 * 分页查询Criteria 288 * @param criteria 289 * @param pageNo 下页页码 290 * @param pageSize 页面数据量 291 * @return List<T> 292 */ 293 public List<T> findPage(Criteria criteria, int pageNo, int pageSize); 294 295 /** 296 * 分页查询Criteria 297 * @param criteria 298 * @param pageNo 299 * @param pageSize 300 * @return PageInfo<T> 301 * @throws SecurityException 302 * @throws NoSuchFieldException 303 * @throws IllegalAccessException 304 * @throws IllegalArgumentException 305 */ 306 public PageInfo<T> findQuery(Criteria criteria, int pageNo, int pageSize); 307 308 /** 309 * 310 * @param hql 311 * @param pageNo 312 * @param pageSize 313 * @param map 314 * @return List<T> 315 */ 316 public List<T> findQuery(String hql, int pageNo, int pageSize, Map<?, ?> map); 317 }
GenericDaoImpl.java
1 package com.agen.dao.impl; 2 3 import java.io.Serializable; 4 import java.lang.reflect.Field; 5 import java.util.ArrayList; 6 import java.util.Collection; 7 import java.util.List; 8 import java.util.Map; 9 import java.util.Map.Entry; 10 11 import org.hibernate.Criteria; 12 import org.hibernate.Query; 13 import org.hibernate.QueryException; 14 import org.hibernate.ScrollableResults; 15 import org.hibernate.Session; 16 import org.hibernate.SessionFactory; 17 import org.hibernate.criterion.CriteriaSpecification; 18 import org.hibernate.criterion.Criterion; 19 import org.hibernate.criterion.DetachedCriteria; 20 import org.hibernate.criterion.Order; 21 import org.hibernate.criterion.Projections; 22 import org.hibernate.criterion.Restrictions; 23 import org.hibernate.internal.CriteriaImpl; 24 import org.hibernate.internal.CriteriaImpl.Subcriteria; 25 import org.springframework.beans.factory.annotation.Autowired; 26 import org.springframework.transaction.annotation.Transactional; 27 import org.springframework.util.Assert; 28 29 import java.lang.reflect.ParameterizedType; 30 31 import com.agen.dao.GenericDao; 32 import com.github.pagehelper.PageInfo; 33 34 public class GenericDaoImpl<T, PK extends Serializable> implements GenericDao<T, PK> { 35 /** 36 * 不建议直接使用 37 */ 38 @Autowired 39 private SessionFactory sessionFactory; 40 41 public Session getSession() { 42 // 需要开启事物，才能得到CurrentSession 43 return sessionFactory.getCurrentSession(); 44 } 45 46 47 protected Class<T> entityClass; 48 49 protected Class getEntityClass() { 50 if (entityClass == null) { 51 if(((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments().length > 0) { 52 entityClass = (Class<T>) ((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0]; 53 } 54 } 55 return entityClass; 56 } 57 58 public SessionFactory getSessionFactory() { 59 return sessionFactory; 60 } 61 62 public void setSessionFactory(SessionFactory sessionFactory) { 63 this.sessionFactory = sessionFactory; 64 } 65 66 @Override 67 public Criteria createCriteria() { 68 return getSession().createCriteria(getEntityClass()); 69 } 70 71 72 @Override 73 public void save(T t) { 74 this.getSession().save(t); 75 } 76 77 @Override 78 public void saveOrUpdate(T t) { 79 Assert.notNull(t); 80 this.getSession().saveOrUpdate(t); 81 } 82 83 @Override 84 public T load(PK id) { 85 Assert.notNull(id); 86 T load = (T) this.getSession().load(getEntityClass(), id); 87 return load; 88 } 89 90 @Override 91 public T get(PK id) { 92 Assert.notNull(id); 93 T load = (T) this.getSession().get(getEntityClass(), id); 94 return load; 95 } 96 97 @Override 98 public boolean contains(T t) { 99 Assert.notNull(t); 100 return this.getSession().contains(t); 101 } 102 103 @Override 104 public void delete(T t) { 105 Assert.notNull(t); 106 this.getSession().delete(t); 107 } 108 109 @Override 110 public boolean deleteById(PK Id) { 111 Assert.notNull(Id); 112 T t = get(Id); 113 if (t == null) return false; 114 delete(t); 115 return true; 116 } 117 118 @Override 119 public void deleteAll(Collection<T> entities) { 120 Assert.notNull(entities); 121 for (Object entity : entities) { 122 this.getSession().delete(entity); 123 } 124 } 125 126 @Override 127 public void queryHql(String hqlString, Object... values) { 128 Query query = this.getSession().createQuery(hqlString); 129 if (values != null) { 130 for (int i = 0; i < values.length; i++) { 131 query.setParameter(i, values[i]); 132 } 133 } 134 query.executeUpdate(); 135 } 136 137 /** 138 * 根据hql 和 map集合中的数据 进行相对应的 insert update delete操作 139 * @param hqlString 140 * @param paras 141 */ 142 public void queryHql(String hqlString, Map<String, Object> paras) { 143 Query query = this.getSession().createQuery(hqlString); 144 if (paras != null) { 145 for (Entry<String, Object> en : paras.entrySet()) { 146 query.setParameter(en.getKey(), en.getValue()); 147 } 148 } 149 query.executeUpdate(); 150 } 151 152 @Override 153 public void querySql(String sqlString, Object... values) { 154 Query query = this.getSession().createSQLQuery(sqlString); 155 if (values != null) { 156 for (int i = 0; i < values.length; i++) { 157 query.setParameter(i, values[i]); 158 } 159 } 160 query.executeUpdate(); 161 } 162 163 @Override 164 public T getByHQL(String hqlString, Object... values) { 165 Query query = this.getSession().createQuery(hqlString); 166 if (values != null) { 167 for (int i = 0; i < values.length; i++) { 168 query.setParameter(i, values[i]); 169 } 170 } 171 return (T) query.uniqueResult(); 172 } 173 174 @Override 175 public List<T> getListByHQL(String hqlString, Object... values) { 176 Query query = this.getSession().createQuery(hqlString); 177 if (values != null) { 178 for (int i = 0; i < values.length; i++) { 179 query.setParameter(i, values[i]); 180 } 181 } 182 return query.list(); 183 } 184 185 @Override 186 public List<T> getListBySQL(String sqlString, Object... values) { 187 Query query = this.getSession().createSQLQuery(sqlString); 188 if (values != null) { 189 for (int i = 0; i < values.length; i++) { 190 query.setParameter(i, values[i]); 191 } 192 } 193 return query.list(); 194 } 195 196 @Override 197 public void refresh(T t) { 198 this.getSession().refresh(t); 199 } 200 201 @Override 202 public void update(T t) { 203 this.getSession().update(t); 204 } 205 206 @Override 207 public Long countByHql(String hql, Object... values) { 208 Query query = this.getSession().createQuery(hql); 209 if (values != null) { 210 for (int i = 0; i < values.length; i++) { 211 query.setParameter(i, values[i]); 212 } 213 } 214 return (Long) query.uniqueResult(); 215 } 216 217 @Override 218 public PageInfo<T> findPageByHql(String hql, String countHql, int pageNo, int pageSize, Object... values) { 219 PageInfo<T> retValue = http://www.mamicode.com/new PageInfo<T>(); 220 Query query = this.getSession().createQuery(hql); 221 if (values != null) { 222 for (int i = 0; i < values.length; i++) { 223 query.setParameter(i, values[i]); 224 } 225 } 226 int currentPage = pageNo > 1 ? pageNo : 1; 227 retValue.setPages(currentPage); 228 retValue.setPageSize(pageSize); 229 if (countHql == null) { 230 ScrollableResults results = query.scroll(); 231 results.last(); 232 retValue.setTotal(results.getRowNumber() + 1); 233 } else { 234 Long count = countByHql(countHql, values); 235 retValue.setTotal(count.intValue()); 236 } 237 List<T> itemList = query.setFirstResult((currentPage - 1) * pageSize).setMaxResults(pageSize).list(); 238 if (itemList == null) { 239 itemList = new ArrayList<T>(); 240 } 241 retValue.setList(itemList); 242 return retValue; 243 } 244 245 246 @Override 247 public void merge(T entity) { 248 // TODO Auto-generated method stub 249 getSession().merge(entity); 250 } 251 252 @Override 253 public boolean exists(PK id) { 254 return null != get(id); 255 } 256 257 @Override 258 public int countAll() { 259 Criteria criteria = createCriteria(); 260 return Integer.valueOf(criteria.setProjection(Projections.rowCount()).uniqueResult().toString()); 261 } 262 263 @Override 264 public int countAll(Criteria criteria) { 265 criteria.setProjection(null); 266 return Integer.valueOf(criteria.setProjection(Projections.rowCount()).uniqueResult().toString()); 267 } 268 269 @Override 270 public List<T> list(Criteria criteria) { 271 return criteria.list(); 272 } 273 274 @Override 275 public List<T> list(DetachedCriteria criteria) { 276 return (List<T>) list(criteria.getExecutableCriteria(getSession())); 277 } 278 279 @Override 280 public List<T> list(String orderBy, boolean isAsc) { 281 Criteria criteria = createCriteria(); 282 if (isAsc) { 283 criteria.addOrder(Order.asc(orderBy)); 284 } else { 285 criteria.addOrder(Order.desc(orderBy)); 286 } 287 return criteria.list(); 288 } 289 290 @Override 291 public List<T> list(String propertyName, Object value) { 292 Criterion criterion = Restrictions.like(propertyName, "%"+ value +"%"); 293 return list(criterion); 294 } 295 296 297 @Override 298 public List<T> list(Criterion criterion) { 299 Criteria criteria = createCriteria(); 300 criteria.add(criterion); 301 return criteria.list(); 302 } 303 304 @Override 305 public List<T> list(Criterion... criterions) { 306 return createCriteria(criterions).list(); 307 } 308 309 @Override 310 public T uniqueResult(String propertyName, Object value) { 311 Criterion criterion = Restrictions.eq(propertyName, value); 312 return (T) createCriteria(criterion).uniqueResult(); 313 } 314 315 @Override 316 public T uniqueResult(Criterion... criterions) { 317 Criteria criteria = createCriteria(criterions); 318 return uniqueResult(criteria); 319 } 320 321 @Override 322 public T uniqueResult(Criteria criteria) { 323 return (T) criteria.uniqueResult(); 324 } 325 326 @Override 327 public Integer uniqueResultInt(Criteria criteria) { 328 return (Integer) criteria.uniqueResult(); 329 } 330 331 332 @Override 333 public Criteria distinct(Criteria criteria) { 334 criteria.setResultTransformer(CriteriaSpecification.DISTINCT_ROOT_ENTITY); 335 return criteria; 336 } 337 338 @Override 339 public void flush() { 340 getSession().flush(); 341 } 342 343 @Override 344 public void clear() { 345 getSession().clear(); 346 } 347 348 349 @Override 350 public Criteria createCriteria(Criterion... criterions) { 351 Criteria criteria = createCriteria(); 352 for (Criterion c : criterions) { 353 criteria.add(c); 354 } 355 return criteria; 356 } 357 358 @Override 359 public List<T> findPage(Criteria criteria, int pageNo, int pageSize) { 360 criteria.setFirstResult((pageNo - 1) * pageSize); 361 criteria.setMaxResults(pageSize); 362 return list(criteria); 363 } 364 365 @Override 366 public PageInfo<T> findQuery(Criteria criteria, int pageNo, int pageSize) { 367 try { 368 Assert.isTrue(pageNo >= 1, "pageNO should start from 1"); 369 while(criteria instanceof Subcriteria){ 370 criteria = ((Subcriteria)criteria).getParent(); 371 } 372 //拆分order by子句 373 while(criteria instanceof Subcriteria){ 374 criteria = ((Subcriteria)criteria).getParent(); 375 } 376 Field field = CriteriaImpl.class.getDeclaredField("orderEntries"); 377 field.setAccessible(true); 378 List<?> orderEntrys = (List<?>) field.get(criteria); 379 field.set(criteria, new ArrayList()); 380 //统计总数 381 long totalCount = countAll(criteria); 382 criteria.setProjection(null); 383 //统计完了再把order by子句加上 这样保证了sql语句不会出错 384 field.set(criteria, orderEntrys); 385 List<T> list = findPage(criteria, pageNo, pageSize); 386 if (totalCount < 1) { 387 return new PageInfo<T>(); 388 } 389 PageInfo<T> page = new PageInfo<T>(); 390 page.setPageNum(pageNo); 391 page.setTotal(totalCount); 392 page.setPages((int) (totalCount % pageSize == 0 ? totalCount / pageSize : totalCount / pageSize + 1)); 393 page.setPageSize(pageSize); 394 page.setList(list); 395 return page; 396 } catch (Exception e) { 397 // TODO: handle exception 398 e.printStackTrace(); 399 throw new QueryException("查询出错！"); 400 } 401 402 } 403 404 @Override 405 public List<T> findQuery(String hql, int pageNo, int pageSize, Map<?, ?> map) { 406 // TODO Auto-generated method stub 407 if(null == hql) return null; 408 Query query = getSession().createQuery(hql); 409 for (Entry<?, ?> en : map.entrySet()) { 410 query.setParameter(en.getKey().toString(), en.getValue()); 411 } 412 if(pageNo > 0) query.setFirstResult(pageNo); 413 if(pageSize > 0) query.setFirstResult(pageSize); 414 return query.list(); 415 } 416 417 @Override 418 public List<T> findAll() { 419 // TODO Auto-generated method stub 420 return createCriteria().list(); 421 } 422 }
GenericService.java
1 package com.agen.service; 2 3 import java.io.Serializable; 4 import java.util.Collection; 5 import java.util.List; 6 import java.util.Map; 7 8 import org.hibernate.Criteria; 9 import org.hibernate.criterion.Criterion; 10 import org.hibernate.criterion.DetachedCriteria; 11 12 import com.github.pagehelper.PageInfo; 13 14 public interface GenericService<T, PK extends Serializable> { 15 /** 16 * 查询全部，可以排序 17 * @param orderBy 18 * @param isAsc 19 * @return List<T> 20 */ 21 public List<T> list(Criteria criteria); 22 23 /** 24 * 查询全部，可以排序 25 * @param orderBy 26 * @param isAsc 27 * @return List<T> 28 */ 29 public List<T> list(String orderBy, boolean isAsc); 30 31 /** 32 * 离线查询 33 * @param criteria 34 * @return List<T> 35 */ 36 public List<T> list(DetachedCriteria criteria); 37 38 /** 39 * 根据Criteria查询条件，获取总数 40 * @param criteria 41 * @return int 42 * @throws SecurityException 43 * @throws NoSuchFieldException 44 * @throws IllegalAccessException 45 * @throws IllegalArgumentException 46 */ 47 public int countAll(Criteria criteria); 48 49 /** 50 * 获取总数(默认为entityClass) 即查询总条数 51 * @return int 52 */ 53 public int countAll(); 54 55 /** 56 * 根据I判断是否存在 57 * @param id 58 * @return boolean 59 */ 60 public boolean exists(PK id); 61 62 /** 63 * 保存实体 64 * @param t 实体参数 65 */ 66 public void save(T t); 67 68 /** 69 * 保存或者更新实体 70 * @param t 实体 71 */ 72 public void saveOrUpdate(T t); 73 74 /** 75 * 加载实体的通过load方法 76 * @param id 实体的id 77 * @return 查询出来的实体 78 */ 79 public T load(PK id); 80 81 /** 82 * 合并实体 83 * @param entity 84 */ 85 public void merge(T entity); 86 87 /** 88 * 查找全部 89 */ 90 public List<T> findAll(); 91 92 /** 93 * 通过get方法加载实体的 94 * @param id 实体的id 95 * @return 查询出来的实体 96 */ 97 public T get(PK id); 98 99 /** 100 * contains 101 * @param t 实体 102 * @return 是否包含 103 */ 104 public boolean contains(T t); 105 106 /** 107 * delete 108 * @param t 109 * 删除实体 110 */ 111 public void delete(T t); 112 113 /** 114 * 根据ID删除数据 115 * @param Id 实体id 116 * @return 是否删除成功 117 */ 118 public boolean deleteById(PK Id); 119 120 /** 121 * 删除所有 122 * @param entities 实体的Collection集合 123 */ 124 public void deleteAll(Collection<T> entities); 125 126 /** 127 * 执行Hql语句 要求 hql中参数顺序与可变参数 中参数顺序相一致 128 * @param hqlString hql 129 * @param values 不定参数数组 130 */ 131 public void queryHql(String hqlString, Object... values); 132 133 /** 134 * 执行Sql语句(不建议用，影响扩展) 135 * @param sqlString sql 136 * @param values 不定参数数组 137 */ 138 public void querySql(String sqlString, Object... values); 139 140 /** 141 * 根据HQL语句查找唯一实体 142 * 143 * @param hqlString HQL语句 144 * @param values 不定参数的Object数组 145 * @return 查询实体 146 */ 147 public T getByHQL(String hqlString, Object... values); 148 149 /** 150 * 根据SQL语句查找唯一实体（不建议用，影响扩展） 151 * @param sqlString SQL语句 152 * @param values 不定参数的Object数组 153 * @return 查询实体 154 */ 155 156 /** 157 * 根据HQL语句，得到对应的list 158 * @param hqlString HQL语句 159 * @param values 不定参数的Object数组 160 * @return 查询多个实体的List集合 161 */ 162 public List<T> getListByHQL(String hqlString, Object... values); 163 164 /** 165 * 根据SQL语句，得到对应的list（不建议用，影响扩展） 166 * @param sqlString HQL语句 167 * @param values 不定参数的Object数组 168 * @return 查询多个实体的List集合 169 */ 170 public List<T> getListBySQL(String sqlString, Object... values); 171 172 /** 173 * refresh 刷新实体，强制与数据库两步 refresh方法应该是数据库的数据更新到本地的person实体中，而不是本地person更新数据到数据库中 也就是执行refresh方法是更新了java代码中变量的数据值 174 * @param t 实体 175 */ 176 public void refresh(T t); 177 178 /** 179 * update 180 * @param t 181 * 更新的是数据库中的数据 182 */ 183 public void update(T t); 184 185 /** 186 * 根据HQL得到记录数 187 * @param hql HQL语句 188 * @param values 不定参数的Object数组 189 * @return 记录总数 190 */ 191 public Long countByHql(String hql, Object... values); 192 193 /** 194 * HQL分页查询 195 * 196 * @param hql HQL语句 197 * @param countHql 查询记录条数的HQL语句 198 * @param pageNo 下一页 199 * @param pageSize 一页总条数 200 * @param values 不定Object数组参数 201 * @return PageResults的封装类，里面包含了页码的信息以及查询的数据List集合 202 */ 203 public PageInfo<T> findPageByHql(String hql, String countHql, int pageNo, int pageSize, Object... values); 204 205 /** 206 * 按属性查找对象列表，匹配方式为相等 207 * @param propertyName 208 * @param value 209 * @return List<T> 210 */ 211 public List<T> list(String propertyName, Object value); 212 213 /** 214 * 根据criterion查询条件获取数据列表 215 * @param criterion 216 * @return List<T> 217 */ 218 public List<T> list(Criterion criterion); 219 220 /** 221 * 按Criteria查询对象列表 222 * @param criterions 223 * @return List<T> 224 */ 225 public List<T> list(Criterion... criterions); 226 227 /** 228 * 按属性查找唯一对象，匹配方式为相等 229 * @param propertyName 230 * @param value 231 * @return T 232 */ 233 public T uniqueResult(String propertyName, Object value); 234 235 /** 236 * 按Criteria查询唯一对象 237 * @param criterions 238 * @return T 239 */ 240 public T uniqueResult(Criterion... criterions); 241 242 /** 243 * 按Criteria查询唯一对象 244 * @param criteria 245 * @return T 246 */ 247 public T uniqueResult(Criteria criteria); 248 /** 249 * 按照criteria返回类型为Integer类型的某个字段的值 250 * @param criteria 251 * @return 252 */ 253 public Integer uniqueResultInt(Criteria criteria); 254 255 256 257 /** 258 * 为Criteria添加distinct transformer 259 * @param criteria 260 * @return Criteria 261 */ 262 public Criteria distinct(Criteria criteria); 263 264 /** 265 * 刷新session 266 */ 267 public void flush(); 268 269 /** 270 * 清空session 271 */ 272 public void clear(); 273 274 /** 275 * 创建Criteria实例 276 */ 277 public Criteria createCriteria(); 278 279 /** 280 * 根据Criterion条件创建Criteria 281 * @param criterions 282 * @return Criteria 283 */ 284 public Criteria createCriteria(Criterion... criterions); 285 286 /** 287 * 分页查询Criteria 288 * @param criteria 289 * @param pageNo 下页页码 290 * @param pageSize 页面数据量 291 * @return List<T> 292 */ 293 public List<T> findPage(Criteria criteria, int pageNo, int pageSize); 294 295 /** 296 * 分页查询Criteria 297 * @param criteria 298 * @param pageNo 299 * @param pageSize 300 * @return PageInfo<T> 301 * @throws SecurityException 302 * @throws NoSuchFieldException 303 * @throws IllegalAccessException 304 * @throws IllegalArgumentException 305 */ 306 public PageInfo<T> findQuery(Criteria criteria, int pageNo, int pageSize); 307 308 /** 309 * 310 * @param hql 311 * @param pageNo 312 * @param pageSize 313 * @param map 314 * @return List<T> 315 */ 316 public List<T> findQuery(String hql, int pageNo, int pageSize, Map<?, ?> map); 317 }
GenericServiceImpl.java
1 package com.agen.service.impl; 2 3 import java.io.Serializable; 4 import java.util.Collection; 5 import java.util.List; 6 import java.util.Map; 7 8 import org.hibernate.Criteria; 9 import org.hibernate.criterion.Criterion; 10 import org.hibernate.criterion.DetachedCriteria; 11 import org.springframework.beans.factory.annotation.Autowired; 12 import org.springframework.stereotype.Component; 13 import org.springframework.stereotype.Service; 14 import org.springframework.transaction.annotation.Propagation; 15 import org.springframework.transaction.annotation.Transactional; 16 17 import com.agen.dao.impl.GenericDaoImpl; 18 import com.agen.service.GenericService; 19 import com.github.pagehelper.PageInfo; 20 21 @Transactional 22 public class GenericServiceImpl<T, PK extends Serializable> implements GenericService<T, PK> { 23 24 25 private GenericDaoImpl<T, PK> dao; 26 /** 27 * 设值注入Dao 28 * @param dao 29 */ 30 @Autowired 31 public void setDao(GenericDaoImpl<T, PK> dao) { 32 this.dao = dao; 33 } 34 35 @Override 36 public List<T> list(Criteria criteria) { 37 // TODO Auto-generated method stub 38 return dao.list(criteria); 39 } 40 41 @Override 42 public List<T> list(String orderBy, boolean isAsc) { 43 // TODO Auto-generated method stub 44 return dao.list(orderBy, isAsc); 45 } 46 47 @Override 48 public List<T> list(DetachedCriteria criteria) { 49 // TODO Auto-generated method stub 50 return dao.list(criteria); 51 } 52 53 @Override 54 public int countAll(Criteria criteria) { 55 // TODO Auto-generated method stub 56 return dao.countAll(criteria); 57 } 58 59 @Override 60 public int countAll() { 61 // TODO Auto-generated method stub 62 return dao.countAll(); 63 } 64 65 @Override 66 public boolean exists(PK id) { 67 // TODO Auto-generated method stub 68 return dao.exists(id); 69 } 70 71 @Override 72 @Transactional(propagation = Propagation.REQUIRED) 73 public void save(T t) { 74 // TODO Auto-generated method stub 75 dao.save(t); 76 } 77 78 @Override 79 @Transactional(propagation = Propagation.REQUIRED) 80 public void saveOrUpdate(T t) { 81 // TODO Auto-generated method stub 82 dao.saveOrUpdate(t); 83 } 84 85 @Override 86 @Transactional(propagation = Propagation.REQUIRED) 87 public T load(PK id) { 88 // TODO Auto-generated method stub 89 return dao.load(id); 90 } 91 92 @Override 93 @Transactional(propagation = Propagation.REQUIRED) 94 public void merge(T entity) { 95 // TODO Auto-generated method stub 96 dao.merge(entity); 97 } 98 99 @Override 100 public List<T> findAll() { 101 // TODO Auto-generated method stub 102 return dao.findAll(); 103 } 104 105 @Override 106 @Transactional(propagation = Propagation.REQUIRED) 107 public T get(PK id) { 108 // TODO Auto-generated method stub 109 return dao.get(id); 110 } 111 112 @Override 113 public boolean contains(T t) { 114 // TODO Auto-generated method stub 115 return dao.contains(t); 116 } 117 118 @Override 119 public void delete(T t) { 120 // TODO Auto-generated method stub 121 dao.delete(t); 122 } 123 124 @Override 125 @Transactional(propagation = Propagation.REQUIRED) 126 public boolean deleteById(PK Id) { 127 // TODO Auto-generated method stub 128 return dao.deleteById(Id); 129 } 130 131 @Override 132 public void deleteAll(Collection<T> entities) { 133 // TODO Auto-generated method stub 134 dao.deleteAll(entities); 135 } 136 137 @Override 138 public void queryHql(String hqlString, Object... values) { 139 // TODO Auto-generated method stub 140 dao.queryHql(hqlString, values); 141 } 142 143 @Override 144 public void querySql(String sqlString, Object... values) { 145 // TODO Auto-generated method stub 146 dao.querySql(sqlString, values); 147 } 148 149 @Override 150 public T getByHQL(String hqlString, Object... values) { 151 // TODO Auto-generated method stub 152 return dao.getByHQL(hqlString, values); 153 } 154 155 @Override 156 public List<T> getListByHQL(String hqlString, Object... values) { 157 // TODO Auto-generated method stub 158 return dao.getListByHQL(hqlString, values); 159 } 160 161 @Override 162 public List<T> getListBySQL(String sqlString, Object... values) { 163 // TODO Auto-generated method stub 164 return dao.getListBySQL(sqlString, values); 165 } 166 167 @Override 168 public void refresh(T t) { 169 // TODO Auto-generated method stub 170 dao.refresh(t); 171 } 172 173 @Override 174 @Transactional(propagation = Propagation.REQUIRED) 175 public void update(T t) { 176 // TODO Auto-generated method stub 177 dao.update(t); 178 } 179 180 @Override 181 public Long countByHql(String hql, Object... values) { 182 // TODO Auto-generated method stub 183 return dao.countByHql(hql, values); 184 } 185 186 @Override 187 public PageInfo<T> findPageByHql(String hql, String countHql, int pageNo, 188 int pageSize, Object... values) { 189 // TODO Auto-generated method stub 190 return dao.findPageByHql(hql, countHql, pageNo, pageSize, values); 191 } 192 193 @Override 194 public List<T> list(String propertyName, Object value) { 195 // TODO Auto-generated method stub 196 return dao.list(propertyName, value); 197 } 198 199 @Override 200 public List<T> list(Criterion criterion) { 201 // TODO Auto-generated method stub 202 return dao.list(criterion); 203 } 204 205 @Override 206 public List<T> list(Criterion... criterions) { 207 // TODO Auto-generated method stub 208 return dao.list(criterions); 209 } 210 211 @Override 212 public T uniqueResult(String propertyName, Object value) { 213 // TODO Auto-generated method stub 214 return dao.uniqueResult(propertyName, value); 215 } 216 217 @Override 218 public T uniqueResult(Criterion... criterions) { 219 // TODO Auto-generated method stub 220 return dao.uniqueResult(criterions); 221 } 222 223 @Override 224 @Transactional(propagation = Propagation.REQUIRED, readOnly = true) 225 public T uniqueResult(Criteria criteria) { 226 // TODO Auto-generated method stub 227 return dao.uniqueResult(criteria); 228 } 229 230 @Override 231 @Transactional(propagation = Propagation.REQUIRED, readOnly = true) 232 public Integer uniqueResultInt(Criteria criteria){ 233 return dao.uniqueResultInt(criteria); 234 } 235 236 @Override 237 public Criteria distinct(Criteria criteria) { 238 // TODO Auto-generated method stub 239 return dao.distinct(criteria); 240 } 241 242 @Override 243 public void flush() { 244 // TODO Auto-generated method stub 245 dao.flush(); 246 } 247 248 @Override 249 public void clear() { 250 // TODO Auto-generated method stub 251 dao.clear(); 252 } 253 254 @Override 255 public Criteria createCriteria() { 256 // TODO Auto-generated method stub 257 return dao.createCriteria(); 258 } 259 260 @Override 261 public Criteria createCriteria(Criterion... criterions) { 262 // TODO Auto-generated method stub 263 return dao.createCriteria(criterions); 264 } 265 266 @Override 267 public List<T> findPage(Criteria criteria, int pageNo, int pageSize) { 268 // TODO Auto-generated method stub 269 return dao.findPage(criteria, pageNo, pageSize); 270 } 271 272 @Override 273 public PageInfo<T> findQuery(Criteria criteria, int pageNo, int pageSize) { 274 // TODO Auto-generated method stub 275 return dao.findQuery(criteria, pageNo, pageSize); 276 } 277 278 @Override 279 public List<T> findQuery(String hql, int pageNo, int pageSize, Map<?, ?> map) { 280 // TODO Auto-generated method stub 281 return dao.findQuery(hql, pageNo, pageSize, map); 282 } 283 284 }
我们看到实体包下的各个实体：
接下来 自动生成每一层的各个实体对应的相对应的代码文件：
1 package com.agen.test.util; 2 3 import java.io.File; 4 import java.io.FileWriter; 5 import java.io.IOException; 6 7 import org.junit.Test; 8 9 public class CreateJava { 10 11 @Test 12 public void justCreateJava() throws IOException{ 13 File file = new File("F:/workspace2/performance/src/main/java/com/agen/entity"); 14 File []list = file.listFiles(); 15 for (File file2 : list) { 16 String fileName = file2.getName().substring(0,file2.getName().lastIndexOf(".")); 17 createDao(fileName); 18 createDaoImpl(fileName); 19 createService(fileName); 20 createServiceImpl(fileName); 21 } 22 } 23 /** 24 * 创建Dao层 25 * @param fileName 26 * @throws IOException 27 */ 28 public void createDao(String fileName) throws IOException{ 29 //拼接 DaoImpl内容 30 String content = "package com.agen.dao;\r\n" 31 + "\r\n" 32 + "import com.agen.entity."+fileName+";\r\n" 33 + "public interface "+fileName+"Dao extends GenericDao<"+fileName+", String> {\r\n" 34 + "\r\n" 35 + "}"; 36 37 //指定将Dao文件生成到对应的指定位置 38 FileWriter writer = new FileWriter(new File("F:/workspace2/performance/src/main/java/com/agen/dao/"+fileName+"Dao.java")); 39 writer.write(content); 40 writer.close(); 41 } 42 43 /** 44 * 创建DaoImpl层 45 */ 46 public void createDaoImpl(String fileName) throws IOException{ 47 //拼接 DaoImpl内容 48 String content = "package com.agen.dao.impl;\r\n" 49 + "\r\n" 50 + "import org.springframework.stereotype.Repository;\r\n" 51 + "import com.agen.dao."+fileName+"Dao;\r\n" 52 + "import com.agen.entity."+fileName+";\r\n" 53 + "@Repository \r\n" 54 + "public class "+fileName+"DaoImpl extends GenericDaoImpl<"+fileName+", String> implements "+fileName+"Dao {\r\n" 55 + "\r\n" 56 + "}"; 57 58 //指定将DaoImpl文件生成到对应的指定位置 59 FileWriter writer = new FileWriter(new File("F:/workspace2/performance/src/main/java/com/agen/dao/impl/"+fileName+"DaoImpl.java")); 60 writer.write(content); 61 writer.close(); 62 } 63 64 /** 65 * 创建 Service层 66 * @param fileName 67 * @throws IOException 68 */ 69 public void createService(String fileName) throws IOException{ 70 //拼接Service内容 71 String content = "package com.agen.service;\r\n" 72 + "import com.agen.entity."+fileName+";\r\n" 73 + "public interface "+fileName+"Service extends GenericService<"+fileName+", String> {\r\n" 74 + "\r\n" 75 + "}"; 76 77 FileWriter writer = new FileWriter(new File("F:/workspace2/performance/src/main/java/com/agen/service/"+fileName+"Service.java")); 78 writer.write(content); 79 writer.close(); 80 } 81 82 /** 83 * 创建ServiceImpl 84 * @throws IOException 85 */ 86 public void createServiceImpl(String fileName) throws IOException{ 87 //拼接Service内容 88 String content = "package com.agen.service.impl;\r\n" 89 + "import org.springframework.beans.factory.annotation.Autowired;\r\n" 90 + "import org.springframework.stereotype.Service;\r\n" 91 + "import com.agen.dao."+fileName+"Dao;\r\n" 92 + "import com.agen.entity."+fileName+";\r\n" 93 + "import com.agen.service."+fileName+"Service;\r\n" 94 + "@Service \r\n" 95 + "public class "+fileName+"ServiceImpl extends GenericServiceImpl<"+fileName+", String> implements "+fileName+"Service {\r\n" 96 + "\r\n" 97 + "@Autowired\r\n" 98 + "private "+fileName+"Dao dao;\r\n" 99 + "}"; 100 FileWriter writer = new FileWriter(new File("F:/workspace2/performance/src/main/java/com/agen/service/impl/"+fileName+"ServiceImpl.java")); 101 writer.write(content); 102 writer.close(); 103 } 104 105 }
生成完刷新
效果如下：
【Java 新建项目】使用程序对新项目的各个实体 创建Dao、DaoImpl、Service、ServiceImpl层的文件
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。