码迷,mamicode.com
首页 > 数据库 > 详细

JdbcTemplate

时间:2017-10-15 14:35:08      阅读:150      评论:0      收藏:0      [点我收藏+]

标签:tin   erro   复杂查询   this   技术   jdbc   行存储   返回结果   value   

测试单元:

package com.lcw.spring.jdbc;

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

public class JDBCTemplate {
    
    @Test
    public void demo(){
        DriverManagerDataSource dataSource=new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql:///spring");
        dataSource.setUsername("root");
        dataSource.setPassword("");
        
        JdbcTemplate jdbcTemplate=new JdbcTemplate(dataSource);
        jdbcTemplate.execute("create table temp(id int primary key,name varchar(32))");
    
    }

}

技术分享

很简单吧,再来看下使用结合配置文件,完整的实现对一个类的增删改查

首先DEMO目录结构:

技术分享

配置appliactionContext.xml:

 
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
    <!--数据源的配置 -->
    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
        <property name="url" value="jdbc:mysql:///spring"></property>
        <property name="username" value="root"></property>
        <property name="password" value=""></property>
    </bean>
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    <bean id="userDao" class="com.curd.spring.impl.UserDAOImpl">
        <property name="jdbcTemplate" ref="jdbcTemplate"></property>
    </bean>
</beans>
 

接口:IUserDAO.java

 
package com.curd.spring.dao;

import java.util.List;

import com.curd.spring.vo.User;

public interface IUserDAO {
    public void addUser(User user);
    public void deleteUser(int id);
    public void updateUser(User user);
    public String searchUserName(int id);
    public User searchUser(int id);
    public List<User> findAll();

}
 

接口实现类:UserDAOImpl.java

按照以往Spring的依赖注入,我们需要在接口实现类中利用构造器去获取JdbcTemplate

Spring早就帮我们想到了这点,它为我们提供了JdbcDaoSupport支持类,所有DAO继承这个类,就会自动获得JdbcTemplate(前提是注入DataSource)。

技术分享
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    
    <bean id="userDao" class="com.curd.spring.impl.UserDAOImpl">
        <property name="jdbcTemplate" ref="jdbcTemplate"></property>
    </bean>
技术分享

在我们的实现类中直接利用getJdbcTemplate就可以获取操作对象了。

JdbcTemplate主要提供下列方法:

  1、execute方法:可以用于执行任何SQL语句,一般用于执行DDL语句;

  2、update方法及batchUpdate方法:update方法用于执行新增、修改、删除等语句;batchUpdate方法用于执行批处理相关语句;

  3、query方法及queryForXXX方法:用于执行查询相关语句;

  4、call方法:用于执行存储过程、函数相关语句。

 
package com.curd.spring.impl;

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

import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.support.JdbcDaoSupport;
import com.curd.spring.dao.IUserDAO;
import com.curd.spring.vo.User;

public class UserDAOImpl extends JdbcDaoSupport implements IUserDAO {

    public void addUser(User user) {
        String sql = "insert into user values(?,?,?)";
        this.getJdbcTemplate().update(sql, user.getId(), user.getUsername(),
                user.getPassword());
    }

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

    }

    public void updateUser(User user) {
        String sql = "update user set username=?,password=? where id=?";
        this.getJdbcTemplate().update(sql, user.getUsername(),
                user.getPassword(), user.getId());
    }

    public String searchUserName(int id) {// 简单查询,按照ID查询,返回字符串
        String sql = "select username from user where id=?";
        // 返回类型为String(String.class)
        return this.getJdbcTemplate().queryForObject(sql, String.class, id);

    }

    public List<User> findAll() {// 复杂查询返回List集合
        String sql = "select * from user";
        return this.getJdbcTemplate().query(sql, new UserRowMapper());

    }

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

    class UserRowMapper implements RowMapper<User> {
     //rs为返回结果集,以每行为单位封装着
        public User mapRow(ResultSet rs, int rowNum) throws SQLException {
    
            User user = new User();
            user.setId(rs.getInt("id"));
            user.setUsername(rs.getString("username"));
            user.setPassword(rs.getString("password"));
            return user;
        }

    }

}
 

测试类:UserTest.java

 
package com.curd.spring.test;

import java.util.List;

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

import com.curd.spring.dao.IUserDAO;
import com.curd.spring.vo.User;

public class UserTest {
    
    @Test//增
    public void demo1(){
        User user=new User();
        user.setId(3);
        user.setUsername("admin");
        user.setPassword("123456");
        
        ApplicationContext applicationContext=new ClassPathXmlApplicationContext("applicationContext.xml");
        IUserDAO dao=(IUserDAO) applicationContext.getBean("userDao");
        dao.addUser(user);
        
    }
    
    @Test//改
    public void demo2(){
        User user=new User();
        user.setId(1);
        user.setUsername("admin");
        user.setPassword("admin");
        
        ApplicationContext applicationContext=new ClassPathXmlApplicationContext("applicationContext.xml");
        IUserDAO dao=(IUserDAO) applicationContext.getBean("userDao");
        dao.updateUser(user);
    }
    
    @Test//删
    public void demo3(){
        ApplicationContext applicationContext=new ClassPathXmlApplicationContext("applicationContext.xml");
        IUserDAO dao=(IUserDAO) applicationContext.getBean("userDao");
        dao.deleteUser(3);
    }
    
    @Test//查(简单查询,返回字符串)
    public void demo4(){
        ApplicationContext applicationContext=new ClassPathXmlApplicationContext("applicationContext.xml");
        IUserDAO dao=(IUserDAO) applicationContext.getBean("userDao");
        String name=dao.searchUserName(1);
        System.out.println(name);
    }
    
    @Test//查(简单查询,返回对象)
    public void demo5(){
        ApplicationContext applicationContext=new ClassPathXmlApplicationContext("applicationContext.xml");
        IUserDAO dao=(IUserDAO) applicationContext.getBean("userDao");
        User user=dao.searchUser(1);
        System.out.println(user.getUsername());
    }
    
    @Test//查(复杂查询,返回对象集合)
    public void demo6(){
        ApplicationContext applicationContext=new ClassPathXmlApplicationContext("applicationContext.xml");
        IUserDAO dao=(IUserDAO) applicationContext.getBean("userDao");
        List<User> users=dao.findAll();
        System.out.println(users.size());
    }
}
 

附:

1、Spring 为每种持久化技术 提供一个支持类,在DAO 中注入 模板工具类
    (1)JDBC : org.springframework.jdbc.core.support.JdbcDaoSupport
    (2)Hibernate 3.0 :org.springframework.orm.hibernate3.support.HibernateDaoSupport
    (3)iBatis :org.springframework.orm.ibatis.support.SqlMapClientDaoSupport

用户自己编写DAO 只需要继承 JdbcDaoSupport, 就可以注入 JdbcTemplate

2、 通过jdbcTemplate 提供 int update(String sql, Object... args) 实现增加 、修改 、删除

3、简单查询,返回原始数据类型, String类型

String sql = "select count(*) from user"; // int queryForInt(String sql)
String sql = "select name from user where id = ? "; // <T> T queryForObject(String sql, Class<T> requiredType, Object... args)

4、 复杂查询
JdbcTemplate 没有handler, 手动完成对象封装

编写实体类 RowMapper

 
class UserRowMapper implements RowMapper<User> {
  @Override
  public User mapRow(ResultSet rs, int rowNum) throws SQLException {
    // rs 已经指向每一条数据,不需要自己调用 next,将rs指向数据 转换 User对象
    User user = new User();
    user.setId(rs.getInt("id"));
    user.setName(rs.getString("name"));
    return user;
  }
}
 

查询单个对象 <T> T queryForObject(String sql, RowMapper<T> rowMapper, Object... args)
return this.getJdbcTemplate().queryForObject(sql, new UserRowMapper(),id);

查询所有对象List集合 <T> List<T> query(String sql, RowMapper<T> rowMapper, Object... args)
return this.getJdbcTemplate().query(sql, new UserRowMapper());

JdbcTemplate

标签:tin   erro   复杂查询   this   技术   jdbc   行存储   返回结果   value   

原文地址:http://www.cnblogs.com/cristin/p/7670216.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!