Κοινή χρήση τεχνολογίας

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

εισαγωγή

Στην ανάπτυξη έργου Springboot, μια σχεσιακή βάση δεδομένων χρησιμοποιείται γενικά ως η κύρια βάση δεδομένων για την αποθήκευση δεδομένων Μερικές φορές τα επαγγελματικά σενάρια απαιτούν επέκταση προσαρμοσμένων επιχειρηματικών πληροφοριών στην υπάρχουσα δομή πίνακα. Σε αυτό το σενάριο, χρησιμοποιείται γενικά η αποθήκευση τύπου json. Αυτό το άρθρο συνοψίζει την πρακτική λύση για τη λειτουργία του json στο έργο Springboot με τη βοήθεια του Mybatis-plus.

2. Στοίβα τεχνολογίας

Spring boot + Mybatis-plus + PostgreSQL, ένα συγκεκριμένο πεδίο στη βάση δεδομένων PostgreSQL είναι τύπου json.

3. Ανάλυση υποβάθρου

Στο MyBatis, ο χειριστής τύπων (TypeHandler) παίζει το ρόλο μιας γέφυρας μεταξύ JavaType και JdbcType. Χρησιμοποιούνται για τον ορισμό της τιμής ενός αντικειμένου Java σε μια PreparedStatement κατά την εκτέλεση μιας πρότασης SQL ή για την ανάκτηση μιας τιμής από ένα ResultSet ή ένα CallableStatement.

Το MyBatis-Plus σας παρέχει ορισμένους ενσωματωμένους επεξεργαστές, οι οποίοι μπορούν να είναι TableField Οι σχολιασμοί εισάγονται γρήγορα στο κοντέινερ MyBatis, απλοποιώντας τη διαδικασία ανάπτυξης. Επίσημο έγγραφο αναφοράς επεξεργαστή τύπου πεδίου MyBatis-Plus:Επεξεργαστής τύπου πεδίου MyBatis-Plus (baomidou.com)

Χειριστής τύπου πεδίου JSON

Το MyBatis-Plus διαθέτει μια ποικιλία από ενσωματωμένους επεξεργαστές τύπου JSON, μεταξύ των οποίων AbstractJsonTypeHandler και τις υποκατηγορίες τουFastjson2TypeHandler、FastjsonTypeHandler、GsonTypeHandler、JacksonTypeHandler Περίμενε. Αυτοί οι επεξεργαστές μπορούν να μετατρέψουν συμβολοσειρές JSON προς και από αντικείμενα Java.

4. Ανάλυση προγράμματος

4.1 Αποθηκεύστε απευθείας τα αντικείμενα json στη βάση δεδομένων PostgreSQL

Τα πεδία βάσης δεδομένων PostgreSQL φαίνονται στο παραπάνω σχήμα: το param_config είναι πεδίο τύπου json.

Βήμα 1: Σύνταξη οντοτήτων DO

Ο τύπος δεδομένων πεδίου είναι com.alibaba.fastjson2.JSONObject 。

@Data
@Accessors(chain = true)
@TableName(autoResultMap = true)
public class User {
    
    private Long id;

    ...

    /**
   	 * 关键代码！！！
     * 必须开启映射注解
     *
     * @TableName(autoResultMap = true)
     *
     * 选择对应的 JSON 处理器，并确保存在对应的 JSON 解析依赖包
     */
    @TableField(value = "param_config", typeHandler = JacksonTypeHandler.class)
    // 或者使用 FastjsonTypeHandler
    // @TableField(typeHandler = FastjsonTypeHandler.class)
    private JSONObject paramConfig;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

Βήμα 2: Ρύθμιση παραμέτρων XML αντίστοιχη μέθοδος γραφής

<!-- 关键代码！！！！！！！ -->
<!-- 单个字段的类型处理器配置 -->
<result column="param_config" jdbcType="VARCHAR" property="paramConfig" typeHandler="com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler" />

<!-- 多个字段中某个字段的类型处理器配置 -->
<resultMap id="departmentResultMap" type="com.baomidou...DepartmentVO">
    <result property="director" column="director" typeHandler="com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler" />
</resultMap>
<select id="selectPageVO" resultMap="departmentResultMap">
   select id,name,director from department ...
</select>
1
2
3
4
5
6
7
8
9
10
11

Δείτε τα αποτελέσματα που είναι αποθηκευμένα στη βάση δεδομένων, όπως φαίνεται παρακάτω:

4.2 Αποθήκευση συμβολοσειρών json στη βάση δεδομένων PostgreSQL

Πρώτα προσθέστε μετά τη διεύθυνση URL της βάσης δεδομένων PostgreSQL &stringtype=απροσδιόριστο, σημειώστε ότι εάν αυτή η ρύθμιση παραμέτρων προηγείται απευθείας από το όνομα της βάσης δεδομένων, θα πρέπει να το κάνετε & Αντικατέστησε με? 。

Βήμα 1: Σύνταξη κλάσης οντοτήτων DO

@TableField(value = "param_config", typeHandler = JacksonTypeHandler.class)
private String paramConfig;
1
2

Βήμα 2: Ρύθμιση παραμέτρων XML αντίστοιχη μέθοδος γραφής

<!-- 单个字段的类型处理器配置 -->
<result column="param_config" jdbcType="VARCHAR" property="paramConfig" typeHandler="com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler" />
1
2

Δείτε τα αποτελέσματα που είναι αποθηκευμένα στη βάση δεδομένων, όπως φαίνεται παρακάτω:

5. Επεξεργαστής προσαρμοσμένου τύπου

Στο MyBatis-Plus, εκτός από τη χρήση του ενσωματωμένου επεξεργαστή τύπου, οι προγραμματιστές μπορούν επίσης να προσαρμόσουν τους επεξεργαστές τύπου ανάλογα με τις ανάγκες.

Για παράδειγμα, όταν χρησιμοποιείτε μια βάση δεδομένων PostgreSQL, ενδέχεται να συναντήσετε πεδία τύπου JSON. Σε αυτήν την περίπτωση, μπορείτε να δημιουργήσετε έναν προσαρμοσμένο τύπο επεξεργαστή για την επεξεργασία δεδομένων JSON.

5.1 Καθορισμός χειριστών τύπου

Το παρακάτω είναι ένα παράδειγμα προσαρμοσμένου επεξεργαστή τύπου JSON:

package com.ruoyi.common.utils.pg;

import com.ruoyi.common.utils.StringUtils;
import org.apache.ibatis.type.BaseTypeHandler;
import org.apache.ibatis.type.JdbcType;
import org.apache.ibatis.type.MappedTypes;
import org.postgresql.util.PGobject;

import java.sql.CallableStatement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

/**
 * @ClassName: JsonTypeHandlerPg
 * @Description: json对象处理
 * @Author: hjm
 * @Date: 2024-07-11 10:34
 */
@MappedTypes(String.class)
public class JsonTypeHandlerPg extends BaseTypeHandler<String> {

    /**
     * 引入PGSQL提供的工具类PGobject
     */
    private static final PGobject JSON_OBJECT = new PGobject();
    public static final String JSON_TYPE = "json";

    /**
     * 关键位置!!!
     */
    @Override
    public void setNonNullParameter(PreparedStatement ps, int i, String param, JdbcType jdbcType) throws SQLException {
        JSON_OBJECT.setType(JSON_TYPE);
        JSON_OBJECT.setValue(param);
        ps.setObject(i, JSON_OBJECT);
    }

    @Override
    public String getNullableResult(ResultSet rs, String columnName) throws SQLException {
        String sqlJson = rs.getString(columnName);
        if (StringUtils.isNotBlank(sqlJson)) {
            return sqlJson;
        }
        return null;
    }

    // 根据列索引，获取可以为空的结果
    @Override
    public String getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
        String sqlJson = rs.getString(columnIndex);
        if (StringUtils.isNotBlank(sqlJson)) {
            return sqlJson;
        }
        return null;
    }

    @Override
    public String getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
        String sqlJson = cs.getString(columnIndex);
        if (StringUtils.isNotBlank(sqlJson)) {
            return sqlJson;
        }
        return null;
    }
}
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

5.2 Χρήση επεξεργαστών προσαρμοσμένου τύπου

Στην κατηγορία οντοτήτων, περάστε TableField Οι σχολιασμοί καθορίζουν χειριστές προσαρμοσμένου τύπου:

/**
 * 测试对象
 *
 * @author hjm
 * @date 2024-07-11
 */
@Data
@EqualsAndHashCode(callSuper = true)
@TableName("data_test")
public class DataTest extends BaseEntity {

    private static final long serialVersionUID = 1L;

    /**
     * 主键
     */
    @TableId(value = "id")
    private Long id;
    
    /**
     * 关键位置!!!
     */
    @TableField(typeHandler = JsonTypeHandlerPg.class)
    private String jsonData;
}
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

Τροποποίηση αρχείου mapper

<?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.ruoyi.dt.mapper.DataTestMapper">

    <resultMap type="com.ruoyi.dt.domain.DataTest" id="DataTestResult">
        <result property="id" column="id"/>
		<!-- 关键位置!!! -->
        <result property="jsonData" column="json_data" typeHandler="com.ruoyi.common.utils.pg.JsonTypeHandlerPg"/>
        <result property="createBy" column="create_by"/>
        <result property="createTime" column="create_time"/>
        <result property="updateBy" column="update_by"/>
        <result property="updateTime" column="update_time"/>
    </resultMap>

</mapper>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

Κωδικός επιχείρησης

    /**
     * 新增数据
     */
    @Override
    public Boolean insertByAo(DataTestAo ao) {
        DataTest add = BeanUtil.toBean(ao, DataTest.class);
        // 关键位置!!!
		add.setJsonData(JSONUtil.toJsonStr(ao));
        validEntityBeforeSave(add);
        boolean flag = baseMapper.insert(add) > 0;
        if (flag) {
            ao.setId(add.getId());
        }
        return flag;
    }

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

Αυτό το άρθρο τελείωσε!