1.完成Account类中的定义私有变量(id,userName,balance)
// com.spring.jdbc.JdbcTemplate;
private Integer id;
private String userName;
private Double balance;
2.完成AccountManage接口类,定义接口(插入add、更新update、查询单个query、查询所有queryAll、删除delete)
// com.spring.jdbc.JdbcTemplate;
public void addAccount(Account account);
public void updateAccount(Account account);
public void queryAllAccount();
public void deleteAccount(Interger id);
3.完成AccountManageImpl接口实现类
// com.spring.jdbc.JdbcTemplate;
package com.spring.jdbc.JdbcTemplate;
import java.util.List;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
//接口实现类
public class AccountManageImpl implements AccountManage {
//定义JdbcTemplate属性以及相关的set方法
private JdbcTemplate jdbcTemplate;
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
@Override
public void addAccount(Account account) {
//定义一个SQL语句,实现插入一条数据
String sql="insert into accounts(id,userName,balance) value(?,?,?)";
//定义数组存放SQL语句中的参数
Object[] obj = new Object[] {
account.getId(),
account.getUserName(),
account.getBalance()
};
//执行SQL语句,返回执行添加操作的记录条数
int num = jdbcTemplate.update(sql,obj);
if(num >0) {
System.out.println("成功插入了"+num+"条转账记录");
System.out.println(account);
}
else {
System.out.println("执行插入账号记录失败");
}
}
@Override
public void queryAccountById(Integer id) {
//定义一个SQL语句,实现根据账户ID进行查询
String sql="select * from accounts where id=?";
//创建一个BeanProPertRowMapper对象
RowMapper<Account> rowMapper;
rowMapper = new BeanPropertyRowMapper<Account>(Account.class);
//执行Sql查询语句,并通过rowMapper类返回Account类对象
Account account = jdbcTemplate.queryForObject(sql,rowMapper,id);
System.out.println("成功查询了1个用户记录");
System.out.println(account);
}
@Override
public void queryAllAccount() {
//定义SQL查询语句,实现查询所有的账号记录
String sql="select * from accounts";
//创建一个BeanProPertRowMapper对象
RowMapper<Account> rowMapper;
rowMapper = new BeanPropertyRowMapper<Account>(Account.class);
//执行Sql查询语句,并通过rowMapper类返回Account类对象
List<Account>accounts = jdbcTemplate.query(sql,rowMapper);
System.out.println("成功查询了所有的用户记录");
//循环输出每个记录
for(Account account:accounts) {
System.out.println(account);
}
}
@Override
public void updateAccount(Account account) {
//定义SQL查询语句,实现更新账号id余额
String sql="update accounts set balance=? where id=?";
//定义数组用来存放SQL语句中的参数
Object[] params = new Object[] {account.getBalance(),account.getId()};
//执行SQL更新语句,返回执行更新操作的记录条数
int num = jdbcTemplate.update(sql,params);
if(num>0) {
System.out.println("数据更新成功"+num+"条账号记录");
}else {
System.out.println("执行更新账号记录失败");
}
}
@Override
public void deleteAccount(Integer id) {
//定义SQL查询语句,实现更新账号id余额
String sql="delete from accounts where id=?";
//执行SQL删除语句,返回执行删除操作的记录条数
int num = jdbcTemplate.update(sql,id);
if(num>0) {
System.out.println("数据成功删除"+num+"条账号记录");
}else {
System.out.println("执行删除账号记录失败");
}
}
}
4.完成jdbcTemplateTest程序测试类,完成创建数据表,查询、插入、更新、删除等操作。
// com.spring.jdbc.JdbcTemplate
//1、使用execute()方法执行sql创建表语句,创建账户表accounts
jdbcTemplate.execute("create table if not exists accounts(id int,userName varchar(50),balance double)");
// 2.查询数据
// 查询所有记录
accountManage.queryAllAccount();
// 按照id查询
accountManage.queryAccountById(20240430);
// 3.插入数据
account.setId(20240430);
account.setUserName("小明");
account.setBalance(1000.0);
accountManage.addAccount(account);
// 4.更新数据(更新id为20240501的用户余额)
account.setId(20240501);
account.setBalance(1000.0);
accountManage.updateAccount(account);
// 5.删除数据(删除id为20240504的用户记录)
accountManage.deleteAccount(20240504);