本博客的目的：①总结自己的学习过程，相当于学习笔记 ②将自己的经验分享给大家，相互学习，互相交流，不可商用
内容难免出现问题，欢迎指正，交流，探讨，可以留言，也可以通过以下方式联系。
本人互联网技术爱好者，互联网技术发烧友
微博：伊直都在0221
QQ：951226918
-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
1.JdbcTemplate 简介
1）为了使 JDBC 更加易于使用, Spring 在 JDBC API 上定义了一个抽象层, 以此建立一个 JDBC 存取框架.
2）作为 Spring JDBC 框架的核心, JDBC 模板的设计目的是为不同类型的 JDBC 操作提供模板方法. 每个模板方法都能控制整个过程, 并允许覆盖过程中的特定任务. 通过这种方式, 可以在尽可能保留灵活性的情况下, 将数据库存取的工作量降到最低.
本篇主要讲述JdbcTemplate 相关的API，主要以代码为例
2.构建工程 及 部分代码
1）导入spring jar，额外加入 mysql c3p0 jar包
2）在配置文件中配置c3p0数据源
db.properties
jdbc.user=root
jdbc.password=zhangzhen
jdbc.driverClass=com.mysql.jdbc.Driver
jdbc.jdbcUrl=jdbc:mysql:///spring jdbc.initPoolSize=5
jdbc.maxPoolSize=10
在配置文件中配置c3p0文件
<!-- 导入资源文件 -->
<context:property-placeholder location="classpath:db.properties"/>
<!-- 配置c3p0 数据源 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="user" value="${jdbc.user}"></property>
<property name="password" value="${jdbc.password}"></property>
<property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property>
<property name="driverClass" value="${jdbc.driverClass}"></property> <property name="initialPoolSize" value="${jdbc.initPoolSize}"></property>
<property name="maxPoolSize" value="${jdbc.maxPoolSize}"></property>
</bean>
3）配置 Spring 的jdbcTemplate
<!-- 配置Spring 的jdbcTemplate -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"></property>
</bean>
3.完整代码
application.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
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-4.0.xsd"> <!-- 导入资源文件 -->
<context:property-placeholder location="classpath:db.properties"/>
<!-- 配置c3p0 数据源 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="user" value="${jdbc.user}"></property>
<property name="password" value="${jdbc.password}"></property>
<property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property>
<property name="driverClass" value="${jdbc.driverClass}"></property> <property name="initialPoolSize" value="${jdbc.initPoolSize}"></property>
<property name="maxPoolSize" value="${jdbc.maxPoolSize}"></property>
</bean> <!-- 配置Spring 的jdbcTemplate -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"></property>
</bean> </beans>
Department.java
package com.jason.spring.jdbc;
public class Department {
private Integer id;
private String name;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
@Override
public String toString() {
return "Department [id=" + id + ", name=" + name + "]";
}
}
Employee.java
package com.jason.spring.jdbc;
public class Employee {
private Integer id;
private String lastName;
private String email;
private Department department;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getLastName() {
return lastName;
}
public void setLastName(String lastName) {
this.lastName = lastName;
}
public String getEmail() {
return email;
}
public void setEmail(String email) {
this.email = email;
}
public Department getDepartment() {
return department;
}
public void setDepartment(Department department) {
this.department = department;
}
@Override
public String toString() {
return "Employee [id=" + id + ", lastName=" + lastName + ", email="
+ email + ", department=" + department + "]";
}
}
单元测试类
package com.jason.spring.jdbc; import static org.junit.Assert.*; import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List; import javax.sql.DataSource; import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper; public class JDBCTest { private ApplicationContext ctx = null;
private JdbcTemplate jdbcTemplate; {
ctx = new ClassPathXmlApplicationContext("application.xml");
jdbcTemplate = (JdbcTemplate) ctx.getBean("jdbcTemplate"); } /**
*
* @Author:jason_zhangz@163.com
* @Title: testQueryForObject2
* @Time:2016年12月6日
* @Description: 获取单个列的值，或做统计查询
* 使用 queryForObject(String sql, Class<Long> requiredType) 方法
*
*/
@Test
public void testQueryForObject2(){
String sql ="SELECT count(id) FROM employee ";
long count = jdbcTemplate.queryForObject(sql, Long.class);
System.out.println(count);
} /**
*
* @Author:jason_zhangz@163.com
* @Title: testQueryForList
* @Time:2016年12月6日
* @Description: 查到实体类的集合
* 注意：调用的方法不是queryForList
*
*/
@Test
public void testQueryForList(){
String sql = "SELECT id, last_name lastName, email FROM employee WHERE id > ?";
RowMapper<Employee> rowMapper = new BeanPropertyRowMapper<>(Employee.class);
List<Employee> employees = jdbcTemplate.query(sql, rowMapper, 5);
System.out.println(employees);
} /**
*
* @Author:jason_zhangz@163.com
* @Title: testQueryForObject
* @Time:2016年12月6日
* @Description: 从数据库中获取一条记录，实际得到对应的对象
* 注意：.queryForObject(String sql, Class<Employee> requiredType, Object... args) 返回的是一个字段
* 需要使用：queryForObject(String sql, RowMapper<Employee> rowMapper, Object... args)
* 1.RowMapper 指定如何映射结果的行，常用的实现类为 BeanPropertyRowMapper
* 2.使用SQL 中列的别名完成列名 和 类的属性名的映射：last_name lastName
* 3.不支持级联属性，jdbcTemplate 是一个JDBC的小工具，不是ORM框架
*
*/
@Test
public void testQueryForObject(){
String sql = "SELECT id, last_name lastName, email, dept_id as \"department.id\" FROM employee WHERE id = ?";
RowMapper<Employee> rowMapper = new BeanPropertyRowMapper<>(Employee.class);
Employee employee = jdbcTemplate.queryForObject(sql, rowMapper, 1);
System.out.println(employee);
} /**
*
* @Author:jason_zhangz@163.com
* @Title: testBatchUpdate
* @Time:2016年12月6日
* @Description: 执行批量的 INSERT, UPDATE, DELETE
* 最后一个参数是Object[] 的list 类型：因为修改一条记录需要一个Object 数据，多条记录 对应多个Object 形成数组
*/
@Test
public void testBatchUpdate(){
String sql = "INSERT INTO employee(last_name, email, dept_id) VALUES(?,?,?)";
List<Object[]> batchArgs = new ArrayList<>();
batchArgs.add(new Object[]{"AA","AA@163.com",1});
batchArgs.add(new Object[]{"bb","bb@163.com",2});
batchArgs.add(new Object[]{"cc","cc@163.com",3});
batchArgs.add(new Object[]{"dd","dd@163.com",4});
batchArgs.add(new Object[]{"ee","ee@163.com",5});
batchArgs.add(new Object[]{"ff","ff@163.com",1});
jdbcTemplate.batchUpdate(sql, batchArgs); } /**
*
* @Author:jason_zhangz@163.com
* @Title: testUpdate
* @Time:2016年12月6日
* @Description: 执行 INSERT, UPDATE, DELETE
*
*/
@Test
public void testUpdate(){
String sql = "UPDATE employee SET last_name = ? WHERE id = ?";
jdbcTemplate.update(sql,"JACK",4); } @Test
public void testDataSource() throws SQLException {
DataSource dataSources = ctx.getBean(DataSource.class);
System.out.println(dataSources.getConnection());
} }
4.简化 JDBC 模板查询
1）每次使用都创建一个 JdbcTemplate 的新实例, 这种做法效率很低下.
2）JdbcTemplate 类被设计成为线程安全的, 所以可以再 IOC 容器中声明它的单个实例, 并将这个实例注入到所有的 DAO 实例中.
3）JdbcTemplate 也利用了 Java 1.5 的特定(自动装箱, 泛型, 可变长度等)来简化开发
注入JDBC 模板
注解方式实现自动注入
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Repository; @Repository
public class EmployeeDao { @Autowired
private JdbcTemplate jdbcTemplate; public Employee get(Integer id){
String sql = "SELECT id, last_name lastName, email FROM employees WHERE id = ?";
RowMapper<Employee> rowMapper = new BeanPropertyRowMapper<>(Employee.class);
Employee employee = jdbcTemplate.queryForObject(sql, rowMapper, id); return employee;
}
}
5.在 JDBC 模板中使用具名参数
1）在经典的 JDBC 用法中, SQL 参数是用占位符 ? 表示,并且受到位置的限制. 定位参数的问题在于, 一旦参数的顺序发生变化, 就必须改变参数绑定.
2）在 Spring JDBC 框架中, 绑定 SQL 参数的另一种选择是使用具名参数(named parameter).
3）具名参数: SQL 按名称(以冒号开头)而不是按位置进行指定. 具名参数更易于维护, 也提升了可读性. 具名参数由框架类在运行时用占位符取代
4）具名参数只在 NamedParameterJdbcTemplate 中得到支持
具体实现
5）在 SQL 语句中使用具名参数时, 可以在一个 Map 中提供参数值, 参数名为键
6）也可以使用 SqlParameterSource 参数
7）批量更新时可以提供 Map 或 SqlParameterSource 的数组
public class JDBCTest {
private ApplicationContext ctx = null;
private JdbcTemplate jdbcTemplate;
private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
{
ctx = new ClassPathXmlApplicationContext("application.xml");
jdbcTemplate = (JdbcTemplate) ctx.getBean("jdbcTemplate");
namedParameterJdbcTemplate = (NamedParameterJdbcTemplate) ctx.getBean("namedParameterJdbcTemplate");
}
/*
* 使用具名参数使用这个方法：update(String sql, SqlParameterSource paramSource)
* 1.sql 语句中的参数名 和 类的属性一致
* 2.使用 SqlParameterSource 的 BeanPropertySqlParameterSource实现类，作为参数
*/
@Test
public void testNamedParameterJdbcTemplate2(){
String sql = "INSERT INTO employee(last_name, email, dept_id) VALUES(:lastName, :email, :deptId)";
Employee employee = new Employee();
employee.setLastName("wl");
employee.setEmail("wl@sina.com");
employee.setDeptId(5);
SqlParameterSource parameterSource = new BeanPropertySqlParameterSource(employee);
namedParameterJdbcTemplate.update(sql, parameterSource);
}
/**
*
* @Author:jason_zhangz@163.com
* @Title: testNamedParameterJdbcTemplate
* @Time:2016年12月6日
* @Description: 使用具名参数
* 可以为参数起名
* 1.好处：若有多个参数，则不用再去对应位置，直接对应参数名，便于维护
* 2.缺点：较为麻烦一台
*
*/
@Test
public void testNamedParameterJdbcTemplate(){
String sql = "INSERT INTO employee(last_name, email, dept_id) VALUES(:ln, :email, :deptid)";
Map<String, Object> paramMap = new HashMap<String, Object>();
paramMap.put("ln", "FF");
paramMap.put("email", "ff@163.com");
paramMap.put("deptid", 5);
namedParameterJdbcTemplate.update(sql, paramMap);
}
}
配置namedParameterJdbcTemplate 的bean
<!-- 配置具名参数 namedParameterJdbcTemplate,该对象可以使用具名参数，其没有无参数的构造器，必须为其构造器指定参数，一般为dataSource -->
<bean id="namedParameterJdbcTemplate" class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate">
<constructor-arg ref="dataSource"></constructor-arg>
</bean>