Spring JDBC 框架使用JdbcTemplate 类的一个实例

JDBC 框架概述

在使用普通的 JDBC 数据库时，就会很麻烦的写不必要的代码来处理异常，打开和关闭数据库连接等。但 Spring JDBC 框架负责所有的低层细节，从开始打开连接，准备和执行 SQL 语句，处理异常，处理事务，到最后关闭连接。

所以当从数据库中获取数据时，你所做的是定义连接参数，指定要执行的 SQL 语句，每次迭代完成所需的工作。

Spring JDBC 提供几种方法和数据库中相应的不同的类与接口。我将给出使用 JdbcTemplate 类框架的经典和最受欢迎的方法。这是管理所有数据库通信和异常处理的*框架类。

JdbcTemplate 类

JdbcTemplate 类执行 SQL 查询、更新语句和存储过程调用，执行迭代结果集和提取返回参数值。它也捕获 JDBC 异常并转换它们到 org.springframework.dao 包中定义的通用类、更多的信息、异常层次结构。

JdbcTemplate 类的实例是线程安全配置的。所以你可以配置 JdbcTemplate 的单个实例，然后将这个共享的引用安全地注入到多个 DAOs 中。

使用 JdbcTemplate 类时常见的做法是在你的 Spring 配置文件中配置数据源，然后共享数据源 bean 依赖注入到 DAO 类中，并在数据源的设值函数中创建了 JdbcTemplate。

环境：导入： mysql-connector-java.jar，org.springframework.jdbc.jar这两个包

1.创建数据访问对象接口文件 StudentDAO.java 的内容：

 package com.spring.jdbcTemplate;

 import java.util.List;

 import javax.sql.DataSource;
 /**
  * 接口StudentDao，是用来封装查询方法
  * @author Administrator
  *
  */

 public interface StudentDao {

     public void setDataSource(DataSource ds);
     //添加记录
     public void addStudent(String name,Integer age);
     //通过Student ID查询学生记录，返回值为Student类型
     public Student getStudentId(Integer id);
     //删除数据通过Student ID
     public void delectStudent(Integer id);
     //更新数据
     public void updata(Integer id,Integer age);
     //查询所有数据
     public List<Student> SelectAllStudent();
 }

2.创建一个实体类Student：

 package com.spring.jdbcTemplate;

 public class Student {
     /**
      * 定义学生类
      */
     private String name;
     private Integer age;
     private Integer id;

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

     public Integer getAge() {
         return age;
     }

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

     public void printAdvice() {
         System.out.println("name:" + name + ",age:" + age);

     }

 }

3.创建一个StudentMapper.java 文件，用来映射结果集（通常用于查询语句~）内容如下：

 package com.spring.jdbcTemplate;

 import java.sql.ResultSet;
 import java.sql.SQLException;

 import org.springframework.jdbc.core.RowMapper;

 public class StudentMapper implements RowMapper<Student>{
     /**
      * 接口RowMapper被JdbcTemplate 用来映射每一行结果集的数据
      * JdbcTemplate 用来执行query方法或者调用存储过程 包含方法mapRow(ResultSet rs, int rowNum)
      * 第一个参数表示获取到的结果集、第二个表示结果集中获取到的结果个数，通常用于查询语句~
      */
     @Override
     public Student mapRow(ResultSet rs, int row) throws SQLException {
         Student student=new Student();
         student.setId(rs.getInt("id"));
         student.setName(rs.getString("name"));
         student.setAge(rs.getInt("age"));
         return student;
     }

 }

4.下面是为定义的 DAO 接口 StudentDAO 的实现类文件 StudentJDBCTemplate.java，具体实现到数据库的操作：

 package com.spring.jdbcTemplate;

 import java.util.List;

 import javax.sql.DataSource;

 import org.springframework.jdbc.core.JdbcTemplate;
 /**
  * 利用Spring 内置jdbc JdbcTemplate来实现StudentDao接口，连接数据库。
  * @author Administrator
  *
  */
 public class StudentJdbcTemplate implements StudentDao {
     private DataSource dataSource;
     private JdbcTemplate jdbcTemplateObject;

     // 设置数据源
     @Override
     public void setDataSource(DataSource dataSource) {
         this.dataSource = dataSource;
         this.jdbcTemplateObject = new JdbcTemplate(dataSource);
     }

     // 添加学生数据
     @Override
     public void addStudent(String name, Integer age) {
         String sql = "insert into Student(name,age) value(?,?)";
         jdbcTemplateObject.update(sql, name, age);
         System.out.println("Created Record Name = " + name + " Age = " + age);
         return;
     }

     // 查询学生
     @Override
     public Student getStudentId(Integer id) {
         String sql = "select * from Student where id=?";
         Student student = jdbcTemplateObject.queryForObject(sql, new Object[] { id }, new StudentMapper());
         return student;
     }

     // 删除学生记录
     @Override
     public void delectStudent(Integer id) {
         String sql = "delete  from Student where id=?";
         jdbcTemplateObject.update(sql, id);
         System.out.println("Deleted Record with ID = " + id);
         return;
     }
     //更新数据
     @Override
     public void updata(Integer id,Integer age) {
         String SQL = "update Student set age = ? where id = ?";
         jdbcTemplateObject.update(SQL, age, id);
         System.out.println("Updated Record with ID = " + id);
         return;
     }
     //查询所有数据
     @Override
     public List<Student> SelectAllStudent() {
         String SQL = "select * from Student";
         List<Student> students = jdbcTemplateObject.query(SQL, new StudentMapper());
         return students;
     }

 }

5.建立一个 MainApp.java 文件，用于测试。内容如下：

 package com.spring.jdbcTemplate;

 import java.util.List;

 import org.springframework.context.support.ClassPathXmlApplicationContext;
 import org.springframework.jdbc.core.JdbcTemplate;

 public class MainApp {

     public static void main(String[] args) {
         ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext("spring_xml/bean.xml");
             //获取getBean("StudentJdbcTemplate")对象，调用其方法操作数据库
         StudentJdbcTemplate jdbcTemplate = (StudentJdbcTemplate)applicationContext.getBean("StudentJdbcTemplate");

             //插入数据
         /*    jdbcTemplate.addStudent("张三", 23);
             jdbcTemplate.addStudent("李四", 24);
             jdbcTemplate.addStudent("王五", 25);
             jdbcTemplate.addStudent("赵六", 26);
             jdbcTemplate.addStudent("田七", 27);*/

             //查询所有数据
         /*    List<Student> list=jdbcTemplate.SelectAllStudent();
             for(Student student:list){
                 System.out.println(student.getId()+student.getName()+student.getAge());
             }*/
             //查询单条记录
         /*    Student student=jdbcTemplate.getStudentId(1);
             System.out.println(student.getId()+student.getName()+student.getAge());*/

             //删除单条记录
             /*jdbcTemplate.delectStudent(2);*/

             //更新数据
             jdbcTemplate.updata(3, 45);
     }

 }

测试结果：