Spring的数据库开发
1、Spring JDBC
1)、Spring JDBC模块的作用：Spring的JDBC模块负责数据库资源管理和错误处理，大大简化了开发人员对数据库的操作，使得开发人员可以从繁琐的数据库操作中解脱出来，从而将更多的精力投入到编写业务逻辑当中。 （只要由new实例就可以用IOC实现，只要有setter方法就可以用DI实现）
2)、Spring JdbcTemplate的解析：
a)、JdbcTemplate类是Spring JDBC的核心类。
b)、JdbcTemplate类的继承结构具体如下图所示：
c)、DataSource（连接池，也称数据源）：其主要功能是获取数据库连接，还可以引入对数据库连接的缓冲池和分布式事务的支持，它可以作为访问数据库资源的标准接口。
d)、SQLExceptionTranslator：该接口负责对SQLException进行转译工作。通过必要的设置获取SQLExceptionTranslator中的方法，可以使JdbcTemplate在需要处理SQLException时，委托SQLExceptionTranslator的实现类来完成相关的转译工作。
e)、JdbcOperations接口定义了在JdbcTemplate类中可以使用的操作集合，包括添加、修改、查询和删除等操作。
3)、Spring JDBC的配置
a)、Spring JDBC模块主要由4个包组成，分别是core（核心包）、dataSource（数据源包）、object（对象包）和support（支持包）。
b)、从上表可以看出，Spring对数据库的操作都封装在了这几个包中，而想要使用Spring JDBC，就需要对其进行配置，配置模板如下：
<!--1、配置数据源-->
<bean id="dataSourceID" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost:3306/spring"/>
<property name="username" value="root"/>
<property name="password" value="****"/>
</bean> <!--配置JDBC模板-->
<bean id="jdbcTemplateID" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSourceID"/> <!--注入数据源-->
</bean> <!--配置需要实例化的Bean-->
<bean id="xxx" class="Xxx">
<property name="jdbcTemplate" ref="jdbcTemplateID"/> <!--注入JDBC模板-->
</bean>
c)、关于上述示例dataSource配置中的4个属性说明，如下表所示：
上表中的属性值在实际配置时，需要根据数据库类型和设置进行相应配置。
2、Spring JdbcTemplate的常用方法
1)、在JdbcTemplate核心类中，提供了大量的更新和查询数据库的方法：
a)、execute(String sql)方法可用于执行sql语句；
b)、update()用于执行插入、更新和删除操作；
c)、query()用于执行数据查询操作。
2)、execute()的使用：
a)、src->applicationContext.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
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-4.3.xsd"> <!-- 1、配置数据源 -->
<bean id="dataSourceID" class="org.springframework.jdbc.datasource.DriverManagerDataSource"> <!--1.1、数据库驱动 -->
<property name="driverClassName" value="com.mysql.jdbc.Driver" /> <!--1.2、连接数据库的url（即数据库所在地址） -->
<property name="url" value="jdbc:mysql://localhost:3306/spring" /> <!--1.3、连接数据库的用户名 -->
<property name="username" value="root" /> <!--1.4、连接数据库的密码 -->
<property name="password" value="******" />
</bean> <!-- 2、配置JDBC模板，并且注入数据源 -->
<bean id="jdbcTemplateID" class="org.springframework.jdbc.core.JdbcTemplate"> <!-- 2.1、默认必须使用数据源 -->
<property name="dataSource" ref="dataSourceID" />
</bean> <!--3、定义id为accountDaoID的Bean，即配置DAO层-->
<bean id="accountDaoID" class="com.itheima.jdbc.AccountDaoImpl"> <!-- 3.1、将jdbcTemplate注入到accountDao类实例中 -->
<property name="jdbcTemplate" ref="jdbcTemplateID" />
</bean> </beans>
b)、src->com.itheima.jdbc
①JdbcTemplateTest.java
package com.itheima.jdbc;
import java.util.List;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate; public class JdbcTemplateTest {
/**
* 使用execute()方法建表
*/
public static void main(String[] args) { // 1、加载配置文件
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml"); // 2、获取JdbcTemplate实例
JdbcTemplate jdTemplate = (JdbcTemplate) applicationContext.getBean("jdbcTemplateID"); // 3、使用该实例的execute()方法执行SQL语句，创建用户账户管理表account
jdTemplate.execute("create table account(" +
"id int primary key auto_increment," +
"username varchar(50)," +
"balance double)");
System.out.println("账户表account创建成功！");
}
}
②运行结果：
3)、update()的使用
a)、update()方法可以完成插入、更新和删除数据的操作。在JdbcTemplate类中，提供了一系列的update()方法，其常用方法下表所示：
b)、src->com.itheima.jdbc
①普通账户类：Account.java
package com.itheima.jdbc; public class Account { // 账户的信息 private Integer id; // 账户id
private String username; // 用户名
private Double balance; // 账户余额 public Integer getId() {
return id;
} public void setId(Integer id) {
this.id = id;
} public String getUsername() {
return username;
} public void setUsername(String username) {
this.username = username;
} public Double getBalance() {
return balance;
} public void setBalance(Double balance) {
this.balance = balance;
} public String toString() {
return "Account [id=" + id + ", " + "username=" + username + ", balance=" + balance + "].";
}
}
②用户接口类：AccountDao.java
package com.itheima.jdbc; import java.util.List; public interface AccountDao { // 创建接口 // 添加
public int addAccount(Account account); // 更新
public int updateAccount(Account account); // 删除
public int deleteAccount(int id); // 通过id查询
public Account findAccountById(int id); // 查询所有账户
public List<Account> findAllAccount();
}
③用户接口实现类：AccountDaoImpl.java
package com.itheima.jdbc;
import java.util.List;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper; public class AccountDaoImpl implements AccountDao { // 数据访问层DAO // 1、声明JdbcTemplate属性及其setter方法
private JdbcTemplate jdbcTemplate; public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { // 由Spring容器注入JBDC模板来操作mysql
this.jdbcTemplate = jdbcTemplate;
} // 2、添加账户
public int addAccount(Account account) { // 2.1、定义SQL
String sql = "insert into account(username,balance) value(?,?)"; // 2.2、定义数组来存放SQL语句中的参数
Object[] obj = new Object[] { account.getUsername(), account.getBalance() }; // 2.3、执行添加操作，返回的是受SQL语句影响的记录条数
int num = this.jdbcTemplate.update(sql, obj);
return num;
} // 3、更新账户
public int updateAccount(Account account) { // 3.1、定义SQL
String sql = "update account set username=?,balance=? where id = ?"; // 3.2、定义数组来存放SQL语句中的参数
Object[] params = new Object[] { account.getUsername(), account.getBalance(), account.getId() }; /*
* 3.3、执行添加操作，返回的是受SQL语句影响的记录条数
* 第1个参数：sql操作语句
* 第2个参数：
*/
int num = this.jdbcTemplate.update(sql, params);
return num;
} // 4、删除账户
public int deleteAccount(int id) { // 4.1、定义SQL
String sql = "delete from account where id = ? "; // 4.2、执行添加操作，返回的是受SQL语句影响的记录条数
int num = this.jdbcTemplate.update(sql, id);
return num;
} // 5、通过id查询账户数据信息
public Account findAccountById(int id) { //5.1、定义SQL语句
String sql = "select * from account where id = ?"; // 5.2、创建一个新的BeanPropertyRowMapper对象
RowMapper<Account> rowMapper = new BeanPropertyRowMapper<Account>(Account.class); // 5.3、将id绑定到SQL语句中，并通过RowMapper返回一个Object类型的单行记录
return this.jdbcTemplate.queryForObject(sql, rowMapper, id);
} // 6、查询所有账户信息
public List<Account> findAllAccount() { // 6.1、定义SQL语句
String sql = "select * from account"; // 6.2、创建一个新的BeanPropertyRowMapper对象
RowMapper<Account> rowMapper = new BeanPropertyRowMapper<Account>(Account.class); // 6.3、执行静态的SQL查询，并通过RowMapper返回结果
return this.jdbcTemplate.query(sql, rowMapper);
}
}
④测试类：JdbcTemplate中添加一个测试方法addAccountTest()，用于添加用户信息：
@Test
public void addAccountTest() { // 1、加载配置文件
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml"); // 2、获取AccountDao的Bena实例AccountDaoID
AccountDao accountDao = (AccountDao) applicationContext.getBean("accountDaoID"); // 3、创建Account对象，并向Account对象中添加数据
Account account = new Account();
account.setUsername("joy");
account.setBalance(100.00); // 4、执行addAccount()方法，并获取返回结果
int num = accountDao.addAccount(account);
if (num > 0) {
System.out.println("成功插入了" + num + "条数据！");
} else {
System.out.println("插入操作执行失败！");
}
}
⑤运行结果：
⑥测试类：JdbcTemplate中添加一个测试方法updateAccountTest()，用于更新用户信息：
@Test
public void updateAccountTest() { // 1、加载配置文件
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml"); // 2、获取AccountDao的Bean实例accountDaoID
AccountDao accountDao = (AccountDao) applicationContext.getBean("accountDaoID"); // 3、创建Account对象，并向Account对象中添加数据
Account account = new Account();
account.setId(1);
account.setUsername("tom");
account.setBalance(2000.00); // 4、执行updateAccount()方法，并获取返回结果
int num = accountDao.updateAccount(account);
if (num > 0) {
System.out.println("成功修改了" + num + "条数据！");
} else {
System.out.println("修改操作执行失败！");
}
}
⑦运行结果：
⑧测试类：JdbcTemplate中添加一个测试方法deleteAccountTest()，用于删除用户信息：
@Test
public void deleteAccountTest() { // 1、加载配置文件
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml"); // 2、获取AccountDao的Bean实例accountDaoID
AccountDao accountDao = (AccountDao) applicationContext.getBean("accountDaoID"); // 3、执行deleteAccount()方法，并获取返回结果
int num = accountDao.deleteAccount(1);
if (num > 0) {
System.out.println("成功删除了" + num + "条数据！");
} else {
System.out.println("删除操作执行失败！");
}
}
⑨运行结果：
4)、query()的使用
a)、JdbcTemplate类中还提供了大量的query()方法来处理各种对数据库表的查询操作。其中，常用的几个query()方法如下表所示：
b)、向数据表account中插入几条数据：
①测试类JdbcTemplate中添加一个测试方法findAccountByIdTest()，用于查找用户id的信息：
@Test
public void findAccountByIdTest() { // 1、加载配置文件
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml"); // 2、获取AccountDao的Bean实例accountDaoID
AccountDao accountDao = (AccountDao) applicationContext.getBean("accountDaoID"); // 3、执行findAccountById()方法
Account account = accountDao.findAccountById(1);
System.out.println(account);
}
②运行结果：
③测试类JdbcTemplate中添加一个测试方法findAllAccountTest()，用于查找所有用户的信息：
@Test
public void findAllAccountTest() { // 1、加载配置文件
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml"); // 2、获取AccountDao实例
AccountDao accountDao = (AccountDao) applicationContext.getBean("accountDaoID"); // 3、执行findAllAccount()方法,获取Account对象的集合
List<Account> account = accountDao.findAllAccount(); // 4、循环输出集合中的对象
for (Account act : account) {
System.out.println(act);
}
}
④运行结果：
个人总结：
如何管理用户的数据库？首先应单独写一个类来存储用户的所有信息；其次“管理员”创建实现操作用户的接口类（拥有的操作方法）以及对应的接口实现类，其中接口实现类要注入JdbcTemplate属性和它的setter方法，因为用JdbcTemplate管理数据库起来很方便，并且要实现对用户的增删查改的具体方法；然后测试操作时，首先都要加载配置文件，因为这些都由Spring容器来管理，然后获取容器中管理用户的Bean实例，若要对用户信息进行增加或更新，则要先new一个普通用户的实例，向这个实例中传入需要操作的数据，最后通过Bean实例去调用相应的操作用户的方法即可。
