結(jié)合jdbcTemplate動(dòng)態(tài)注入數(shù)據(jù)源的示例分析

這篇文章給大家介紹結(jié)合jdbcTemplate動(dòng)態(tài)注入數(shù)據(jù)源的示例分析，內(nèi)容非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對(duì)大家能有所幫助。

結(jié)合jdbcTemplate動(dòng)態(tài)注入數(shù)據(jù)源

maven配置

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-starter</artifactId>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
</dependency>

數(shù)據(jù)庫設(shè)計(jì)

CREATE TABLE `data_source` (
  `id` bigint(11) NOT NULL AUTO_INCREMENT,
  `source_name` varchar(32) DEFAULT NULL COMMENT '數(shù)據(jù)源名稱',
  `source_code` varchar(12) DEFAULT NULL COMMENT '數(shù)據(jù)源編碼',
  `source_type` tinyint(2) DEFAULT NULL COMMENT '數(shù)據(jù)源類型（1 mysql）',
  `url` varchar(128) DEFAULT NULL COMMENT 'URL',
  `user_name` varchar(64) DEFAULT NULL COMMENT '用戶名',
  `password` varchar(64) DEFAULT NULL COMMENT '密碼',
  `state` tinyint(2) NOT NULL COMMENT '狀態(tài)(0停用 1啟用)',
  `create_by` varchar(20) DEFAULT NULL COMMENT '創(chuàng)建人',
  `create_time` datetime DEFAULT NULL COMMENT '創(chuàng)建時(shí)間',
  `update_by` varchar(20) DEFAULT NULL COMMENT '修改人',
  `update_time` datetime DEFAULT NULL COMMENT '修改時(shí)間',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8mb4 COMMENT='數(shù)據(jù)源';

LocalCacheUtil

public class LocalCacheUtil {


    private static ConcurrentMap<String, DruidDataSource> cacheRepository = new ConcurrentHashMap<String, DruidDataSource>();

    /**
     * set cache
     *
     * @param key
     * @param dataSource
     * @return
     */
    public static boolean set(String key, DruidDataSource dataSource){
        // set new cache
        if (key==null || key.trim().length()==0) {
            return false;
        }
        cacheRepository.put(key, dataSource);
        return true;
    }

    /**
     * get cache
     *
     * @param key
     * @return
     */
    public static DruidDataSource get(String key){
        if (key==null || key.trim().length()==0) {
            return null;
        }
        DruidDataSource localCacheData = cacheRepository.get(key);
        if (localCacheData!=null) {
            return localCacheData;
        } else {
            return null;
        }
    }

}

JobDataSourceDO

@Data
@TableName("data_source")
public class JobDataSourceDO implements Serializable {
	private static final long serialVersionUID = 1L;

	/**
	 * 
	 */
	@TableId(value = "ID", type = IdType.AUTO)
	private Long id;
	/**
	 * 數(shù)據(jù)源名稱
	 */
	private String sourceName;
	/**
	 * 數(shù)據(jù)源編碼
	 */
	private String sourceCode;
	/**
	 * 數(shù)據(jù)源類型（1 mysql 2 mongoDB）
	 */
	private Integer sourceType;
	/**
	 * URL
	 */
	private String url;
	/**
	 * 用戶名
	 */
	private String userName;
	/**
	 * 密碼
	 */
	private String password;
	/**
	 * 狀態(tài)(0停用 1啟用)
	 */
	private Integer state;
	/**
	 * 創(chuàng)建人
	 */
	private String createBy;
	/**
	 * 創(chuàng)建時(shí)間
	 */
	private Date createTime;
	/**
	 * 修改人
	 */
	private String updateBy;
	/**
	 * 修改時(shí)間
	 */
	private Date updateTime;

}

BaseQueryTool

public class BaseQueryTool {

    protected static final Logger logger = LoggerFactory.getLogger(BaseQueryTool.class);
    private static ConcurrentMap<String, JdbcTemplate> cacheJdbcTemplate = new ConcurrentHashMap<String, JdbcTemplate>();

    private DruidDataSource druidDataSource;
    private JdbcTemplate jdbcTemplate;
    /**
     * @param jobDatasource
     */
    BaseQueryTool(JobDataSourceDO jobDatasource) {
        logger.info("獲取數(shù)據(jù)源-------------------{}", JSON.toJSONString(jobDatasource));
        try{
            if (LocalCacheUtil.get(jobDatasource.getSourceName()) == null) {
                druidDataSource = getDataSource(jobDatasource);
                LocalCacheUtil.set(jobDatasource.getSourceName(),druidDataSource);
            } else {
                druidDataSource = LocalCacheUtil.get(jobDatasource.getSourceName());
            }
            if (BaseQueryTool.cacheJdbcTemplate.get(jobDatasource.getSourceName()) == null) {
                JdbcTemplate  jdbcTemplate = new JdbcTemplate();
                jdbcTemplate.setDataSource(druidDataSource);
                BaseQueryTool.cacheJdbcTemplate.put(jobDatasource.getSourceName(),jdbcTemplate);
                this.jdbcTemplate = jdbcTemplate;
            } else {
                this.jdbcTemplate = BaseQueryTool.cacheJdbcTemplate.get(jobDatasource.getSourceName());
            }
            logger.info("開始獲取數(shù)據(jù)源連接數(shù)-------------------,{},{}",druidDataSource.getInitialSize(),druidDataSource.getActiveCount());

        }catch (Throwable e){
            logger.error("獲取數(shù)據(jù)源-------------------{}",JSON.toJSONString(e));
        }
        logger.info("獲取數(shù)據(jù)源-------------------");
    }

    private DruidDataSource  getDataSource(JobDataSourceDO jobDatasource){
        DruidDataSource  dataSource = new DruidDataSource ();
        dataSource.setUsername(jobDatasource.getUserName());
        dataSource.setPassword(jobDatasource.getPassword());
        dataSource.setUrl(jobDatasource.getUrl());
        dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
        dataSource.setInitialSize(5);
        dataSource.setMinIdle(5);
        dataSource.setMaxActive(50);
        dataSource.setMaxWait(60000);
        dataSource.setTimeBetweenEvictionRunsMillis(60000);
        dataSource.setMinEvictableIdleTimeMillis(30000);
        dataSource.setValidationQuery("SELECT 1 FROM DUAL");
        dataSource.setTestWhileIdle(true);
        dataSource.setTestOnBorrow(false);
        dataSource.setTestOnReturn(false);
        dataSource.setPoolPreparedStatements(true);
        return dataSource;
    }


    public JSONArray getArrByQuerySql(String querySql) {
        return jdbcTemplate.query(querySql,new ResultSetExtractor<JSONArray>() {
            @Override
            public JSONArray extractData(ResultSet resultSet) throws SQLException, DataAccessException {
                ResultSetMetaData rsd = resultSet.getMetaData();
                int clength = rsd.getColumnCount();
                JSONArray ja = new JSONArray();
                String columnName;
                try {
                    while (resultSet.next()) {
                        JSONObject jo = new JSONObject();
                        for (int i = 0; i < clength; i++) {
                            columnName = rsd.getColumnLabel(i + 1);
                            jo.put(columnName, resultSet.getObject(i + 1));
                        }
                        ja.add(jo);
                    }
                } catch (Exception e) {

                }
                return ja;
            }
        });
    }

}

使用

 JobDataSourceDO dataSourceDO = new JobDataSourceDO();
            dataSourceDO.setPassword(queryJobDefinitionByJobcode.getPassword());
            dataSourceDO.setUserName(queryJobDefinitionByJobcode.getUserName());
            dataSourceDO.setUrl(queryJobDefinitionByJobcode.getUrl());
            dataSourceDO.setSourceType(queryJobDefinitionByJobcode.getSourceType());
            dataSourceDO.setSourceName(queryJobDefinitionByJobcode.getSourceName());

JSONArray array = baseQueryTool.getArrByQuerySql(respBO.getRunSql());

關(guān)于結(jié)合jdbcTemplate動(dòng)態(tài)注入數(shù)據(jù)源的示例分析就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到。