0
点赞
收藏
分享

微信扫一扫

Mybatis存储数据将数据转为json

夕阳孤草 2024-05-09 阅读 44
mybatisjsonajax

第一种方法

  1. 先创建一个表类型如下
    在这里插入图片描述
  2. 创建一个项目，写一个接口 ，
    在这里插入图片描述
  3. 写一个JsonTypeHandler类继承BaseTypeHandler
public class JsonTypeHandler<T> extends BaseTypeHandler<T> {
    private Class<T> clazz;
    //构造函数 --- >接收一个 Class 对象作为参数，用于指定处理的数据类型。
    public JsonTypeHandler(Class<T> clazz) {
        this.clazz = clazz;
    }
    public JsonTypeHandler() {
    }

    //插入数据将任何类型转换为json
    @Override
    public void setNonNullParameter(PreparedStatement ps, int i, T parameter, JdbcType jdbcType) throws SQLException {
        ps.setString(i, JSON.toJSONString(parameter));
    }

    //获取数据json转换类型
    @Override
    public T getNullableResult(ResultSet rs, String columnName) throws SQLException {
        return JSON.parseObject(rs.getString(columnName), clazz);
    }

    @Override
    public T getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
        return null;
    }

    @Override
    public T getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
        return null;
    }
}
实体类
@Data
public class User {
    private Integer id;
    private String name;
    private Map<String,String> addressBook;
    private Adderss friendAddress;
    private List<Animal> pet;    
}

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class Animal {
    public String name;
    public String category;

}

@Data
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class Adderss{
    private String province;
    private String city;
    private String area;
}
Controller
@RestController
public class UserController {

    @Autowired
    private UserService userService;

    @GetMapping("/api/add")
    public void add(){
        User user = new User();
        user.setName("小明");

        Map map = new HashMap();
        map.put("张三","123123132");
        map.put("李四","789789798");
        map.put("王五","456456464");
        // String s = JSONUtil.toJsonStr(map);
        user.setAddressBook(map);


        Adderss adderss = Adderss.builder().province("河南省").city("郑州市").area("高新区").build();
        user.setFriendAddress(adderss);

        List<Animal> list = new ArrayList<>();
        list.add(Animal.builder().name("喵喵").category("哺乳类").build());
        list.add(Animal.builder().name("汪汪").category("哺乳类").build());
        list.add(Animal.builder().name("鹦鹉").category("鸟类").build());
        //String s1 = JSONUtil.toJsonStr(list);
        user.setPet(list);
        userService.add(user);
    }

    @GetMapping("/api/select")
    public List<User> select(){
        List<User> select = userService.select();
        return null;
    }

}
Service
@Service
public class UserService {

    @Autowired
    private UserDao userDao;

    public  List<User> select() {
        return userDao.select();
    }
    
    public void add(User user){
     userDao.add(user);
    }
}
Dao
@Mapper
public interface UserDao {
     
     void add(User user);
     List<User> select();
}
Mapper.xml 主要使用是在xml中配置类型 typeHandler=“com.by.config.JsonTypeHandler”
<?xml version="1.0" encoding="UTF-8" ?>
           <!DOCTYPE mapper
                   PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
                   "https://mybatis.org/dtd/mybatis-3-mapper.dtd">
   <-- -->
   <mapper namespace="com.by.dao.UserDao">
    <resultMap id="UserMap" type="com.by.moder.User">
       <result property="id" column="id"/>
       <result property="addressBook" column="addressBook" typeHandler="com.by.config.JsonTypeHandler"/>
       <result property="friendAddress" column="friendAddress" typeHandler="com.by.config.JsonTypeHandler"/>
       <result property="pet" column="pet" typeHandler="com.by.config.JsonTypeHandler"/>
    </resultMap>

    <insert id="add">
        insert into user2 (name, addressBook, friendAddress,pet)
        values (#{name}, #{addressBook,typeHandler=com.by.config.JsonTypeHandler}, #{friendAddress,typeHandler=com.by.config.JsonTypeHandler},#{pet,typeHandler=com.by.config.JsonTypeHandler})
    </insert>
    <select id="select" resultMap="UserMap">
        select * from user2
    </select>
   </mapper>

添加结果
在这里插入图片描述
查询结果
在这里插入图片描述
虽然结果可以的出来但是pet类型不对，list中本来该存放的是Animal对象，但存储的确实json类型。
有没有什么办法可以将全类名和这个对象都存储到数据库（以json类型形式），取得时候就可以得到与它对应的的类型

第二种方法：根据redis配置文件进行改进

使用Jackson2JsonRedisSerializer ，它 Spring Data Redis 提供的一个序列化器，用于将 Java 对象序列化为 JSON 字符串存储到 Redis 中，以及从 Redis 中读取 JSON 字符串反序列化回 Java 对象

  1. 添加依赖
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>

2.改进

public class JsonTypeHandler02<T> extends BaseTypeHandler<T> {
    private Class<T> clazz;
    Jackson2JsonRedisSerializer<Object> serializer;
    public JsonTypeHandler02(Class<T> clazz) {
        this.clazz = clazz;
       serializer = new Jackson2JsonRedisSerializer<>(Object.class);

        //定义一个对象映射器
        ObjectMapper objectMapper = new ObjectMapper();
        //JsonAutoDetect.Visibility.ANY 代表所有属性或字段都可以序列化
        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        //新版用法
        //以数组的方式存放到Redis，Class Type 全类名作为为第一个元素，Json字符串为第二个元素。
        objectMapper.activateDefaultTyping(objectMapper.getPolymorphicTypeValidator(), ObjectMapper.DefaultTyping.NON_FINAL);
        //老版用法，已弃用
        //objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        serializer.setObjectMapper(objectMapper);
    }

    @Override
    public void setNonNullParameter(PreparedStatement ps, int i, T parameter, JdbcType jdbcType) throws SQLException {
        ps.setString(i,new String( serializer.serialize(parameter)));
    }

    @Override
    public T getNullableResult(ResultSet rs, String columnName) throws SQLException {
        return (T) serializer.deserialize(rs.getString(columnName).getBytes(StandardCharsets.UTF_8));
    }

    @Override
    public T getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
        return null;
    }

    @Override
    public T getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
        return null;
    }

}
  1. 更改Mapper.xml中的类型typeHandler=“com.by.config.JsonTypeHandler02”
    <resultMap id="UserMap" type="com.by.moder.User">
        <result property="id" column="id"/>
        <result property="addressBook" column="addressBook" typeHandler="com.by.config.JsonTypeHandler02"/>
        <result property="friendAddress" column="friendAddress" typeHandler="com.by.config.JsonTypeHandler02"/>
        <result property="pet" column="pet" typeHandler="com.by.config.JsonTypeHandler02"/>
    </resultMap>
   <insert id="add">
        insert into user2 (name, addressBook, friendAddress,pet)
        values (#{name}, #{addressBook,typeHandler=com.by.config.JsonTypeHandler02}, #{friendAddress,typeHandler=com.by.config.JsonTypeHandler02},#{pet,typeHandler=com.by.config.JsonTypeHandler02})
    </insert>
     <select id="select" resultMap="UserMap">
        select * from user2
    </select>

最后
添加结果：在这里插入图片描述
查询结果在这里插入图片描述
但这种方法

第三种方法

  1. 写一个MybatisToJsonConfig
public class MybatisToJsonConfig<T> {
    public static final Charset DEFAULT_CHARSET;
    private final JavaType javaType;

    private ObjectMapper objectMapper = new ObjectMapper();

    public MybatisToJsonConfig(Class<T> type) {
        this.javaType = this.getJavaType(type);
    }

    public MybatisToJsonConfig(JavaType javaType) {
        this.javaType = javaType;
    }

    public T deserialize(@Nullable byte[] bytes) throws Exception {

            try {
                return this.objectMapper.readValue(bytes, 0, bytes.length, this.javaType);
            } catch (Exception var3) {
                throw new Exception("Could not read JSON: " + var3.getMessage(), var3);
            }
    }

    public byte[] serialize(@Nullable Object t) throws Exception {

            try {
                return this.objectMapper.writeValueAsBytes(t);
            } catch (Exception var3) {
                throw new Exception("Could not write JSON: " + var3.getMessage(), var3);
            }
    }

    public void setObjectMapper(ObjectMapper objectMapper) {
        Assert.notNull(objectMapper, "'objectMapper' must not be null");
        this.objectMapper = objectMapper;
    }

    protected JavaType getJavaType(Class<?> clazz) {
        return TypeFactory.defaultInstance().constructType(clazz);
    }

    static {
        DEFAULT_CHARSET = StandardCharsets.UTF_8;
    }

}
  1. 在改进JsonTypeHandler03
public class JsonTypeHandler03<T> extends BaseTypeHandler<T> {

    private static MybatisToJsonConfig<Object> serializer = null;
    static {
        serializer = new MybatisToJsonConfig<>(Object.class);

        //创建对象映射器
        ObjectMapper objectMapper = new ObjectMapper();
        //JsonAutoDetect.Visibility.ANY 代表所有属性或字段都可以序列化
        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        //新版用法
        //以数组的方式存放到Redis，Class Type 全类名作为为第一个元素，Json字符串为第二个元素。
        objectMapper.activateDefaultTyping(objectMapper.getPolymorphicTypeValidator(), ObjectMapper.DefaultTyping.NON_FINAL);
        //老版用法，已弃用
        //objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        serializer.setObjectMapper(objectMapper);

    }
    public JsonTypeHandler03(Class<T> clazz) {


    }

    //插入数据将任何类型转换为json
    @Override
    @SneakyThrows
    //@SneakyThrows 是 Lombok 提供的一个注解，用于在方法上自动抛出异常。
    // 使用 @SneakyThrows 注解可以使方法在遇到异常时，自动将异常转换为 java.lang.RuntimeException 并抛出，
    // 而无需显式地在方法中编写异常处理代码
    public void setNonNullParameter(PreparedStatement ps, int i, T parameter, JdbcType jdbcType) throws SQLException {
        ps.setString(i,new String(serializer.serialize(parameter)));
    }

    //获取数据json转换类型
    @Override
    public T getNullableResult(ResultSet rs, String columnName) throws SQLException {
        try {
            return (T) serializer.deserialize(rs.getString(columnName).getBytes(StandardCharsets.UTF_8));
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    @Override
    public T getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
        return null;
    }

    @Override
    public T getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
        return null;
    }
}

最后更改mapper.xml类型typeHandler=“com.by.config.JsonTypeHandler03”

举报

相关推荐

mysql存储json数据

json建表json数据虚拟化云计算

MyBatis-plus 3.5之前版本 处理存储json数据

json自定义ListJava后端开发

python将文件内容转为json格式

json读取文件数据Linux系统/运维

将JSON字符串转为list

jsonjava开发语言

将Kotlin类转为json字符串,批量生成测试数据

jsonkotlinjavajson字符串

bpmn-js中实现xml数据转为json数据

javascriptxmljsonbpmn-js

将json类型转换为字符串存储在浏览器storage，取出转为json

javascript

将json对象转为xml进行操作属性

网络服务器linux

nodejs 如何将 Buffer 数据转为 String

边缘计算人工智能

Node.js 将Json文件数据转为SQL可执行的insert语句

json数据sqlNode.js前端开发
0 条评论