SpringBoot+MyBatis中通用动态CRUDP的实现
SpringBoot MyBatis
软件设计 JAVA 2018-10-23

SpringBoot+MyBatis中通用动态CRUDP的实现

SpringBoot+MyBatis框架的优缺点我就不表啦, 今天来说就怎么动态实现CRUDP.
先来一个通用Mapper

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
package cn.miw.rpc.batis.common;

import java.util.List;

import org.apache.ibatis.annotations.DeleteProvider;
import org.apache.ibatis.annotations.InsertProvider;
import org.apache.ibatis.annotations.Options;
import org.apache.ibatis.annotations.SelectProvider;
import org.apache.ibatis.annotations.UpdateProvider;

import cn.miw.rpc.jdbc.common.BaseEntity;

/**
 * 通用Mapper基础接口,使用范型,其他Mapper继承即可
 * @author mrzhou
 *
 * @param <T>
 */
public interface GeneralMapper<T extends BaseEntity> {
    @InsertProvider(method="insert",type=SQLGen.class)
    @Options(useGeneratedKeys=true,keyProperty="id")
    int save(T t);
    
    @DeleteProvider(method="del",type=SQLGen.class)
    int del(T t);
    
    @UpdateProvider(method="update",type=SQLGen.class)
    int update(T t);
    
    @SelectProvider(method="select",type=SQLGen.class)
    List<T> list(T t);
    
    @SelectProvider(method="page",type=SQLGen.class)
    List<T> page(T t);
    
}


这里需要一个SQLGen
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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
package cn.miw.rpc.batis.common;

import java.lang.reflect.Field;

import org.apache.ibatis.jdbc.SQL;

import cn.miw.rpc.jdbc.common.BaseEntity;
/**
 * 常规CRUD四个方法
 * @author mrzhou
 *
 * @param <T>
 */
public class SQLGen<T extends BaseEntity> {
    public String page(T object) {
        return new SQL() {
            {
                SELECT("*");
                FROM(object.getClass().getSimpleName());
                try {
                    Field[] fields = object.getClass().getDeclaredFields();
                    for (Field field : fields) {
                        field.setAccessible(true);
                        Object v = field.get(object);
                        if (v != null) {
                            String fieldName = field.getName();
                            if (v instanceof String && ((String)v).contains("%")) {
                                WHERE(fieldName + " like '"+v+"'" );
                            } else {
                                WHERE(fieldName + "=#{" + fieldName + "}");
                            }
                            
                        }
                    }
                } catch (Exception e) {
                }
            }
        }.toString()+" limit #{start},#{pageSize}";
    }
    public String select(T object) {
        return new SQL() {
            {
                SELECT("*");
                FROM(object.getClass().getSimpleName());
                try {
                    Field[] fields = object.getClass().getDeclaredFields();
                    for (Field field : fields) {
                        field.setAccessible(true);
                        Object v = field.get(object);
                        if (v != null) {
                            String fieldName = field.getName();
                            if (v instanceof String && ((String)v).contains("%")) {
                                WHERE(fieldName + " like '"+v+"'" );
                            } else {
                                WHERE(fieldName + "=#{" + fieldName + "}");
                            }
                        }
                    }
                } catch (Exception e) {
                }
                
            }
        }.toString();
    }
    public String update(T object) {
        return new SQL() {
            {
                UPDATE(object.getClass().getSimpleName());
                try {
                    Field[] fields = object.getClass().getDeclaredFields();
                    for (Field field : fields) {
                        field.setAccessible(true);
                        Object v = field.get(object);
                        if (v != null) {
                            String fieldName = field.getName();
                            SET(fieldName + "=#{" + fieldName + "}");
                        }
                    }
                } catch (Exception e) {
                }
                WHERE("id=#{id}");
            }
        }.toString();
    }
    public String insert(T object) {
        return new SQL() {
            {
                INSERT_INTO(object.getClass().getSimpleName());
                try {
                    Field[] fields = object.getClass().getDeclaredFields();
                    for (Field field : fields) {
                        field.setAccessible(true);
                        Object v = field.get(object);
                        if (v != null) {
                            String fieldName = field.getName();
                            VALUES(fieldName,"#{"+fieldName+"}");
                        }
                    }
                } catch (Exception e) {
                }
            }
        }.toString();
    }
    public String del(T object) {
        return new SQL() {
            {
                DELETE_FROM(object.getClass().getSimpleName());
                try {
                    Field[] fields = object.getClass().getDeclaredFields();
                    for (Field field : fields) {
                        field.setAccessible(true);
                        Object v = field.get(object);
                        if (v != null) {
                            String fieldName = field.getName();
                            if (v instanceof String && ((String)v).contains("%")) {
                                WHERE(fieldName + " like '"+v+"'" );
                            } else {
                                WHERE(fieldName + "=#{" + fieldName + "}");
                            }
                        }
                    }
                } catch (Exception e) {
                }
            }
        }.toString();
    }
}


在这里的分页查询中, 可以看到多了两个变量, 其实这个是我对每个实体都定义了一个基础类, 但这些属性对于使用来说是不需要的, 所以在这里忽略了.
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
package cn.miw.rpc.jdbc.common;

import com.fasterxml.jackson.annotation.JsonIgnore;

public class BaseEntity {

    @JsonIgnore
    private int page = 1;
    @JsonIgnore
    private int pageSize = 10;

    public int getPage() {
        return page;
    }

    @JsonIgnore
    public int getStart() {
        return (page - 1) * pageSize;
    }

    public void setPage(int page) {
        this.page = page;
    }

    public int getPageSize() {
        return pageSize;
    }

    public void setPageSize(int pageSize) {
        this.pageSize = pageSize;
    }

}


再下看一下具体的实体
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
package cn.miw.rpc.jdbc.model;

import org.springframework.data.annotation.Id;

import cn.miw.rpc.jdbc.common.BaseEntity;

public class User extends BaseEntity {
    @Id
    private Integer id;
    private String name;
    private Integer age;

    public Integer getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    @Override
    public String toString() {
        return "User [id=" + id + ", name=" + name + ", age=" + age + "]";
    }

    public User() {
        super();
    }

    public User(int id, String name) {
        super();
        this.id = id;
        this.name = name;
    }

    public Integer getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

}


来看看实例对应的mapper, 在这里还可以继续定义其他你喜欢的方法
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
package cn.miw.rpc.batis.mapper;

import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update;
import org.springframework.stereotype.Repository;

import com.github.pagehelper.Page;

import cn.miw.rpc.batis.common.GeneralMapper;
import cn.miw.rpc.jdbc.model.User;

@Mapper
@Repository("umapper")
public interface UserMapper extends GeneralMapper<User> {

    @Insert("insert into User(name,age) values(#{name},#{age})")
    int addUser(@Param("name") String name, @Param("age") int age);

    @Select("select * from User where id =#{id}")
    User findById(@Param("id") int id);
    
    @Update("update User set name=#{name} where id=#{id}")
    void updataById(@Param("id") int id, @Param("name") String name);

    @Delete("delete from User where id=#{id}")
    void deleteById(@Param("id") int id);
    
    @Select("select * from User order by id desc")
    Page<User> getPage();
}

最后来看看Controller中的调用
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
package cn.miw.rpc.batis;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;

import cn.miw.rpc.batis.common.JSON;
import cn.miw.rpc.batis.mapper.UserMapper;
import cn.miw.rpc.jdbc.model.User;
import io.swagger.annotations.Api;
@Api
@RestController
public class BatisController {

    @Autowired
    private UserMapper userMapper;

    @GetMapping("/batis/{id}")
    public User insert(@PathVariable int id) {
        return userMapper.findById(id);

    }

    @GetMapping("/batis/find/{page}")
    public Object find(@PathVariable int page) {
        User user = new User();
        user.setName("%");
        user.setPage(page);
        user.setPageSize(10);
        List<User> list = userMapper.page(user);
        return list;
    }
}


使用是不是很简单呢?

赏

转载请注明: 蜜友工作室 SpringBoot+MyBatis中通用动态CRUDP的实现

上一篇
SpringBoot+JdbcTemplate通用Mapper的实现 SpringBoot+JdbcTemplate通用Mapper的实现
SpringBoot+JdbcTemplate通用Mapper的实现就我个人而言, 使用某个框架, 还是建议尽是只使用框架原生提供的方法来完成相关的操作, 这样从各方面来说应该都是性能最优的. 代码也应该是最好阅读和理解的. 这里还用上一篇
2018-10-25 软件设计 JAVA
SpringBoot JdbcTemplate
下一篇
JRebel 2018.1.6 注册服务搭建 JRebel 2018.1.6 注册服务搭建
JRebel 2018.1.6 注册服务搭建JRebel热部署功能使用起来确实很方便, 只是需要激活使用, 虽然有好多在线的激活服务地址, 但需要都可能被和谐掉, 也有可能被Jetbrain封掉, 不如自己架一个注册服务. 下载地址: ht
2018-10-15 软件设计 JAVA
java JRebel 注册

目录

  1. SpringBoot+MyBatis中通用动态CRUDP的实现