springboot配置数据库？如何使用Springboot操作mysql数据库

其实springboot配置数据库的问题并不复杂，但是又很多的朋友都不太了解如何使用Springboot操作mysql数据库，因此呢，今天小编就来为大家分享springboot配置数据库的一些知识，希望可以帮助到大家，下面我们一起来看看这个问题的分析吧！

15《Spring Boot 入门教程》多数据源与分布式事务

一个项目中使用多个数据源的需求，我们在日常工作中时常会遇到。

以商城系统为例，有一个 MySQL的数据库负责存储交易数据。公司还有一套 ERP企业信息化管理系统，要求订单信息同步录入 ERP数据库，便于公司统一管理，而该 ERP系统采用的数据库为 SQL Server。

此时，就可以在 Spring Boot项目中配置多个数据源。另外，使用多数据源后，需要采用分布式事务来保持数据的完整性。

本小节我们使用 Spring Boot开发一个商城系统的订单生成功能，订单信息同时进入 MySQL与 SQL Server数据库。

首先创建 MySQL数据库 shop，并新建订单表 order，表结构如下：

order表结构

然后创建 SQL Server数据库 erpshop，并新建订单表 erp_order，表结构如下。注意 id是自增长的唯一标识，out_id是对应订单在 MySQL数据库中的唯一标识，以便在两个库中比对订单。

erp_order结构

接下来，我们开始实现 Spring Boot后端项目，数据持久层采用 MyBatis框架，同时访问两个数据源。

Spring Boot版本选择 2.2.5，Group为 com.imooc， Artifact为 spring-boot-multidb，生成项目后导入 Eclipse开发环境。

我们引入热部署依赖、 Web依赖、数据库访问相关依赖及测试相关依赖，具体如下：

实例：

由于我们要同时访问两个数据库，所以需要在配置文件中添加两个数据源的配置信息。注意配置多数据源时， url配置需要使用 spring.datasource.db1.jdbc-url=xxx的形式。

实例：

多个数据源的情况下，我们需要通过配置类，将数据源注册为组件放入 Spring容器中。

实例：

通过这个配置类， Spring容器中就有两个数据源组件，这两个组件分别采用 spring.datasource.db1和 spring.datasource.db2开头的配置信息。所以通过这两个组件，就能分别操作 MySQL数据源 1和 SQL Sever数据源 2。

多数据源情况下， MyBatis中的关键组件 SqlSessionFactory和 SqlSessionTemplate也需要单独配置，我们需要为两个数据源分别配置一套组件。

实例：

通过上面的配置类， com.imooc.springbootmultidb.mapper1包中的 DAO数据访问接口会自动调用 sqlSessionTemplate1组件实现具体数据库操作，而 sqlSessionTemplate1操作的数据源已经通过配置类设置为 db1。同时， DAO数据访问接口对应的映射文件已经指定到 classpath:mapper1/目录去寻找。这样数据源– DAO数据访问接口–映射文件三者的对应关系就建立起来了。

数据源 2的配置方法是一样的， com.imooc.springbootmultidb.mapper2包中的 DAO数据访问接口会自动调用 sqlSessionTemplate2组件，其操作的数据源即为 db2，其对应的映射文件指定到 classpath:mapper2/目录去寻找。

实例：

数据访问接口的位置已经在配置类指定，首先在 com.imooc.springbootmultidb.mapper1创建 OrderDao，操作的是数据源 1中的 order表。

实例：

然后在 com.imooc.springbootmultidb.mapper2创建 ErpOrderDao，操作的是数据源 2中的 erporder表。

实例：

这两个接口中使用的数据对象比较简单，代码如下：

实例：

分别针对 OrderDao、 ErpOrderDao编写对应的映射文件，然后按照配置类指定的位置，两个文件分别放到 resources/mapper1和 resources/mapper2目录下。

实例：

实例：

数据操作接口与对应的映射文件均已编写完毕，现在可以通过测试类进行多数据源测试了，我们在测试类中同时向两个库插入记录。

实例：

运行测试方法后，两个数据库表中均新增数据成功，这样我们就成功的使用 Spring Boot同时操作了两个数据源。

采用多数据源之后，事务的实现方式也随之发生变化。当某个数据源操作出现异常时，该数据源和其他数据源的事务都需要回滚。这种涉及多个数据源的事务，称为分布式事务，接来下我们就来具体实现一下。

在 pom.xml引入 Atomikos事务管理器相关的依赖项， Atomikos是一个开源的事务管理器，支持分布式事务。

实例：

需要将默认的数据源更换为支持分布式事务的数据源， MySQL对应的数据源为 MysqlXADataSource， SQL Server对应的数据源为 SQLServerXADataSource。

实例：

继续修改 DataSourceConfig类，在其中配置分布式事务管理器组件。当项目中使用事务时，会通过配置的分布式事务管理器管理分布式事务操作。

实例：

在测试方法上添加@Transactional开启事务，然后在两个数据源操作中间模拟抛出异常。

实例：

此时运行测试类，可以发现数据源 1的事务已回滚，验证成功！

在开发 Spring Boot项目时，如果默认配置满足不了我们的需求，可以通过手工配置组件实现我们需要的功能。这些组件可能是各个公司提供的，我们根据相应文档，为其配置各个属性即可。

如何使用Springboot操作mysql数据库

软硬件环境macOS Sierra

java 1.8.0_65

maven 3.5.0

idea 2017.1.5

前言前面一篇<>已经搭建好了spring boot的开发环境并且完成了第一个Hello world程序，本文紧接着上篇的内容，开始数据库相关的知识点。

工程相关配置pom.xml在dependencies标签下增加依赖，一个是spring data jpa，另一个是mysql

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-data-jpa</artifactId></dependency><dependency>

<groupId>mysql</groupId>

<artifactId>mysql-connector-java</artifactId></dependency>

application.properties在这个配置文件中需要写上mysql的驱动、服务器地址、端口、数据库名称、用户名、密码等信息。

spring.datasource.dbcp2.driver-class-name=com.mysql.jdbc.Driverspring.datasource.url=jdbc:mysql://127.0.0.1:3306/dbvcms

spring.datasource.username=root

spring.datasource.password=djstava

spring.jpa.hibernate.ddl-auto=update

spring.jpa.show-sql=true其中spring.jpa.hibernate.ddl-auto=update表示操作数据库时，所有的操作都是更新操作，这里还可以取值create、create-drop等值

spring data jpaspring data jpa操作mysql数据库非常简单，简单到什么程度？根本不需要你创建任何表以及表的各个字段。这个有点像ORM(对象关系映射)。眼见为实，下面就看看具体实现步骤。

创建实体类这里的实体类是指欲操作对象，包含它的各种属性，对应到数据中的各个字段。

LiveChannel.java

package com.xugaoxiang;import org.springframework.beans.factory.annotation.Autowired;import javax.persistence.Entity;import javax.persistence.Id;/**

* Created by djstava on 10/09/2017.

*/@Entitypublic class LiveChannel{

@Id

@Autowired

private Integer id;//频道名称中文

private String name_chn;//频道名称英文

private String name_eng;//频道url

private String url;//频道是否需要播放广告

private Boolean hasAds; public String getName_chn(){ return name_chn;

} public void setName_chn(String name_chn){ this.name_chn= name_chn;

} public String getName_eng(){ return name_eng;

} public void setName_eng(String name_eng){ this.name_eng= name_eng;

} public String getUrl(){ return url;

} public void setUrl(String url){ this.url= url;

} public Boolean getHasAds(){ return hasAds;

} public void setHasAds(Boolean hasAds){ this.hasAds= hasAds;

}

}上面实体类包含直播频道的一些信息。

接口实现创建LiveChannelRepository.java,继承自JpaRepository,其中的Interger表示的是id的数据类型

package com.xugaoxiang;

import org.springframework.data.jpa.repository.JpaRepository;/**

* Created by djstava on 10/09/2017.

*/public interface LiveChannelRepository extends JpaRepository<LiveChannel,Integer>{}操作数据库创建LiveController,这里设计了一个RestfulAPI，/live，返回的是数据库中所以的直播列表。

package com.xugaoxiang;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;import java.util.List;/**

* Created by djstava on 10/09/2017.

*/@RestControllerpublic class LiveController{

public LiveController(){

}@Autowired

private LiveChannelRepository liveChannelRepository;@GetMapping(value="/live") public List<LiveChannel> getLiveChannel(){ return liveChannelRepository.findAll();

}

}创建数据库如上配置信息所示，创建数据库dbvcms

这里我们是没有去创建表结构的，启动工程的话，jpa会自动帮你把表创建好，各个字段的信息就来自于文件LiveChannel.java

为了方便查询，我们添加2条记录，如下所示

测试一切准备就绪，启动项目，在浏览器中输入

http://localhost:8080/live

springboot+quartz持久化到数据库各表含义

1、去quartz官网下载quartz2.2.2版本的压缩包，quartz下载，注意：quartz2.3.0版本的在docs目录下没有发现dbtable目录（存放生成数据库表的sql文件的目录）。

2、执行创建数据库表的sql文件，我使用的是mysql数据库。

生成的表结构

3、在springboot项目中配置quartz。

3.1、两种方式配置quartz，

3.1.1、第一种是使用自定义的quartz.properties,这是简单配置，如果有其他配置可以参考，quartz.properties配置详情

org.quartz.jobStore.useProperties:true

#org.quartz.scheduler.instanceName: quartzScheduler

#org.quartz.scheduler.instanceId= AUTO

org.quartz.threadPool.class= org.quartz.simpl.SimpleThreadPool

org.quartz.threadPool.threadCount= 15

org.quartz.threadPool.threadPriority: 5

org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true

org.quartz.jobStore.class= org.quartz.impl.jdbcjobstore.JobStoreTX

org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate

org.quartz.jobStore.isClustered= false

#org.quartz.jobStore.clusterCheckinInterval=20000

org.quartz.jobStore.tablePrefix= qrtz_

org.quartz.jobStore.misfireThreshold= 60000

org.quartz.jobStore.maxMisfiresToHandleAtATime= 20

org.quartz.scheduler.rmi.export: false

org.quartz.scheduler.rmi.proxy: false

org.quartz.scheduler.wrapJobExecutionInUserTransaction: false

登录后复制



3.1.2、使用配置文件配置springboot中的SchedulerFactoryBean。

@Configuration

public class SchedulerConfig implements SchedulerFactoryBeanCustomizer{

@Autowired

private DataSource dataSource;

@Override

public void customize(SchedulerFactoryBean schedulerFactoryBean){

schedulerFactoryBean.setStartupDelay(10);

schedulerFactoryBean.setOverwriteExistingJobs(true);

schedulerFactoryBean.setDataSource(dataSource);

ClassPathResource resource= new ClassPathResource("quartz.properties");

Properties properties= new Properties();

InputStream in= null;

try{

in= resource.getInputStream();

BufferedReader bf= new BufferedReader(new InputStreamReader(in,"UTF-8"));

properties.load(bf);

schedulerFactoryBean.setQuartzProperties(properties);

} catch(IOException e){

e.printStackTrace();

}

}

}

登录后复制



3.2.1、第二种方式是在application.properties文件中的配置，application.properties文件中的spring.quartz.properties.加上quartz.properties中的键值对，效果与quartz.properties类似。

spring.quartz.properties.org.quartz.jobStore.tablePrefix= qrtz_

spring.quartz.properties.org.quartz.threadPool.threadCount= 10

登录后复制

项目中配置org.quartz.jobStore.tablePrefix= qrtz_，这个配置是默认查询数据库中表的前缀，默认是QRTZ_,以下sql中通过rpt方法组装一条新的sql，替换掉{0},{1}，如果没有明确声明就会使用默认值 org.quartz.jobStore.tablePrefix= QRTZ_，org.quartz.scheduler.instanceName: quartzScheduler。

如果进行简单的定时任务，可以使用springboot中默认的quartz配置。

3.2.2自定义配置springboot中的SchedulerFactoryBean。

@Configuration

public class SchedulerConfig implements SchedulerFactoryBeanCustomizer{

@Autowired

private DataSource dataSource;

@Override

public void customize(SchedulerFactoryBean schedulerFactoryBean){

schedulerFactoryBean.setStartupDelay(10);

schedulerFactoryBean.setOverwriteExistingJobs(true);

schedulerFactoryBean.setDataSource(dataSource);

}

}

登录后复制



4、新建Job

public class TestJob implements Job{

@Override

public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException{

System.out.println(System.nanoTime());

}

}

登录后复制

5、数据库中新增job任务脚本，com.example.quartzdemo.job.TestJob是我本地的测试Job，需要修改成你自己Job类。

INSERT INTO `qrtz_job_details`(`SCHED_NAME`, `JOB_NAME`, `JOB_GROUP`, `DESCRIPTION`, `JOB_CLASS_NAME`, `IS_DURABLE`, `IS_NONCONCURRENT`, `IS_UPDATE_DATA`, `REQUESTS_RECOVERY`, `JOB_DATA`) VALUES('quartzScheduler','test2Job','testGroup', NULL,'com.example.quartzdemo.job.TestJob','1','0','0','0', NULL);

INSERT INTO `qrtz_triggers`(`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`, `JOB_NAME`, `JOB_GROUP`, `DESCRIPTION`, `NEXT_FIRE_TIME`, `PREV_FIRE_TIME`, `PRIORITY`, `TRIGGER_STATE`, `TRIGGER_TYPE`, `START_TIME`, `END_TIME`, `CALENDAR_NAME`, `MISFIRE_INSTR`, `JOB_DATA`) VALUES('quartzScheduler','testTrigger2','testTriggerGroup','test2Job','testGroup', NULL,'1554122914000','1554122913000','5','ACQUIRED','CRON','1554039857000','0', NULL,'0', NULL);

INSERT INTO `qrtz_cron_triggers`(`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`, `CRON_EXPRESSION`, `TIME_ZONE_ID`) VALUES('quartzScheduler','testTrigger2','testTriggerGroup','0/1****?','Asia/Shanghai');

登录后复制

6、启动项目，查看控制台打印的日志，成功

关于springboot配置数据库和如何使用Springboot操作mysql数据库的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。