format code

Author: xlorne

src/main/java/com/codingapi/dbstream/event/DBEventContext.java

@@ -31,10 +31,10 @@ void push(JdbcQuery jdbcQuery, List<DBEvent> events) {
         });
         if (!this.pushers.isEmpty()) {
             for (DBEventPusher pusher : pushers) {
-                pusher.push(jdbcQuery,events);
+                pusher.push(jdbcQuery, events);
             }
         } else {
-            defaultDBEventPusher.push(jdbcQuery,events);
+            defaultDBEventPusher.push(jdbcQuery, events);
         }
     }
 

src/main/java/com/codingapi/dbstream/event/DBEventPusher.java

@@ -11,9 +11,10 @@ public interface DBEventPusher {
 
     /**
      * 推送事件
+     *
      * @param jdbcQuery JDBC数据查询对象
-     * @param events DB事件消息
+     * @param events    DB事件消息
      */
-    void push(JdbcQuery jdbcQuery,List<DBEvent> events);
+    void push(JdbcQuery jdbcQuery, List<DBEvent> events);
 
 }

src/main/java/com/codingapi/dbstream/event/DefaultDBEventPusher.java

@@ -11,7 +11,7 @@
 public class DefaultDBEventPusher implements DBEventPusher {
 
     @Override
-    public void push(JdbcQuery jdbcQuery,List<DBEvent> events) {
+    public void push(JdbcQuery jdbcQuery, List<DBEvent> events) {
         System.out.println("<=== DBStream DBEvent Total " + events.size() + " ===> ");
         for (DBEvent event : events) {
             System.out.println(event);

src/main/java/com/codingapi/dbstream/event/TransactionEventPools.java

@@ -40,7 +40,7 @@ public boolean isAutoCommit() {
     /**
      * 添加事务事件
      */
-    public void addEvents(JdbcQuery jdbcQuery,String transactionKey, List<DBEvent> events) {
+    public void addEvents(JdbcQuery jdbcQuery, String transactionKey, List<DBEvent> events) {
         List<DBEvent> currentEvents = pools.get();
         if (currentEvents == null) {
             currentEvents = new ArrayList<>();
@@ -49,15 +49,15 @@ public void addEvents(JdbcQuery jdbcQuery,String transactionKey, List<DBEvent> e
         currentEvents.addAll(events);
 
         if (this.isAutoCommit()) {
-            this.commitEvents(jdbcQuery,transactionKey);
+            this.commitEvents(jdbcQuery, transactionKey);
         }
 
     }
 
     /**
      * 提交消息
      *
-     * @param jdbcQuery 数据查询对象
+     * @param jdbcQuery      数据查询对象
      * @param transactionKey 事务标示
      */
     public void commitEvents(JdbcQuery jdbcQuery, String transactionKey) {
@@ -66,7 +66,7 @@ public void commitEvents(JdbcQuery jdbcQuery, String transactionKey) {
             currentEvents.forEach(dbEvent -> {
                 dbEvent.setTransactionKey(transactionKey);
             });
-            DBEventContext.getInstance().push(jdbcQuery,currentEvents);
+            DBEventContext.getInstance().push(jdbcQuery, currentEvents);
             currentEvents.clear();
         }
         this.clear();
@@ -75,10 +75,10 @@ public void commitEvents(JdbcQuery jdbcQuery, String transactionKey) {
     /**
      * 回滚消息
      *
-     * @param jdbcQuery 数据查询对象
+     * @param jdbcQuery      数据查询对象
      * @param transactionKey 事务标示
      */
-    public void rollbackEvents(JdbcQuery jdbcQuery,String transactionKey) {
+    public void rollbackEvents(JdbcQuery jdbcQuery, String transactionKey) {
         this.clear();
     }
 

src/main/java/com/codingapi/dbstream/interceptor/SQLExecuteState.java

@@ -278,7 +278,7 @@ public List<Map<String, Object>> query(String sql) throws SQLException {
      * @throws SQLException 查询异常
      */
     public List<Map<String, Object>> query(String sql, List<Object> params) throws SQLException {
-        return jdbcQuery.query(sql,params);
+        return jdbcQuery.query(sql, params);
     }
 
     /**
@@ -311,7 +311,6 @@ public List<Map<String, Object>> getStatementGenerateKeys(DbTable dbTable) {
     }
 
 
-
     /**
      * 获取驱动配置信息
      *

src/main/java/com/codingapi/dbstream/listener/dbevent/DBEventExecuteListener.java

@@ -128,7 +128,7 @@ public void after(SQLExecuteState executeState, Object result) throws SQLExcepti
                     if (dataParser != null) {
                         // 获取DB事件信息
                         List<DBEvent> eventList = dataParser.loadEvents(arrays.get(i));
-                        TransactionEventPools.getInstance().addEvents(sqlExecuteState.getJdbcQuery(),transactionKey, eventList);
+                        TransactionEventPools.getInstance().addEvents(sqlExecuteState.getJdbcQuery(), transactionKey, eventList);
                     }
                 }
                 // 清空本地缓存数据
@@ -139,7 +139,7 @@ public void after(SQLExecuteState executeState, Object result) throws SQLExcepti
                 if (dataParser != null) {
                     // 获取DB事件信息
                     List<DBEvent> eventList = dataParser.loadEvents(result);
-                    TransactionEventPools.getInstance().addEvents(executeState.getJdbcQuery(),transactionKey, eventList);
+                    TransactionEventPools.getInstance().addEvents(executeState.getJdbcQuery(), transactionKey, eventList);
                 }
                 // 清空本地缓存数据
                 ThreadLocalContext.getInstance().remove();

src/main/java/com/codingapi/dbstream/parser/InsertDBEventParser.java

@@ -128,7 +128,7 @@ private void loadDefaultInsertDataList() throws SQLException {
                     }
                 }
             } else if (insertValue.isJdbc()) {
-                value = paramList.get(insertValue.getJdbcParamIndex()-1);
+                value = paramList.get(insertValue.getJdbcParamIndex() - 1);
             } else {
                 value = insertValue.getValue();
             }

src/main/java/com/codingapi/dbstream/parser/InsertSQLParser.java

@@ -108,12 +108,12 @@ public List<InsertValue> getValues() {
         List<InsertValue> insertValues = new ArrayList<>();
         List<String> values = SQLUtils.parseInsertSQLValues(this.getValuesSQL());
         int jdbcIndex = 0;
-        for (String value:values) {
+        for (String value : values) {
             InsertValue insertValue = new InsertValue();
             if (value.trim().equals("?")) {
                 insertValue.setType(ValueType.JDBC);
                 jdbcIndex++;
-                insertValue.setValue(value+jdbcIndex);
+                insertValue.setValue(value + jdbcIndex);
             } else if (SQLUtils.isSQLKeyword(value.trim()) || value.trim().startsWith("(")) {
                 insertValue.setType(ValueType.SELECT);
                 insertValue.setValue(value);
@@ -140,8 +140,8 @@ public boolean isJdbc() {
             return ValueType.JDBC == this.type;
         }
 
-        public int getJdbcParamIndex(){
-            return Integer.parseInt(this.value.replace("?",""));
+        public int getJdbcParamIndex() {
+            return Integer.parseInt(this.value.replace("?", ""));
         }
     }
 

src/main/java/com/codingapi/dbstream/proxy/ConnectionProxy.java

@@ -66,7 +66,7 @@ public void setAutoCommit(boolean autoCommit) throws SQLException {
     @Override
     public void commit() throws SQLException {
         JdbcQuery jdbcQuery = new JdbcQuery(this);
-        TransactionEventPools.getInstance().commitEvents(jdbcQuery,transactionKey);
+        TransactionEventPools.getInstance().commitEvents(jdbcQuery, transactionKey);
         connection.commit();
         // 事务提交以后，更换事务的标识信息
         this.generateTransactionKey();
@@ -75,7 +75,7 @@ public void commit() throws SQLException {
     @Override
     public void rollback() throws SQLException {
         JdbcQuery jdbcQuery = new JdbcQuery(this);
-        TransactionEventPools.getInstance().rollbackEvents(jdbcQuery,transactionKey);
+        TransactionEventPools.getInstance().rollbackEvents(jdbcQuery, transactionKey);
         connection.rollback();
         // 事务提交以后，更换事务的标识信息
         this.generateTransactionKey();

src/main/java/com/codingapi/dbstream/query/JdbcQuery.java

@@ -62,5 +62,4 @@ public List<Map<String, Object>> query(String sql, List<Object> params) throws S
     }
 
 
-
 }