快捷導(dǎo)航

Springboot手動(dòng)連接庫并獲取指定表結(jié)構(gòu)的示例代碼

更新時(shí)間：2023年07月14日 09:50:12 作者：bug菌1

這篇文章主要介紹了Springboot手動(dòng)連接庫并獲取指定表結(jié)構(gòu)的示例代碼,本文通過實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

一、前言??

通過，在使用springboot框架之后，就很少涉及到手動(dòng)連接數(shù)據(jù)庫的方式了，但bug菌有遇到這么一個(gè)需求場(chǎng)景，給到你的是無上限的數(shù)據(jù)庫連接信息，要求你能按連接信息指定獲取表數(shù)據(jù)，突然我就一愣，我問了問，能給我具體的那些數(shù)據(jù)庫嗎？由于是對(duì)接第三方，不確定，所以只能給到你生成好的連接信息，你只能依據(jù)它的連接信息自動(dòng)連接并解析。

很完美，這不就得回到以前玩springmvc的日子么，通過連接信息手動(dòng)連接數(shù)據(jù)并獲取表結(jié)構(gòu)字段，且返回該表的數(shù)據(jù)。

接下來，廢話不多說，我就給大家演示一下，具體如何實(shí)現(xiàn)？

二、正文??

接下來我還是以接口的請(qǐng)求方式，給大家簡單演示一下，具體場(chǎng)景，你們自己依據(jù)情況而定，我就給大家展示下我手動(dòng)獲取本地庫指定表的表結(jié)構(gòu)字段吧。

定義一個(gè)Controller接口

    /**
     * 獲取指定表的字段集合
     */
    @PostMapping("/get-db-columns")
    @ApiOperation(value = "獲取指定表的字段集合",notes = "獲取指定表的字段集合")
    public ResultResponse<List<String>> getDbColumns(@RequestBody FindDbColumnModel model){
        return new ResultResponse<>(dbService.getDbColumns(model));
    }

如下是上接口所涉及的入?yún)Ⅲw：

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 FindDbColumnModel {
    @ApiModelProperty(value = "數(shù)據(jù)庫url")
    private String dbUrl;
    @ApiModelProperty(value = "數(shù)據(jù)庫連接用戶名")
    private String userName;
    @ApiModelProperty(value = "數(shù)據(jù)庫連接密碼")
    private String passWord;
    @ApiModelProperty(value = "數(shù)據(jù)庫驅(qū)動(dòng)")
    private String driverClass;
    @ApiModelProperty(value = "指定查詢表名")
    private String tableName;
}

定義一個(gè)獲取表結(jié)構(gòu)的接口

    /**
     * 獲取指定表的字段集合
     */
    List<String> getDbColumns(FindDbColumnModel model);

實(shí)現(xiàn)獲取表結(jié)構(gòu)的接口

    /**     * 獲取指定表的字段集合     */    &#64;Override    public List<String> getDbColumns(FindDbColumnModel model) {        //與數(shù)據(jù)庫取的連接        Connection conn &#61; this.getConn(model.getDbUrl(), model.getUserName(), model.getPassWord(), model.getDriverClass());        //拼接分頁sql(以mysql為例)        String sql &#61; &#34;select * from &#34; &#43; model.getTableName();        //申明PreparedStatement        PreparedStatement pst &#61; null;        try {            //執(zhí)行SQL語句            pst &#61; conn.prepareStatement(sql);            ResultSet rs &#61; pst.executeQuery(sql);            ResultSetMetaData metaData &#61; rs.getMetaData();            //定義一個(gè)存放所有列名的集合            List<String> columnArr &#61; new ArrayList<>();            //獲取表字段名            for (int i &#61; 1; i <&#61; metaData.getColumnCount(); i&#43;&#43;) {                //循環(huán)獲取&#xff0c;再儲(chǔ)存到集合中。                String columnName &#61; metaData.getColumnName(i);                columnArr.add(columnName);            }            return columnArr;        } catch (SQLException e) {            e.printStackTrace();        }        return new ArrayList<>();    }    /**
     * 獲取指定表的字段集合
     */
    @Override
    public List<String> getDbColumns(FindDbColumnModel model) {
        //與數(shù)據(jù)庫取的連接
        Connection conn = this.getConn(model.getDbUrl(), model.getUserName(), model.getPassWord(), model.getDriverClass());
        //拼接分頁sql(以mysql為例)
        String sql = "select * from " + model.getTableName();
        //申明PreparedStatement
        PreparedStatement pst = null;
        try {
            //執(zhí)行SQL語句
            pst = conn.prepareStatement(sql);
            ResultSet rs = pst.executeQuery(sql);
            ResultSetMetaData metaData = rs.getMetaData();
            //定義一個(gè)存放所有列名的集合
            List<String> columnArr = new ArrayList<>();
            //獲取表字段名
            for (int i = 1; i <= metaData.getColumnCount(); i++) {
                //循環(huán)獲取，再儲(chǔ)存到集合中。
                String columnName = metaData.getColumnName(i);
                columnArr.add(columnName);
            }
            return columnArr;
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return new ArrayList<>();
    }

如下是手動(dòng)連接庫獲取Connection對(duì)象的封裝方法。

    /**
     * 手動(dòng)連接數(shù)據(jù)庫
     *
     * @param url
     * @param userName
     * @param passWord
     * @param driverClass
     */
    public Connection getConn(String url, String userName, String passWord, String driverClass) {
        //聲明數(shù)據(jù)庫連接對(duì)象
        Connection conn = null;
        try {
            //加載驅(qū)動(dòng)
            Class.forName(driverClass);
            //初始化數(shù)據(jù)庫連接,獲取連接對(duì)象
            conn = DriverManager.getConnection(url, userName, passWord);
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("獲得數(shù)據(jù)庫連接出錯(cuò)");
        }
        return conn;
    }

接口測(cè)試

接下來既然我們已經(jīng)實(shí)現(xiàn)了接口，那我們就來進(jìn)行測(cè)試，還是老樣子，直接通過在線接口文檔swagger進(jìn)行測(cè)試，集成swagger文檔我前期文章已經(jīng)講過了，這個(gè)你們自己去看。

參數(shù)體給與正確的，我就以本地庫為例。

具體請(qǐng)看如下截圖，很顯然，是正常獲取到了該【grade】表的表結(jié)構(gòu)信息。

附上請(qǐng)求樣例：

{
	"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"
}

到此這篇關(guān)于Springboot如何手動(dòng)連接庫并獲取指定表結(jié)構(gòu)的文章就介紹到這了,更多相關(guān)Springboot指定表結(jié)構(gòu)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: