From b017102e0e59ec36e9863a2a2fa90d55a376d5ad Mon Sep 17 00:00:00 2001
From: sanChouIsACat <993924507@qq.com>
Date: Thu, 23 Dec 2021 15:20:56 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9C=80=E7=BB=88=E7=89=88?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../oceanbasev10reader/ext/ReaderJob.java     | 21 +++++++++++--------
 1 file changed, 12 insertions(+), 9 deletions(-)

diff --git a/oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/ext/ReaderJob.java b/oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/ext/ReaderJob.java
index 2584ca33..d574e3e1 100644
--- a/oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/ext/ReaderJob.java
+++ b/oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/ext/ReaderJob.java
@@ -17,32 +17,35 @@ import org.slf4j.LoggerFactory;
 
 
 public class ReaderJob extends CommonRdbmsReader.Job {
-    private Logger LOG=LoggerFactory.getLogger(OceanBaseReader.Task.class);
+    private Logger LOG = LoggerFactory.getLogger(OceanBaseReader.Task.class);
+
     public ReaderJob() {
         super(ObReaderUtils.DATABASE_TYPE);
 
     }
-    public void init(Configuration originalConfig,DataBaseType databaseType){
+
+    public void init(Configuration originalConfig, DataBaseType databaseType) {
         //将config中的column和table中的关键字进行转义
         try {
             DatabaseKeywordTransformer.setDatabaseType(databaseType);
         } catch (Exception e) {
             LOG.warn("database type is " + databaseType + e.getMessage());
         }
-        List<String> columns=originalConfig.getList(Key.COLUMN,String.class);
+        List<String> columns = originalConfig.getList(Key.COLUMN, String.class);
         DatabaseKeywordTransformer.transferDatabaseKeywords(columns);
         originalConfig.set(Key.COLUMN, columns);
 
-        List<JSONObject> conns=originalConfig.getList(com.alibaba.datax.plugin.rdbms.reader.Constant.CONN_MARK,JSONObject.class);
-        for(int i=0;i<conns.size();i++){
-            JSONObject conn=conns.get(i);
-            Configuration connConfig=Configuration.from(conn.toString());
-            List<String> tables=connConfig.getList(Key.TABLE,String.class);
+        List<JSONObject> conns = originalConfig.getList(com.alibaba.datax.plugin.rdbms.reader.Constant.CONN_MARK, JSONObject.class);
+        for (int i = 0; i < conns.size(); i++) {
+            JSONObject conn = conns.get(i);
+            Configuration connConfig = Configuration.from(conn.toString());
+            List<String> tables = connConfig.getList(Key.TABLE, String.class);
             DatabaseKeywordTransformer.transferDatabaseKeywords(tables);
-            originalConfig.set(String.format("%s[%d].%s", com.alibaba.datax.plugin.rdbms.reader.Constant.CONN_MARK,i,Key.TABLE),tables);
+            originalConfig.set(String.format("%s[%d].%s", com.alibaba.datax.plugin.rdbms.reader.Constant.CONN_MARK, i, Key.TABLE), tables);
         }
         super.init(originalConfig);
     }
+
     @Override
     public List<Configuration> split(Configuration originalConfig, int adviceNumber) {
         List<Configuration> list = super.split(originalConfig, adviceNumber);