MessageVo.java 837 字节
package com.aukey.example.vo;

import lombok.Data;
import lombok.ToString;

import java.util.List;
import java.util.Map;

/**
 * @author: wgf
 * @create: 2020-06-09 10:44
 * @description: 消息实体
 **/
@Data
@ToString
public class MessageVo<T> {

    // 数据库
    private String database;

    // 数据表
    private String table;

    // INSERT,DELETE,UPDATE
    private String type;

    // 最新版本binlog数据
    private List<T> data;

    // 旧版本binlog数据,只有UPDATE时才有值
    private List<T> old;

    // 主键字段
    private String[] pkNames;

    /**
     * value 每个字段对应的sql规范数据枚举类型
     * 参考 {@link java.sql.Types}
     */
    private Map<String, Integer> sqlType;

    // 每个字段对应的Mysql数据类型
    private Map<String, String> mysqlType;
}