首页 文章资讯内容详情

Spring Boot实战:数据库操作

2026-06-01 4 花语

本文内容纲要:

上篇文章中已经通过一个简单的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)NOTNULLDEFAULT0, `type`int(11)NOTNULL, `user_id`bigint(20)NOTNULLDEFAULT0, `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:Noqualifyingbeanoftypecom.pandy.blog.dao.ArticleDaoavailable: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:Noqualifyingbeanoftypecom.pandy.blog.dao.ArticleRepositoryavailable: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