springboot数据库配置(如何使用Springboot操作mysql数据库)
老铁们,大家好,相信还有很多朋友对于springboot数据库配置和如何使用Springboot操作mysql数据库的相关问题不太懂,没关系,今天就由我来为大家分享分享springboot数据库配置以及如何使用Springboot操作mysql数据库的问题,文章篇幅可能偏长,希望可以帮助到大家,下面一起来看看吧!
SpringBoot整合MyBatisPlus配置动态数据源
MybatisPlus特性
快速开始
初始化测试数据表:
父工程依赖
该工程用于依赖管理,pom如下:
创建MyBaitsPlus工程
依赖如下:
properties配置
在这里配置数据库连接,以及数据连接池与mybatisplus的配置等
常规增删改查实现
创建实体类:
该lombok插件省去getset方法。
创建UserMapper接口,并且实现BaseMapper<User>这里我们指定实体类为user可直接使用接口中的方法。
UserMapper.xml,如下:
执行SQL:
在SpringBoot中使用MybatisPlus分页需要注入Bean,并且在启动类上使用@MapperScan("com.simple.spring.boot.mapper")扫描mapper文件路径如下:
使用MyBatisPlus可以为我们减少很多很多的代码,不过需要编写实体类,有失必有得。
配置动态数据源
dynamic-datasource-spring-boot-starter是一个基于springboot的快速集成多数据源的启动器。
优势
网上关于动态数据源的切换的文档有很多,核心只有两种。
如果你的数据源较少,场景不复杂,选择以上任意一种都可以。如果你需要更多特性,请尝试本动态数据源。
劣势
不能使用多数据源事务(同一个数据源下能使用事务),网上其他方案也都不能提供。
如果你需要使用到分布式事务,那么你的架构应该到了微服务化的时候了。
如果呼声强烈,项目达到800 star,作者考虑集成分布式事务。
PS:如果您只是几个数据库但是有强烈的需求分布式事务,建议还是使用传统方式自己构建多套环境集成atomic这类,网上百度很多。
约定
建议
强烈建议在主从模式下遵循普遍的规则,以便他人能更轻易理解你的代码。
主数据库建议只执行 INSERT UPDATE DELETE操作。
从数据库建议只执行 SELECT操作。
快速开始
加入依赖:
注释掉原来的数据库配置,加入:
使用@DS切换数据源。
@DS可以注解在方法上和类上,同时存在方法注解优先于类上注解。
注解在service实现或mapper接口方法上,但强烈不建议同时在service和mapper注解。(可能会有问题)
如果不加入主键则使用默认数据源。
DruidDataSourceAutoConfigure会注入一个DataSourceWrapper,其会在原生的spring.datasource下找url,username,password等。而我们动态数据源的配置路径是变化的,所以需要排除:
或者在类上排除:
然后更换properties配置信息:
本篇代码案例地址:
https://github.com/450255266/open-doubi
作者:SimpleWu
出处:https://www.cnblogs.com/SimpleWu/p/10930388.html
如何使用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
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项目时,如果默认配置满足不了我们的需求,可以通过手工配置组件实现我们需要的功能。这些组件可能是各个公司提供的,我们根据相应文档,为其配置各个属性即可。
END,本文到此结束,如果可以帮助到大家,还望关注本站哦!