Springboot系列: 根据数据库连接信息指定分页查询表结构信息|超级详细，建议收藏

站长

2023年09月07日 20:29 · 阅读数 69

本专栏致力打造最硬核 Spring Boot 从零基础到进阶系列学习内容，🚀均为全网独家首发，打造精品专栏，专栏持续更新中…欢迎大家订阅持续学习。

小伙伴们在批阅文章的过程中如果觉得文章对您有一丝丝帮助，还请别吝啬您手里的赞呀，大胆的把文章点亮👍吧，您的点赞三连(收藏⭐+关注👨‍🎓+留言📃)就是对bug菌我创作道路上最好的鼓励与支持😘。时光不弃🏃🏻‍♀️，创作不停💕，加油☘️

1. 前言🔥

环境说明：Windows10 + Idea2021.3.2 + Jdk1.8 + SpringBoot 2.3.1.RELEASE

通过，在使用springboot框架之后，就很少涉及到手动连接数据库的方式了，但bug菌有遇到这么一个需求场景，给到你的是无上限的数据库连接信息，要求你能按连接信息指定获取表数据，突然我就一愣，我问了问，能给我具体的那些数据库吗？由于是对接第三方，不确定，所以只能给到你生成好的连接信息，你只能依据它的连接信息自动连接并解析。

很完美，这不就得回到以前玩springmvc的日子么，通过连接信息手动连接数据并获取表结构字段，且返回该表的数据。

接下来，废话不多说，我就给大家演示一下，具体如何实现？

2. 正文🔥

接下来我还是以接口的请求方式，给大家简单演示一下，具体场景，你们自己依据情况而定，我就给大家展示下我手动获取本地库指定表的表结构字段吧。

2.1 定义一个Controller接口

    /**
     * 根据数据库连接信息指定分页查询表获取表数据
     */
    @PostMapping("/find-db-info-by-page")
    @ApiOperation(value = "根据数据库连接信息指定分页查询表获取表数据",notes = "根据数据库连接信息指定分页查询表获取表数据")
    public ResultResponse<Map> findDbInfoByPage(@RequestBody FindDbByPageModel model){
        return new ResultResponse<>(dbService.findDbInfoByPage(model));
    }

Springboot系列: 根据数据库连接信息指定分页查询表结构信息|超级详细，建议收藏如下是上接口所涉及的入参体：

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.2 定义一个获取指定表数据的接口

    /**
     * 根据数据库连接信息指定分页查询表获取表数据
     */
    Map findDbInfoByPage(FindDbByPageModel model);

2.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;
    }

Springboot系列: 根据数据库连接信息指定分页查询表结构信息|超级详细，建议收藏如果是oracle数据库，那分页sql语法就有点区别了。这个你们要注意！

2.4 接口测试

接下来既然我们已经实现了接口，那我们就来进行测试，还是老样子，直接通过在线接口文档swagger进行测试，集成swagger文档我前期文章已经讲过了，这个你们自己去看。

参数体给与正确的，我就以本地库为例。

Springboot系列: 根据数据库连接信息指定分页查询表结构信息|超级详细，建议收藏

具体请看如下截图，很显然，是正常获取到了该【grade】表的表结构信息及将数据进行分页。

Springboot系列: 根据数据库连接信息指定分页查询表结构信息|超级详细，建议收藏如下是具体获取到的数据，将获取到的表字段名作为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"
}