jdbcTemplate涉及到的内容很多，再结合spring和数据库来看地话，所涵盖的点就更为复杂。本篇只是作为一个开端，创建一套简洁有效的数据库连接的代码，后续还会有更多的关于各种spring配置，连接参数，以及数据库基础的知识进行分门别类进行分析，消化。
工程结构：
dao中定义了一个简单的查询操作，关于jdbcTemplate的各种查询方法，后续也会详细讨论，这里这是为了搭建这一套简易框架。
package com.changjiang.test.jdbcTemplate.dao;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
@Repository
public class VideoSecuriteDaoImpl {
@Autowired
private JdbcTemplate jdbcTemplate;
private static final Logger log = LoggerFactory.getLogger(VideoSecuriteDaoImpl.class);
public List<Map<String,Object>> getSecuriteMap(int pageSize, int pageNo) {
List<Map<String,Object>> list = new ArrayList<>();
if (pageSize != 0) {
String sql = "select camillo,encode from video_securities where is_use = 0 limit " + (pageNo - 1) * pageSize
+ "," + pageSize;
try {
list = jdbcTemplate.queryForList(sql);
} catch (DataAccessException e) {
log.error("查询VideoSecurite中camillo,encode报错: " + e.toString());
}
}
return list;
}
}
这里实现了一个分页查询，App.java的任务是选择profile，加载配置文件，以及简单测试dao查询的内容：
package com.changjiang.test.jdbcTemplate;
import java.util.List;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.changjiang.test.jdbcTemplate.dao.VideoSecuriteDaoImpl;
/**
* Hello world!
*
*/
public class App {
private static Logger logger = LoggerFactory.getLogger(App.class);
public static void main(String[] args) {
System.setProperty("spring.profiles.active", "production");
logger.info("===========================================================================");
logger.info(" 服务将在[{}]环境启动 ", "production");
logger.info("===========================================================================");
ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext(
new String[] { "applicationContext.xml" });
ac.start();
VideoSecuriteDaoImpl videoSecuriteDaoImpl = ac.getBean(VideoSecuriteDaoImpl.class);
List<Map<String, Object>> list = videoSecuriteDaoImpl.getSecuriteMap(1000, 1);
for (Map<String, Object> map : list) {
System.out.println(map.get("camillo"));
}
ac.close();
}
}
在applicationContext.xml中只定义了一个profile，即production，实际开发中可以根据开发，测试和发布的需要配置不同的profile，切换时只需要改一个jar文件的输入参数即可，看看该文件的配置：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:p="http://www.springframework.org/schema/p" xmlns="http://www.springframework.org/schema/beans"
xmlns:c="http://www.springframework.org/schema/c" xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:cache="http://www.springframework.org/schema/cache"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/cache
http://www.springframework.org/schema/cache/spring-cache.xsd"
default-lazy-init="true">
<description>Spring公共配置</description>
<!-- 该 BeanPostProcessor 将自动对标注 @Autowired 的 Bean 进行注入 -->
<context:annotation-config />
<!-- 使用annotation 自动注册bean, 并保证@Required、@Autowired的属性被注入 -->
<context:component-scan base-package="com.changjiang.test.jdbcTemplate" />
<!-- spring-jdbc -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource" />
</bean>
<!-- 使用annotation定义事务 -->
<tx:annotation-driven proxy-target-class="true" />
<bean id="transactionManager" name="transactionManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource">
<ref bean="dataSource" />
</property>
</bean>
<!-- 定义事务规则 -->
<tx:advice id="transactionAdvice" transaction-manager="transactionManager">
<tx:attributes>
<tx:method name="*" propagation="REQUIRED" rollback-for="Exception" />
</tx:attributes>
</tx:advice>
<!-- 声明事务 -->
<aop:config proxy-target-class="true">
<aop:pointcut id="transactionPointcut"
expression="execution(* com.changjiang.test.jdbcTemplate.*.*(..))" />
<aop:advisor pointcut-ref="transactionPointcut"
advice-ref="transactionAdvice" />
</aop:config>
<!-- production环境 -->
<beans profile="production">
<context:property-placeholder
ignore-unresolvable="true" location="classpath*:/application.properties" />
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
init-method="init" destroy-method="close">
<property name="driverClassName" value="${jdbc.driver}" />
<property name="url" value="${jdbc.url}" />
<property name="username" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
<!-- 初始化连接大小 -->
<property name="initialSize" value="5" />
<property name="maxActive">
<value>${jdbc.pool.maxActive}</value>
</property>
<property name="minIdle">
<value>${jdbc.pool.minIdle}</value>
</property>
<property name="maxWait">
<value>${jdbc.pool.maxWait}</value>
</property>
<!-- 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 -->
<property name="timeBetweenEvictionRunsMillis" value="60000" />
<!-- 配置一个连接在池中最小生存的时间，单位是毫秒 -->
<property name="minEvictableIdleTimeMillis" value="300000" />
<!-- 打开removeAbandoned功能 -->
<property name="removeAbandoned" value="true" />
<!-- 1800秒，也就是30分钟 -->
<property name="removeAbandonedTimeout" value="1800" />
<!-- 关闭abanded连接时输出错误日志 -->
<property name="logAbandoned" value="true" />
<property name="timeBetweenLogStatsMillis" value="300000" />
<!-- 加密 -->
<property name="connectionProperties" value="config.decrypt=true" />
<property name="proxyFilters">
<list>
<ref bean="logFilter" />
</list>
</property>
<property name="filters" value="stat,config,wall,slf4j,log4j" />
</bean>
<bean id="logFilter" class="com.alibaba.druid.filter.logging.Log4jFilter">
<property name="statementExecutableSqlLogEnable" value="false" />
<property name="statementLoggerName" value="sqlLogger" />
<!--<property name="resultSetLogEnabled" value="false" /> -->
</bean>
</beans>
</beans>
在该配置中有许多点，可以作为专门的小节来分析，在这里，需要注意的是，在所有的数据加载进spring容器之前，需要激活对应的剖面--profile，App.java中提供了一种方式，它会先将production激活，并在指定的位置找到各个属性对应的值，再将bean加载到spring容器之中，否则会出现org.springframework.beans.factory.NoSuchBeanDefinitionException。这是在Spring3.1之后新增加的功能，关于它的详细用法，看下一篇Spring之Environment。
时间： 2024-08-11 03:30:38