[原创]java WEB学习笔记109：Spring学习---spring对JDBC的支持：使用 JdbcTemplate 查询数据库，简化 JDBC 模板查询，在 JDBC 模板中使用具名参数两种实现

本博客的目的：①总结自己的学习过程，相当于学习笔记 ②将自己的经验分享给大家，相互学习，互相交流，不可商用

内容难免出现问题，欢迎指正，交流，探讨，可以留言，也可以通过以下方式联系。

本人互联网技术爱好者，互联网技术发烧友

微博：伊直都在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>