详解SpringBoot实现JPA的save方法不更新null属性

序言：直接调用原生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。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。