聊聊 Spring 数据库开发

• 1. Spring JDBC
• Spring JDBC的配置
• 2. Spring JdbcTemplate的常用方法
  • execute()
• 总结

GitHub：https://github.com/nateshao/ssm/tree/master/104-spring-jdbc

1. Spring JDBC

Spring JDBC模块有什么作用?

Spring的JDBC模块负责数据库资源管理和错误处理，大大简化了开发人员对数据库的操作，使得开发人员可以从繁琐的数据库操作中解脱出来，从而将更多的精力投入到编写业务逻辑当中。

Spring JdbcTemplate的解析

针对数据库的操作，Spring框架提供了JdbcTemplate类，该类是Spring框架数据抽象层的基础。可以说，JdbcTemplate类是Spring JDBC的核心类。

JdbcTemplate类的继承结构具体如下图所示：

从JdbcTemplate的继承关系图可以看出，JdbcTemplate类的直接父类是JdbcAccessor，该类为子类提供了一些访问数据库时使用的公共属性。

DataSource：其主要功能是获取数据库连接，还可以引入对数据库连接的缓冲池和分布式事务的支持，它可以作为访问数据库资源的标准接口。

SQLExceptionTranslator：该接口负责对SQLException进行转译工作。通过必要的设置获取SQLExceptionTranslator中的方法，可以使JdbcTemplate在需要处理SQLException时，委托SQLExceptionTranslator的实现类来完成相关的转译工作。

而JdbcOperations接口定义了在JdbcTemplate类中可以使用的操作集合，包括添加、修改、查询和删除等操作。

Spring JDBC的配置

Spring JDBC模块主要由4个包组成，分别是core(核心包)、dataSource(数据源包)、object(对象包)和support(支持包)。

从上表可以看出，Spring对数据库的操作都封装在了这几个包中，而想要使用Spring JDBC，就需要对其进行配置。

<?xmlversion="1.0"encoding="UTF-8"?>
<beansxmlns="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配置数据源-->
<beanid="dataSource"class=
"org.springframework.jdbc.datasource.DriverManagerDataSource">
<!--数据库驱动-->
<propertyname="driverClassName"value="com.mysql.jdbc.Driver"/>
<!--连接数据库的url-->
<propertyname="url"value="jdbc:mysql://localhost:3306/spring"/>
<!--连接数据库的用户名-->
<propertyname="username"value="root"/>
<!--连接数据库的密码-->
<propertyname="password"value="123456"/>
</bean>
<!--2配置JDBC模板-->
<beanid="jdbcTemplate"
class="org.springframework.jdbc.core.JdbcTemplate">
<!--默认必须使用数据源-->
<propertyname="dataSource"ref="dataSource"/>
</bean>

<!--定义id为accountDao的Bean-->
<beanid="accountDao"class="com.nateshao.jdbc.AccountDaoImpl">
<!--将jdbcTemplate注入到accountDao实例中-->
<propertyname="jdbcTemplate"ref="jdbcTemplate"/>
</bean>

</beans>

关于上述示例dataSource配置中的4个属性说明，如下表所示：

注意：上表中的属性值在实际配置时，需要根据数据库类型和设置进行相应配置。

2. Spring JdbcTemplate的常用方法

“在JdbcTemplate核心类中，提供了大量的更新和查询数据库的方法，我们就是使用的这些方法来操作数据库的。

execute( )：execute(String sql)方法可用于执行sql语句update()：update())用于执行插入、更新和删除操作query()：query()用于执行数据查询操作

execute()

使用execute(String sql)方法执行建表的案例实现步骤如下：

• 在MySQL中创建一个名为spring的数据库;
• 创建Web项目，导入相关maven包;
• 创建Spring配置文件，配置数据源和JDBC模板;
• 创建测试类，
• 测试程序。

Spring.sql

CREATEDATABASEIFNOTEXISTS`spring`;

USE`spring`;

/*Tablestructurefortable`account`*/

DROPTABLEIFEXISTS`account`;

CREATETABLE`account`(
`id`int(11)NOTNULLAUTO_INCREMENT,
`username`varchar(50)DEFAULTNULL,
`balance`doubleDEFAULTNULL,
PRIMARYKEY(`id`)
)ENGINE=InnoDBAUTO_INCREMENT=6DEFAULTCHARSET=utf8;

/*Dataforthetable`account`*/

insertinto`account`(`id`,`username`,`balance`)values(2,'shaotongjie',2222),(3,'1',2222),(4,'a',2022),(5,'b',2322);

Account.java

packagecom.nateshao.jdbc;

/**
*@dateCreatedby邵桐杰on2021/10/1515:50
*@微信公众号程序员千羽
*@个人网站www.nateshao.cn
*@博客https://nateshao.gitee.io
*@GitHubhttps://github.com/nateshao
*@Giteehttps://gitee.com/nateshao
*Description:
*/
@Data
publicclassAccount{
privateIntegerid;//账户id
privateStringusername;//用户名
privateDoublebalance;//账户余额
}

applicationContext.xml

<?xmlversion="1.0"encoding="UTF-8"?>
<beansxmlns="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配置数据源-->
<beanid="dataSource"class=
"org.springframework.jdbc.datasource.DriverManagerDataSource">
<!--数据库驱动-->
<propertyname="driverClassName"value="com.mysql.jdbc.Driver"/>
<!--连接数据库的url-->
<propertyname="url"value="jdbc:mysql://localhost:3306/spring?useSSL=false"/>
<!--连接数据库的用户名-->
<propertyname="username"value="root"/>
<!--连接数据库的密码-->
<propertyname="password"value="123456"/>
</bean>
<!--2配置JDBC模板-->
<beanid="jdbcTemplate"
class="org.springframework.jdbc.core.JdbcTemplate">
<!--默认必须使用数据源-->
<propertyname="dataSource"ref="dataSource"/>
</bean>

<!--定义id为accountDao的Bean-->
<beanid="accountDao"class="com.nateshao.jdbc.AccountDaoImpl">
<!--将jdbcTemplate注入到accountDao实例中-->
<propertyname="jdbcTemplate"ref="jdbcTemplate"/>
</bean>

</beans>

AccountDao.java

packagecom.nateshao.jdbc;

importjava.util.List;

/**
*@dateCreatedby邵桐杰on2021/10/1515:50
*@微信公众号程序员千羽
*@个人网站www.nateshao.cn
*@博客https://nateshao.gitee.io
*@GitHubhttps://github.com/nateshao
*@Giteehttps://gitee.com/nateshao
*Description:
*/
publicinterfaceAccountDao{
//添加
publicintaddAccount(Accountaccount);

//更新
publicintupdateAccount(Accountaccount);

//删除
publicintdeleteAccount(intid);

//通过id查询
publicintqueryAccountById(intid);
//查询所有账户
publicList<Account>findAllAccount();

AccountfindAccountById(inti);
}

AccountDaoImpl.java

packagecom.nateshao.jdbc;

importorg.springframework.jdbc.core.BeanPropertyRowMapper;
importorg.springframework.jdbc.core.JdbcTemplate;
importorg.springframework.jdbc.core.RowMapper;
importjava.util.List;

/**
*@dateCreatedby邵桐杰on2021/10/1515:55
*@微信公众号程序员千羽
*@个人网站www.nateshao.cn
*@博客https://nateshao.gitee.io
*@GitHubhttps://github.com/nateshao
*@Giteehttps://gitee.com/nateshao
*Description:
*/
publicclassAccountDaoImplimplementsAccountDao{
//声明JdbcTemplate属性及其setter方法
privateJdbcTemplatejdbcTemplate;

publicvoidsetJdbcTemplate(JdbcTemplatejdbcTemplate){
this.jdbcTemplate=jdbcTemplate;
}

/**
*添加账户
*@paramaccount
*@return
*/
publicintaddAccount(Accountaccount){
//定义SQL
Stringsql="insertintoaccount(username,balance)value(?,?)";
//定义数组来存放SQL语句中的参数
Object[]obj=newObject[]{
account.getUsername(),
account.getBalance()
};
//执行添加操作，返回的是受SQL语句影响的记录条数
intnum=this.jdbcTemplate.update(sql,obj);
returnnum;
}

/**
*更新账户
*@paramaccount
*@return
*/
publicintupdateAccount(Accountaccount){
//定义SQL
Stringsql="updateaccountsetusername=?,balance=?whereid=?";
//定义数组来存放SQL语句中的参数
Object[]params=newObject[]{
account.getUsername(),
account.getBalance(),
account.getId()
};
//执行添加操作，返回的是受SQL语句影响的记录条数
intnum=this.jdbcTemplate.update(sql,params);
returnnum;
}

/**
*删除账户
*@paramid
*@return
*/
publicintdeleteAccount(intid){
//定义SQL
Stringsql="deletefromaccountwhereid=?";
//执行添加操作，返回的是受SQL语句影响的记录条数
intnum=this.jdbcTemplate.update(sql,id);
returnnum;
}

@Override
publicintqueryAccountById(intid){
return0;
}

/**
*通过id查询账户数据信息
*@paramid
*@return
*/
publicAccountfindAccountById(intid){
//定义SQL语句
Stringsql="select*fromaccountwhereid=?";
//创建一个新的BeanPropertyRowMapper对象
RowMapper<Account>rowMapper=
newBeanPropertyRowMapper<Account>(Account.class);
//将id绑定到SQL语句中，并通过RowMapper返回一个Object类型的单行记录
returnthis.jdbcTemplate.queryForObject(sql,rowMapper,id);
}

/**
*查询所有账户信息
*@return
*/
publicList<Account>findAllAccount(){
//定义SQL语句
Stringsql="select*fromaccount";
//创建一个新的BeanPropertyRowMapper对象
RowMapper<Account>rowMapper=
newBeanPropertyRowMapper<Account>(Account.class);
//执行静态的SQL查询，并通过RowMapper返回结果
returnthis.jdbcTemplate.query(sql,rowMapper);
}

}

测试类JdbcTemplateTest.java

packagecom.nateshao.jdbc;

importorg.junit.jupiter.api.Test;
importorg.springframework.context.ApplicationContext;
importorg.springframework.context.support.ClassPathXmlApplicationContext;
importorg.springframework.jdbc.core.JdbcTemplate;
importjava.util.List;

/**
*@dateCreatedby邵桐杰on2021/10/1515:57
*@微信公众号程序员千羽
*@个人网站www.nateshao.cn
*@博客https://nateshao.gitee.io
*@GitHubhttps://github.com/nateshao
*@Giteehttps://gitee.com/nateshao
*Description:
*/
publicclassJdbcTemplateTest{
/**
*使用execute()方法建表
*/
//publicstaticvoidmain(String[]args){
////加载配置文件
//ApplicationContextapplicationContext=
//newClassPathXmlApplicationContext("applicationContext.xml");
////获取JdbcTemplate实例
//JdbcTemplatejdTemplate=
//(JdbcTemplate)applicationContext.getBean("jdbcTemplate");
////使用execute()方法执行SQL语句，创建用户账户管理表account
//jdTemplate.execute("createtableaccount("+
//"idintprimarykeyauto_increment,"+
//"usernamevarchar(50),"+
//"balancedouble)");
//System.out.println("账户表account创建成功！");
//}
@Test
publicvoidmainTest(){
//加载配置文件
ApplicationContextapplicationContext=
newClassPathXmlApplicationContext("applicationContext.xml");
//获取JdbcTemplate实例
JdbcTemplatejdTemplate=
(JdbcTemplate)applicationContext.getBean("jdbcTemplate");
//使用execute()方法执行SQL语句，创建用户账户管理表account
jdTemplate.execute("createtableaccount("+
"idintprimarykeyauto_increment,"+
"usernamevarchar(50),"+
"balancedouble)");
System.out.println("账户表account创建成功！");
}

@Test
publicvoidaddAccountTest(){
//加载配置文件
ApplicationContextapplicationContext=
newClassPathXmlApplicationContext("applicationContext.xml");
//获取AccountDao实例
AccountDaoaccountDao=
(AccountDao)applicationContext.getBean("accountDao");
//创建Account对象，并向Account对象中添加数据
Accountaccount=newAccount();
account.setUsername("千羽");
account.setBalance(1000.00);
//执行addAccount()方法，并获取返回结果
intnum=accountDao.addAccount(account);
if(num>0){
System.out.println("成功插入了"+num+"条数据！");
}else{
System.out.println("插入操作执行失败！");
}
}

@Test
publicvoidupdateAccountTest(){
//加载配置文件
ApplicationContextapplicationContext=
newClassPathXmlApplicationContext("applicationContext.xml");
//获取AccountDao实例
AccountDaoaccountDao=
(AccountDao)applicationContext.getBean("accountDao");
//创建Account对象，并向Account对象中添加数据
Accountaccount=newAccount();
account.setId(1);
account.setUsername("tom");
account.setBalance(2000.00);
//执行updateAccount()方法，并获取返回结果
intnum=accountDao.updateAccount(account);
if(num>0){
System.out.println("成功修改了"+num+"条数据！");
}else{
System.out.println("修改操作执行失败！");
}
}

@Test
publicvoiddeleteAccountTest(){
//加载配置文件
ApplicationContextapplicationContext=
newClassPathXmlApplicationContext("applicationContext.xml");
//获取AccountDao实例
AccountDaoaccountDao=
(AccountDao)applicationContext.getBean("accountDao");
//执行deleteAccount()方法，并获取返回结果
intnum=accountDao.deleteAccount(1);
if(num>0){
System.out.println("成功删除了"+num+"条数据！");
}else{
System.out.println("删除操作执行失败！");
}
}

@Test
publicvoidfindAccountByIdTest(){
//加载配置文件
ApplicationContextapplicationContext=
newClassPathXmlApplicationContext("applicationContext.xml");
//获取AccountDao实例
AccountDaoaccountDao=
(AccountDao)applicationContext.getBean("accountDao");
//执行findAccountById()方法
Accountaccount=accountDao.findAccountById(1);
System.out.println(account);
}

@Test
publicvoidfindAllAccountTest(){
//加载配置文件
ApplicationContextapplicationContext=
newClassPathXmlApplicationContext("applicationContext.xml");
//获取AccountDao实例
AccountDaoaccountDao=
(AccountDao)applicationContext.getBean("accountDao");
//执行findAllAccount()方法,获取Account对象的集合
List<Account>account=accountDao.findAllAccount();
//循环输出集合中的对象
for(Accountact:account){
System.out.println(act);
}
}
}

多学一招：使用JUnit单元测试

在进行接口开发完成后，一般是写个单元测试or采用PostMan去测试，或者前端项目对接，一起调试。

在开发过程中，需要有相应的测试工作。依据测试目的不同，可以将软件测试分为单元测试、集成测试、确认测试和系统测试等。其中单元测试在软件开发阶段是最底层的测试，它易于及时发现并解决问题。JUnit就是一个进行单元测试的开源框架，下面以上个示例，来学习单元测试框架JUnit4的使用。

update()

update()方法可以完成插入、更新和删除数据的操作。在JdbcTemplate类中，提供了一系列的update()方法，其常用方法下表所示：

query()

“JdbcTemplate类中还提供了大量的query()方法来处理各种对数据库表的查询操作。其中，常用的几个query()方法如下表所示：

总结

这篇文章主要是对Spring框架中，使用JDBC进行数据操作的知识进行了详细讲解。

首先讲解了Spring JDBC中的核心类以及如何在Spring中配置JDBC，

然后通过案例讲解了Spring JDBC核心类JdbcTemplate中常用方法的使用。

通过这篇文章的学习，能够学会如何使用Spring框架进行数据库开发，并能深切的体会到Spring框架的强大。