SpringBoot动态数据源连接测试的操作详解

// 声明为一个 Spring Boot 控制器
@RestController
public class DatabaseController {

    // POST请求映射到/test-database-connection路径
    @PostMapping("/test-database-connection")
    public String testDatabaseConnection(@RequestBody DatabaseConfig config) {
        try {
            // 创建数据源
            DataSource dataSource = createDataSource(config);
            // 使用JdbcTemplate执行SQL语句
            JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
            jdbcTemplate.execute("SELECT 1");
            // 如果连接成功，返回"ok"
            return "ok";
        } catch (Exception e) {
            // 如果发生异常，打印异常信息并返回"error"
            e.printStackTrace();
            return "error";
        }
    }

    // 创建数据源
    private DataSource createDataSource(DatabaseConfig config) {
        // 使用DriverManagerDataSource创建数据源
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        // 设置数据源的驱动类名、URL、用户名和密码
        dataSource.setDriverClassName(config.getDriverClassName());
        dataSource.setUrl(config.getUrl());
        dataSource.setUsername(config.getUsername());
        dataSource.setPassword(config.getPassword());
        return dataSource;
    }
}

package com.example.test111;

public class DatabaseConfig {
    private String driverClassName;
    private String url;
    private String username;
    private String password;

    // 构造函数、getter和setter方法

    public DatabaseConfig() {
    }

    public DatabaseConfig(String driverClassName, String url, String username, String password) {
        this.driverClassName = driverClassName;
        this.url = url;
        this.username = username;
        this.password = password;
    }

    public String getDriverClassName() {
        return driverClassName;
    }

    public void setDriverClassName(String driverClassName) {
        this.driverClassName = driverClassName;
    }

    public String getUrl() {
        return url;
    }

    public void setUrl(String url) {
        this.url = url;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }
}

mysql -u root -p

use mysql;

update user set host = '%' where user = 'root';

flush privileges; 

select host,user from user;