文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

怎么利用泛型封装通用的service层

2023-07-02 11:17

关注

这篇“怎么利用泛型封装通用的service层”文章的知识点大部分人都不太理解,所以小编给大家总结了以下内容,内容详细,步骤清晰,具有一定的借鉴价值,希望大家阅读完这篇文章能有所收获,下面我们一起来看看这篇“怎么利用泛型封装通用的service层”文章吧。

身为一名开发人员,大家都知道,我们经常会在项目中大量的编写许多重复的代码,比如说

public Entity find(String id);

像这种代码,简单,但是写多了,可能也会容易出错,那么我们能不能直接编写一套完整的,通用的方法呢,这样既不用重复编写,还不用出错,说道通用的方法,泛型是个不错的选择.

基础架构:spring-boot+spring mvc+spring jpa.

jpa是个好东西,个人感觉它最大的好处是不需要自己手动建表.还能在修改了表字段以后,自动给你添加上上去,它不像mybatis,业务改了之后,还需要调整sql语句,

好了,废话不多说,上代码:

一、首先建立一个实体类WebVisitRecordEntity

继承BaseEntity.BaseEntity在项目里面,是所有实体类的最顶层.里面是封装了一些通用的属性.

BaseEntity

package cn.yxw.function; import cn.yxw.function.Enum.status.StatusEnum; import javax.persistence.Column;import javax.persistence.Id;import javax.persistence.MappedSuperclass;import java.io.Serializable;import java.util.Date; @MappedSuperclasspublic abstract class BaseEntity implements Serializable{         @Id    @Column(length = 32 )    private String id;         private Date createTime;         @Column(length = 32 )    private String createUser;         private Date updateTime;         @Column(length = 32 )    private String updateUser;         @Column(length = 8 )    private String delStatus = StatusEnum.FALSE.getStatus();         @Column(length = 8 )    private String enAbleStatus = StatusEnum.TRUE.getStatus();     public String getId() {        return id;    }     public void setId(String id) {        this.id = id;    }     public Date getCreateTime() {        return createTime;    }     public void setCreateTime(Date createTime) {        this.createTime = createTime;    }     public String getCreateUser() {        return createUser;    }     public void setCreateUser(String createUser) {        this.createUser = createUser;    }     public Date getUpdateTime() {        return updateTime;    }     public void setUpdateTime(Date updateTime) {        this.updateTime = updateTime;    }     public String getUpdateUser() {        return updateUser;    }     public void setUpdateUser(String updateUser) {        this.updateUser = updateUser;    }     public String getDelStatus() {        return delStatus;    }     public void setDelStatus(String delStatus) {        this.delStatus = delStatus;    }     public String getEnAbleStatus() {        return enAbleStatus;    }     public void setEnAbleStatus(String enAbleStatus) {        this.enAbleStatus = enAbleStatus;    }}

WebVisitRecordEntity

package cn.yxw.function.domain.plugins; import cn.yxw.function.BaseEntity; import javax.persistence.Entity;import javax.persistence.Inheritance;import javax.persistence.InheritanceType;import javax.persistence.Table; @Entity()@Inheritance(strategy = InheritanceType.TABLE_PER_CLASS)@Table(name = "web_visit_Record")public class WebVisitRecordEntity extends BaseEntity {     private static final long serialVersionUID = 341666498307329777L;        private int count = 0;     public int getCount() {        return count;    }     public void setCount(int count) {        this.count = count;    }}

二、有了实体类之后

首先建立一个顶层的api接口。所有通用的api方法,可以放在这里(ResultBean是一个封装了一个结果的数据类,里面包含了定义执行是否成功,执行返回的数据,执行错误提示的消息)

package cn.yxw.function; import cn.yxw.function.result.ResultBean;import org.springframework.data.domain.Page;import org.springframework.data.domain.Pageable; public interface BaseApi<T extends BaseEntity> {         T get(String id);         T find(String id);         ResultBean<T> delete(String id);     ResultBean<T> delete(T entity);         ResultBean<T> create(T entity);         ResultBean<T> update(T entity);         Page<T> page(Pageable pageable);         boolean exists(String id); }

三、实现BaseApi

既然是要定义通用的api,那么不仅仅只是一套接口,我们需要在定义一个可以实现BaseApi的BaseServiceImpl,之后的所有实现类,都可以继承这个BaseServiceImpl.java的泛型,给了我们的项目很好的扩展性,而顶层BaseEntity也给了我很好的实现方案,将BaseEntity作为泛型的入口

基本时限BaseApi

package cn.yxw.function.service.impl.domain.userCenter; import cn.yxw.function.BaseApi;import cn.yxw.function.BaseEntity;import cn.yxw.function.result.ResultBean;import org.springframework.data.domain.Page;import org.springframework.data.domain.Pageable;  public class BaseServiceImpl<T extends BaseEntity> implements BaseApi<T> {      @Override    public T get(String id) {        return null;    }     @Override    public T find(String id) {        return null;    }     @Override    public ResultBean<T> delete(String id) {        return null;    }     @Override    public ResultBean<T> delete(T entity) {        return null;    }     @Override    public ResultBean<T> create(T entity) {        return null;    }     @Override    public ResultBean<T> update(T entity) {        return null;    }     @Override    public Page<T> page(Pageable pageable) {        return null;    }     @Override    public boolean exists(String id) {        return false;    }}

使用jpa作为BaseServiceImpl的属性.

package cn.yxw.function.service.impl.domain.userCenter; import cn.yxw.function.BaseApi;import cn.yxw.function.BaseEntity;import cn.yxw.function.Enum.code.ServiceCodeEnum;import cn.yxw.function.result.ResultBean;import cn.yxw.function.util.ObjectUtil;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.domain.Page;import org.springframework.data.domain.Pageable;import org.springframework.data.jpa.repository.JpaRepository; public class BaseServiceImpl<T extends BaseEntity> implements BaseApi<T> {     @Autowired    private JpaRepository<T, String> baseRepository;      @Override    public T get(String id) {        T entity =  this.baseRepository.getOne(id);        return entity;    }     @Override    public T find(String id) {        return this.baseRepository.findById(id).get();    }     @Override    public ResultBean<T> delete(String id) {        this.baseRepository.deleteById(id);        return ResultBean.success("");    }     @Override    public ResultBean<T> delete(T entity) {        this.baseRepository.delete(entity);        return ResultBean.success(entity);    }     @Override    public ResultBean<T> create(T entity) {        if(ObjectUtil.isNull(entity)){            return ResultBean.failfure("数据为空,无法创建!");        }        if(this.exists(entity.getId())){            return ResultBean.failfure("实体id相同,无法重复创建!");        }        entity = this.baseRepository.saveAndFlush(entity);        if(ObjectUtil.isNull(entity)){            return ResultBean.failfure(ServiceCodeEnum.CORE_SYSTEM_FAILURE);        }        return ResultBean.success(entity);    }     @Override    public ResultBean<T> update(T entity) {        if(ObjectUtil.isNull(entity)){            return ResultBean.failfure("数据为空,无法创建!");        }        if(!this.exists(entity.getId())){            return ResultBean.failfure("数据库不存在该数据,无法执行更新");        }        entity = this.baseRepository.saveAndFlush(entity);        if(ObjectUtil.isNull(entity)){            return ResultBean.failfure(ServiceCodeEnum.CORE_SYSTEM_FAILURE);        }        return ResultBean.success(entity);    }     @Override    public Page<T> page(Pageable pageable) {        return null;    }     @Override    public boolean exists(String id) {        return this.baseRepository.existsById(id);    }}

四、定义类自己的api

继承BaseApi,定义实现类,继承BaseServiceImpl.并实现自己的api

package cn.yxw.function.domain.userCenter; import cn.yxw.function.BaseApi;import cn.yxw.function.domain.plugins.WebVisitRecordEntity; public interface WebVisitRecordApi extends BaseApi<WebVisitRecordEntity> {}
package cn.yxw.function.service.impl.domain.userCenter; import cn.yxw.function.domain.plugins.WebVisitRecordEntity;import cn.yxw.function.domain.userCenter.WebVisitRecordApi;import org.springframework.stereotype.Service; @Servicepublic class WebVisitRecordServiceImpl extends BaseServiceImpl<WebVisitRecordEntity> implements WebVisitRecordApi {   }

五、测试

到这里,代码已经结束. 测试一下,构建下controller层. 并进行测试

package cn.yxw.function.controller.System.admin; import cn.yxw.function.controller.BaseController;import cn.yxw.function.domain.plugins.WebVisitRecordEntity;import cn.yxw.function.result.ResultBean;import cn.yxw.function.service.impl.domain.userCenter.WebVisitRecordServiceImpl;import cn.yxw.function.util.ObjectUtil;import com.alibaba.druid.util.StringUtils;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PostMapping;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController; import java.util.Date;import java.util.Map; @RestController()@RequestMapping(value = "web/record")public class WebVisitRecordsController extends BaseController {     @Autowired    private WebVisitRecordServiceImpl webVisitRecordService;      @GetMapping(value = "/get")    public Map get(String id){        if(StringUtils.isEmpty(id)){            return this.errorWithMsg("参数不得为空");        }        WebVisitRecordEntity entity = this.webVisitRecordService.find(id);        return this.result(entity,"");    }     @PostMapping(value = "/create")    public Map create(int num){        WebVisitRecordEntity entity = new WebVisitRecordEntity();        entity.setId(System.currentTimeMillis()+"");        entity.setCreateTime(new Date());        entity.setCount(num);        ResultBean<WebVisitRecordEntity> result = this.webVisitRecordService.create(entity);        return this.result(result.getDate(),result.getMsg());    }      @PostMapping(value = "/update")    public Map update(String id, int num){        if(StringUtils.isEmpty(id)){            return this.errorWithMsg("参数不得为空");        }        WebVisitRecordEntity entity = this.webVisitRecordService.find(id);        if(ObjectUtil.isNull(entity)){            return this.errorWithMsg("不存在该数据");        }        entity.setUpdateTime(new Date());        entity.setCount(entity.getCount()+num);        ResultBean<WebVisitRecordEntity> result = this.webVisitRecordService.update(entity);        return this.result(result.getDate(),result.getMsg());    } }

怎么利用泛型封装通用的service层

三次测试都已经成功,但是我们真实的项目不可能这么简单.所以我们再次测试下扩展性

等等,不知道你们发现没有,上面的代码有一段是错误的.

我在controller层的属性不是api,而是实现类.......

虽然不影响,但是就无法扩展了...此处做修正

怎么利用泛型封装通用的service层

六、扩展性

WebVisitRecordApi

package cn.yxw.function.domain.userCenter; import cn.yxw.function.BaseApi;import cn.yxw.function.domain.plugins.WebVisitRecordEntity; public interface WebVisitRecordApi extends BaseApi<WebVisitRecordEntity> {         int countAll();}

WebVisitRecordServiceImpl

package cn.yxw.function.service.impl.domain.userCenter; import cn.yxw.function.domain.plugins.WebVisitRecordEntity;import cn.yxw.function.domain.userCenter.WebVisitRecordApi;import cn.yxw.function.util.ObjectUtil;import org.springframework.stereotype.Service; import java.util.List; @Servicepublic class WebVisitRecordServiceImpl extends BaseServiceImpl<WebVisitRecordEntity> implements WebVisitRecordApi {      @Override    public int countAll() {        List<WebVisitRecordEntity> list = super.baseRepository.findAll();        int count = 0;        if(ObjectUtil.isNull(list) || list.size() <= 0){            return count;        }        for (WebVisitRecordEntity entity : list){            count += entity.getCount();        }        return count;    }}

WebVisitRecordController

    @GetMapping(value = "count")    public Map count(){        return this.result(this.webVisitRecordService.countAll(),"执行成功");    }

测试

怎么利用泛型封装通用的service层

以上就是关于“怎么利用泛型封装通用的service层”这篇文章的内容,相信大家都有了一定的了解,希望小编分享的内容对大家有帮助,若想了解更多相关的知识内容,请关注编程网行业资讯频道。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯