增加表

src/main/java/com/huazheng/project/greenplum/mapper/GpAbc3Mapper.java

+package com.huazheng.project.greenplum.mapper;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huazheng.project.greenplum.model.GpAbc3;
+
+public interface GpAbc3Mapper extends BaseMapper<GpAbc3> {
+	
+}
\ No newline at end of file

src/main/java/com/huazheng/project/greenplum/mapper/GpTb3Mapper.java

+package com.huazheng.project.greenplum.mapper;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huazheng.project.greenplum.model.GpTb3;
+
+public interface GpTb3Mapper extends BaseMapper<GpTb3> {
+	
+}
\ No newline at end of file

src/main/java/com/huazheng/project/greenplum/mapper/GpTest3Mapper.java

+package com.huazheng.project.greenplum.mapper;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huazheng.project.greenplum.model.GpTest3;
+
+public interface GpTest3Mapper extends BaseMapper<GpTest3> {
+	
+}
\ No newline at end of file

src/main/java/com/huazheng/project/greenplum/model/GpAbc3.java

+package com.huazheng.project.greenplum.model;
+
+import java.io.Serializable;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import lombok.experimental.Accessors;
+
+@Data
+@Builder
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("mssql_abc3")
+@NoArgsConstructor
+@AllArgsConstructor
+@ApiModel(value="GpAbc3对象", description="测试表")
+public class GpAbc3 extends Model<GpAbc3> {
+	
+	private static final long serialVersionUID = 1L;
+	
+	@ApiModelProperty(value = "主键")
+    @TableId("id")
+	private Integer id;
+	
+	@ApiModelProperty(value = "用户")
+	@TableField("username")
+	private String username;
+	
+	@ApiModelProperty(value = "密码")
+	@TableField("userpswd")
+	private String userpswd;
+	
+	@Override
+    protected Serializable pkVal() {
+        return this.id;
+    }
+	
+}

src/main/java/com/huazheng/project/greenplum/model/GpTb3.java

+package com.huazheng.project.greenplum.model;
+
+import java.io.Serializable;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import lombok.experimental.Accessors;
+
+@Data
+@Builder
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("mysql_tb3")
+@NoArgsConstructor
+@AllArgsConstructor
+@ApiModel(value="GpTb3对象", description="测试表")
+public class GpTb3 extends Model<GpTb3> {
+	
+	private static final long serialVersionUID = 1L;
+	
+	@ApiModelProperty(value = "主键")
+    @TableId("id")
+	private Integer id;
+	
+	@ApiModelProperty(value = "用户")
+	@TableField("username")
+	private String username;
+	
+	@ApiModelProperty(value = "密码")
+	@TableField("userpswd")
+	private String userpswd;
+	
+	@Override
+    protected Serializable pkVal() {
+        return this.id;
+    }
+	
+}

src/main/java/com/huazheng/project/greenplum/model/GpTest3.java

+package com.huazheng.project.greenplum.model;
+
+import java.io.Serializable;
+import java.util.Date;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import lombok.experimental.Accessors;
+
+@Data
+@Builder
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("hana_test3")
+@NoArgsConstructor
+@AllArgsConstructor
+@ApiModel(value="GpTest3对象", description="测试表")
+public class GpTest3 extends Model<GpTest3> {
+	
+	private static final long serialVersionUID = 1L;
+	
+	@ApiModelProperty(value = "主键")
+    @TableId("id")
+	private Integer id;
+	
+	@ApiModelProperty(value = "用户")
+	@TableField("\"user\"")
+	private String user;
+	
+	@ApiModelProperty(value = "密码")
+	@TableField("pswd")
+	private String pswd;
+	
+	@ApiModelProperty(value = "时间")
+	@TableField("times")
+	private Date times;
+	
+	@Override
+    protected Serializable pkVal() {
+        return this.id;
+    }
+	
+}

src/main/java/com/huazheng/project/service/impl/GpAbc3ServiceImpl.java

+package com.huazheng.project.service.impl;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.kafka.annotation.KafkaListener;
+import org.springframework.stereotype.Service;
+
+import com.huazheng.project.greenplum.mapper.GpAbc3Mapper;
+import com.huazheng.project.greenplum.model.GpAbc3;
+
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+
+@Service
+public class GpAbc3ServiceImpl {
+
+	private Log log = LogFactory.getLog(getClass());
+
+	@Autowired
+	private GpAbc3Mapper mapper;
+
+	@KafkaListener(topics = "sqlserver.test2.dbo.abc3")
+	public void mssqlData(ConsumerRecord<?, ?> record) {
+		Object value = record.value();
+		if (value != null) {
+			String data = value.toString();
+			JSONObject json = JSONUtil.parseObj(data);
+			JSONObject payload = json.getJSONObject("payload");
+			String op = payload.getStr("op");
+			JSONObject before = payload.getJSONObject("before");
+			JSONObject after = payload.getJSONObject("after");
+			if (op.equals("c")) {
+				GpAbc3 bean = JSONUtil.toBean(after, GpAbc3.class);
+				mapper.insert(bean);
+				log.info("mssql insert --> " + bean);
+			} else if (op.equals("u")) {
+				GpAbc3 bean = JSONUtil.toBean(after, GpAbc3.class);
+				mapper.updateById(bean);
+				log.info("mssql update --> " + bean);
+			} else if (op.equals("d")) {
+				GpAbc3 bean = JSONUtil.toBean(before, GpAbc3.class);
+				mapper.deleteById(bean.getId());
+				log.info("mssql delete --> " + bean);
+			}
+		}
+	}
+	
+}

src/main/java/com/huazheng/project/service/impl/GpTb3ServiceImpl.java

+package com.huazheng.project.service.impl;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.kafka.annotation.KafkaListener;
+import org.springframework.stereotype.Service;
+
+import com.huazheng.project.greenplum.mapper.GpTb3Mapper;
+import com.huazheng.project.greenplum.model.GpTb3;
+
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+
+@Service
+public class GpTb3ServiceImpl {
+
+	private Log log = LogFactory.getLog(getClass());
+
+	@Autowired
+	private GpTb3Mapper mapper;
+	
+	@KafkaListener(topics = "mysql.abc.abc.tb3")
+	public void mysqlData(ConsumerRecord<?, ?> record) {
+		Object value = record.value();
+		if (value != null) {
+			String data = value.toString();
+			JSONObject json = JSONUtil.parseObj(data);
+			JSONObject payload = json.getJSONObject("payload");
+			String op = payload.getStr("op");
+			JSONObject before = payload.getJSONObject("before");
+			JSONObject after = payload.getJSONObject("after");
+			if (op.equals("c")) {
+				GpTb3 bean = JSONUtil.toBean(after, GpTb3.class);
+				mapper.insert(bean);
+				log.info("mysql insert --> " + bean);
+			} else if (op.equals("u")) {
+				GpTb3 bean = JSONUtil.toBean(after, GpTb3.class);
+				mapper.updateById(bean);
+				log.info("mysql update --> " + bean);
+			} else if (op.equals("d")) {
+				GpTb3 bean = JSONUtil.toBean(before, GpTb3.class);
+				mapper.deleteById(bean.getId());
+				log.info("mysql delete --> " + bean);
+			}
+		}
+	}
+	
+}

src/main/java/com/huazheng/project/service/impl/GpTest3ServiceImpl.java

+package com.huazheng.project.service.impl;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.kafka.annotation.KafkaListener;
+import org.springframework.stereotype.Service;
+
+import com.huazheng.project.greenplum.mapper.GpTest3Mapper;
+import com.huazheng.project.greenplum.model.GpTest3;
+
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+
+@Service
+public class GpTest3ServiceImpl {
+
+	private Log log = LogFactory.getLog(getClass());
+
+	@Autowired
+	private GpTest3Mapper mapper;
+	
+	@KafkaListener(topics = "test_topic_4")
+	public void hanaData(ConsumerRecord<?, ?> record) {
+		Object value = record.value();
+		if (value != null) {
+			String data = value.toString();
+			JSONObject json = JSONUtil.parseObj(data);
+			JSONObject payload = json.getJSONObject("payload");
+			String op = payload.getStr("TYPE");
+			JSONObject before = payload.getJSONObject("BEFORE");
+			JSONObject after = payload.getJSONObject("AFTER");
+			if (op.equals("c")) {
+				after.set("times", after.getStr("times").substring(0, 19));
+				GpTest3 bean = JSONUtil.toBean(after, GpTest3.class);
+				mapper.insert(bean);
+				log.info("hana insert --> " + bean);
+			} else if (op.equals("u")) {
+				after.set("times", after.getStr("times").substring(0, 19));
+				GpTest3 bean = JSONUtil.toBean(after, GpTest3.class);
+				mapper.updateById(bean);
+				log.info("hana update --> " + bean);
+			} else if (op.equals("d")) {
+				before.set("times", before.getStr("times").substring(0, 19));
+				GpTest3 bean = JSONUtil.toBean(before, GpTest3.class);
+				mapper.deleteById(bean.getId());
+				log.info("hana delete --> " + bean);
+			}
+		}
+	}
+	
+}