springboot配置多个数据源工具类方式

jdbcUtils

package com.kunshan.dockapi.util;

import com.alibaba.druid.pool.DruidDataSource;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;

public class JDBCUtils {
    private final static Logger log = LoggerFactory.getLogger(JDBCUtils.class);

    
    private static String DriverClassName;
    private static String Url;
    private static String Username;
    private static String Password;
    @Value("${spring.datasource.driver-class-name}")
    public void setDriverClassName(String driverClassName) {
        DriverClassName = driverClassName;
    }
    @Value("${spring.datasource.middle.url}")
    public void setUrl(String url) {
        Url = url;
    }
    @Value("${spring.datasource.middle.username}")
    public void setUsername(String username) {
        Username = username;
    }
    @Value("${spring.datasource.middle.password}")
    public void setPassword(String password) {
        Password = password;
    }


    
    private static DataSource ds;

    

    static {
        try {
            
            DruidDataSource dataSource = new DruidDataSource();
            dataSource.setDriverClassName(DriverClassName);
            dataSource.setUrl("jdbc:mysql://10.119.1.197:3306/lock_yijie?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8");
            dataSource.setUsername("YiJie");
            dataSource.setPassword("YiJieLock*789");
            ds = dataSource;
        } catch (Exception e) {
            log.error("create connection pool error,errorMessage:{}", e);
        }
    }

    
    public static DataSource getDataSource(){
        return ds;
    }

    
    public static Connection getConn() throws SQLException {
        return ds.getConnection();
    }

    
    public static void close(Statement stmt, Connection conn){
        if(stmt != null){
            try {
                stmt.close();
            } catch (SQLException e) {
                log.error("close error,errorMessage:{}", e);
            }
        }

        if(conn != null){
            try {
                conn.close();
            } catch (SQLException e) {
                log.error("close error,errorMessage:{}", e);
            }
        }
    }

    
    public static void close(ResultSet rs, Statement stmt, Connection conn){
        if(rs != null){
            try {
                rs.close();
            } catch (SQLException e) {
                log.error("close error,errorMessage:{}", e);
            }
        }

        if(stmt != null){
            try {
                stmt.close();
            } catch (SQLException e) {
                log.error("close error,errorMessage:{}", e);
            }
        }

        if(conn != null){
            try {
                conn.close();
            } catch (SQLException e) {
                log.error("close error,errorMessage:{}", e);
            }
        }
    }
}

使用

  String sql = "select * from t_mb_card_campus";
        // 获得数据库连接
        DataSource ds = JDBCUtils.getDataSource();
        JdbcTemplate jdbcTemplate = new JdbcTemplate(ds);
        List list = jdbcTemplate.queryForList(sql);
        for (int i = 0; i < list.size(); i++) {
            System.out.println(list.get(i));

        }