聊聊 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，就需要对其进行配置。

"1.0" encoding= "UTF-8" ?> "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配置数据源--> "dataSource" class= "org.springframework.jdbc.datasource.DriverManagerDataSource" > --数据库驱动--> name = "driverClassName" value= "com.mysql.jdbc.Driver" /> --连接数据库的url--> name = "url" value= "jdbc:mysql://localhost:3306/spring" /> --连接数据库的用户名--> name = "username" value= "root" /> --连接数据库的密码--> name = "password" value= "123456" /> --2配置JDBC模板--> "jdbcTemplate" class= "org.springframework.jdbc.core.JdbcTemplate" > --默认必须使用数据源--> name = "dataSource" ref= "dataSource" /> --定义id为accountDao的Bean--> "accountDao" class= "com.nateshao.jdbc.AccountDaoImpl" > --将jdbcTemplate注入到accountDao实例中--> name = "jdbcTemplate" ref= "jdbcTemplate" />

关于上述示例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

CREATE DATABASE IF NOT EXISTS`spring`; USE`spring`; /* Table structure for table `account`*/ DROP TABLE IFEXISTS`account`; CREATE TABLE `account`( `id` int (11) NOT NULL AUTO_INCREMENT, `username` varchar (50) DEFAULT NULL , `balance` double DEFAULT NULL , PRIMARY KEY (`id`) )ENGINE=InnoDBAUTO_INCREMENT=6 DEFAULT CHARSET=utf8; /*Data for the table `account`*/ insert into `account`(`id`,`username`,`balance`) values (2, 'shaotongjie' ,2222),(3, '1' ,2222),(4, 'a' ,2022),(5, 'b' ,2322);

Account.java

packagecom.nateshao.jdbc; /** *@ date Created by 邵桐杰 on 2021/10/1515:50 *@微信公众号程序员千羽 *@个人网站www.nateshao.cn *@博客https://nateshao.gitee.io *@GitHubhttps://github.com/nateshao *@Giteehttps://gitee.com/nateshao *Description: */ @Data public classAccount{ private Integer id;//账户id privateStringusername;//用户名 private Double balance;//账户余额 }

applicationContext.xml

"1.0" encoding= "UTF-8" ?> "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配置数据源--> "dataSource" class= "org.springframework.jdbc.datasource.DriverManagerDataSource" > --数据库驱动--> name = "driverClassName" value= "com.mysql.jdbc.Driver" /> --连接数据库的url--> name = "url" value= "jdbc:mysql://localhost:3306/spring?useSSL=false" /> --连接数据库的用户名--> name = "username" value= "root" /> --连接数据库的密码--> name = "password" value= "123456" /> --2配置JDBC模板--> "jdbcTemplate" class= "org.springframework.jdbc.core.JdbcTemplate" > --默认必须使用数据源--> name = "dataSource" ref= "dataSource" /> --定义id为accountDao的Bean--> "accountDao" class= "com.nateshao.jdbc.AccountDaoImpl" > --将jdbcTemplate注入到accountDao实例中--> name = "jdbcTemplate" ref= "jdbcTemplate" />

AccountDao.java

packagecom.nateshao.jdbc; importjava.util.List; /** *@ date Created by 邵桐杰 on 2021/10/1515:50 *@微信公众号程序员千羽 *@个人网站www.nateshao.cn *@博客https://nateshao.gitee.io *@GitHubhttps://github.com/nateshao *@Giteehttps://gitee.com/nateshao *Description: */ public interfaceAccountDao{ //添加 public int addAccount(Accountaccount); //更新 public int updateAccount(Accountaccount); //删除 public int deleteAccount( int id); //通过id查询 public int queryAccountById( int id); //查询所有账户 public List findAllAccount(); AccountfindAccountById( int i); }

AccountDaoImpl.java

packagecom.nateshao.jdbc; importorg.springframework.jdbc.core.BeanPropertyRowMapper; importorg.springframework.jdbc.core.JdbcTemplate; importorg.springframework.jdbc.core.RowMapper; importjava.util.List; /** *@ date Created by 邵桐杰 on 2021/10/1515:55 *@微信公众号程序员千羽 *@个人网站www.nateshao.cn *@博客https://nateshao.gitee.io *@GitHubhttps://github.com/nateshao *@Giteehttps://gitee.com/nateshao *Description: */ public classAccountDaoImplimplementsAccountDao{ //声明JdbcTemplate属性及其setter方法 privateJdbcTemplatejdbcTemplate; public voidsetJdbcTemplate(JdbcTemplatejdbcTemplate){ this.jdbcTemplate=jdbcTemplate; } /** *添加账户 *@paramaccount *@ return */ public int addAccount(Accountaccount){ //定义SQL Stringsql= "insertintoaccount(username,balance)value(?,?)" ; //定义数组来存放SQL语句中的参数 Object[]obj=newObject[]{ account.getUsername(), account.getBalance() }; //执行添加操作，返回的是受SQL语句影响的记录条数 int num=this.jdbcTemplate. update (sql,obj); return num; } /** *更新账户 *@paramaccount *@ return */ public int updateAccount(Accountaccount){ //定义SQL Stringsql= "updateaccountsetusername=?,balance=?whereid=?" ; //定义数组来存放SQL语句中的参数 Object[]params=newObject[]{ account.getUsername(), account.getBalance(), account.getId() }; //执行添加操作，返回的是受SQL语句影响的记录条数 int num=this.jdbcTemplate. update (sql,params); return num; } /** *删除账户 *@paramid *@ return */ public int deleteAccount( int id){ //定义SQL Stringsql= "deletefromaccountwhereid=?" ; //执行添加操作，返回的是受SQL语句影响的记录条数 int num=this.jdbcTemplate. update (sql,id); return num; } @Override public int queryAccountById( int id){ return 0; } /** *通过id查询账户数据信息 *@paramid *@ return */ public AccountfindAccountById( int id){ //定义SQL语句 Stringsql= "select*fromaccountwhereid=?" ; //创建一个新的BeanPropertyRowMapper对象 RowMapper rowMapper= newBeanPropertyRowMapper (Account.class); //将id绑定到SQL语句中，并通过RowMapper返回一个Object类型的单行记录 return this.jdbcTemplate.queryForObject(sql,rowMapper,id); } /** *查询所有账户信息 *@ return */ public List findAllAccount(){ //定义SQL语句 Stringsql= "select*fromaccount" ; //创建一个新的BeanPropertyRowMapper对象 RowMapper rowMapper= newBeanPropertyRowMapper (Account.class); //执行静态的SQL查询，并通过RowMapper返回结果 return this.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; /** *@ date Created by 邵桐杰 on 2021/10/1515:57 *@微信公众号程序员千羽 *@个人网站www.nateshao.cn *@博客https://nateshao.gitee.io *@GitHubhttps://github.com/nateshao *@Giteehttps://gitee.com/nateshao *Description: */ public classJdbcTemplateTest{ /** *使用 execute ()方法建表 */ // public static voidmain(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 public voidmainTest(){ //加载配置文件 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 public voidaddAccountTest(){ //加载配置文件 ApplicationContextapplicationContext= newClassPathXmlApplicationContext( "applicationContext.xml" ); //获取AccountDao实例 AccountDaoaccountDao= (AccountDao)applicationContext.getBean( "accountDao" ); //创建Account对象，并向Account对象中添加数据 Accountaccount=newAccount(); account.setUsername( "千羽" ); account.setBalance(1000.00); //执行addAccount()方法，并获取返回结果 int num=accountDao.addAccount(account); if(num>0){ System. out .println( "成功插入了" +num+ "条数据！" ); } else { System. out .println( "插入操作执行失败！" ); } } @Test public voidupdateAccountTest(){ //加载配置文件 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()方法，并获取返回结果 int num=accountDao.updateAccount(account); if(num>0){ System. out .println( "成功修改了" +num+ "条数据！" ); } else { System. out .println( "修改操作执行失败！" ); } } @Test public voiddeleteAccountTest(){ //加载配置文件 ApplicationContextapplicationContext= newClassPathXmlApplicationContext( "applicationContext.xml" ); //获取AccountDao实例 AccountDaoaccountDao= (AccountDao)applicationContext.getBean( "accountDao" ); //执行deleteAccount()方法，并获取返回结果 int num=accountDao.deleteAccount(1); if(num>0){ System. out .println( "成功删除了" +num+ "条数据！" ); } else { System. out .println( "删除操作执行失败！" ); } } @Test public voidfindAccountByIdTest(){ //加载配置文件 ApplicationContextapplicationContext= newClassPathXmlApplicationContext( "applicationContext.xml" ); //获取AccountDao实例 AccountDaoaccountDao= (AccountDao)applicationContext.getBean( "accountDao" ); //执行findAccountById()方法 Accountaccount=accountDao.findAccountById(1); System. out .println(account); } @Test public voidfindAllAccountTest(){ //加载配置文件 ApplicationContextapplicationContext= newClassPathXmlApplicationContext( "applicationContext.xml" ); //获取AccountDao实例 AccountDaoaccountDao= (AccountDao)applicationContext.getBean( "accountDao" ); //执行findAllAccount()方法,获取Account对象的集合 List 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框架的强大。

原文链接：https://mp.weixin.qq.com/s/BvOzzcc2L9PUb4oXl4mxkw

查看更多关于聊聊 Spring 数据库开发的详细内容...