构建dubbo分布式平台-maven构建ant-framework核心代码Base封装

IT牛

因为涉及到springmvc、mybatis的集成，为了使项目编码更简洁易用，这边将基础的BASE进行封装，其中包括：BaseBean、BaseDao、BaseService、CRUD的基础封装、分页组件的封装、mybatis的mapper的基础封装，各种数据源支持的封装等。


1. BaseEntity基础封装，代码如下：

1. /**
   
2.  * Entity基础封装
   
3.  */
   
4. public abstract class BaseEntity<T> implements Serializable {
   
5. private static final long serialVersionUID = 1234567890987654321L;
   
6. /**
   
7. * 实体编号（唯一标识）
   
8. */
   
9. protected String id;
   
10. 
    
11. /**
    
12. * 当前实体分页对象
    
13. */
    
14. protected Page<T> page;
    
15. /**
    
16. * 是否插入新纪录
    
17. */
    
18. protected boolean isNewRecord = false;
    
19. public BaseEntity() {
    
20. }
    
21. public BaseEntity(String id) {
    
22. this();
    
23. this.id = id;
    
24. }
    
25. public String getId() {
    
26. return id;
    
27. }
    
28. public void setId(String id) {
    
29. this.id = id;
    
30. }
    
31. /**
    
32. * 数据插入之前
    
33. */
    
34. public abstract void preInsert();
    
35. 
    
36. /**
    
37. * 更新数据之前
    
38. */
    
39. public abstract void preUpdate();
    
40. 
    
41. &#160; &#160; &#160; &#160;/**
    
42. * 是否是新记录（默认：false）
    
43. &#160; &#160; &#160; &#160; */
    
44. public boolean getIsNewRecord() {
    
45. &#160; &#160; &#160; &#160; return isNewRecord || StringUtils.isBlank(getId());
    
46. &#160; &#160; }
    
47. /**
    
48. * 是否是新记录（默认：false）
    
49. */
    
50. public void setIsNewRecord(boolean isNewRecord) {
    
51. this.isNewRecord = isNewRecord;
    
52. }
    
53. /**
    
54. * 全局变量对象
    
55. */
    
56. @JsonIgnore
    
57. public Global getGlobal() {
    
58. return Global.getInstance();
    
59. }
    
60. @Override
    
61. public boolean equals(Object obj) {
    
62. if (null == obj) {
    
63. &#160; &#160;return false;
    
64. }
    
65. if (this == obj) {
    
66. &#160; &#160;return true;
    
67. }
    
68. if (!getClass().equals(obj.getClass())) {
    
69. &#160; &#160;return false;
    
70. }
    
71. BaseEntity<?> that = (BaseEntity<?>) obj;
    
72. return null == this.getId() ? false : this.getId().equals(that.getId());
    
73. }&#160;
    
74. }
    

复制代码

2. BaseDao的基础封装（这个很简单，因为使用的是mybatis集成方案，只需要保留接口即可），代码如下：

1. public interface BaseDao {
   
2. }
   

复制代码

3. CrudDao的基础封装

1. /**
   
2. &#160;* DAO基础封装
   
3. &#160;*/
   
4. public interface CrudDao<T> extends BaseDao {
   
5. 
   
6. 
   
7. /**
   
8. * 获取单条数据
   
9. * @param id
   
10. * @return
    
11. */
    
12. public T get(String id);
    
13. 
    
14. /**
    
15. * 获取单条数据
    
16. * @param entity
    
17. * @return
    
18. */
    
19. public T get(T entity);
    
20. 
    
21. /**
    
22. * 查询数据列表，如果需要分页，请设置分页对象，如：entity.setPage(new Page<T>());
    
23. * @param entity
    
24. * @return
    
25. */
    
26. public List<T> findList(T entity);
    
27. 
    
28. /**
    
29. * 查询所有数据列表
    
30. * @param entity
    
31. * @return
    
32. */
    
33. public List<T> findAllList(T entity);
    
34. 
    
35. /**
    
36. * 查询所有数据列表
    
37. * @see public List<T> findAllList(T entity)
    
38. * @return
    
39. */
    
40. @Deprecated
    
41. public List<T> findAllList();
    
42. 
    
43. /**
    
44. * 插入数据
    
45. * @param entity
    
46. * @return
    
47. */
    
48. public int insert(T entity);
    
49. 
    
50. /**
    
51. * 更新数据
    
52. * @param entity
    
53. * @return
    
54. */
    
55. public int update(T entity);
    
56. 
    
57. /**
    
58. * 删除数据
    
59. * @param id
    
60. * @see public int delete(T entity)
    
61. * @return
    
62. */
    
63. @Deprecated
    
64. public int delete(String id);
    
65. 
    
66. /**
    
67. * 删除数据
    
68. * @param entity
    
69. * @return
    
70. */
    
71. public int delete(T entity);
    
72. 
    
73. }
    

复制代码

4. BaseService的基础封装（里面封装了基础的CRUD操作，包括基础get，find，insert，update等）

1. /**
   
2. &#160;* BaseService基础封装
   
3. &#160;*/
   
4. @Transactional(readOnly = true)
   
5. public abstract class CrudService<D extends CrudDao<T>, T extends DataEntity<T>> extends BaseService {
   
6. 
   
7. /**
   
8. * 持久层dao
   
9. */
   
10. @Autowired
    
11. protected D dao;
    
12. 
    
13. /**
    
14. * 获取单条数据
    
15. * @param id
    
16. * @return
    
17. */
    
18. public T get(String id) {
    
19. return dao.get(id);
    
20. }
    
21. 
    
22. /**
    
23. * 获取单条数据
    
24. * @param entity
    
25. * @return
    
26. */
    
27. public T get(T entity) {
    
28. return dao.get(entity);
    
29. }
    
30. 
    
31. /**
    
32. * 查询列表数据
    
33. * @param entity
    
34. * @return
    
35. */
    
36. public List<T> findList(T entity) {
    
37. return dao.findList(entity);
    
38. }
    
39. 
    
40. /**
    
41. * 查询分页数据
    
42. * @param page 分页对象
    
43. * @param entity
    
44. * @return
    
45. */
    
46. public Page<T> findPage(Page<T> page, T entity) {
    
47. entity.setPage(page);
    
48. page.setList(dao.findList(entity));
    
49. return page;
    
50. }
    
51. 
    
52. 
    
53. /**
    
54. * 保存数据（插入或更新）
    
55. * @param entity
    
56. */
    
57. @Transactional(readOnly = false)
    
58. public void save(T entity) {
    
59. if (entity.getIsNewRecord()){
    
60. entity.preInsert();
    
61. dao.insert(entity);
    
62. }else{
    
63. entity.preUpdate();
    
64. dao.update(entity);
    
65. }
    
66. }
    
67. 
    
68. /**
    
69. * 删除数据
    
70. * @param entity
    
71. */
    
72. @Transactional(readOnly = false)
    
73. public void delete(T entity) {
    
74. dao.delete(entity);
    
75. }
    
76. }
    

复制代码

文章内容不写太多，希望大家能够掌握每一个知识点，基础的CRUD，BASE的封装差不多都在这里，后面会继续补充，具体的业务和实现后面会讲解到。

IT牛

希望可以帮助到你们哦