code rename

Author: xlorne

README.md

@@ -102,28 +102,29 @@ DBStreamContext.getInstance().addEventPusher(new DBEventPusher() {
 实现并注册 `SQLExecuteListener`，可以获取原始 SQL 和参数信息：
 
 ```java
-import com.codingapi.dbstream.DBStreamContext;
-import com.codingapi.dbstream.interceptor.SQLExecuteState;
+
+import com.codingapi.dbstream.listener.SQLRunningState;
 import com.codingapi.dbstream.listener.SQLExecuteListener;
 
 public class MySQLListener implements SQLExecuteListener {
 
     @Override
     public int order() {
+        // 执行顺序 小的在前，大的在后
         return 0;
     }
-    
+
     @Override
-    public void before(SQLExecuteState executeState) {
-        System.out.println("执行前 - SQL: " + executeState.getSql());
-        System.out.println("执行前 - 参数: " + executeState.getListParams());
+    public void before(SQLRunningState runningState) {
+        System.out.println("执行前 - SQL: " + runningState.getSql());
+        System.out.println("执行前 - 参数: " + runningState.getListParams());
     }
 
     @Override
-    public void after(SQLExecuteState executeState, Object result) {
-        System.out.println("执行后 - SQL: " + executeState.getSql());
-        System.out.println("执行后 - 参数: " + executeState.getListParams());
-        System.out.println("执行后 - 耗时: " + executeState.getExecuteTimestamp());
+    public void after(SQLRunningState runningState, Object result) {
+        System.out.println("执行后 - SQL: " + runningState.getSql());
+        System.out.println("执行后 - 参数: " + runningState.getListParams());
+        System.out.println("执行后 - 耗时: " + runningState.getExecuteTimestamp());
         System.out.println("执行后 - 结果: " + result);
     }
 }
@@ -224,8 +225,8 @@ List<DBMetaData> metaDataList = DBStreamContext.getInstance().metaDataList();
 // 通过 jdbcKey 获取指定数据库的元数据信息
 DBMetaData metaData = DBStreamContext.getInstance().getMetaData(String jdbcKey);
 
-// 主动更新表的元数据信息，在使用改变时将会先更新metadata然后再执行业务。（动态更新表的元数据）
-metaData.addUpdateTableMateList(String tableName);
+// 添加数据表更新订阅，当执行对应表的数据事件分析时将会自动更新同步该表的元数据信息到DBMetaData数据中。
+metaData.addUpdateSubscribe(String tableName);
 
 // 获取所有已缓存的数据库连接 jdbcKey 列表
 List<String> dbKeys = DBStreamContext.getInstance().loadDbKeys();
@@ -245,6 +246,7 @@ DBStreamContext.getInstance().clearAll();
 - `type`: 操作类型（INSERT/UPDATE/DELETE）
 - `data`: 变更的数据（Map 格式，key 为字段名，value 为字段值）
 - `primaryKeys`: 主键列表
+- `jdbcKey`: 数据库唯一标识
 - `jdbcUrl`: 数据库连接 URL
 - `transactionKey`: 事务标识（同一事务内的操作共享相同标识）
 - `timestamp`: 事件产生时间戳

pom.xml

@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.codingapi.dbstream</groupId>
     <artifactId>dbstream-driver</artifactId>
-    <version>1.0.11</version>
+    <version>1.0.12</version>
 
     <url>https://github.com/codingapi/dbstream-driver</url>
     <name>dbstream-driver</name>

src/main/java/com/codingapi/dbstream/DBStreamContext.java

@@ -1,6 +1,6 @@
 package com.codingapi.dbstream;
 
-import com.codingapi.dbstream.interceptor.SQLExecuteListenerContext;
+import com.codingapi.dbstream.listener.SQLRunningContext;
 import com.codingapi.dbstream.listener.SQLExecuteListener;
 import com.codingapi.dbstream.supporter.DBEventSupporter;
 import com.codingapi.dbstream.supporter.DefaultDBEventSupporter;
@@ -37,7 +37,7 @@ private DBStreamContext() {
      * @param sqlExecuteListener 订阅
      */
     public void addListener(SQLExecuteListener sqlExecuteListener) {
-        SQLExecuteListenerContext.getInstance().addListener(sqlExecuteListener);
+        SQLRunningContext.getInstance().addListener(sqlExecuteListener);
     }
 
     /**

src/main/java/com/codingapi/dbstream/driver/DBStreamProxyDriver.java

@@ -1,9 +1,9 @@
 package com.codingapi.dbstream.driver;
 
-import com.codingapi.dbstream.interceptor.SQLExecuteListenerContext;
-import com.codingapi.dbstream.listener.dbevent.SQLDeleteExecuteListener;
-import com.codingapi.dbstream.listener.dbevent.SQLInsertExecuteListener;
-import com.codingapi.dbstream.listener.dbevent.SQLUpdateExecuteListener;
+import com.codingapi.dbstream.listener.SQLRunningContext;
+import com.codingapi.dbstream.listener.dbevent.DeleteEventListener;
+import com.codingapi.dbstream.listener.dbevent.InsertEventListener;
+import com.codingapi.dbstream.listener.dbevent.UpdateEventListener;
 import com.codingapi.dbstream.proxy.ConnectionProxy;
 import com.codingapi.dbstream.scanner.DBMetaContext;
 import com.codingapi.dbstream.scanner.DBMetaData;
@@ -30,9 +30,9 @@ public class DBStreamProxyDriver implements Driver {
             LOGGER.log(Level.SEVERE, "Failed to register DBStreamProxyDriver", e);
             throw new RuntimeException("Failed to register DBStreamProxyDriver", e);
         }
-        SQLExecuteListenerContext.getInstance().addListener(new SQLDeleteExecuteListener());
-        SQLExecuteListenerContext.getInstance().addListener(new SQLInsertExecuteListener());
-        SQLExecuteListenerContext.getInstance().addListener(new SQLUpdateExecuteListener());
+        SQLRunningContext.getInstance().addListener(new DeleteEventListener());
+        SQLRunningContext.getInstance().addListener(new InsertEventListener());
+        SQLRunningContext.getInstance().addListener(new UpdateEventListener());
         LOGGER.info("DBStreamProxyDriver initialized and registered");
     }
 
@@ -108,7 +108,6 @@ public Connection connect(String url, Properties info) throws SQLException {
         if (metaData == null) {
             DBScanner scanner = new DBScanner(connection, info);
             metaData = scanner.loadMetadata();
-            DBMetaContext.getInstance().update(metaData);
         }
         return new ConnectionProxy(connection, metaData);
     }

src/main/java/com/codingapi/dbstream/listener/SQLExecuteListener.java

@@ -1,9 +1,10 @@
 package com.codingapi.dbstream.listener;
 
-import com.codingapi.dbstream.interceptor.SQLExecuteState;
-
 import java.sql.SQLException;
 
+/**
+ * SQL执行监听器
+ */
 public interface SQLExecuteListener {
 
     /**
@@ -16,17 +17,17 @@ public interface SQLExecuteListener {
     /**
      * before sql execute
      *
-     * @param executeState execute state content
+     * @param runningState execute state content
      * @throws SQLException throws {@link SQLException}
      */
-    void before(SQLExecuteState executeState) throws SQLException;
+    void before(SQLRunningState runningState) throws SQLException;
 
     /**
      * after sql execute
      *
-     * @param executeState execute state content
+     * @param runningState execute state content
      * @throws SQLException throws {@link SQLException}
      */
-    void after(SQLExecuteState executeState, Object result) throws SQLException;
+    void after(SQLRunningState runningState, Object result) throws SQLException;
 
 }

…terceptor/SQLExecuteListenerContext.java …dbstream/listener/SQLRunningContext.javasrc/main/java/com/codingapi/dbstream/interceptor/SQLExecuteListenerContext.java renamed to src/main/java/com/codingapi/dbstream/listener/SQLRunningContext.java src/main/java/com/codingapi/dbstream/interceptor/SQLExecuteListenerContext.java renamed to src/main/java/com/codingapi/dbstream/listener/SQLRunningContext.java

@@ -1,6 +1,5 @@
-package com.codingapi.dbstream.interceptor;
+package com.codingapi.dbstream.listener;
 
-import com.codingapi.dbstream.listener.SQLExecuteListener;
 import lombok.Getter;
 
 import java.sql.SQLException;
@@ -11,15 +10,15 @@
 /**
  * SQLExecuteListener 上下文对象
  */
-public class SQLExecuteListenerContext {
+public class SQLRunningContext {
 
     @Getter
-    private final static SQLExecuteListenerContext instance = new SQLExecuteListenerContext();
+    private final static SQLRunningContext instance = new SQLRunningContext();
 
     @Getter
     private final List<SQLExecuteListener> listeners = new CopyOnWriteArrayList<>();
 
-    private SQLExecuteListenerContext() {
+    private SQLRunningContext() {
 
     }
 
@@ -38,7 +37,7 @@ public void addListener(SQLExecuteListener listener) {
     /**
      * SQL执行后拦截
      */
-    public void after(SQLExecuteState executeState, Object result) throws SQLException {
+    public void after(SQLRunningState executeState, Object result) throws SQLException {
         executeState.setResult(result);
         executeState.after();
         for (SQLExecuteListener listener : listeners) {
@@ -50,7 +49,7 @@ public void after(SQLExecuteState executeState, Object result) throws SQLExcepti
     /**
      * SQL执行前拦截
      */
-    public void before(SQLExecuteState executeState) throws SQLException {
+    public void before(SQLRunningState executeState) throws SQLException {
         executeState.begin();
         for (SQLExecuteListener listener : listeners) {
             listener.before(executeState);

…bstream/interceptor/SQLExecuteParam.java …i/dbstream/listener/SQLRunningParam.javasrc/main/java/com/codingapi/dbstream/interceptor/SQLExecuteParam.java renamed to src/main/java/com/codingapi/dbstream/listener/SQLRunningParam.java src/main/java/com/codingapi/dbstream/interceptor/SQLExecuteParam.java renamed to src/main/java/com/codingapi/dbstream/listener/SQLRunningParam.java

@@ -1,4 +1,4 @@
-package com.codingapi.dbstream.interceptor;
+package com.codingapi.dbstream.listener;
 
 import lombok.Getter;
 import lombok.Setter;
@@ -8,7 +8,7 @@
 /**
  * SQL执行参数信息
  */
-public class SQLExecuteParam {
+public class SQLRunningParam {
 
 
     /**
@@ -29,7 +29,7 @@ public class SQLExecuteParam {
     @Setter
     private String sql;
 
-    public SQLExecuteParam() {
+    public SQLRunningParam() {
         this.indexParams = new HashMap<>();
         this.mapParams = new HashMap<>();
     }