SpringBoot数据访问自定义使用Druid数据源的方法

<dependency>

     <groupid>com.alibaba</groupid>

     <artifactid>druid</artifactid>

     <version>版本号</version>

</dependency>

import com.alibaba.druid.pool.druiddatasource;

import org.springframework.context.annotation.bean;

import org.springframework.context.annotation.configuration;

import javax.sql.datasource;   //注意不要导错包

@configuration

//配置数据源

public class mydtasourceconfig {

     @bean

     public datasource datasource() {

         return new druiddatasource();   //创建druid数据源

     }

}

@configuration (proxybeanmethods = false )

     @conditional (pooleddatasourcecondition. class )

     @conditionalonmissingbean ({ datasource. class , xadatasource. class })

     @import ({ datasourceconfiguration.hikari. class , datasourceconfiguration.tomcat. class ,

             datasourceconfiguration.dbcp2. class , datasourceconfiguration.oracleucp. class ,

             datasourceconfiguration.generic. class , datasourcejmxconfiguration. class })

     protected static class pooleddatasourceconfiguration {

     }

@configuration (proxybeanmethods = false )

     @conditionalonclass (hikaridatasource. class )

     @conditionalonmissingbean (datasource. class )

     @conditionalonproperty (name = "spring.datasource.type" , havingvalue = "com.zaxxer.hikari.hikaridatasource" ,

             matchifmissing = true )

     static class hikari {

         @bean

         @configurationproperties (prefix = "spring.datasource.hikari" ) 

         hikaridatasource datasource(datasourceproperties properties) {

             hikaridatasource datasource = createdatasource(properties, hikaridatasource. class );

             if (stringutils.hastext(properties.getname())) {

                 datasource.setpoolname(properties.getname());

             }

             return datasource;

         }

     }

spring:

   datasource:

     url: jdbc:mysql: //localhost:3306/vuesite

     username: root

     password: 123456

     driver- class -name: com.mysql.jdbc.driver

package com.xbhog.config;

import com.alibaba.druid.pool.druiddatasource;

import org.springframework.boot.context.properties.configurationproperties;

import org.springframework.context.annotation.bean;

import org.springframework.context.annotation.configuration;

import javax.sql.datasource;

@configuration

//配置数据源

public class mydtasourceconfig {

     @configurationproperties ( "spring.datasource" )  //属性绑定 要加对位置

     @bean

     public datasource datasource() {

         druiddatasource druiddatasource = new druiddatasource();

         return druiddatasource;

     }

}

package com.xbhog;

import lombok.extern.slf4j.slf4j;

import org.junit.jupiter.api.test;

import org.springframework.beans.factory.annotation.autowired;

import org.springframework.boot.test.context.springboottest;

import org.springframework.jdbc.core.jdbctemplate;

import javax.sql.datasource;

@springboottest

@slf4j

class firstadminapplicationtests {

     @autowired

     datasource datasource;

     @test

     void contextloads() {

         log.info( "数据类型：{}" ,datasource.getclass());

     }

}

/**

* 配置监控页

*/

@bean

public servletregistrationbean staviewservlet(){

     //实例化statviewservlet

     statviewservlet statviewservlet = new statviewservlet();

      //将实例化的实例化statviewservlet 传入servletregistrationbean，并设置访问路径

     servletregistrationbean<statviewservlet> registrationbean = new servletregistrationbean<>(statviewservlet, "/druid/*" );

     return registrationbean;

}

@bean

public servletregistrationbean staviewservlet(){

     statviewservlet statviewservlet = new statviewservlet();

     servletregistrationbean<statviewservlet> registrationbean = new servletregistrationbean<>(statviewservlet, "/druid/*" );

     //配置登录信息

     registrationbean.addinitparameter( "loginusername" , "admin" );

     registrationbean.addinitparameter( "loginpassword" , "123456" );

     return registrationbean;

}

public class mydtasourceconfig {

     @configurationproperties ( "spring.datasource" )

     @bean

     public datasource datasource() throws sqlexception {

         druiddatasource druiddatasource = new druiddatasource();

         //加入监控功能

         druiddatasource.setfilters( "stat" );

         return druiddatasource;

     }

}

spring:

   datasource:

     url: jdbc:mysql: //localhost:3306/vuesite

     username: root

     password: 123456

     driver- class -name: com.mysql.jdbc.driver

     filters: stat

     tomcat:

       max-active: 12

@controller

public class tablecontro {

       @autowired

     jdbctemplate jdbctemplate;

     @responsebody    //不经过视图解析器

     @getmapping ( "/sql" )

     public string druidquery(){

         long along = jdbctemplate.queryforobject( "select count(*) from user" , long . class );

         return along.tostring();

     }

}

/**

      * webstatfilter用于采集web-jdbc关联监控的数据。

      */

@bean

public filterregistrationbean webregistrationbean(){

     webstatfilter webstatfilter = new webstatfilter();

     filterregistrationbean<webstatfilter> registrationbean = new filterregistrationbean<>(webstatfilter);

     registrationbean.seturlpatterns(arrays.aslist( "/*" ));

     //添加一些不必要的ulr,在初始化的时候就执行

     registrationbean.addinitparameter( "exclusions" , "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*" );

     return   registrationbean;

}

public class mydtasourceconfig {

     @configurationproperties ( "spring.datasource" )

     @bean

     public datasource datasource() throws sqlexception {

         druiddatasource druiddatasource = new druiddatasource();

         //加入监控功能

         druiddatasource.setfilters( "stat,wall" );

         return druiddatasource;

     }

}