【7.0.3】更新数据库连接api

kernel-d-ds-container/ds-container-api/src/main/java/cn/stylefeng/roses/kernel/dsctn/api/DataSourceApi.java

@@ -0,0 +1,23 @@
+package cn.stylefeng.roses.kernel.dsctn.api;
+
+import cn.stylefeng.roses.kernel.dsctn.api.pojo.DataSourceDto;
+
+/**
+ * 数据库连接的api
+ *
+ * @author fengshuonan
+ * @date 2021/4/22 14:19
+ */
+public interface DataSourceApi {
+
+    /**
+     * 根据dbId获取数据库连接信息
+     *
+     * @param dbId 数据库连接id
+     * @return 数据库连接信息
+     * @author fengshuonan
+     * @date 2021/4/22 14:21
+     */
+    DataSourceDto getDataSourceInfoById(Long dbId);
+
+}

kernel-d-ds-container/ds-container-api/src/main/java/cn/stylefeng/roses/kernel/dsctn/api/pojo/DataSourceDto.java

@@ -0,0 +1,39 @@
+package cn.stylefeng.roses.kernel.dsctn.api.pojo;
+
+import lombok.Data;
+
+/**
+ * 数据库连接信息传输DTO
+ *
+ * @author fengshuonan
+ * @date 2021/4/22 14:20
+ */
+@Data
+public class DataSourceDto {
+
+    /**
+     * jdbc的驱动类型
+     */
+    private String jdbcDriver;
+
+    /**
+     * jdbc的url
+     */
+    private String jdbcUrl;
+
+    /**
+     * 数据库连接的账号
+     */
+    private String username;
+
+    /**
+     * 数据库连接密码
+     */
+    private String password;
+
+    /**
+     * 数据库schemaName，注意，每种数据库的schema意义不同
+     */
+    private String schemaName;
+
+}

kernel-d-ds-container/ds-container-api/src/main/java/cn/stylefeng/roses/kernel/dsctn/api/pojo/request/DatabaseInfoRequest.java

@@ -87,6 +87,11 @@ public class DatabaseInfoRequest extends BaseRequest {
     @NotBlank(message = "数据库连接密码", groups = {add.class, edit.class})
     private String password;
 
+    /**
+     * 数据库schemaName，注意，每种数据库的schema意义不同
+     */
+    private String schemaName;
+
     /**
      * 状态标识：1-正常，2-无法连接
      */

kernel-d-ds-container/ds-container-business/src/main/java/cn/stylefeng/roses/kernel/dsctn/modular/entity/DatabaseInfo.java

@@ -78,6 +78,12 @@ public class DatabaseInfo extends BaseEntity {
     @TableField("password")
     private String password;
 
+    /**
+     * 数据库的schema名称，每种数据库的schema意义都不同
+     */
+    @TableField("schema_name")
+    private String schemaName;
+
     /**
      * 状态标识：1-正常，2-无法连接
      */

kernel-d-ds-container/ds-container-business/src/main/java/cn/stylefeng/roses/kernel/dsctn/modular/service/DatabaseInfoService.java

@@ -25,6 +25,7 @@
 package cn.stylefeng.roses.kernel.dsctn.modular.service;
 
 import cn.stylefeng.roses.kernel.db.api.pojo.page.PageResult;
+import cn.stylefeng.roses.kernel.dsctn.api.DataSourceApi;
 import cn.stylefeng.roses.kernel.dsctn.api.pojo.request.DatabaseInfoRequest;
 import cn.stylefeng.roses.kernel.dsctn.modular.entity.DatabaseInfo;
 import com.baomidou.mybatisplus.extension.service.IService;
@@ -37,7 +38,7 @@ import java.util.List;
  * @author fengshuonan
  * @date 2020/11/1 21:46
  */
-public interface DatabaseInfoService extends IService<DatabaseInfo> {
+public interface DatabaseInfoService extends IService<DatabaseInfo>, DataSourceApi {
 
     /**
      * 新增数据库信息

kernel-d-ds-container/ds-container-business/src/main/java/cn/stylefeng/roses/kernel/dsctn/modular/service/impl/DatabaseInfoServiceImpl.java

@@ -33,6 +33,7 @@ import cn.stylefeng.roses.kernel.db.api.factory.PageResultFactory;
 import cn.stylefeng.roses.kernel.db.api.pojo.druid.DruidProperties;
 import cn.stylefeng.roses.kernel.db.api.pojo.page.PageResult;
 import cn.stylefeng.roses.kernel.dsctn.api.exception.DatasourceContainerException;
+import cn.stylefeng.roses.kernel.dsctn.api.pojo.DataSourceDto;
 import cn.stylefeng.roses.kernel.dsctn.api.pojo.request.DatabaseInfoRequest;
 import cn.stylefeng.roses.kernel.dsctn.context.DataSourceContext;
 import cn.stylefeng.roses.kernel.dsctn.modular.entity.DatabaseInfo;
@@ -162,12 +163,7 @@ public class DatabaseInfoServiceImpl extends ServiceImpl<DatabaseInfoMapper, Dat
         return databaseInfo;
     }
 
-    /**
+    @Override
-     * 判断数据库连接是否可用
-     *
-     * @author fengshuonan
-     * @date 2020/11/1 21:50
-     */
     public void validateConnection(DatabaseInfoRequest param) {
         Connection conn = null;
         try {
@@ -186,6 +182,17 @@ public class DatabaseInfoServiceImpl extends ServiceImpl<DatabaseInfoMapper, Dat
         }
     }
 
+    @Override
+    public DataSourceDto getDataSourceInfoById(Long dbId) {
+        DataSourceDto dataSourceDto = new DataSourceDto();
+
+        DatabaseInfoRequest databaseInfoRequest = new DatabaseInfoRequest();
+        databaseInfoRequest.setDbId(dbId);
+        DatabaseInfo databaseInfo = this.queryDatabaseInfoById(databaseInfoRequest);
+        BeanUtil.copyProperties(databaseInfo, dataSourceDto);
+        return dataSourceDto;
+    }
+
     /**
      * 往数据源容器文中添加数据源
      *
@@ -263,5 +270,4 @@ public class DatabaseInfoServiceImpl extends ServiceImpl<DatabaseInfoMapper, Dat
 
         return queryWrapper;
     }
-
 }