/**
 * 
 */
package org.springblade.etl.connector.sink.config;

import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.springblade.etl.connector.base.SeatunnelConfig;

import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import java.util.List;

/**
 * @author wookvn
 *
 */
@Data
@EqualsAndHashCode(callSuper = true)
public class SeatunnelMongoSinkConfig extends SeatunnelConfig {
	
	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;

	@NotEmpty(message = "MongoDB 连接 uri。")
	private String uri;
	
	@NotNull(message = "要读取或写入的 MongoDB 数据库的名称。")
	private String database;
	
	@NotEmpty(message = "要读取或写入的 MongoDB 集合的名称。")
	private String collection;

	//MongoDB 的 BSON 和 seatunnel 数据结构映射
	private Integer schema = 0;

	
}
