Spring之JDBCTemplate实现CRUD操作
前言：Spring管理JDBCTemplate
一、 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语句中的变量；
@Testpublic 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
1.7 获取对象列表
query(String sql, RowMapper rowMapper) throws DataAccessException* 第一个参数是SQL语句；* 第二个参数是Spring包中RowMapper接口的实现类，需要自己写该接口的实现类，自己将结果集做数据的封装；* 第三个参数是SQL语句中的变量（可省略）；
1.获取对象List方法
@Test//获取对象Listpublic 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++软件开发二班]
1
2
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;
}
}