数据流向日志查看，只查系统连接的数据库

xzl-admin/src/main/java/com/xzl/web/model/dataGovernance/dto/SysDataLogQueryParam.java

@@ -7,4 +7,5 @@ import lombok.Data;
 public class SysDataLogQueryParam {
     private PageParam pageParam;
     private String actionType;
+    private String connectionId;
 }

xzl-admin/src/main/java/com/xzl/web/service/impl/DataGovernanceServiceImpl.java

@@ -288,6 +288,14 @@ public class DataGovernanceServiceImpl implements DataGovernanceService {
         queryParam.put("page", String.valueOf(page));
         queryParam.put("pageSize", String.valueOf(pageParam.getPageSize()));
         queryParam.put("actionType", param.getActionType());
+        queryParam.put("connectionId", param.getConnectionId());
+
+        // 日志都只存在服务端，此处数据库只能用系统数据源
+        try {
+            this.connection = DriverManager.getConnection(url, username, password);
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
         Integer logCount = this.getData(Integer.class, this.getExecuteSql("getSysDataLogCount", queryParam));
         result.setCount(logCount);
         List<SysDataLog> logList = this.getDataList(SysDataLog.class, this.getExecuteSql("getSysDataLogList", queryParam));

xzl-admin/src/main/resources/mapper/DataGovernanceMapper.xml

@@ -61,7 +61,8 @@
         select count(1)
         from sys_data_log
         <where>
-            <if test="actionType != ''">action_type = #{actionType}</if>
+            <if test="actionType != ''">and action_type = #{actionType}</if>
+            <if test="connectionId != ''">and db_cfg_id = #{connectionId}</if>
         </where>
     </select>
 
@@ -87,7 +88,8 @@
         FROM
                SYS_DATA_LOG
         <where>
-            <if test="actionType != ''">action_type = #{actionType}</if>
+            <if test="actionType != ''">and action_type = #{actionType}</if>
+            <if test="connectionId != ''">and db_cfg_id = #{connectionId}</if>
         </where>
         ORDER BY CREATE_TIME DESC
         LIMIT ${page},${pageSize}

xzl-ui/src/views/dataGovernance/dataFlowDirectionRecord.vue

@@ -111,7 +111,7 @@ export default {
         ],
         pageParam:{
           pageNum: 1,
-          pageSize: 10
+          pageSize: 10,
         },
         count:0,
       },
@@ -119,7 +119,6 @@ export default {
     }
   },
   mounted() {
-    this.queryData();
     this.initOption();
   },
   methods: {
@@ -161,6 +160,9 @@ export default {
         method: "get"
       }).then(rs=>{
         t.connectionOptions=rs;
+
+        t.queryParams.connectionId=rs[0].id;
+        t.queryData();
       })
     },
     handleSizeChange(val){
@@ -173,6 +175,7 @@ export default {
     },
     handleConnectionChange(val){
       const t=this
+      t.queryParams.connectionId=val;
       request({
         url:"/dataGovernance/changeConnection?id="+val
       }).then(rs=>{