序言：直接调用原生save方法会导致null属性覆盖到数据库，使用起来十分不方便。本文提供便捷方法解决此问题。
核心思路
如果现在保存某user对象，首先根据主键查询这个user的最新对象，然后将此user对象的非空属性覆盖到最新对象。
核心代码
直接修改通用jparepository的实现类，然后在启动类标记此实现类即可。
一、通用crud实现类
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
|
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]); }} |
二、启动类
|
1
2
3
4
5
6
7
8
|
@enablejparepositories(value = "com.hehe.repository", repositorybaseclass = simplejparepositoryimpl.class)@springbootapplicationpublic class jpaapplication { public static void main(string[] args) { springapplication.run(jpaapplication.class, args); }} |
三、实体类和通用save
|
1
2
3
4
5
6
7
8
9
10
11
12
|
@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
|
1
2
3
4
5
6
|
spring: datasource: url: jdbc:mysql://localhost:3306/socks?usessl=false username: root password: root driver-class-name: com.mysql.jdbc.driver |
五、数据库脚本
|
1
2
3
4
5
6
7
8
9
|
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'); |
六、测试代码
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
@restcontrollerpublic class usercontroller { @autowired private userrepository userrepository; @requestmapping("/") public user get() { userrepository.save(new user("1", "", null)); return userrepository.findbyid("1").get(); }} |
整体结构图
在实际项目中，可以直接复制simplejparepositoryimpl使用，并不影响原有的其它api。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：https://www.jianshu.com/p/4931fbc52ea1
