• SpringBoot、MyBatis、PostgreSQL储存JSON、对象等自定义TypeHandler

            由于MyBatis没有提供直接处理JSON的方法，因此需要自己实现处理JSON的类，并继承BaseTypeHandler来处理储存JSON字段。

           一、JSON转换

            首先引入pom文件：

    1. <dependency>
    2.     <groupId>org.postgresqlgroupId>
    3.     <artifactId>postgresqlartifactId>
    4. dependency>

            实体类接收定义为Object：

    1. import lombok.Data;
    2.  
    3.  
    4. @Data
    5. public class TestJson {
    6.     private Long id;
    7.    
    8.  
    9.     private Object value;
    10. }

            创建Handler：

    1. import org.apache.ibatis.type.BaseTypeHandler;
    2. import org.apache.ibatis.type.JdbcType;
    3. import org.apache.ibatis.type.MappedTypes;
    4. import org.postgresql.util.PGobject;
    5.  
    6. import java.sql.CallableStatement;
    7. import java.sql.PreparedStatement;
    8. import java.sql.ResultSet;
    9. import java.sql.SQLException;
    10.  
    11.  
    12. @MappedTypes({Object.class})
    13. public class JsonTypeHandler extends BaseTypeHandler {
    14.     //引入PGSQL提供的工具类PGobject
    15.     private static final PGobject jsonObject = new PGobject();
    16.  
    17.     @Override
    18.     public void setNonNullParameter(PreparedStatement ps, int i, Object parameter, JdbcType jdbcType) throws SQLException {
    19.         jsonObject.setType("json");
    20.         jsonObject.setValue(parameter.toString());
    21.         ps.setObject(i, jsonObject);
    22.     }
    23.  
    24.     @Override
    25.     public Object getNullableResult(ResultSet rs, String s) throws SQLException {
    26.  
    27.         return rs.getString(s);
    28.     }
    29.  
    30.     @Override
    31.     public Object getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
    32.         return rs.getString(columnIndex);
    33.     }
    34.  
    35.     @Override
    36.     public Object getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
    37.         return cs.getString(columnIndex);
    38.     }
    39. }
      40.  

              需要在Mapper.xml文件中加入：
       

      1.  <result column="classify_value" jdbcType="OTHER"
      2.              property="classifyValue" typeHandler="xx.xx.xx.JsonTypeHandler"/>
       

              typeHandler指的是自定义的JsonTypeHandler 的全类限定名。
       

              二、List转换 

              存储对象实际上存储的也是JSON，只是需要对接收的参数进行一定的处理，比如传入的List，这里的Object指自定义的java对象，其余的处理都跟传入Object一致，只需要进行Handler的编写：
       

              定义一个Java对象：
       

      1.  
      2. import lombok.Data;
      3.  
      4.  
      5. import java.util.List;
      6.  
      7. @Data
      8. public class ListObjectTest{
      9.  
      10.     
      11.     private String name;
      12.  
      13.     
      14.     private Stirng address;
      15. }
       

              编写自定义的Handler： 
       

      1. @MappedJdbcTypes({JdbcType.VARCHAR})
      2. @MappedTypes(value = {List.class})
      3. public class ListObjectHandler extends BaseTypeHandler> {
      4.  
      5.     @SneakyThrows
      6.     @Override
      7.     public void setNonNullParameter(PreparedStatement ps, int i, List parameter, JdbcType jdbcType) throws SQLException {
      8.         ps.setString(i, JSONUtil.toJsonStr(parameter));
      9.     }
      10.  
      11.     @SneakyThrows
      12.     @Override
      13.     public List getNullableResult(ResultSet rs, String  columnName){
      14.         String value = rs.getString(columnName);
      15.         return JSONUtil.parseArray(value).toList(TestListObject.class);
      16.     }
      17.  
      18.     @SneakyThrows
      19.     @Override
      20.     public List getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
      21.         String value = rs.getString(columnIndex);
      22.         return JSONUtil.parseArray(value).toList(TestListObject.class);
      23.  
      24.     }
      25.  
      26.     @SneakyThrows
      27.     @Override
      28.     public List getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
      29.         String value = cs.getString(columnIndex);
      30.         return JSONUtil.parseArray(value).toList(TestListObject.class);
      31.     }
      32. }
       

              三、List转换
       

              handler编写：
       

      1. import lombok.SneakyThrows;
      2. import org.apache.ibatis.type.BaseTypeHandler;
      3. import org.apache.ibatis.type.JdbcType;
      4. import org.apache.ibatis.type.MappedJdbcTypes;
      5. import org.apache.ibatis.type.MappedTypes;
      6.  
      7. import java.sql.CallableStatement;
      8. import java.sql.PreparedStatement;
      9. import java.sql.ResultSet;
      10. import java.sql.SQLException;
      11. import java.util.ArrayList;
      12. import java.util.Arrays;
      13. import java.util.List;
      14.  
      15. @MappedJdbcTypes({JdbcType.VARCHAR})
      16. @MappedTypes(value = {List.class})
      17. public class HeadersTypeHandler extends BaseTypeHandler> {
      18.  
      19.     @SneakyThrows
      20.     @Override
      21.     public void setNonNullParameter(PreparedStatement ps, int i, List parameter, JdbcType jdbcType) throws SQLException {
      22.         ps.setString(i, String.join(",", parameter));
      23.     }
      24.  
      25.     @SneakyThrows
      26.     @Override
      27.     public List getNullableResult(ResultSet rs, String columnName) {
      28.         String value = rs.getString(columnName);
      29.         if (value == null) {
      30.             return new ArrayList<>();
      31.         }
      32.         return Arrays.asList(value.split(","));
      33.     }
      34.  
      35.     @SneakyThrows
      36.     @Override
      37.     public List getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
      38.         String value = rs.getString(columnIndex);
      39.         if (value == null) {
      40.             return new ArrayList();
      41.         }
      42.         return Arrays.asList(value.split(","));
      43.     }
      44.  
      45.     @SneakyThrows
      46.     @Override
      47.     public List getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
      48.         String value = cs.getString(columnIndex);
      49.         if (value == null) {
      50.             return new ArrayList<>();
      51.         }
      52.         return Arrays.asList(value.split(","));
      53.     }
      54. }
       

              四、List转换
       

              handler：
       

      1. import cn.hutool.json.JSONUtil;
      2. import com.pearadmin.system.domain.ProductStrategyDetail;
      3. import lombok.extern.slf4j.Slf4j;
      4. import org.apache.commons.lang.StringEscapeUtils;
      5. import org.apache.ibatis.type.BaseTypeHandler;
      6. import org.apache.ibatis.type.JdbcType;
      7. import org.apache.ibatis.type.MappedJdbcTypes;
      8. import org.apache.ibatis.type.MappedTypes;
      9.  
      10. import java.sql.CallableStatement;
      11. import java.sql.PreparedStatement;
      12. import java.sql.ResultSet;
      13. import java.sql.SQLException;
      14. import java.util.List;
      15.  
      16. @MappedJdbcTypes({JdbcType.OTHER})
      17. @MappedTypes(value = {List.class})
      18. @Slf4j
      19. public class DetailHandler extends BaseTypeHandler {
      20.  
      21.     @Override
      22.     public void setNonNullParameter(PreparedStatement preparedStatement, int i, List list, JdbcType jdbcType) throws SQLException {
      23.         preparedStatement.setString(i, JSONUtil.toJsonStr(list));
      24.     }
      25.  
      26.     @Override
      27.     public List getNullableResult(ResultSet resultSet, String s) throws SQLException {
      28.         String value = resultSet.getString(s);
      29.         if (value == null) {
      30.             return null;
      31.         }
      32.         return JSONUtil.toList(value, ProductStrategyDetail.class);
      33.     }
      34.  
      35.     @Override
      36.     public List getNullableResult(ResultSet resultSet, int i) throws SQLException {
      37.         String value = resultSet.getString(i);
      38.         if (value == null) {
      39.             return null;
      40.         }
      41.         return JSONUtil.toList(value, ProductStrategyDetail.class);
      42.     }
      43.  
      44.     @Override
      45.     public List getNullableResult(CallableStatement callableStatement, int i) throws SQLException {
      46.         String value = callableStatement.getString(i);
      47.         if (value == null) {
      48.             return null;
      49.         }
      50.         return JSONUtil.toList(value, ProductStrategyDetail.class);
      51.     }
      52. }
       

              五、Map转换
       

              handler：
       

      1. import cn.hutool.json.JSONUtil;
      2. import com.fasterxml.jackson.databind.ObjectMapper;
      3. import lombok.SneakyThrows;
      4. import lombok.extern.slf4j.Slf4j;
      5. import org.apache.ibatis.type.BaseTypeHandler;
      6. import org.apache.ibatis.type.JdbcType;
      7. import org.apache.ibatis.type.MappedJdbcTypes;
      8. import org.apache.ibatis.type.MappedTypes;
      9.  
      10. import java.io.IOException;
      11. import java.lang.reflect.InvocationTargetException;
      12. import java.math.BigDecimal;
      13. import java.nio.charset.StandardCharsets;
      14. import java.sql.CallableStatement;
      15. import java.sql.PreparedStatement;
      16. import java.sql.ResultSet;
      17. import java.sql.SQLException;
      18. import java.util.HashMap;
      19. import java.util.Map;
      20.  
      21. @MappedJdbcTypes({JdbcType.VARCHAR})
      22. @MappedTypes(value = {Map.class})
      23. @Slf4j
      24. public class JsonTypeHandler extends BaseTypeHandler {
      25.  
      26.     private ObjectMapper objectMapper = new ObjectMapper();
      27.  
      28.     @SneakyThrows
      29.     @Override
      30.     public void setNonNullParameter(PreparedStatement ps, int i, Map parameter, JdbcType jdbcType) throws SQLException {
      31.         ps.setString(i, objectMapper.writeValueAsString(parameter));
      32.     }
      33.  
      34.     @SneakyThrows
      35.     @Override
      36.     public Map getNullableResult(ResultSet rs, String columnName) {
      37.         String value = rs.getString(columnName);
      38.         if (value == null) {
      39.             return new HashMap();
      40.         }
      41.         Map map = objectMapper.readValue(value.getBytes(), Map.class);
      42.         return toStructureElementObjectMap(map);
      43.     }
      44.  
      45.     @SneakyThrows
      46.     @Override
      47.     public Map getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
      48.         String value = rs.getString(columnIndex);
      49.         if (value == null) {
      50.             return new HashMap();
      51.         }
      52.         Map map = objectMapper.readValue(value.getBytes(), Map.class);
      53.         return toStructureElementObjectMap(map);
      54.     }
      55.  
      56.     @SneakyThrows
      57.     @Override
      58.     public Map getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
      59.         String value = cs.getString(columnIndex);
      60.         if (value == null) {
      61.             return new HashMap();
      62.         }
      63.         Map map = objectMapper.readValue(value.getBytes(), Map.class);
      64.         return toStructureElementObjectMap(map);
      65.     }
      66.  
      67.  
      68. }
       

      
                
                    
                

                
    40. 

                    相关阅读:
      
                    
基于java+springboot+mybatis+vue+elementui的人职匹配推荐系统                            
      
古代汉语 郭锡良版本 复习要点                            
      
不断迭代的收银系统，工厂_策略_装饰器_反射                            
      
STM32H743 RTC精密数字校准 深度剖析                            
      
公司只有功能测试，如何进一步提升自己？                            
      
ATFX汇市：欧央行利率决议来袭，能够逆转欧元跌势吗？                            
      
微信小程序 生成跳转体验版url，可直接跳转到体验版小程序（可通过此方法测试模板消息）                            
      
Nomad 系列-Nomad+Traefik+Tailscale 集成实现零信任安全                            
      
i7 11800h和i7 12800hx选哪个好                            
      
MySQL8实现主从备份                            
      
                          
                
      41. 
                
    41. 
                    原文地址：https://blog.csdn.net/qq_41061437/article/details/126951993
                
      42.