SpringBoot無廢話入門04:MyBatis整合

1.Parent引入及pom配置java

        首先,若是要支持mybatis,那麼咱們就應該引入mybatis的starter。同時,因爲鏈接自己還須要用jdbc的connetor和鏈接池,因此一併須要引入這些依賴。以下是一個完整的的最簡pom,mysql

<?xml version="1.0" encoding="UTF-8"?>web

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">spring

  <modelVersion>4.0.0</modelVersion>sql

  <packaging>war</packaging>數據庫

  <parent>apache

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

    <artifactId>spring-boot-starter-parent</artifactId>tomcat

    <version>2.1.3.RELEASE</version>session

  </parent>

  <name>testboot01</name>

  <groupId>com.zuikc</groupId>

  <artifactId>testboot01</artifactId>

  <version>1.0-SNAPSHOT</version>

  <dependencies>

      <!--jsp支持, servlet 依賴. -->

      <dependency>

          <groupId>javax.servlet</groupId>

          <artifactId>javax.servlet-api</artifactId>

          <scope>provided</scope>

      </dependency>

      <dependency>

          <groupId>javax.servlet</groupId>

          <artifactId>jstl</artifactId>

      </dependency>

      <!-- tomcat 的支持.-->

      <dependency>

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

          <artifactId>spring-boot-starter-tomcat</artifactId>

      </dependency>

      <dependency>

          <groupId>org.apache.tomcat.embed</groupId>

          <artifactId>tomcat-embed-jasper</artifactId>

          <scope>provided</scope>

      </dependency>

      <dependency>

          <groupId>mysql</groupId>

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

      </dependency>

      <dependency>

          <groupId>org.apache.tomcat</groupId>

          <artifactId>tomcat-dbcp</artifactId>

          <version>7.0.47</version>

      </dependency>

      <dependency>

          <groupId>org.apache.tomcat</groupId>

          <artifactId>tomcat-dbcp</artifactId>

          <version>7.0.47</version>

      </dependency>

      <dependency>

          <groupId>org.mybatis.spring.boot</groupId>

          <artifactId>mybatis-spring-boot-starter</artifactId>

          <version>1.3.2</version>

      </dependency>

    <dependency>

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

      <artifactId>spring-boot-starter-web</artifactId>

    </dependency>

  </dependencies>

  <build>

    <plugins>

      <plugin>

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

        <artifactId>spring-boot-maven-plugin</artifactId>

      </plugin>

    </plugins>

  </build>

</project>

2.配置初始化

        首先咱們須要將數據庫鏈接配置到文件中,好比prop.properties,

jdbc.driver=com.mysql.jdbc.Driver

jdbc.url=jdbc:mysql://localhost:3306/test01?useUnicode=true&characterEncoding=utf8

jdbc.username=root

jdbc.password=root

jdbc.maxActive=2335

jdbc.maxIdel=120

jdbc.maxWait=100

        而後,用java配置的方式將其引入到代碼中,建立DataSourceConfiguration,

package com.zuikc.config;

import org.apache.tomcat.dbcp.dbcp.BasicDataSource;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.context.annotation.PropertySource;

@Configuration

//這個註解導入剛纔增長的jdbc配置文件

@PropertySource("classpath:prop.properties")

public class DataSourceConfiguration {

    @Value("${jdbc.driver}")

    private String driver;

    @Value("${jdbc.url}")

    private String url;

    @Value("${jdbc.username}")

    private String username;

    @Value("${jdbc.password}")

    private String password;

    @Value("${jdbc.maxActive}")

    private int maxActive;

    @Value("${jdbc.maxIdel}")

    private int maxIdel;

    @Value("${jdbc.maxWait}")

    private long maxWait;

    @Bean

    public BasicDataSource dataSource(){

        BasicDataSource dataSource = new BasicDataSource();

        dataSource.setDriverClassName(driver);

        dataSource.setUrl(url);

        dataSource.setUsername(username);

        dataSource.setPassword(password);

        dataSource.setMaxActive(maxActive);

        dataSource.setMaxIdle(maxIdel);

        dataSource.setMaxWait(maxWait);

        dataSource.setValidationQuery("SELECT 1");

        dataSource.setTestOnBorrow(true);

        return dataSource;

    }

}

        接着,增長mybatis配置,

package com.zuikc.config;

import javax.sql.DataSource;

import org.apache.ibatis.session.SqlSessionFactory;

import org.mybatis.spring.SqlSessionFactoryBean;

import org.mybatis.spring.SqlSessionTemplate;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import org.springframework.transaction.PlatformTransactionManager;

import org.springframework.transaction.annotation.EnableTransactionManagement;

import org.springframework.transaction.annotation.TransactionManagementConfigurer;

@Configuration

//加上這個註解,使得支持事務

@EnableTransactionManagement

public class MyBatisConfig implements TransactionManagementConfigurer {

    @Autowired

    private DataSource dataSource;

    @Override

    public PlatformTransactionManager annotationDrivenTransactionManager() {

        return new DataSourceTransactionManager(dataSource);

    }

    @Bean(name = "sqlSessionFactory")

    public SqlSessionFactory sqlSessionFactoryBean() {

        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();

        bean.setDataSource(dataSource);

        try {

            return bean.getObject();

        } catch (Exception e) {

            e.printStackTrace();

            throw new RuntimeException(e);

        }

    }

    @Bean

    public SqlSessionTemplate sqlSessionTemplate(SqlSessionFactory sqlSessionFactory) {

        return new SqlSessionTemplate(sqlSessionFactory);

    }

}

        注意上面的sqlSessionFactory這個bean。

        而後須要配置MyBatis配置文件的路徑,這個配置須要與上面的配置分開來寫,由於它們有着一個前後順序,

package com.zuikc.config;

import org.mybatis.spring.mapper.MapperScannerConfigurer;

import org.springframework.boot.autoconfigure.AutoConfigureAfter;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

@Configuration

// 由於這個對象的掃描,須要在MyBatisConfig的後面注入,因此加上下面的註解

@AutoConfigureAfter(MyBatisConfig.class)

public class MyBatisMapperScannerConfig {

    @Bean

    public MapperScannerConfigurer mapperScannerConfigurer() {

        MapperScannerConfigurer mapperScannerConfigurer = new MapperScannerConfigurer();

        //獲取以前注入的beanName爲sqlSessionFactory的對象

        mapperScannerConfigurer.setSqlSessionFactoryBeanName("sqlSessionFactory");

        //指定xml配置文件的路徑

        mapperScannerConfigurer.setBasePackage("com.zuikc.dao");

        return mapperScannerConfigurer;

    }

}

3.三層架構

        先建立最底層的dao接口,以下:

package com.zuikc.dao;

import java.util.List;

import java.util.Map;

import org.apache.ibatis.annotations.Mapper;

import org.apache.ibatis.annotations.Select;

@Mapper

public interface TestDao {

    @Select("SELECT * FROM tbl_user;")

    public List<Map<String,Object>> find();

}

        接着建立service,

package com.zuikc.service;

import com.zuikc.dao.TestDao;

import org.springframework.stereotype.Service;

import javax.annotation.Resource;

import java.util.List;

import java.util.Map;

@Service

public class TestService {

    @Resource

    TestDao dao;

    public List<Map<String,Object>> find(){

        List<Map<String,Object>> users = dao.find();

        return users;

    }

}

        而後是controller,

package com.zuikc.controller;

import com.zuikc.dao.TestDao;

import com.zuikc.service.TestService;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import javax.annotation.Resource;

import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.List;

import java.util.Map;

@Controller

public class StudentController {

    @Autowired

    TestService service;

    @RequestMapping(value = {"test01"})

    public String view(Map<String, Object> map) {

        List<Map<String,Object>> users = service.find();

        for (Map<String, Object> user : users) {

            for (Map.Entry<String, Object> entry : user.entrySet()) {

                System.out.println("Key = " + entry.getKey() + ", Value = " + entry.getValue());

            }

        }

        System.out.println(users.size());

        map.put("name", "zuikc.com");

        map.put("date", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));

        return "views/test01";

    }

}

        通過上面的建立以後,咱們的代碼結構是這樣的,

        執行之,

        注意了,若是你已經忘記了如何啓動MySQL,那麼,下面就是命令哦:

        sudo bin/mysqld_safe --user=mysql &

4.事務支持

        第一步,導入JDBC依賴,

      <dependency>

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

          <artifactId>spring-boot-starter-jdbc</artifactId>

      </dependency>

        注意,有了這個依賴,SpringBoot會自動注入DataSourceTransactionManager。 

        接着,直接在Service中添加@Transactional註解就能支持事務啦。本文再也不贅述,你們本身嘗試一下吧。

        感謝關注「碼農星球」。本文版權屬於「碼農星球」。咱們提供諮詢和培訓服務,關於本文有任何困惑,請關注並聯系咱們。

相關文章
相關標籤/搜索