Spring Boot实战：数据库操作
本文内容纲要：
上篇文章中已经通过一个简单的HelloWorld程序讲解了Springboot的基本原理和使用。本文主要讲解如何通过springboot来访问数据库，本文会演示三种方式来访问数据库，第一种是JdbcTemplate，第二种是JPA，第三种是Mybatis。之前已经提到过，本系列会以一个博客系统作为讲解的基础，所以本文会讲解文章的存储和访问（但不包括文章的详情），因为最终的实现是通过MyBatis来完成的，所以，对于JdbcTemplate和JPA只做简单演示，MyBatis部分会完整实现对文章的增删改查。
一、准备工作
在演示这几种方式之前，需要先准备一些东西。第一个就是数据库，本系统是采用MySQL实现的，我们需要先创建一个tb_article的表：
DROPTABLEIFEXISTS`tb_article`;
CREATETABLE`tb_article`(
`id`bigint(20)NOTNULLAUTO_INCREMENT,
`title`varchar(255)NOTNULLDEFAULT'',
`summary`varchar(1024)NOTNULLDEFAULT'',
`status`int(11)NOTNULLDEFAULT'0',
`type`int(11)NOTNULL,
`user_id`bigint(20)NOTNULLDEFAULT'0',
`create_time`timestampNOTNULLDEFAULTCURRENT_TIMESTAMP,
`update_time`timestampNOTNULLDEFAULTCURRENT_TIMESTAMP,
`public_time`timestampNOTNULLDEFAULTCURRENT_TIMESTAMP,
PRIMARYKEY(`id`)
)ENGINE=InnoDBDEFAULTCHARSET=utf8;
后续的演示会对这个表进行增删改查，大家应该会看到这个表里面并没有文章的详情，原因是文章的详情比较长，如果放在这个表里面容易影响查询文章列表的效率，所以文章的详情会单独存在另外的表里面。此外我们需要配置数据库连接池，这里我们使用druid连接池，另外配置文件使用yaml配置，即application.yml（你也可以使用application.properties配置文件，没什么太大的区别，如果对ymal不熟悉，有兴趣也可以查一下，比较简单）。连接池的配置如下：
spring:
datasource:
url:jdbc:mysql://127.0.0.1:3306/blog?useUnicode=true&characterEncoding=UTF-8&useSSL=false
driverClassName:com.mysql.jdbc.Driver
username:root
password:123456
type:com.alibaba.druid.pool.DruidDataSource
最后，我们还需要建立与数据库对应的POJO类，代码如下：
publicclassArticle{
privateLongid;
privateStringtitle;
privateStringsummary;
privateDatecreateTime;
privateDatepublicTime;
privateDateupdateTime;
privateLonguserId;
privateIntegerstatus;
privateIntegertype;
}
好了，需要准备的工作就这些，现在开始实现数据库的操作。
二、与JdbcTemplate集成
首先，我们先通过JdbcTemplate来访问数据库，这里只演示数据的插入，上一篇文章中我们已经提到过，Springboot提供了许多的starter来支撑不同的功能，要支持JdbcTemplate我们只需要引入下面的starter就可以了：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
现在我们就可以通过JdbcTemplate来实现数据的插入了：
publicinterfaceArticleDao{
LonginsertArticle(Articlearticle);
}
@Repository
publicclassArticleDaoJdbcTemplateImplimplementsArticleDao{
@Autowired
privateNamedParameterJdbcTemplatejdbcTemplate;
@Override
publicLonginsertArticle(Articlearticle){
Stringsql="insertintotb_article(title,summary,user_id,create_time,public_time,update_time,status)"+
"values(:title,:summary,:userId,:createTime,:publicTime,:updateTime,:status)";
Map<String,Object>param=newHashMap<>();
param.put("title",article.getTitle());
param.put("summary",article.getSummary());
param.put("userId",article.getUserId());
param.put("status",article.getStatus());
param.put("createTime",article.getCreateTime());
param.put("publicTime",article.getPublicTime());
param.put("updateTime",article.getUpdateTime());
return(long)jdbcTemplate.update(sql,param);
}
}
我们通过JUnit来测试上面的代码：
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes=Application.class)
publicclassArticleDaoTest{
@Autowired
privateArticleDaoarticleDao;
@Test
publicvoidtestInsert(){
Articlearticle=newArticle();
article.setTitle("测试标题");
article.setSummary("测试摘要");
article.setUserId(1L);
article.setStatus(1);
article.setCreateTime(newDate());
article.setUpdateTime(newDate());
article.setPublicTime(newDate());
articleDao.insertArticle(article);
}
}
要支持上面的测试程序，也需要引入一个starter：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
从上面的代码可以看出，其实除了引入jdbc的start之外，基本没有配置，这都是springboot的自动帮我们完成了配置的过程。上面的代码需要注意的Application类的位置，该类必须位于Dao类的父级的包中，比如这里Dao都位于com.pandy.blog.dao这个包下，现在我们把Application.java这个类从com.pandy.blog这个包移动到com.pandy.blog.app这个包中，则会出现如下错误：
Causedby:org.springframework.beans.factory.NoSuchBeanDefinitionException:Noqualifyingbeanoftype'com.pandy.blog.dao.ArticleDao'available:expectedatleast1beanwhichqualifiesasautowirecandidate.Dependencyannotations:{@org.springframework.beans.factory.annotation.Autowired(required=true)}
atorg.springframework.beans.factory.support.DefaultListableBeanFactory.raiseNoMatchingBeanFound(DefaultListableBeanFactory.java:1493)
atorg.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1104)
atorg.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1066)
atorg.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:585)
...28more
也就是说，找不到ArticleDao的实现，这是什么原因呢？上一篇博文中我们已经看到@SpringBootApplication这个注解继承了@ComponentScan，其默认情况下只会扫描Application类所在的包及子包。因此，对于上面的错误，除了保持Application类在Dao的父包这种方式外，也可以指定扫描的包来解决：
@SpringBootApplication
@ComponentScan({"com.pandy.blog"})
publicclassApplication{
publicstaticvoidmain(String[]args)throwsException{
SpringApplication.run(Application.class,args);
}
}
三、与JPA集成
现在我们开始讲解如何通过JPA的方式来实现数据库的操作。还是跟JdbcTemplate类似，首先，我们需要引入对应的starter：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
然后我们需要对POJO类增加Entity的注解，并指定表名（如果不指定，默认的表名为article），然后需要指定ID的及其生成策略，这些都是JPA的知识，与Springboot无关，如果不熟悉的话可以看下JPA的知识点：
@Entity(name="tb_article")
publicclassArticle{
@Id
@GeneratedValue
privateLongid;
privateStringtitle;
privateStringsummary;
privateDatecreateTime;
privateDatepublicTime;
privateDateupdateTime;
privateLonguserId;
privateIntegerstatus;
}
最后，我们需要继承JpaRepository这个类，这里我们实现了两个查询方法，第一个是符合JPA命名规范的查询，JPA会自动帮我们完成查询语句的生成，另一种方式是我们自己实现JPQL（JPA支持的一种类SQL的查询）。
publicinterfaceArticleRepositoryextendsJpaRepository<Article,Long>{
publicList<Article>findByUserId(LonguserId);
@Query("selectartfromcom.pandy.blog.po.Articleartwheretitle=:title")
publicList<Article>queryByTitle(@Param("title")Stringtitle);
}
好了，我们可以再测试一下上面的代码：
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes=Application.class)
publicclassArticleRepositoryTest{
@Autowired
privateArticleRepositoryarticleRepository;
@Test
publicvoidtestQuery(){
List<Article>articleList=articleRepository.queryByTitle("测试标题");
assertTrue(articleList.size()>0);
}
}
注意，这里还是存在跟JdbcTemplate类似的问题，需要将Application这个启动类未于Respository和Entity类的父级包中，否则会出现如下错误：
Causedby:org.springframework.beans.factory.NoSuchBeanDefinitionException:Noqualifyingbeanoftype'com.pandy.blog.dao.ArticleRepository'available:expectedatleast1beanwhichqualifiesasautowirecandidate.Dependencyannotations:{@org.springframework.beans.factory.annotation.Autowired(required=true)}
atorg.springframework.beans.factory.support.DefaultListableBeanFactory.raiseNoMatchingBeanFound(DefaultListableBeanFactory.java:1493)
atorg.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1104)
atorg.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1066)
atorg.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:585)
...28more
当然，同样也可以通过注解@EnableJpaRepositories指定扫描的JPA的包，但是还是不行，还会出现如下错误：
Causedby:java.lang.IllegalArgumentException:Notamanagedtype:classcom.pandy.blog.po.Article
atorg.hibernate.jpa.internal.metamodel.MetamodelImpl.managedType(MetamodelImpl.java:210)
atorg.springframework.data.jpa.repository.support.JpaMetamodelEntityInformation.<init>(JpaMetamodelEntityInformation.java:70)
atorg.springframework.data.jpa.repository.support.JpaEntityInformationSupport.getEntityInformation(JpaEntityInformationSupport.java:68)
atorg.springframework.data.jpa.repository.support.JpaRepositoryFactory.getEntityInformation(JpaRepositoryFactory.java:153)
atorg.springframework.data.jpa.repository.support.JpaRepositoryFactory.getTargetRepository(JpaRepositoryFactory.java:100)
atorg.springframework.data.jpa.repository.support.JpaRepositoryFactory.getTargetRepository(JpaRepositoryFactory.java:82)
atorg.springframework.data.repository.core.support.RepositoryFactorySupport.getRepository(RepositoryFactorySupport.java:199)
atorg.springframework.data.repository.core.support.RepositoryFactoryBeanSupport.initAndReturn(RepositoryFactoryBeanSupport.java:277)
atorg.springframework.data.repository.core.support.RepositoryFactoryBeanSupport.afterPropertiesSet(RepositoryFactoryBeanSupport.java:263)
atorg.springframework.data.jpa.repository.support.JpaRepositoryFactoryBean.afterPropertiesSet(JpaRepositoryFactoryBean.java:101)
atorg.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1687)
atorg.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1624)
...39more
这个错误说明识别不了Entity，所以还需要通过注解@EntityScan来指定Entity的包，最终的配置如下：
@SpringBootApplication
@ComponentScan({"com.pandy.blog"})
@EnableJpaRepositories(basePackages="com.pandy.blog")
@EntityScan("com.pandy.blog")
publicclassApplication{
publicstaticvoidmain(String[]args)throwsException{
SpringApplication.run(Application.class,args);
}
}
四、与MyBatis集成
最后，我们再看看如何通过MyBatis来实现数据库的访问。同样我们还是要引入starter：
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.1.1</version>
</dependency>
由于该starter不是springboot官方提供的，所以版本号于Springboot不一致，需要手动指定。
MyBatis一般可以通过XML或者注解的方式来指定操作数据库的SQL，个人比较偏向于XML，所以，本文中也只演示了通过XML的方式来访问数据库。首先，我们需要配置mapper的目录。我们在application.yml中进行配置：
mybatis:
config-locations:mybatis/mybatis-config.xml
mapper-locations:mybatis/mapper/*.xml
type-aliases-package:com.pandy.blog.po
这里配置主要包括三个部分，一个是mybatis自身的一些配置，例如基本类型的别名。第二个是指定mapper文件的位置，第三个POJO类的别名。这个配置也可以通过Javaconfiguration来实现，由于篇幅的问题，我这里就不详述了，有兴趣的朋友可以自己实现一下。
配置完后，我们先编写mapper对应的接口：
publicinterfaceArticleMapper{
publicLonginsertArticle(Articlearticle);
publicvoidupdateArticle(Articlearticle);
publicArticlequeryById(Longid);
publicList<Article>queryArticlesByPage(@Param("article")Articlearticle,@Param("pageSize")intpageSize,
@Param("offset")intoffset);
}
该接口暂时只定义了四个方法，即添加、更新，以及根据ID查询和分页查询。这是一个接口，并且和JPA类似，可以不用实现类。接下来我们编写XML文件：
<?xmlversion="1.0"encoding="UTF-8"?>
<!DOCTYPEmapperPUBLIC"-//mybatis.org//DTDMapper3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mappernamespace="com.pandy.blog.dao.ArticleMapper">
<resultMapid="articleMap"type="com.pandy.blog.po.Article">
<idcolumn="id"property="id"jdbcType="INTEGER"/>
<resultcolumn="title"property="title"jdbcType="VARCHAR"/>
<resultcolumn="summary"property="summary"jdbcType="VARCHAR"/>
<resultcolumn="user_id"property="userId"jdbcType="INTEGER"/>
<resultcolumn="status"property="status"jdbcType="INTEGER"/>
<resultcolumn="create_time"property="createTime"jdbcType="TIMESTAMP"/>
<resultcolumn="update_time"property="updateTime"jdbcType="TIMESTAMP"/>
<resultcolumn="public_time"property="publicTime"jdbcType="TIMESTAMP"/>
</resultMap>
<sqlid="base_column">
title,summary,user_id,status,create_time,update_time,public_time
</sql>
<insertid="insertArticle"parameterType="Article">
INSERTINTO
tb_article(<includerefid="base_column"/>)
VALUE
(#{title},#{summary},#{userId},#{status},#{createTime},#{updateTime},#{publicTime})
</insert>
<updateid="updateArticle"parameterType="Article">
UPDATEtb_article
<set>
<iftest="title!=null">
title=#{title},
</if>
<iftest="summary!=null">
summary=#{summary},
</if>
<iftest="status!=null">
status=#{status},
</if>
<iftest="publicTime!=null">
public_time=#{publicTime},
</if>
<iftest="updateTime!=null">
update_time=#{updateTime},
</if>
</set>
WHEREid=#{id}
</update>
<selectid="queryById"parameterType="Long"resultMap="articleMap">
SELECTid,<includerefid="base_column"></include>FROMtb_article
WHEREid=#{id}
</select>
<selectid="queryArticlesByPage"resultMap="articleMap">
SELECTid,<includerefid="base_column"></include>FROMtb_article
<where>
<iftest="article.title!=null">
titlelikeCONCAT（'%',${article.title},'%'）
</if>
<iftest="article.userId!=null">
user_id=#{article.userId}
</if>
</where>
limit#{offset},#{pageSize}
</select>
</mapper>
最后，我们需要手动指定mapper扫描的包：
@SpringBootApplication
@MapperScan("com.pandy.blog.dao")
publicclassApplication{
publicstaticvoidmain(String[]args)throwsException{
SpringApplication.run(Application.class,args);
}
}
好了，与MyBatis的集成也完成了，我们再测试一下：
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes=Application.class)
publicclassArticleMapperTest{
@Autowired
privateArticleMappermapper;
@Test
publicvoidtestInsert(){
Articlearticle=newArticle();
article.setTitle("测试标题2");
article.setSummary("测试摘要2");
article.setUserId(1L);
article.setStatus(1);
article.setCreateTime(newDate());
article.setUpdateTime(newDate());
article.setPublicTime(newDate());
mapper.insertArticle(article);
}
@Test
publicvoidtestMybatisQuery(){
Articlearticle=mapper.queryById(1L);
assertNotNull(article);
}
@Test
publicvoidtestUpdate(){
Articlearticle=mapper.queryById(1L);
article.setPublicTime(newDate());
article.setUpdateTime(newDate());
article.setStatus(2);
mapper.updateArticle(article);
}
@Test
publicvoidtestQueryByPage(){
Articlearticle=newArticle();
article.setUserId(1L);
List<Article>list=mapper.queryArticlesByPage(article,10,0);
assertTrue(list.size()>0);
}
}
****
五、总结
本文演示Springboot与JdbcTemplate、JPA以及MyBatis的集成，整体上来说配置都比较简单，以前做过相关配置的同学应该感觉比较明显，Springboot确实在这方面给我们提供了很大的帮助。后续的文章中我们只会使用MyBatis这一种方式来进行数据库的操作，这里还有一点需要说明一下的是，MyBatis的分页查询在这里是手写的，这个分页在正式开发中可以通过插件来完成，不过这个与Springboot没什么关系，所以本文暂时通过这种手动的方式来进行分页的处理。
本文内容总结：
原文链接：https://www.cnblogs.com/paddix/p/8178943.html