spring jdbcTemplate

一、JdbcTemplate主要提供以下五类方法：

• execute方法：可以用于执行任何SQL语句，一般用于执行DDL语句；
• update方法及batchUpdate方法：update方法用于执行新增、修改、删除等语句；batchUpdate方法用于执行批处理相关语句；
• query方法及queryForXXX方法：用于执行查询相关语句；
• call方法：用于执行存储过程、函数相关语句。

JdbcTemplate类支持的回调类：

• 预编译语句及存储过程创建回调：用于根据JdbcTemplate提供的连接创建相应的语句；

         PreparedStatementCreator：通过回调获取JdbcTemplate提供的Connection，由用户使用该Conncetion创建相关的PreparedStatement；

         CallableStatementCreator：通过回调获取JdbcTemplate提供的Connection，由用户使用该Conncetion创建相关的CallableStatement；

• 预编译语句设值回调：用于给预编译语句相应参数设值；

         PreparedStatementSetter：通过回调获取JdbcTemplate提供的PreparedStatement，由用户来对相应的预编译语句相应参数设值；

         BatchPreparedStatementSetter：；类似于PreparedStatementSetter，但用于批处理，需要指定批处理大小；

• 自定义功能回调：提供给用户一个扩展点，用户可以在指定类型的扩展点执行任何数量需要的操作；

         ConnectionCallback：通过回调获取JdbcTemplate提供的Connection，用户可在该Connection执行任何数量的操作；

         StatementCallback：通过回调获取JdbcTemplate提供的Statement，用户可以在该Statement执行任何数量的操作；

         PreparedStatementCallback：通过回调获取JdbcTemplate提供的PreparedStatement，用户可以在该PreparedStatement执行任何数量的操作；

         CallableStatementCallback：通过回调获取JdbcTemplate提供的CallableStatement，用户可以在该CallableStatement执行任何数量的操作；

• 结果集处理回调：通过回调处理ResultSet或将ResultSet转换为需要的形式；

         RowMapper：用于将结果集每行数据转换为需要的类型，用户需实现方法mapRow(ResultSet rs, int rowNum)来完成将每行数据转换为相应的类型。

         RowCallbackHandler：用于处理ResultSet的每一行结果，用户需实现方法processRow(ResultSet rs)来完成处理，在该回调方法中无需执行rs.next()，该操作由JdbcTemplate来执行，用户只需按行获取数据然后处理即可。

         ResultSetExtractor：用于结果集数据提取，用户需实现方法extractData(ResultSet rs)来处理结果集，用户必须处理整个结果集；

二、接下来，看个小Demo吧

 （1）小Demo整体架构

 

（2）jar包

（3）建立数据库

create database spring

建立user表

create table user(id int primary key auto_increment, name varchar(16), age int);

（4）具体代码

model层

package com.xpw.model;

public class User {
    private int id;
    private String name;
    private int age;

    public User() {

    }

    public User(String name, int age) {
        this.name = name;
        this.age = age;
    }

    public User(int id, String name, int age) {
        this.id = id;
        this.name = name;
        this.age = age;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

}

dao接口层

package com.xpw.dao;

import java.util.List;

import com.xpw.model.User;

public interface UserDao {
    public void add(User user);
    
    public void update(User user);
    
    public void delete(int id);
    
    public List<User> queryAll();
}

dao实现层

package com.xpw.dao.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowCallbackHandler;

import com.xpw.dao.UserDao;
import com.xpw.model.User;

public class UserDaoImpl implements UserDao {

    private JdbcTemplate jdbcTemplate;

    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    @Override
    public void add(User user) {
        String sql = "insert into user(name, age) values(?,?)";
        Object[] args = { user.getName(), user.getAge() };
        int res = jdbcTemplate.update(sql, args);
        if (res == 1)
            System.out.println("add success");
    }

    @Override
    public void update(User user) {
        String sql = "update user set name = ?, age = ? where id = ?";
        Object[] args = { user.getName(), user.getAge(), user.getId() };
        int res = jdbcTemplate.update(sql, args);
        if (res == 1)
            System.out.println("update success");
    }

    @Override
    public void delete(int id) {
        String sql = "delete from user where id = ?";
        int res = jdbcTemplate.update(sql, id);
        if (res == 1)
            System.out.println("delete success");
    }

    @Override
    public List<User> queryAll() {
        String sql = "select * from user";
        
        final List<User> list = new ArrayList<User>();
        
        jdbcTemplate.query(sql, new RowCallbackHandler() {
            @Override
            public void processRow(ResultSet rs) throws SQLException {
                User u = new User();
                u.setId(rs.getInt("id"));
                u.setName(rs.getString("name"));
                u.setAge(rs.getInt("age"));
                list.add(u);
            }
        });
        return list;
    }
}

service实现层

package com.xpw.service;

import java.util.List;

import com.xpw.model.User;

public interface UserService {
    public void add(User user);

    public void update(User user);

    public void delete(int id);

    public List<User> queryAll();
}

service实现层.

package com.xpw.service.impl;

import java.util.List;

import com.xpw.dao.UserDao;
import com.xpw.model.User;
import com.xpw.service.UserService;

public class UserServiceImpl implements UserService {
    
    private UserDao userDao;
    
    public void setUserDao(UserDao userDao) {
        this.userDao = userDao;
    }

    @Override
    public void add(User user) {
        this.userDao.add(user);
    }
    
    @Override
    public void update(User user) {
        this.userDao.update(user);
    }
    
    @Override
    public void delete(int id) {
        this.userDao.delete(id);
    }
    
    @Override
    public List<User> queryAll() {
        return this.userDao.queryAll();
    }
}

（3）文件配置

beans.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.xsd">    
    
    <context:component-scan base-package="org.springframework.docs.test" />
    <context:property-placeholder location="jdbc.properties"/>    
    
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
        <property name="driverClassName" value="${jdbc.driverClassName}"/>
        <property name="url" value="${jdbc.url}"/>
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>
    </bean>
    
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
           <property name="dataSource" ref="dataSource"/> 
    </bean>

    <bean id="userDao" class="com.xpw.dao.impl.UserDaoImpl">
        <property name="jdbcTemplate" ref="jdbcTemplate"/>
    </bean>

    <bean id="userService" class="com.xpw.service.impl.UserServiceImpl">
        <property name="userDao" ref="userDao"></property>
    </bean>
</beans>

jdbc.properties

jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/spring
jdbc.username=root
jdbc.password=root

（4）测试

package com.xpw.test;

import java.util.List;

import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.xpw.model.User;
import com.xpw.service.UserService;

public class JdbcTemplateTest {

    private static ApplicationContext ac;

    static {
        ac = new ClassPathXmlApplicationContext("beans.xml");
    }

    @Test
    public void testAdd() {
        UserService us = (UserService) ac.getBean("userService");
        us.add(new User("2b", 10));
    }

    @Test
    public void testUpdate() {
        UserService us = (UserService) ac.getBean("userService");
        us.update(new User(1, "2b", 11));
    }

    @Test
    public void testDelete() {
        UserService us = (UserService) ac.getBean("userService");
        us.delete(1);
    }

    @Test
    public void testQuery() {
        UserService us = (UserService) ac.getBean("userService");
        List<User> list = us.queryAll();
        for (User u : list) {
            System.out
                    .println(u.getId() + " " + u.getName() + " " + u.getAge());
        }
    }
}

结果就不直接给出来了。。

是不是，觉得很简单O(∩_∩)O哈哈~