同步资产结构

muyu-source-common/src/main/java/com/muyu/source/domain/AssetDataSource.java

@@ -48,4 +48,8 @@ public class AssetDataSource extends BaseEntity {
      */
     @Excel(name = "数据库名称")
     private String databaseName;
+    /**
+     * 前台展示类型
+     */
+    private String type;
 }

muyu-source-common/src/main/java/com/muyu/source/domain/Children.java

@@ -48,6 +48,10 @@ public class Children extends BaseEntity {
      */
     @Excel(name = "数据条数")
     private Integer dataTotal;
+    /**
+     * 前台展示类型
+     */
+    private String type;
     /**
      * 数据源
      */

muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java

@@ -208,6 +208,7 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
                 Children children = Children.builder()
                         .name(resultSet.getString("TABLE_NAME"))
                         .remark(resultSet.getString("TABLE_COMMENT"))
+                        .type(resultSet.getString("TABLE_TYPE"))
                         .assetId(build.getId())
                         .build();
                 //添加到数据库中
@@ -320,7 +321,7 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
                         .dictKey("")
                         .childrenId(serviceOne.getId())
                         .build();
-                //添加字段自信到数据库中
+                //添加字段信息到数据库中
                 tableDataService.save(tableData);
             }
             //关闭资源
@@ -345,8 +346,10 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
      * @return 结果
      */
     private boolean testConnection(String driverManager, String jdbcUrl, String userName, String password) {
+        // 判断参数是否为空
         if (StringUtils.isNotEmpty(driverManager) && StringUtils.isNotEmpty(jdbcUrl) && StringUtils.isNotEmpty(userName) && StringUtils.isNotEmpty(password)) {
             try {
+                // 加载驱动
                 Class.forName(driverManager);
                 return true;
             } catch (Exception e) {