微服务架构和实践微服务

SpringBoot整合MyBatis

2018-05-12  本文已影响193人  Coding小聪

数据源配置

这里选择阿里的Druid数据源,Druid性能优秀,同时还提供对应用性能的监控。

首先,在POM文件中加入连接器和数据库的依赖

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.0.4</version>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.1.0</version>
</dependency>

在配置文件application.yml中,进行数据库连接信息和数据源的配置。

spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource # 配置当前要使用的数据源的操作类型
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/test
    username: root
    password: 123456
    filters: stat,wall,log4j                       # Durid监控使用
    dbcp2:                                             # 进行数据库连接池的配置
      min-idle: 5
      initial-size: 5
      max-total: 10
      max-wait-millis: 200                      # 等待连接获取的最大超时时间

此时如果,想要验证数据的配置和连接池的配置是否生效,可以通过在测试类中获取数据库连接进行打印。

@SpringBootTest(classes = StartSpringBootMain.class)
@RunWith(SpringJUnit4ClassRunner.class)
@WebAppConfiguration
public class TestDataSource {
  @Resource
  private DataSource dataSource;
  @Test
  public void testConnection() throws Exception {
    System.out.println(this.dataSource.getConnection());
  }
}

在 mybatis 开发包里面会将 druid的配置的数据库连接池变为所需要的 DataSource 数据源对象。所以运行上面测试代码的前提条件是引入了mybatis-spring-boot-starter依赖。

配置Druid监控

要想进行 Druid 的性能的监控操作,则需要做一些基础配置,例如:你访问的 IP 地址是否是白名单。

@Configuration
public class DruidConfig {
    @Bean
    public ServletRegistrationBean druidServlet() { // 主要实现WEB监控的配置处理
        ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(
                new StatViewServlet(), "/druid/*"); // 现在要进行druid监控的配置处理操作
        servletRegistrationBean.addInitParameter("allow",
                "127.0.0.1,192.168.2.104"); // 白名单
        servletRegistrationBean.addInitParameter("deny", "192.168.28.200"); // 黑名单
        servletRegistrationBean.addInitParameter("loginUsername", "druid"); // 用户名
        servletRegistrationBean.addInitParameter("loginPassword", "druid"); // 密码
        servletRegistrationBean.addInitParameter("resetEnable", "false"); // 是否可以重置数据源
        return servletRegistrationBean ;
    }
    @Bean
    public FilterRegistrationBean filterRegistrationBean() {
        FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean() ;
        filterRegistrationBean.setFilter(new WebStatFilter());
        filterRegistrationBean.addUrlPatterns("/*"); // 所有请求进行监控处理
        filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.css,/druid/*");
        return filterRegistrationBean ;
    }
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource")
    public DataSource druidDataSource() {
        return new DruidDataSource();
    }
}

Druid提供了性能监控的控台,可以通过http://127.0.0.1/druid进行访问。

整合MyBatis

整合MyBatis首先需要引入相应的jar包和配置MyBatis的相关属性

<dependency>
    <groupId>org.mybatis.spring.boot</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
</dependency>

在application.yml文件中,配置Mybatis相关的配置项

mybatis:
  config-location: classpath:mybatis/mybatis.cfg.xml
  type-aliases-package: cn.zgc.springboot.mybatis.pojo # 定义所有操作类的别名所在包
  mapper-locations: mybatis/mapper/**/*.xml

下面通过一个产品(Product)的例子进行说明

在 src/main/resources 目录下建立 mybatis/mybatis.cfg.xml 配置文件

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <!-- 进行Mybatis的相应的环境的属性定义 -->
    <settings>  <!-- 在本项目之中开启二级缓存 -->
        <setting name="cacheEnabled" value="true"/>
    </settings>
</configuration>

建立Product的Bean对象

public class Product {
  private Long id;
  private String name;
  private Long size;

  // ignore get/set method
}

创建ProductMapper接口

@Mapper   //此注解要加上,不然DAO接口和 Mapper 文件无法整合在一起。
public interface ProductMapper {
    List<Product> findAll();

    boolean add(Product product);
}

在src/main/resources/mybatis 下建立有一个 mapper 子目录,然后创建Product的Mapper文件ProductMapper.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.zgc.springboot.mybatis.mapper.ProductMapper">
    <select id="findAll" resultType="Product">
        SELECT * FROM product ;
    </select>

    <insert id="add" parameterType="Product">
        INSERT INTO product(name,size) VALUES (#{name},#{size});
    </insert>
</mapper>

Service和Controller相关的类省略,具体请参考:https://gitee.com/codingXcong/spring-boot-demo/tree/master/springboot-mybatis

Spring事务

在Spring中可以通过@EnableTransactionManagement启用事务。

@SpringBootApplication
@EnableTransactionManagement //启用事务
public class StartSpringBootMain {
    public static void main(String[] args) {
        SpringApplication.run(StartSpringBootMain.class, args);
    }
}

如果想要对某个方式使用事务,可以通过@Transactional注解。

public interface ProductService {

    //@Transactional(readOnly = true)
    @Transactional(propagation = Propagation.REQUIRED,isolation=Isolation.READ_COMMITTED)
    boolean add(Product product);
}

其中propagation属性表示的为事务的传播行为,Spring当中定义了七种传播行为。


事务的传播行为

isolation属性表示设置隔离级别,Spring支持的事务隔离级别如下所示


事务隔离级别
上一篇下一篇

猜你喜欢

热点阅读