spring配置数据源 druid

r囧r小猫 2021-11-09 06:34 379阅读 0赞

### spring配置数据源 druid ###

*  maven 依赖
 *  DataSourceConfig
 *  jdbc.properties
 *  测试

# maven 依赖 #

<properties>
    		<maven.compiler.source>1.8</maven.compiler.source>
    		<maven.compiler.target>1.8</maven.compiler.target>
    		<spring.version>4.3.24.RELEASE</spring.version>
    	</properties>
    
    
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-context</artifactId>
    			<version>${spring.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-jdbc</artifactId>
    			<version>${spring.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>mysql</groupId>
    			<artifactId>mysql-connector-java</artifactId>
    			<version>5.1.46</version>
    		</dependency>
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>druid</artifactId>
    			<version>1.0.28</version>
    		</dependency>
    		<dependency>
    			<groupId>log4j</groupId>
    			<artifactId>log4j</artifactId>
    			<version>1.2.17</version>
    		</dependency>

# DataSourceConfig #

package com.sky.springtest.config;
    import java.sql.SQLException;
    import javax.sql.DataSource;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.PropertySource;
    import org.springframework.jdbc.core.JdbcTemplate;
    import com.alibaba.druid.pool.DruidDataSource;
    @Configuration
    @PropertySource(value = { "classpath:jdbc.properties"}, ignoreResourceNotFound = true)
    public class DataSourceConfig { 
    	@Bean
    	JdbcTemplate jdbcTemplate() { 
    		JdbcTemplate jdbcTemplate = new JdbcTemplate();
    		jdbcTemplate.setDataSource(dataSource());
    		return jdbcTemplate;
    	}
    	@Value("${jdbc.driverClassName}")
    	private String jdbcDriverClassName;
    	@Value("${jdbc.url}")
    	private String jdbcUrl;
    	@Value("${jdbc.username}")
    	private String jdbcUsername;
    	@Value("${jdbc.password}")
    	private String jdbcPassword;
    	@Bean
    	DataSource dataSource() { 
    		DruidDataSource dataSource = new DruidDataSource();
    		dataSource.setDriverClassName(jdbcDriverClassName);
    		dataSource.setUrl(jdbcUrl);
    		dataSource.setUsername(jdbcUsername);
    		dataSource.setPassword(jdbcPassword);
    		// 配置初始化大小、最小、最大
    		dataSource.setInitialSize(1);
    		dataSource.setMinIdle(1);
    		dataSource.setMaxActive(20);
    		
    		// 配置获取连接等待超时的时间
    		dataSource.setMaxWait(60000);
    		// 一个连接在池中最小生存的时间，单位是毫秒
    		dataSource.setMinEvictableIdleTimeMillis(30000);
    		dataSource.setValidationQuery("select 1");
    		dataSource.setTestWhileIdle(true);
    		dataSource.setTestOnBorrow(false);
    		dataSource.setTestOnReturn(false);
    		dataSource.setMaxPoolPreparedStatementPerConnectionSize(20);
    
    		// 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
    		dataSource.setTimeBetweenEvictionRunsMillis(60000);
    
    		// 通过connectProperties属性来打开mergeSql功能；慢SQL记录
    		dataSource.setConnectionProperties("druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000;");
    		try { 
    			// 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
    			dataSource.setFilters("stat,wall,log4j,config");
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    		return dataSource;
    	}
    }

# jdbc.properties #

jdbc.driverClassName=com.mysql.jdbc.Driver
    jdbc.url=jdbc:mysql://centoshost:3306/test
    jdbc.username=root
    jdbc.password=123456

# 测试 #

package com.sky.springtest.config;
    import java.util.List;
    import java.util.Map;
    import javax.sql.DataSource;
    import org.junit.BeforeClass;
    import org.junit.Test;
    import org.springframework.beans.BeansException;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.annotation.AnnotationConfigApplicationContext;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.util.Assert;
    public class DataSourceConfigTest { 
    	private static ApplicationContext context = null;
    	@BeforeClass
    	public static void beforeClass() { 
    		context = new AnnotationConfigApplicationContext(DataSourceConfig.class);
    	}
    	@Test
    	public void test01() { 
    		DataSource dataSource = context.getBean(DataSource.class);
    		Assert.notNull(dataSource, "数据源为空");
    	}
    	@Test
    	public void test02() { 
    		try { 
    			JdbcTemplate jdbcTemplate = context.getBean(JdbcTemplate.class);
    			System.err.println("name=" + jdbcTemplate);
    			List<Map<String, Object>> list = jdbcTemplate.queryForList("select * from t_student");
    			System.err.println(list);
    		} catch (BeansException e) { 
    			e.printStackTrace();
    		} catch (Exception e) { 
    			e.printStackTrace();
    		}
    	}
    }