[原创]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.构建工程 及 部分代码

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

  1)导入spring jar,额外加入  mysql c3p0 jar包

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

  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());
} }

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

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

4.简化 JDBC 模板查询

  1)每次使用都创建一个 JdbcTemplate 的新实例, 这种做法效率很低下.

  2)JdbcTemplate 类被设计成为线程安全的, 所以可以再 IOC 容器中声明它的单个实例, 并将这个实例注入到所有的 DAO 实例中.

  3)JdbcTemplate 也利用了 Java 1.5 的特定(自动装箱, 泛型, 可变长度等)来简化开发

  注入JDBC 模板

  [原创]java WEB学习笔记109:Spring学习---spring对JDBC的支持:使用 JdbcTemplate 查询数据库,简化 JDBC 模板查询,在 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 的数组

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

 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>

  

  

上一篇:EasyTouch基本用法


下一篇:java程序中加入@SuppressWarnings("serial")是什么意思?