You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 03:20:15 UTC
[rocketmq-connect] 07/43: Add Config File
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit 2cc48d9a56f38abc4a82296e4e6e3d8b3c190813
Author: yuchenlichuck <yu...@126.com>
AuthorDate: Tue Jul 23 22:43:01 2019 +0800
Add Config File
---
.../org/apache/rocketmq/connect/jdbc/Config.java | 224 +++++++++++++++++++--
1 file changed, 208 insertions(+), 16 deletions(-)
diff --git a/src/main/java/org/apache/rocketmq/connect/jdbc/Config.java b/src/main/java/org/apache/rocketmq/connect/jdbc/Config.java
index 2b485e4..217b449 100644
--- a/src/main/java/org/apache/rocketmq/connect/jdbc/Config.java
+++ b/src/main/java/org/apache/rocketmq/connect/jdbc/Config.java
@@ -18,27 +18,56 @@
package org.apache.rocketmq.connect.jdbc;
import io.openmessaging.KeyValue;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
import java.lang.reflect.Method;
import java.util.HashSet;
+import java.util.List;
import java.util.Set;
-import javax.jms.Session;
-
public class Config {
@SuppressWarnings("serial")
- public String jdbcAddr;
- public Integer jdbcPort;
+ private static final Logger LOG = LoggerFactory.getLogger(Config.class);
+
+ /* Database Connection Config */
+ public String jdbcUrl;
public String jdbcUsername;
public String jdbcPassword;
+ public String rocketmqTopic;
+ public String jdbcBackoff;
+ public String jdbcAttempts;
+ public String catalogPattern=null;
+ public List tableWhitelist;
+ public List tableBlacklist;
+ public String schemaPattern=null;
+ public boolean numericPrecisionMapping=false;
+ public String bumericMapping=null;
+ public String dialectName="";
+ /* Mode Config */
+ public String mode="";
+ public String incrementingColumnName= "";
+ public String query="";
+ public String timestampColmnName="";
+ public boolean validateNonNull=true;
+
+ /*Connector config*/
+ public String tableTypes="table";
+ public int pollInterval=5000;
+ public int batchMaxRows=100;
+ public long tablePollInterval=60000;
+ public long timestampDelayInterval=0;
+ public String dbTimezone="UTC";
public String queueName;
public static final Set<String> REQUEST_CONFIG = new HashSet<String>() {
{
- add("jdbcAddr");
- add("jdbcPort");
+ add("jdbcUrl");
add("jdbcUsername");
add("jdbcPassword");
+ add("mode");
+ add("queueName");
}
};
@@ -49,7 +78,6 @@ public class Config {
}
private void properties2Object(final KeyValue p, final Object object) {
- //Java Reflection Application
Method[] methods = object.getClass().getMethods();
for (Method method : methods) {
String mn = method.getName();
@@ -90,20 +118,20 @@ public class Config {
}
}
- public String getJdbcAddr() {
- return jdbcAddr;
+ public String getQueueName() {
+ return queueName;
}
- public void setJdbcAddr(String JdbcAddr) {
- this.jdbcAddr = jdbcAddr;
+ public void setQueueName(String queueName) {
+ this.queueName = queueName;
}
- public int getJdbcPort() {
- return jdbcPort;
+ public String getJdbcUrl() {
+ return jdbcUrl;
}
- public void setJdbcPort(Integer jdbcPort) {
- this.jdbcPort = jdbcPort;
+ public void setJdbcUrl(String jdbcUrl) {
+ this.jdbcUrl = jdbcUrl;
}
public String getJdbcUsername() {
@@ -122,7 +150,171 @@ public class Config {
this.jdbcPassword = jdbcPassword;
}
+ public String getRocketmqTopic() {
+ return rocketmqTopic;
+ }
+
+ public void setRocketmqTopic(String rocketmqTopic) {
+ this.rocketmqTopic = rocketmqTopic;
+ }
+
+ public String getJdbcBackoff() {
+ return jdbcBackoff;
+ }
+
+ public void setJdbcBackoff(String jdbcBackoff) {
+ this.jdbcBackoff = jdbcBackoff;
+ }
+
+ public String getJdbcAttempts() {
+ return jdbcAttempts;
+ }
+
+ public void setJdbcAttempts(String jdbcAttempts) {
+ this.jdbcAttempts = jdbcAttempts;
+ }
+
+ public String getCatalogPattern() {
+ return catalogPattern;
+ }
+
+ public void setCatalogPattern(String catalogPattern) {
+ this.catalogPattern = catalogPattern;
+ }
+
+ public List getTableWhitelist() {
+ return tableWhitelist;
+ }
+
+ public void setTableWhitelist(List tableWhitelist) {
+ this.tableWhitelist = tableWhitelist;
+ }
+
+ public List getTableBlacklist() {
+ return tableBlacklist;
+ }
+
+ public void setTableBlacklist(List tableBlacklist) {
+ this.tableBlacklist = tableBlacklist;
+ }
+
+ public String getSchemaPattern() {
+ return schemaPattern;
+ }
+
+ public void setSchemaPattern(String schemaPattern) {
+ this.schemaPattern = schemaPattern;
+ }
+
+ public boolean isNumericPrecisionMapping() {
+ return numericPrecisionMapping;
+ }
+
+ public void setNumericPrecisionMapping(boolean numericPrecisionMapping) {
+ this.numericPrecisionMapping = numericPrecisionMapping;
+ }
+
+ public String getBumericMapping() {
+ return bumericMapping;
+ }
+
+ public void setBumericMapping(String bumericMapping) {
+ this.bumericMapping = bumericMapping;
+ }
+
+ public String getDialectName() {
+ return dialectName;
+ }
+
+ public void setDialectName(String dialectName) {
+ this.dialectName = dialectName;
+ }
+
+ public String getMode() {
+ return mode;
+ }
+
+ public void setMode(String mode) {
+ this.mode = mode;
+ }
+
+ public String getIncrementingColumnName() {
+ return incrementingColumnName;
+ }
+
+ public void setIncrementingColumnName(String incrementingColumnName) {
+ this.incrementingColumnName = incrementingColumnName;
+ }
+
+ public String getQuery() {
+ return query;
+ }
+
+ public void setQuery(String query) {
+ this.query = query;
+ }
+
+ public String getTimestampColmnName() {
+ return timestampColmnName;
+ }
+
+ public void setTimestampColmnName(String timestampColmnName) {
+ this.timestampColmnName = timestampColmnName;
+ }
+
+ public boolean isValidateNonNull() {
+ return validateNonNull;
+ }
+
+ public void setValidateNonNull(boolean validateNonNull) {
+ this.validateNonNull = validateNonNull;
+ }
+ public String getTableTypes() {
+ return tableTypes;
+ }
+
+ public void setTableTypes(String tableTypes) {
+ this.tableTypes = tableTypes;
+ }
+ public int getPollInterval() {
+ return pollInterval;
+ }
+
+ public void setPollInterval(int pollInterval) {
+ this.pollInterval = pollInterval;
+ }
-}
+ public int getBatchMaxRows() {
+ return batchMaxRows;
+ }
+
+ public void setBatchMaxRows(int batchMaxRows) {
+ this.batchMaxRows = batchMaxRows;
+ }
+
+ public long getTablePollInterval() {
+ return tablePollInterval;
+ }
+
+ public void setTablePollInterval(long tablePollInterval) {
+ this.tablePollInterval = tablePollInterval;
+ }
+
+ public long getTimestampDelayInterval() {
+ return timestampDelayInterval;
+ }
+
+ public void setTimestampDelayInterval(long timestampDelayInterval) {
+ this.timestampDelayInterval = timestampDelayInterval;
+ }
+
+ public String getDbTimezone() {
+ return dbTimezone;
+ }
+
+ public void setDbTimezone(String dbTimezone) {
+ this.dbTimezone = dbTimezone;
+ }
+}
\ No newline at end of file