Spring框架学习第六讲（JDBCTemplate实现CRUD操作）

一、 Spring 中的JDBCTemplate对JDBC进行了封装

1.1 添加相关的JAR包

spring-jdbc,spring-tx(事务),mysql驱动包

1.2 创建对象，设置数据库信息

DriverManagerDataSource source = new DriverManagerDataSource();
source.setDriverClassName("com.mysql.jdbc.Driver");
source.setUrl("jdbc:mysql://localhost:3306/my?useUnicode=true&characterEncoding=UTF-8");
source.setUsername("root");
source.setPassword("");

1.3 创建JDBCTemplate对象，设置数据库

JdbcTemplate template = new JdbcTemplate(source);

1.4 调用JDBCTemplate对象里面的方法实现操作

String sql = "insert into grade value(?,?,?)";
int row = template.update(sql,5,"C++高级班","数据库操作");  //返回的是数据库影响行数

1.5 实现增删改操作

package test;

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

public class TestJDBC {
JdbcTemplate template;
public void upload(){
//设置数据库信息
DriverManagerDataSource source = new DriverManagerDataSource();
source.setDriverClassName("com.mysql.jdbc.Driver");
source.setUrl("jdbc:mysql://localhost:3306/my?useUnicode=true&characterEncoding=UTF-8");
source.setUsername("root");
source.setPassword("");
//创建JDBCTemplate对象，设置数据源
template = new JdbcTemplate(source);
}
@Test//添加操作
public void add(){
upload();
//调用JDBCTemplate对象里面的方法实现操作
String sql = "insert into grade value(?,?,?)";//创建SQL语句
int row = template.update(sql,5,"C++高级班","数据库操作");
System.out.println(row);
//返回的是数据库影响行数
}
@Test
//更新操作
public void update(){
upload();
String sql = "update grade set GNAME=? where GID=?";
int row = template.update(sql,"C#",5);
System.out.println(row);
}
@Test//删除操作
public void delete(){
upload();
String sql = "delete from grade where GID=?";
int row = template.update(sql,5);
System.out.println(row);
}
}

1.6 实现查询功能

1.6.1 查询单个

@Test//获取表中数据个数操作
public void count(){
upload();
String sql = "select count(*) from grade";
int row = template.queryForObject(sql, Integer.class);
System.out.println(row);
}

1.6.2 查询单个对象

将数据库中的查询结果转换成类

1. 创建Grade类

package com.spring.jdbc;

public class Grade {
private int gid;
private String gName;
private String gDesc;
public String getgDesc() {
return gDesc;
}
public void setgDesc(String gDesc) {
this.gDesc = gDesc;
}
public String getgName() {
return gName;
}
public void setgName(String gName) {
this.gName = gName;
}
public int getGid() {
return gid;
}
public void setGid(int gid) {
this.gid = gid;
}
@Override
public String toString() {
// TODO Auto-generated method stub
return "[GName:]"+gName+",[GDesc:]"+gDesc;
}
}

2. 查询单个对象方法

queryForObject(String sql, RowMapper rowMapper, Object… args)

第一个参数是SQL语句；

第二个参数是Spring包中RowMapper接口的实现类，需要自己写该接口的实现类，自己将结果集做数据的封装；

第三个参数是SQL语句中的变量；

@Test
public void getObject(){
template = upload();
String sql = "select * from grade where gid=?";
Grade grade = template.queryForObject(sql, new MyRowMapper(), 4);
System.out.println(grade);
}

3. 写RowMapper接口的实现类

从结果集里面把数据得到

把得到的数据封装到对象中

返回对象

class MyRowMapper implements RowMapper<Grade>{

@Override
public Grade mapRow(ResultSet arg0, int arg1) throws SQLException {
Grade grade = new Grade();
grade.setgName(arg0.getString("GName"));
grade.setgDesc(arg0.getString("GDesc"));
return grade;
}
}

4. 输出结果

[GName:]C++二班,[GDesc:]C++软件开发二班

1.7 获取对象列表

query(String sql, RowMapper rowMapper) throws DataAccessException

* 第一个参数是SQL语句；

* 第二个参数是Spring包中RowMapper接口的实现类，需要自己写该接口的实现类，自己将结果集做数据的封装；

* 第三个参数是SQL语句中的变量（可省略）；

1.获取对象List方法

@Test//获取对象List
public void ObjectList(){
upload();
String sql = "select * from grade";
List<Grade> list = template.query(sql, new MyRowMapper());
System.out.println(list);
}
}

2. 写RowMapper接口的实现类（同上）

3. 输出结果

[[GName:]java一班,[GDesc:]JAVA软件开发一班, [GName:]java二班,[GDesc:]JAVA软件开发二班, [GName:]C++二班,[GDesc:]C++软件开发二班, [GName:]C++二班,[GDesc:]C++软件开发二班]

4. 测试类的整体代码

package test;

import java.sql.ResultSet;
import java.sql.SQLException;
import org.junit.Test;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import com.spring.jdbc.Grade;

public class TestJDBC {
JdbcTemplate template;
public void upload(){
//设置数据库信息
DriverManagerDataSource source = new DriverManagerDataSource();
source.setDriverClassName("com.mysql.jdbc.Driver");
source.setUrl("jdbc:mysql://localhost:3306/my?useUnicode=true&characterEncoding=UTF-8");
source.setUsername("root");
source.setPassword("");
//创建JDBCTemplate对象，设置数据源
template = new JdbcTemplate(source);
}
@Test//添加操作
public void add(){
upload();
//调用JDBCTemplate对象里面的方法实现操作
String sql = "insert into grade value(?,?,?)";//创建SQL语句
int row = template.update(sql,5,"C++高级班","数据库操作");
System.out.println(row);
//返回的是数据库影响行数
}
@Test
//更新操作
public void update(){
upload();
String sql = "update grade set GNAME=? where GID=?";
int row = template.update(sql,"C#",5);
System.out.println(row);
}
@Test//删除操作
public void delete(){
upload();
String sql = "delete from grade where GID=?";
int row = template.update(sql,5);
System.out.println(row);
}
@Test//获取表中数据个数操作
public void count(){
upload();
String sql = "select count(*) from grade";
int row = template.queryForObject(sql, Integer.class);
System.out.println(row);
}
@Test
public void getObject(){
upload();
String sql = "select * from grade where gid=?";
Grade grade = template.queryForObject(sql, new MyRowMapper(), 4);
System.out.println(grade);
}

}
class MyRowMapper implements RowMapper<Grade>{

@Override
public Grade mapRow(ResultSet arg0, int arg1) throws SQLException {
Grade grade = new Grade();
grade.setgName(arg0.getString("GName"));
grade.setgDesc(arg0.getString("GDesc"));
return grade;
}

}