👨🎓作者：bug 菌
✏️博客：CSDN、掘金、infoQ、51CTO 等
🎉简介：CSDN 博客专家，C 站历届博客之星 Top50，掘金/InfoQ/51CTO 等社区优质创作者，全网粉丝合计 10w+，对一切技术感兴趣，重心偏 Java 方向；硬核公众号「 猿圈奇妙屋」，欢迎小伙伴们的加入，一起秃头，一起变强。
..
✍️温馨提醒：本文字数：3425 字, 阅读完需：约 10 分钟
如果小伙伴们在批阅文章的过程中觉得文章对自己有帮助，请别吝啬手中的赞呀，大胆的把文章点亮👍，相信你点赞了好的文章，平台也会经常给你推荐高质量好文，您的点赞三连(收藏+关注+留言)就是对 bug 菌写文道路上最好的鼓励与支持😘。时光不弃🏃🏻♀️，创作不停💕，加油☘️
一、前言🔥
环境说明：Windows10 + Idea2021.3.2 + Jdk1.8 + SpringBoot 2.3.1.RELEASE
通过，在使用 springboot 框架之后，就很少涉及到手动连接数据库的方式了，但 bug 菌有遇到这么一个需求场景，给到你的是无上限的数据库连接信息，要求你能按连接信息指定获取表数据，突然我就一愣，我问了问，能给我具体的那些数据库吗？由于是对接第三方，不确定，所以只能给到你生成好的连接信息，你只能依据它的连接信息自动连接并解析。
很完美，这不就得回到以前玩 springmvc 的日子么，通过连接信息手动连接数据并获取表结构字段，且返回该表的数据。
接下来，废话不多说，我就给大家演示一下，具体如何实现？
二、正文🔥
接下来我还是以接口的请求方式，给大家简单演示一下，具体场景，你们自己依据情况而定，我就给大家展示下我手动获取本地库指定表的表结构字段吧。
1️⃣定义一个 Controller 接口
/** * 根据数据库连接信息指定分页查询表获取表数据 */ @PostMapping("/find-db-info-by-page") @ApiOperation(value = "根据数据库连接信息指定分页查询表获取表数据",notes = "根据数据库连接信息指定分页查询表获取表数据") public ResultResponse<Map> findDbInfoByPage(@RequestBody FindDbByPageModel model){ return new ResultResponse<>(dbService.findDbInfoByPage(model)); }
复制代码
如下是上接口所涉及的入参体：
package com.example.demo.model;
import io.swagger.annotations.ApiModel;import io.swagger.annotations.ApiModelProperty;import lombok.Data;
/** * @author luoYong * @version 1.0 * @date 2022/8/30 16:02 */@Data@ApiModel(value = "查询用户参数体", description = "查询用户参数体")public class FindDbByPageModel {
@ApiModelProperty(value = "数据库url") private String dbUrl;
@ApiModelProperty(value = "数据库连接用户名") private String userName;
@ApiModelProperty(value = "数据库连接密码") private String passWord;
@ApiModelProperty(value = "数据库驱动") private String driverClass;
@ApiModelProperty(value = "指定查询表名") private String tableName;
@ApiModelProperty(value = "页码") private int page;
@ApiModelProperty(value = "容量") private int limit;}
复制代码
2️⃣定义一个获取指定表数据的接口
/** * 根据数据库连接信息指定分页查询表获取表数据 */ Map findDbInfoByPage(FindDbByPageModel model);
复制代码
3️⃣实现获取指定表数据并分页
/** * 根据数据库连接信息指定分页查询表获取表数据 */ @Override public Map findDbInfoByPage(FindDbByPageModel model) { //手动计算分页参数 int limit = model.getLimit(); int pageStart = (model.getPage() - 1) * limit;
//与数据库取的连接 Connection conn = this.getConn(model.getDbUrl(), model.getUserName(), model.getPassWord(), model.getDriverClass());
//拼接分页sql(以mysql为例) String sql = "select * from " + model.getTableName() + " limit " + pageStart + "," + limit; //申明PreparedStatement PreparedStatement pst = null; int total = 0; try { //执行SQL语句 pst = conn.prepareStatement(sql); ResultSet rs = pst.executeQuery(sql); ResultSetMetaData metaData = rs.getMetaData(); //定义一个存放所有列名的集合 List<String> columnArr = new ArrayList<>(); // total = metaData.getColumnCount();
//获取表字段名 for (int i = 1; i <= total; i++) { String columnName = metaData.getColumnName(i); columnArr.add(columnName); } List<Map> dbData = new ArrayList<>(); while (rs.next()) { //存放单条数据 Map<String, String> linkedHashMap = new LinkedHashMap<>(); columnArr.forEach(p -> { //根据列名获取值 try { String value = rs.getString(p); linkedHashMap.put(p, value); } catch (SQLException e) { e.printStackTrace(); } }); dbData.add(linkedHashMap); } Map res = new LinkedHashMap<>();
res.put("records", dbData); res.put("total", total); res.put("current", model.getPage()); res.put("size", model.getLimit()); //手动分页 res.put("pages", total % model.getLimit() == 0 ? total / model.getLimit() : total / model.getLimit() + 1);
//返回 return res; } catch (SQLException e) { e.printStackTrace(); } return new HashMap(); }
复制代码
如下是手动连接库获取 Connection 对象的封装方法。
/** * 手动连接数据库 * * @param url * @param userName * @param passWord * @param driverClass */public Connection getConn(String url, String userName, String passWord, String driverClass) {
//声明数据库连接对象 Connection conn = null; try { //加载驱动 Class.forName(driverClass); //初始化数据库连接,获取连接对象 conn = DriverManager.getConnection(url, userName, passWord); } catch (Exception e) { e.printStackTrace(); System.out.println("获得数据库连接出错"); } return conn;}
复制代码
4️⃣接口测试
接下来既然我们已经实现了接口，那我们就来进行测试，还是老样子，直接通过在线接口文档 swagger 进行测试，集成 swagger 文档我前期文章已经讲过了，这个你们自己去看。
参数体给与正确的，我就以本地库为例。
具体请看如下截图，很显然，是正常获取到了该【grade】表的表结构信息及将数据进行分页。
如下是具体获取到的数据，将获取到的表字段名作为 key，value 为具体的数据库存放数据。而且手动对其数据进行了分页处理。
附上请求样例：
{ "dbUrl": "jdbc:mysql://127.0.0.1:3306/springboot_db?serverTimezone=GMT%2B8", "userName": "root", "passWord": "123456", "driverClass": "com.mysql.cj.jdbc.Driver", "tableName": "grade"}
复制代码
... ...
ok，以上就是我这期的全部内容啦，如果还想学习更多，可以看看我的往期热文推荐哦，不积跬步,无以至千里; 不积小流,无以成江海，一口吃不成一个大胖子，加油！咱们下期拜拜~~
文末🔥
我是 bug 菌，一名想走👣出大山改变命运的程序猿。接下来的路还很长，都等待着我们去突破、去挑战。来吧，小伙伴们，我们一起加油！未来皆可期，fighting！
感谢认真读完我博客的铁子萌，在这里呢送给大家一句话，不管你是在职还是在读，绝对终身受用。
时刻警醒自己：
抱怨没有用，一切靠自己；
想要过更好的生活，那就要逼着自己变的更强，生活加油！！！
评论