IT评测·应用市场-qidao123.com技术社区

标题: springboot~mybatis-plus更优雅的处理mysql8.0的json字段 [打印本页]

---

作者: 祗疼妳一个    时间: 2025-4-10 09:24
标题: springboot~mybatis-plus更优雅的处理mysql8.0的json字段
MySQL 8.0 引入了许多新特性和改进，旨在增强性能、可用性和安全性。以下是一些主要的新特性：数据字典，窗口函数，公共表表达式 (CTE)，JSON 改进，隐式列和生成列，字符集和排序规则，原生支持 GIS 功能，支持更强的 SSL/TLS 加密选项等。
下面文章主要介绍mysql字段为Json类型主动映射到java的实体类型的方法：
数据表结构

1. CREATE TABLE user_actions (
2.     action_id INT PRIMARY KEY,
3.     user_id INT,
4.     action_time DATETIME,
5.     action_details JSON
6. );
8. -- 示例数据插入
9. INSERT INTO user_actions (action_id, user_id, action_time, action_details) VALUES
10. (1, 1, '2025-04-01 10:00:00', '{"action": "login", "duration": 120}'),
11. (2, 1, '2025-04-02 11:00:00', '{"action": "view", "item_id": 101, "duration": 300}'),
12. (3, 2, '2025-04-05 12:00:00', '{"action": "login", "duration": 150}'),
13. (4, 3, '2025-04-08 13:00:00', '{"action": "purchase", "item_id": 102, "amount": 29.99}'),
14. (5, 2, '2025-04-09 14:00:00', '{"action": "view", "item_id": 103, "duration": 200}'),
15. (6, 3, '2025-04-09 15:00:00', '{"action": "view", "item_id": 101, "duration": 100}');

复制代码

实体结构

1. @Data
2. @TableName(value = "user_actions", autoResultMap = true)
3. public class UserAction {
5.         private Integer actionId;
7.         private Integer userId;
9.         private LocalDateTime actionTime;
11.         @TableField(typeHandler = JsonTypeHandler.class)
12.         private ActionDetail actionDetails;
14. }
16. @Data
17. class ActionDetail {
19.         private String action;
21.         private Integer duration;
23.         @JsonProperty("item_id")
24.         private Integer itemId;
26.         private double amount;
28. }

复制代码

注意：实体类必要添加@TableName(autoResultMap = true)
字段上添加对应的注解@TableField(typeHandler = JsonTypeHandler.class)

类型转换器JsonTypeHandler代码

1. @MappedTypes(Map.class)
2. public class JsonTypeHandler<T> extends BaseTypeHandler<T> {
4.         private static final ObjectMapper objectMapper = new ObjectMapper();
6.         private Class<T> type;
8.         public JsonTypeHandler(Class<T> type) {
9.                 this.type = type;
10.         }
12.         @Override
13.         public void setNonNullParameter(PreparedStatement ps, int i, T parameter, JdbcType jdbcType) throws SQLException {
14.                 try {
15.                         ps.setString(i, objectMapper.writeValueAsString(parameter));
16.                 }
17.                 catch (IOException e) {
18.                         throw new SQLException("Failed to convert JSON to String", e);
19.                 }
20.         }
22.         @Override
23.         public T getNullableResult(ResultSet rs, String columnName) throws SQLException {
24.                 String json = rs.getString(columnName);
25.                 if (json != null) {
26.                         try {
27.                                 return objectMapper.readValue(json, type);
28.                         }
29.                         catch (IOException e) {
30.                                 throw new SQLException("Failed to convert String to JSON", e);
31.                         }
32.                 }
33.                 return null;
34.         }
36.         @Override
37.         public T getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
38.                 String json = rs.getString(columnIndex);
39.                 if (json != null) {
40.                         try {
41.                                 return objectMapper.readValue(json, type);
42.                         }
43.                         catch (IOException e) {
44.                                 throw new SQLException("Failed to convert String to JSON", e);
45.                         }
46.                 }
47.                 return null;
48.         }
50.         @Override
51.         public T getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
52.                 String json = cs.getString(columnIndex);
53.                 if (json != null) {
54.                         try {
55.                                 return objectMapper.readValue(json, type);
56.                         }
57.                         catch (IOException e) {
58.                                 throw new SQLException("Failed to convert String to JSON", e);
59.                         }
60.                 }
61.                 return null;
62.         }
64. }

复制代码

最后，可正常剖析出效果

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

---

欢迎光临 IT评测·应用市场-qidao123.com技术社区 (https://dis.qidao123.com/)

Powered by Discuz! X3.4