/**
 * DBSyncer Copyright 2019-2024 All Rights Reserved.
 */
package org.dbsyncer.common.event;

import org.dbsyncer.common.util.JsonUtil;

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

/**
 * 监听行变更事件
 *
 * @version 1.0.0
 * @Author AE86
 * @Date 2020-06-15 20:00
 */
public class RowChangedEvent {

    private int                 tableGroupIndex;
    private String              tableName;
    private String              event;
    private List<Object>        beforeData;
    private List<Object>        afterData;
    private String              rowId;
    private String              pk;
    private Map<String, Object> before;
    private Map<String, Object> after;

    /**
     * 定时模式
     *
     * @param tableGroupIndex
     * @param event
     * @param before
     * @param after
     */
    public RowChangedEvent(int tableGroupIndex, String event, Map<String, Object> before, Map<String, Object> after) {
        this.tableGroupIndex = tableGroupIndex;
        this.event = event;
        this.before = before;
        this.after = after;
    }

    /**
     * Mysql
     *
     * @param tableName
     * @param event
     * @param beforeData
     * @param afterData
     */
    public RowChangedEvent(String tableName, String event, List<Object> beforeData, List<Object> afterData) {
        this.tableName = tableName;
        this.event = event;
        this.beforeData = beforeData;
        this.afterData = afterData;
    }

    /**
     * Oracle
     *
     * @param tableName
     * @param event
     * @param beforeData
     * @param afterData
     * @param rowId
     */
    public RowChangedEvent(String tableName, String event, List<Object> beforeData, List<Object> afterData, String rowId) {
        this.tableName = tableName;
        this.event = event;
        this.beforeData = beforeData;
        this.afterData = afterData;
        this.rowId = rowId;
    }

    public int getTableGroupIndex() {
        return tableGroupIndex;
    }

    public String getTableName() {
        return tableName;
    }

    public String getEvent() {
        return event;
    }

    public List<Object> getBeforeData() {
        return beforeData;
    }

    public List<Object> getAfterData() {
        return afterData;
    }

    public String getRowId() {
        return rowId;
    }

    public String getPk() {
        return pk;
    }

    public void setPk(String pk) {
        this.pk = pk;
    }

    public Map<String, Object> getBefore() {
        return before;
    }

    public void setBefore(Map<String, Object> before) {
        this.before = before;
    }

    public Map<String, Object> getAfter() {
        return after;
    }

    public void setAfter(Map<String, Object> after) {
        this.after = after;
    }

    @Override
    public String toString() {
        return JsonUtil.objToJson(this);
    }
}