详解SpringBoot实现JPA的save方法不更新null属性
程序员文章站
2024-03-03 15:39:52
序言:直接调用原生save方法会导致null属性覆盖到数据库,使用起来十分不方便。本文提供便捷方法解决此问题。
核心思路
如果现在保存某user对象,首先根据主键查...
序言:直接调用原生save方法会导致null属性覆盖到数据库,使用起来十分不方便。本文提供便捷方法解决此问题。
核心思路
如果现在保存某user对象,首先根据主键查询这个user的最新对象,然后将此user对象的非空属性覆盖到最新对象。
核心代码
直接修改通用jparepository的实现类,然后在启动类标记此实现类即可。
一、通用crud实现类
public class simplejparepositoryimpl<t, id> extends simplejparepository<t, id> { private final jpaentityinformation<t, ?> entityinformation; private final entitymanager em; @autowired public simplejparepositoryimpl(jpaentityinformation<t, ?> entityinformation, entitymanager entitymanager) { super(entityinformation, entitymanager); this.entityinformation = entityinformation; this.em = entitymanager; } /** * 通用save方法 :新增/选择性更新 */ @override @transactional public <s extends t> s save(s entity) { //获取id id entityid = (id) entityinformation.getid(entity); optional<t> optionalt; if (stringutils.isempty(entityid)) { string uuid = uuid.randomuuid().tostring(); //防止uuid重复 if (findbyid((id) uuid).ispresent()) { uuid = uuid.randomuuid().tostring(); } //若id为空 则设置为uuid new beanwrapperimpl(entity).setpropertyvalue(entityinformation.getidattribute().getname(), uuid); //标记为新增数据 optionalt = optional.empty(); } else { //若id非空 则查询最新数据 optionalt = findbyid(entityid); } //获取空属性并处理成null string[] nullproperties = getnullproperties(entity); //若根据id查询结果为空 if (!optionalt.ispresent()) { em.persist(entity);//新增 return entity; } else { //1.获取最新对象 t target = optionalt.get(); //2.将非空属性覆盖到最新对象 beanutils.copyproperties(entity, target, nullproperties); //3.更新非空属性 em.merge(target); return entity; } } /** * 获取对象的空属性 */ private static string[] getnullproperties(object src) { //1.获取bean beanwrapper srcbean = new beanwrapperimpl(src); //2.获取bean的属性描述 propertydescriptor[] pds = srcbean.getpropertydescriptors(); //3.获取bean的空属性 set<string> properties = new hashset<>(); for (propertydescriptor propertydescriptor : pds) { string propertyname = propertydescriptor.getname(); object propertyvalue = srcbean.getpropertyvalue(propertyname); if (stringutils.isempty(propertyvalue)) { srcbean.setpropertyvalue(propertyname, null); properties.add(propertyname); } } return properties.toarray(new string[0]); } }
二、启动类
@enablejparepositories(value = "com.hehe.repository", repositorybaseclass = simplejparepositoryimpl.class) @springbootapplication public class jpaapplication { public static void main(string[] args) { springapplication.run(jpaapplication.class, args); } }
三、实体类和通用save
@entity @table(name = "t_user") @jsonignoreproperties({"handler","hibernatelazyinitializer"}) public class user { @id private string userid; private string username; private string password; //省略get/set } public interface userrepository extends jparepository<user, string> { }
四、配置文件 application.yml
spring: datasource: url: jdbc:mysql://localhost:3306/socks?usessl=false username: root password: root driver-class-name: com.mysql.jdbc.driver
五、数据库脚本
drop table if exists t_user; create table t_user ( user_id varchar(50), username varchar(50), password varchar(50) ); insert into t_user values ('1', 'admin', 'admin'); insert into t_user values ('2', 'yizhiwazi', '123456');
六、测试代码
@restcontroller public class usercontroller { @autowired private userrepository userrepository; @requestmapping("/") public user get() { userrepository.save(new user("1", "", null)); return userrepository.findbyid("1").get(); } }
整体结构图
在实际项目中,可以直接复制simplejparepositoryimpl使用,并不影响原有的其它api。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
上一篇: 遗传算法之Python实现代码