Spring的JdbcTemplate(10)

  • JdbcTemplate模板与DbUtils工具类比较类似.

    • Spring对持久层技术支持

    • JDBC : org.springframework.jdbc.core.JdbcTemplate
    • Hibernate3.0 : org.springframework.orm.hibernate3.HibernateTemplate
    • IBatis(MyBatis) : org.springframework.orm.ibatis.SqlMapClientTemplate
    • JPA : org.springframework.orm.jpa.JpaTemplate

    开发JDBCTemplate入门:

    • 第一步:引入相应jar包:

      • spring-tx-3.2.0.RELEASE.jar
      • spring-jdbc-3.2.0.RELEASE.jar
      • mysql驱动.
    • 传统JDBC连接demo
    package cn.spring3.demo1;

import org.junit.Test;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;

public class SpringTest1 {

    @Test
    public void demo1(){
        //创建连接池
        DriverManagerDataSource dateSource = new DriverManagerDataSource();
        //设置参数
        dateSource.setDriverClassName("com.mysql.jdbc.Driver");
        //dateSource.setUrl("jdbc:mysql://172.16.30.189:3306/spring3_day02");
        dateSource.setUrl("jdbc:mysql://192.168.0.120:3306/spring3_day02");
        dateSource.setUsername("root");
        dateSource.setPassword("123");

        //使用jdbc的模板
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dateSource);
        //这个是第二种方式：jdbcTemplate.setDataSource(dateSource);
        String sql="create table user (id int primary key auto_increment,name varchar(20))";
        jdbcTemplate.execute(sql);
    }

}
    • 第一种方式：创建applicationContext.xml(配置Spring默认连接池)
    <!-- 配置Spring默认连接池 -->
    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://172.16.30.189:3306/spring3_day02"/>
        <property name="username" value="root"/>
        <property name="password" value="123"/>
    </bean>

    <!-- 定义jdbctmplate -->
    <bean id="jdbcTmplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    • 编写一个测试类:
    package cn.spring3.demo1;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:applicationContext.xml")
public class SpringTest2 {
    //配置Spring默认连接池
    @Autowired
    @Qualifier("jdbcTmplate")
    private JdbcTemplate jdbcTmplate;
    @Test
    public void demo1(){
        jdbcTmplate.execute("create table user (id int primary key auto_increment,name varchar(20))");
    }
    }
    • 第二种方式：创建applicationContext.xml(配置DBCP连接池)
    <!-- 配置DBCP连接池 -->
    <bean id="dateSourceDbcp" class="org.apache.commons.dbcp.BasicDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://172.16.30.189:3306/spring3_day02"/>
        <property name="username" value="root"/>
        <property name="password" value="123"/>
    </bean>

    <!-- 定义jdbctmplate DBCP -->
    <bean id="jdbcTmplateDbcp" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dateSourceDbcp"></property>
    </bean>
    • 编写测试类：
    package cn.spring3.demo1;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:applicationContext.xml")
public class SpringTest2 {
    //配置DBCP连接池
    @Autowired
    @Qualifier("jdbcTmplateDbcp")
    private JdbcTemplate jdbcTmplateDbcp;

    @Test
    public void demo2(){
        jdbcTmplateDbcp.execute("create table user (id int primary key auto_increment,name varchar(20))");
    }
    }
    • 第三种方式：创建applicationContext.xml(配置C3p0连接池)
    <!-- 配置C3P0连接池 -->
    <bean id="dateSourceC3p0" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="com.mysql.jdbc.Driver"/>
        <property name="jdbcUrl" value="jdbc:mysql://172.16.30.189:3306/spring3_day02"/>
        <property name="user" value="root"/>
        <property name="password" value="123"/>
    </bean>

    <!-- 定义jdbctmplate DBCP -->
    <bean id="jdbcTmplateC3p0" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dateSourceC3p0"></property>
    </bean>
    • 编写测试类：
    package cn.spring3.demo1;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:applicationContext.xml")
public class SpringTest2 {
    //配置C3p0连接池
    @Autowired
    @Qualifier("jdbcTmplateC3p0")
    private JdbcTemplate jdbcTmplateC3p0;

    @Test
    public void demo3(){
        jdbcTmplateC3p0.execute("create table user (id int primary key auto_increment,name varchar(20))");
    }
    }

    引入配置文件方式，配置连接池（C3P0举例说明）

    1.第一步：新建JDBC.properties(名字随便)

    jdbc.driver = com.mysql.jdbc.Driver
jdbc.url = jdbc:mysql://172.16.30.189:3306/spring3_day02
jdbc.user = root
jdbc.password =123

    2.第二步：配置applicationContext.xml(两种方式引入)
    2.1 第一种配置方式：

    <!-- 配置C3P0连接池 引入配置文件的方式  方法一-->
    <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
          <property name="location" value="classpath:JDBC.properties"></property>
    </bean>

    <bean id="dateSourceC3p0ref" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${jdbc.driver}"/>
        <property name="jdbcUrl" value="${jdbc.url}"/>
        <property name="user" value="${jdbc.user}"/>
        <property name="password" value="${jdbc.password}"/>
    </bean>

    <!-- 定义jdbctmplate DBCP -->
    <bean id="jdbcTmplateC3p0ref" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dateSourceC3p0ref"></property>
    </bean>

    编写测试类：

     package cn.spring3.demo1;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:applicationContext.xml")
public class SpringTest2 {//配置C3p0连接池  引入配置文件方式 方法一 第二种方法请见springtest3.java
    @Autowired
    @Qualifier("jdbcTmplateC3p0ref")
    private JdbcTemplate jdbcTmplateC3p0ref;

    @Test
    public void demo4(){
        jdbcTmplateC3p0ref.execute("create table user (id int primary key auto_increment,name varchar(20))");
    }
    }
    2.2  第二种配置方式：
    xmlns:context="http://www.springframework.org/schema/context"

<!-- 配置C3P0连接池 引入配置文件的方式  方法二-->
    <context:property-placeholder location="classpath:JDBC.properties"/>

    <bean id="dateSourceC3p0ref" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${jdbc.driver}"/>
        <property name="jdbcUrl" value="${jdbc.url}"/>
        <property name="user" value="${jdbc.user}"/>
        <property name="password" value="${jdbc.password}"/>
    </bean>

    <!-- 定义jdbctmplate DBCP -->
    <bean id="jdbcTmplateC3p0ref" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dateSourceC3p0ref"></property>
    </bean>

    编写测试类：

     package cn.spring3.demo1;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:applicationContext1.xml")
public class SpringTest3 {

    //配置C3p0连接池  引入配置文件方式 方法二   方法一见springtest2.java
    @Autowired
    @Qualifier("jdbcTmplateC3p0ref")
    private JdbcTemplate jdbcTmplateC3p0ref;

    @Test
    public void demo1(){
        jdbcTmplateC3p0ref.execute("create table user (id int primary key auto_increment,name varchar(20))");
    }

}
    * 总结以上：
    在src下创建jdbc.properties
jdbc.driver = com.mysql.jdbc.Driver
jdbc.url = jdbc:mysql:///spring3_day02
jdbc.user = root
jdbc.password = 123

需要在applicationContext.xml 中使用属性文件配置的内容.
* 第一种写法:
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
          <property name="location" value="classpath:jdbc.properties"></property>
</bean>

* 第二种写法:
<context:property-placeholder location="classpath:jdbc.properties"/>

    JdbcTemplate的CRUD的操作:

    Spring框架中提供了对持久层技术支持的类:
JDBC            :   org.springframework.jdbc.core.support.JdbcDaoSupport
Hibernate 3.0   :   org.springframework.orm.hibernate3.support.HibernateDaoSupport
iBatis      :   org.springframework.orm.ibatis.support.SqlMapClientDaoSupport

编写DAO的时候:
Public class UserDao extends JdbcDaoSupport{

}

进行CRUD的操作;
* 保存:update(String sql,Object... args)
* 修改:update(String sql,Object... args)
* 删除:update(String sql,Object... args)
    • 例子：

    User类

    package cn.spring3.demo2;

public class User {
    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;
    }

}

    UserDao类

    package cn.spring3.demo2;

import org.springframework.jdbc.core.support.JdbcDaoSupport;

public class UserDao extends JdbcDaoSupport{

    public void add(User user) {
        String sql="insert into user values(null,?)";
        this.getJdbcTemplate().update(sql, user.getName());
    }

    public void update(User user) {
        String sql="update user set name= ? where id= ?";
        this.getJdbcTemplate().update(sql, user.getName(),user.getId());
    }

    public void delete(User user) {
        String sql="delete from user where id= ?";
        this.getJdbcTemplate().update(sql, user.getId());
    }

}

    测试类：

    package cn.spring3.demo2;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:applicationContext1.xml")
public class StringTest1 {
    @Autowired
    @Qualifier("userDao")
    private UserDao userDao;
    //增
    @Test
    public void demo1(){
        User user = new User();
        user.setName("one");
        userDao.add(user);
    }
    //修改
    @Test
    public void demo2(){
        User user = new User();
        user.setId(2);
        user.setName("two");
        userDao.update(user);
    }
    //删除
    @Test
    public void demo3(){
        User user = new User();
        user.setId(3);
        userDao.delete(user);
    }
}

    查询:

    • 简单查询(单一类型查询):

      • select count(*) from user; --- queryForInt(String sql);
      • select name from user where id = ?; --- queryForObject(String sql,Class clazz,Object... args);
    • 复杂查询:(返回对象,和对象集合)
      • select * from user where id = ? --- queryForObjectString sql,RowMapper<T> rowMapper,Object... args);
      • select * from user; --- query(String sql,RowMapper<T> rowMapper,Object... args);

    UserDao类添加方法

    public int findCount(){
        String sql = "select count(*) from user";
        return this.getJdbcTemplate().queryForInt(sql);
    }

    public String findNameById(User user){
        String sql = "select name from user where id= ?";
        return this.getJdbcTemplate().queryForObject(sql, String.class, user.getId());
    }

    测试类编写：

    //简单查询1
    @Test
    public void demo4(){
        System.out.println(userDao.findCount());
    }

    //简单查询2
    @Test
    public void demo5(){
        User user = new User();
        user.setId(2);
        System.out.println(userDao.findNameById(user));
    }

    复杂查询
    UserDao类添加方法

    class UserRowMapper implements RowMapper<User>{
        /*
         * rc:结果集
         * rowNum：行号
         */
        public User mapRow(ResultSet rs, int rownum) throws SQLException {
            User user = new User();
            user.setId(rs.getInt("id"));
            user.setName(rs.getString("name"));
            return user;
        }

    }

    public User findById(int id){
        String sql = "select * from user where id= ?";
        User user = this.getJdbcTemplate().queryForObject(sql,new UserRowMapper(), id);
        return user;
    }

    或者用内部类的方式：

    public User findById(int id){
        String sql = "select * from user where id = ?";
        return this.getJdbcTemplate().queryForObject(sql, new RowMapper<User>(){
            public User mapRow(ResultSet rs, int rowNum) throws SQLException {
                User user = new User();
                user.setId(rs.getInt("id"));
                user.setName(rs.getString("name"));
                return user;
            }
        }, id);
    }

    public List<User> find(){
        String sql = "select * from user ";
        return this.getJdbcTemplate().query(sql, new RowMapper<User>(){
            public User mapRow(ResultSet rs, int rowNum) throws SQLException {
                User user = new User();
                user.setId(rs.getInt("id"));
                user.setName(rs.getString("name"));
                return user;
            }
        });
    }

    编写测试类：

    //复杂查询
    @Test
    public void demo6(){
        User user = userDao.findById(2);
        System.out.println(user);
    }

    多条查询
    UserDao

    public List<User> findAll(){
        String sql = "select * from user";
        return this.getJdbcTemplate().query(sql,new UserRowMapper());
    }

    编写测试类：

    // 复杂查询2
    @Test
    public void demo7() {
        List<User> list = userDao.findAll();
        for (User user : list) {
            System.out.println(user);
        }
    }

    原文地址：http://blog.51cto.com/4534309/2112489

    时间： 2024-10-07 23:56:13

    Spring的JdbcTemplate(10)的相关文章

    Spring之JDBCTemplate学习

    一.Spring对不同的持久化支持: Spring为各种支持的持久化技术,都提供了简单操作的模板和回调 ORM持久化技术 模板类 JDBC org.springframework.jdbc.core.JdbcTemplate Hibernate5.0 org.springframework.orm.hibernate5.HibernateTemplate IBatis(MyBatis) org.springframework.orm.ibatis.SqlMapClientTemplate JPA

    spring之jdbcTemplate实例

    如果我们不使用spring或使用spring但不使用spring的jdbcTemplate模板的时候我们要取得一个数据库的连接以及关闭要经过如下几步: 1.使用Java反射加载驱动 2.通过DriverManager 的getConnection() 方法获取Connection对象 3.获取Statement    或PrepareStatement 4. 调用Statement  或PrepareStatement的方法进行数据ddl  dcl  dml 操作 5.获取结果 6.释放资源 7

    spring使用jdbcTemplate和jdbcdaosupport和namedparameter

    jdbcTemplate: 首先连接数据库 <!-- 导入外部文件 --> <context:property-placeholder location="classpath:db.properties"/> <!-- 配置c3p0数据源 --> <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> <

    使用Spring的JdbcTemplate访问数据库 转

    使用Spring的JdbcTemplate访问数据库 JdbcTemplate 模板可以简化JDBC操作,但是创建一个JdbcTemplate需要一个DataSource接口,在Spring中,当然就是向 JdbcTemplate中注入一个DataSource,然后通过JdbcTemplate来获取一个连接(Connection). 假设SQL Server 2000数据库(新建的数据库名称为hibernate)中有一张person表,简单地记录了人员的详细信息. 使用Spring的IOC机制实

    Spring基础系列10 -- Spring AOP-----------Pointcut, Advisor

    Spring基础系列10 -- Spring AOP-----------Pointcut, Advisor 转载:http://www.cnblogs.com/leiOOlei/p/3557643.html 上一篇的Spring AOP Advice例子中,Class(CustomerService)中的全部method都被自动的拦截了.但是大多情况下,你只需要一个方法去拦截一两个method.这样就引入了Pointcut(切入点)的概念,它允许你根据method的名字去拦截指定的method

    spring学习（四）spring的jdbcTemplate（增删改查封装）

    Spring的jdbcTemplate操作 1.Spring框架一站式框架 (1)针对javaee三层,每一层都有解决技术 (2)到dao 层,使用 jdbcTemplate 2.Spring对不同的持久化都进行了封装 (1)jdbcTemplate  对  jdbc 进行封装 3.jdbcTemplate 使用和 dbutils 使用很相似,都是对数据库进行 crud 操作 4.使用jdbcTemplate 实现增删改查操作 增加: 1.导入 jdbcTemplate 相关jar 包 一定要导

    Spring中JdbcTemplate中使用RowMapper

    Spring中JdbcTemplate中使用RowMapper 博客分类: spring Java代码   package com.cxl.demo.dao; import java.sql.ResultSet; import java.sql.SQLException; import java.util.List; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.Ro

    【Spring】利用spring的JdbcTemplate查询返回结果映射到自定义类型

    // org.springframework.jdbc.core.JdbcTemplate 中的查询方法基本都有支持参数RowMapper<T> rowMapper的重载方法.下面只是随便举例2个,还有很多 public <T> List<T> query(String sql, Object[] args, RowMapper<T> rowMapper) throws DataAccessException { ... }; public <T>

    2018.12.25 Spring中JDBCTemplate模版API学习

    1 Spring整合JDBC模版 1.1 spring中土拱了一个可以操作数据库的对象.对象封装了jdbc技术 JDBCTemplateJDBC模板对象 1.2 与DBUtils中的QueryRunner非常相似 1.3 准备工作 1.导包 4+2 基础包+日志包. junit5+spring-test.spring-aop.c3p0连接池.JDBC驱动.spring-jdbc.spring-tx事务 JDBC演示 1.4 JDBC模版实现增删改查操作 准备接口UserDao 编写实现类 Use