Hutoll简介：
Hutool是一个小而全的Java工具类库，通过静态方法封装，降低相关API的学习成本，提高工作效率，使Java拥有函数式语言般的优雅，让Java语言也可以“甜甜的”。
Hutool中的工具方法来自每个用户的精雕细琢，它涵盖了Java开发底层代码中的方方面面，它既是大型项目开发中解决小问题的利器，也是小型项目中的效率担当；
Hutool网站：
Hutool🍬一个功能丰富且易用的Java工具库，涵盖了字符串、数字、集合、编码、日期、文件、IO、加密、数据库JDBC、JSON、HTTP客户端等功能。
业务需求：
需要我去通过各种不同的id找到不同的表，最后的重点是通过数据库表里存的连接信息，用户名和密码去指定数据库类型（比如MySql、DM等）数据库做链接然后找到对应数据表里的所有信息。
编辑
编辑
pom文件增加Hutool依赖
<!-- hutool依赖 -->
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.8.25</version>
</dependency>
代码
/** * @Title: getDataPreview * @Description: 数据资产拿到数据库的数据 * @author: sxy * @date 2025-02-20 * @return ResultData */ @PostMapping(value = "/getDataPreview") public ResultData getDataPreview(Long code) throws SQLException { //通过code找到med_data_dictory表的dd_scheme_id if (code == null) { return ResultData.error(ResultData.PARAM_ERROR_CODE, "参数错误"); } DataDictoryDto dataDictory = dataDictoryMapper.getInfo(code); Long schemeId = dataDictory.getSchemaId(); //获取数据库表名字 String tableName = dataDictory.getTableName(); //通过dd_scheme_id找到med_data_scheme表的ds_pk_id DataSchema dataSchema = dataSchemaMapper.selectById(schemeId); //获取数据源id Long dataBaseSourceId = dataSchema.getDsDatabaseId(); //通过ds_pk_id去和云平台的ma_dataBase_source表的id去匹配拿到数据库的链接 //通过数据源id去云平台ma_dataBase_source表里找数据 JSONObject manageDataSource = cloudFlowUtil.getManageDataSource(dataBaseSourceId); MaDataSourceDto maDataSourceDto = new MaDataSourceDto(); if (manageDataSource.getInteger("code") == 20000) { maDataSourceDto=JSONObject.parseObject(manageDataSource.getString("data"), MaDataSourceDto.class); } String dbType = maDataSourceDto.getDbType(); String url = maDataSourceDto.getUrl(); String userName = maDataSourceDto.getUserName(); String password = maDataSourceDto.getPassword(); String driverClassName = maDataSourceDto.getDriverClassName(); //引入hutool工具包创建数据源对象 DruidDataSource ds = new DruidDataSource(); //判断数据库类型是否为MySql if (dbType.equals("MySql")){ ds.setUrl(url); ds.setUsername(userName); ds.setPassword(password); ds.setDriverClassName(driverClassName); Connection conn = ds.getConnection(); //查询数据 List<Entity> entityList = SqlExecutor.query(conn, "select * from " + tableName , new EntityListHandler()); return ResultData.success("ok",entityList); }else if (dbType.equals("DM")){ //判断数据库类型是否为达梦数据库 ds.setUrl(url); ds.setUsername(userName); ds.setPassword(password); ds.setDriverClassName(driverClassName); Connection conn = ds.getConnection(); //查询数据 List<Entity> entityList = SqlExecutor.query(conn, "select * from " + tableName , new EntityListHandler()); return ResultData.success("ok",entityList); }else if(dbType.equals("Oracle")){ //判断数据库类型是否为Oracle数据库 ds.setUrl(url); ds.setUsername(userName); ds.setPassword(password); ds.setDriverClassName(driverClassName); Connection conn = ds.getConnection(); //查询数据 List<Entity> entityList = SqlExecutor.query(conn, "select * from " + tableName , new EntityListHandler()); return ResultData.success("ok",entityList); }else if (dbType.equals("Marinadb")){ //判断数据库类型是否为Marinadb数据库 ds.setUrl(url); ds.setUsername(userName); ds.setPassword(password); ds.setDriverClassName(driverClassName); Connection conn = ds.getConnection(); //查询数据 List<Entity> entityList = SqlExecutor.query(conn, "select * from " + tableName , new EntityListHandler()); return ResultData.success("ok",entityList); }else if (dbType.equals("SQLServer")){ //判断数据库类型是否为SQLServer数据库 ds.setUrl(url); ds.setUsername(userName); ds.setPassword(password); ds.setDriverClassName(driverClassName); Connection conn = ds.getConnection(); //查询数据 List<Entity> entityList = SqlExecutor.query(conn, "select * from " + tableName , new EntityListHandler()); return ResultData.success("ok",entityList); }else if (dbType.equals("PostgreSQL")){ //判断数据库类型是否为PostgreSQL数据库 ds.setUrl(url); ds.setUsername(userName); ds.setPassword(password); ds.setDriverClassName(driverClassName); Connection conn = ds.getConnection(); //查询数据 List<Entity> entityList = SqlExecutor.query(conn, "select * from " + tableName , new EntityListHandler()); return ResultData.success("ok",entityList); }else if (dbType.equals("瀚高")){ //判断数据库类型是否为瀚高数据库 ds.setUrl(url); ds.setUsername(userName); ds.setPassword(password); ds.setDriverClassName(driverClassName); Connection conn = ds.getConnection(); //查询数据 List<Entity> entityList = SqlExecutor.query(conn, "select * from " + tableName , new EntityListHandler()); return ResultData.success("ok",entityList); }else if (dbType.equals("Hive")){ //判断数据库类型是否为Hive数据库 ds.setUrl(url); ds.setUsername(userName); ds.setPassword(password); ds.setDriverClassName(driverClassName); Connection conn = ds.getConnection(); //查询数据 List<Entity> entityList = SqlExecutor.query(conn, "select * from " + tableName , new EntityListHandler()); return ResultData.success("ok",entityList); } return ResultData.success("ok"); }
cloudFlowUtil：
public JSONObject getManageDataSource(Long code) { HttpHeaders headers = new HttpHeaders(); headers.setContentType(MediaType.APPLICATION_JSON); headers.add(StpUtil.getTokenName(), StpUtil.getTokenValue()); ResponseEntity<String> postForEntity = restTemplate.postForEntity( BASE_URL + "maDataSource/getInfoDataAsset?code=" + code, headers, String.class); JSONObject reData = JSONObject.parseObject(postForEntity.getBody()); return reData; }
返回数据：
编辑
编辑
