SpringBoot中使用mysql8的json类型存储json数据实现CRUD操作

字数统计: 1.5k字   |   阅读时长≈ 7分

前言

       对于关系型数据，我们经常会碰到一些复杂的业务场景需要设计大宽表去存储一对多和多对多关系的数据，大宽表这样的反范式的设计，存在筛选不方便、不支持灵活动态拓展无法直观的表达一对多和多对多的关系等诸多缺点，而mysql8.0的json类型支持直接存储json数据可以很好的解决上面的缺点。

案例一 天眼查企业展台网页数据

1.案例介绍

以下面天眼查企业展台为例，我们要存储多家企业的基本信息、主要人员和股东信息这些数据。
天眼查企业展台.jpg

2.表结构设计

以往的设计思路我们则至少需要三张表存储这些数据且查询主要人员和股东信息这些一对多关系数据也不太方便，现在我们可以将一对多关系数据直接用json数据存储，那么我们只需要设计一张表即可，以下是表结构

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
create table company_basic_info
(
    id                     bigint                             auto_increment comment '物理主键' primary key,
    company_name           varchar(300)                       not null comment '企业名称',
    credit_code            varchar(100)                       null comment '统一社会信用代码',
    leg_represent          varchar(300)                       null comment '法定代表人',
    telephone              varchar(200)                       null comment '电话',
    email                  varchar(200)                       null comment '邮箱',
    website                varchar(200)                       null comment '网址',
    address                varchar(500)                       null comment '地址',
    profile                text                               null comment '简介',
    main_officer           json                               null comment '主要人员',
    sharehd_info           json                               null comment '股东信息',
    delete_flag            tinyint  default 0                 not null comment '删除标志：0-正常状态，1-逻辑删除',
    create_by              bigint   default 1100              not null comment '创建者',
    create_time            datetime default CURRENT_TIMESTAMP not null comment '创建时间',
    update_by              bigint                             null comment '更新者',
    update_time            datetime                           null comment '更新时间',
    version                bigint   default 1                 not null comment '版本号'
) comment '企业基本信息' charset = utf8mb4;

3.后端代码

采用mybatis-plus持久层框架3.4.0版本，框架封装好了CRUD接口，简单易用，以下主要介绍如何接入json类型字段

Entiy代码

主要人员和股东信息这两个json字段注意要添加@TableField(typeHandler = acksonTypeHandler.class),
CompanyBasicInfoEntity实体类中@TableName注解映射中配置映射表名和resultMap是必须的后续xml中会用到，
SpanBaseEntity已封装好了delete_flag,create_by,…,version基础字段

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
/**
 * @author yinshuang
 * @date 2023-06-10
 * @description CompanyBasicInfo 企业基本信息表
 */
@Data
@EqualsAndHashCode(callSuper = true)
@NoArgsConstructor
@TableName(value = "company_basic_info", autoResultMap = true, resultMap = "BaseResultMap")
public class CompanyBasicInfoEntity extends SpanBaseEntity<CompanyBasicInfoEntity> {

    /**
     * 物理主键
     */
    @TableId(value = "id", type = IdType.AUTO)
    private Long id;

    /**
     * 机构名称
     */
    private String companyName;

    /**
     * 社会信用代码
     */
    private String creditCode;

    /**
     * 法定代表人
     */
    private String legRepresent;

    /**
     * 电话
     */
    private String telephone;

    /**
     * 邮箱
     */
    private String email;

    /**
     * 网址
     */
    private String website;

    /**
     * 地址
     */
    private String address;

    /**
     * 简介
     */
    private String profile;

    /**
     * 主要人员
     */
    @TableField(typeHandler = JacksonTypeHandler.class)
    private List<MainOfficerVO> mainOfficer;

    /**
     * 股东信息
     */
    @TableField(typeHandler = JacksonTypeHandler.class)
    private List<SharehdInfoVO> sharehdInfo;
}
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
/**
 * @author yinshuang
 * @date 2023/6/10
 * @description MainOfficerVO 主要人员
 */
@Data
public class MainOfficerVO {

    /**
     * 序号
     */
    private Integer id;

    /**
     * 姓名
     */
    private String name;

    /**
     * 职位
     */
    private String position;

    /**
     * 持股比例
     */
    private String sharehdRatio;

    /**
     * 最终受益股份
     */
    private String finalBenefitShares;
}
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
/**
 * @author yinshuang
 * @date 2023/6/10
 * @description SharehdInfoVO 股东信息
 */
@Data
public class SharehdInfoVO {

    /**
     * 序号
     */
    private Integer id;

    /**
     * 股东
     */
    private String sharehdName;

    /**
     * 持股比例
     */
    private String sharehdRatio;

    /**
     * 最终受益股份
     */
    private String finalBenefitShares;

    /**
     * 认缴出资额
     */
    private BigDecimal subscribeAmout;

    /**
     * 认缴出资日期
     */
    private String subscribeDate;
}
Mapper和Mapper XML代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
/**
 * @author yinshuang
 * @date 2023/6/10
 * @description CompanyBasicInfoMapper 企业基本信息
 */
@Mapper
public interface CompanyBasicInfoMapper extends BaseMapper<CompanyBasicInfoEntity> {

    /**
     * 机构基本信息
     *
     * @param creditCode 统一社会信用代码
     * @return CompanyBasicInfoEntity
     */
    CompanyBasicInfoEntity selectByCreditCode(String creditCode);
}

注意main_officer和sharehd_info这两个json字段resultMap写法

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
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.chinacscs.factoring.core.mapper.CompanyBasicInfoMapper">
    
    <resultMap id="BaseResultMap" type="com.chinacscs.factoring.core.entity.CompanyBasicInfoEntity">
        <id column="id" jdbcType="BIGINT" property="id"/>
        <id column="company_name" jdbcType="VARCHAR" property="companyName"/>
        <id column="credit_code" jdbcType="VARCHAR" property="creditCode"/>
        <id column="leg_represent" jdbcType="VARCHAR" property="legRepresent"/>
        <id column="telephone" jdbcType="VARCHAR" property="telephone"/>
        <id column="email" jdbcType="VARCHAR" property="email"/>
        <id column="website" jdbcType="VARCHAR" property="website"/>
        <id column="address" jdbcType="VARCHAR" property="address"/>
        <id column="profile" jdbcType="VARCHAR" property="profile"/>
        <id column="main_officer" property="mainOfficer" typeHandler="com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler"/>
        <id column="sharehd_info" property="sharehdInfo" typeHandler="com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler"/>
        <id column="delete_flag" jdbcType="TINYINT" property="deleteFlag"/>
        <id column="create_by" jdbcType="BIGINT" property="createBy"/>
        <id column="create_time" jdbcType="TIMESTAMP" property="createTime"/>
        <id column="update_by" jdbcType="BIGINT" property="updateBy"/>
        <id column="update_time" jdbcType="TIMESTAMP" property="updateTime"/>
        <id column="version" jdbcType="BIGINT" property="version"/>
    </resultMap>
    
    <sql id="Base_Column_List">
        id,
        company_name,
        credit_code,
        leg_represent,
        telephone,
        email,
        website,
        address,
        profile,
        main_officer,
        sharehd_info,
        delete_flag,
        create_by,
        create_time,
        update_by,
        update_time,
        version
    </sql>

    <select id="selectByCreditCode" resultType="com.chinacscs.factoring.core.entity.CompanyBasicInfoEntity">
        select
        <include refid="Base_Column_List"/>
        from company_basic_info
        where credit_code = #{creditCode}
    </select>
</mapper>

Service代码

举例CRU操作

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
/**
 * @author yinshuang
 * @date 2023/6/10
 * @description CompanyBasicInfoServiceImpl
 */
@Slf4j
@Service()
@RequiredArgsConstructor(onConstructor_ = {@Autowired})
public class CompanyBasicInfoServiceImpl implements ICompanyBasicInfoService {

    private final CompanyBasicInfoMapper companyBasicInfoMapper;

    @Override
    public CompanyBasicInfoVO detail(String creditCode) {
        return getCompanyBasicInfoVO(companyBasicInfoMapper.selectByCreditCode(creditCode));
    }

    private CompanyBasicInfoVO getCompanyBasicInfoVO(CompanyBasicInfoEntity entity) {
        return BeanUtil.getClass(CompanyBasicInfoVO.class, entity).orElse(new CompanyBasicInfoVO());
    }

    @Override
    public boolean save(CompanyBasicInfoDTO dto) {
        if (Objects.isNull(dto.getId())) {
            return insert(dto);
        }
        return update(dto);
    }

    private boolean insert(CompanyBasicInfoDTO dto) {
        return BeanUtil.getClass(CompanyBasicInfoEntity.class, dto).map(entity -> {
            return companyBasicInfoMapper.insert(entity) > 0;
        }).orElse(false);
    }

    private boolean update(CompanyBasicInfoDTO dto) {
        return Optional.ofNullable(companyBasicInfoMapper.selectById(dto.getId())).map(entity -> {
            BeanUtil.copyProperties(dto, entity);
            entity.setUpdateTime(LocalDateTime.now());
            entity.setUpdateBy(CurrentUserUtil.getCurrentUserId());
            return companyBasicInfoMapper.updateById(entity) > 0;
        }).orElse(false);
    }
}

案例二 自定义动态表单

整理中敬请期待。。。

赏

谢谢你请我吃糖果

微信

扫一扫，分享到微信

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia-plus根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置：

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true

主要涉及技术：
Java后端开发


联系QQ:875038467

很惭愧

只做了一点微小的工作
谢谢大家