天天看點

Spring整合

作者:tianlongbabu

環境準備

步驟1:準備資料庫表

Mybatis是來操作資料庫表,是以先建立一個資料庫及表

create database spring_db character set utf8;
   use spring_db;

   create table tbl_account(
  id int primary key auto_increment,
  name varchar(35),
  money double

        );           

步驟2:建立項目導入jar包

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

<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/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.itheima</groupId>
    <artifactId>spring_16_spring_junit</artifactId>
    <version>1.0-SNAPSHOT</version>

    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.2.10.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.1.16</version>
        </dependency>

        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.5.6</version>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.47</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>5.2.10.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis-spring</artifactId>
            <version>1.3.0</version>
        </dependency>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>test</scope>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>5.2.10.RELEASE</version>
        </dependency>

    </dependencies>
</project>

           

步驟3:根據表建立模型類

package com.itheima.domain;

import java.io.Serializable;

public class Account implements Serializable {

    private Integer id;
    private String name;
    private Double money;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Double getMoney() {
        return money;
    }

    public void setMoney(Double money) {
        this.money = money;
    }

    @Override
    public String toString() {
        return "Account{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", money=" + money +
                '}';
    }
}
           

步驟4:建立Dao接口

package com.itheima.dao;

import com.itheima.domain.Account;
import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update;

import java.util.List;

public interface AccountDao {

    @Insert("insert into tbl_account(name,money)values(#{name},#{money})")
    void save(Account account);

    @Delete("delete from tbl_account where id = #{id} ")
    void delete(Integer id);

    @Update("update tbl_account set name = #{name} , money = #{money} where id = #{id} ")
    void update(Account account);

    @Select("select * from tbl_account")
    List<Account> findAll();

    @Select("select * from tbl_account where id = #{id} ")
    Account findById(Integer id);
}           

步驟5:建立Service接口和實作類

package com.itheima.service;

import com.itheima.domain.Account;

import java.util.List;

public interface AccountService {

    void save(Account account);

    void delete(Integer id);

    void update(Account account);

    List<Account> findAll();

    Account findById(Integer id);

}

package com.itheima.service.impl;

import com.itheima.dao.AccountDao;
import com.itheima.domain.Account;
import com.itheima.service.AccountService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;
@Service
public class AccountServiceImpl implements AccountService {

    @Autowired
    private AccountDao accountDao;

    public void save(Account account) {
        accountDao.save(account);
    }

    public void update(Account account){
        accountDao.update(account);
    }

    public void delete(Integer id) {
        accountDao.delete(id);
    }

    public Account findById(Integer id) {
        return accountDao.findById(id);
    }

    public List<Account> findAll() {
        return accountDao.findAll();
    }
}
           

步驟6:添加jdbc.properties檔案

resources目錄下添加,用于配置資料庫連接配接四要素

jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/spring_db?useSSL=false
jdbc.username=root
jdbc.password=caicai123           

useSSL:關閉MySQL的SSL連接配接

步驟7:添加Mybatis核心配置檔案

SqlMapConfg.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>
    <properties resource="jdbc.properties"></properties>
    <typeAliases>
        <package name="com.itheima.domain"/>
    </typeAliases>
    <environments default="mysql">
        <environment id="mysql">
            <transactionManager type="JDBC"></transactionManager>
            <dataSource type="POOLED">
                <property name="driver" value="${jdbc.driver}"></property>
                <property name="url" value="${jdbc.url}"></property>
                <property name="username" value="${jdbc.username}"></property>
                <property name="password" value="${jdbc.password}"></property>
            </dataSource>
        </environment>
    </environments>
    <mappers>
        <package name="com.itheima.dao"></package>
    </mappers>
</configuration>           

步驟8:編寫應用程式

package com;
import com.itheima.dao.AccountDao;
import com.itheima.domain.Account;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import java.io.IOException;
import java.io.InputStream;

public class App {
    public static void main(String[] args) throws IOException {
        // 1. 建立SqlSessionFactoryBuilder對象
        SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
        // 2. 加載SqlMapConfig.xml配置檔案
        InputStream inputStream = Resources.getResourceAsStream("SqlMapConfig.xml.bak");
        // 3. 建立SqlSessionFactory對象
        SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(inputStream);
        // 4. 擷取SqlSession
        SqlSession sqlSession = sqlSessionFactory.openSession();
        // 5. 執行SqlSession對象執行查詢,擷取結果User
        AccountDao accountDao = sqlSession.getMapper(AccountDao.class);

        Account ac = accountDao.findById(2);
        System.out.println(ac);

        // 6. 釋放資源
        sqlSession.close();
    }
}
           

步驟9:運作程式

Spring整合

整合思路分析

  • Mybatis程式核心對象分析
Spring整合

從圖中可以擷取到,真正需要交給Spring管理的是SqlSessionFactory

  • 整合Mybatis,就是将Mybatis用到的内容交給Spring管理,分析下配置檔案
Spring整合

說明:

  • 第一行讀取外部properties配置檔案,Spring有提供具體的解決方案@PropertySource ,需 要交給Spring
  • 第二行起别名包掃描,為SqlSessionFactory服務的,需要交給Spring
  • 第三行主要用于做連接配接池,Spring之前我們已經整合了Druid連接配接池,這塊也需要交給
  • Spring
  • 前面三行一起都是為了建立SqlSession對象用的,那麼用Spring管理SqlSession對象嗎?
  • 回憶下SqlSession是由SqlSessionFactory建立出來的,是以隻需要将SqlSessionFactory交給Spring管理即可。
  • 第四行是Mapper接口和映射檔案[如果使用注解就沒有該映射檔案],這個是在擷取到
  • SqlSession以後執行具體操作的時候用,是以它和SqlSessionFactory建立的時機都不在 同一個時間,可能需要單獨管理。

Spring整合Mybatis

前面我們已經分析了Spring與Mybatis的整合,大體需要做兩件事, 第一件事是:Spring要管理MyBatis中的SqlSessionFactory

第二件事是:Spring要管理Mapper接口的掃描 具體該如何實作,具體的步驟為:

步驟1:項目中導入整合需要的jar包

<dependency>

    <!--Spring操作資料庫需要該jar包-->

           <groupId>org.springframework</groupId>

           <artifactId>spring-jdbc</artifactId>

           <version>5.2.10.RELEASE</version>
</dependency>
<dependency>

    <!--

        Spring與Mybatis整合的jar包

        這個jar包mybatis在前面,是Mybatis提供的

        -->

           <groupId>org.mybatis</groupId>

           <artifactId>mybatis-spring</artifactId>

           <version>1.3.0</version>
</dependency>           

步驟2:建立Spring的主配置類

package com.itheima.config;

import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
import org.springframework.context.annotation.PropertySource;

@Configuration
@ComponentScan("com.itheima")
//@PropertySource:加載類路徑jdbc.properties檔案
@PropertySource("classpath:jdbc.properties")
@Import({JdbcConfig.class,MybatisConfig.class})
public class SpringConfig {
}
           

步驟3:建立資料源的配置類

在配置類中完成資料源的建立

package com.itheima.config;

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.sql.DataSource;


public class JdbcConfig {
    @Value("${jdbc.driver}")
    private String driver;
    @Value("${jdbc.url}")
    private String url;
    @Value("${jdbc.username}")
    private String userName;
    @Value("${jdbc.password}")
    private String password;

    @Bean
    public DataSource dataSource(){
        DruidDataSource ds = new DruidDataSource();
        ds.setDriverClassName(driver);
        ds.setUrl(url);
        ds.setUsername(userName);
        ds.setPassword(password);
        return ds;
    }
}           

步驟4:建立Mybatis配置類并配置SqlSessionFactory

package com.itheima.config;

import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.mapper.MapperScannerConfigurer;
import org.springframework.context.annotation.Bean;

import javax.sql.DataSource;

public class MybatisConfig {
    //定義bean,SqlSessionFactoryBean,用于産生SqlSessionFactory對象
    @Bean
    public SqlSessionFactoryBean sqlSessionFactory(DataSource dataSource){
        SqlSessionFactoryBean ssfb = new SqlSessionFactoryBean();
        ssfb.setTypeAliasesPackage("com.itheima.domain");
        ssfb.setDataSource(dataSource);
        return ssfb;
    }
    //定義bean,傳回MapperScannerConfigurer對象
    @Bean
    public MapperScannerConfigurer mapperScannerConfigurer(){
        MapperScannerConfigurer msc = new MapperScannerConfigurer();
        msc.setBasePackage("com.itheima.dao");
        return msc;
    }
}



           

說明:

  • 使用SqlSessionFactoryBean封裝SqlSessionFactory需要的環境資訊
Spring整合
  • SqlSessionFactoryBean是前面我們講解FactoryBean的一個子類,在該類中将SqlSessionFactory的建立進行了封裝,簡化對象的建立,我們隻需要将其需要的内容設定 即可。
  • 方法中有一個參數為dataSource,目前Spring容器中已經建立了Druid資料源,類型剛好是DataSource類型,此時在初始化SqlSessionFactoryBean這個對象的時候,發現需要使用DataSource對象,而容器中剛好有這麼一個對象,就自動加載了DruidDataSource對象。
  • 使用MapperScannerConfigurer加載Dao接口,建立代理對象儲存到IOC容器中
Spring整合
  • 這個MapperScannerConfigurer對象也是MyBatis提供的專用于整合的jar包中的類,用來 處理原始配置檔案中的mappers相關配置,加載資料層的Mapper接口類
  • MapperScannerConfigurer有一個核心屬性basePackage,就是用來設定所掃描的包路徑

步驟5:編寫運作類

package com;

import com.itheima.config.SpringConfig;
import com.itheima.domain.Account;
import com.itheima.service.AccountService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

public class App2 {
    public static void main(String[] args) {
        ApplicationContext ctx = new AnnotationConfigApplicationContext(SpringConfig.class);

        AccountService accountService = ctx.getBean(AccountService.class);

        Account ac = accountService.findById(1);
        System.out.println(ac);
    }
}



           

步驟6:運作程式

Spring整合

支援Spring與Mybatis的整合就已經完成了,其中主要用到的兩個類分别是:

  • SqlSessionFactoryBean
  • MapperScannerConfigurer

Spring整合Junit

整合Junit步驟

步驟1:引入依賴

<dependency>

    <groupId>junit</groupId>

           <artifactId>junit</artifactId>

           <version>4.12</version>

           <scope>test</scope>
</dependency>



<dependency>

    <groupId>org.springframework</groupId>

           <artifactId>spring-test</artifactId>

           <version>5.2.10.RELEASE</version>
</dependency>           

步驟2:編寫測試類

在test\java下建立一個AccountServiceTest,這個名字任意

package com.itheima.service;

import com.itheima.config.SpringConfig;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
//設定類運作器
@RunWith(SpringJUnit4ClassRunner.class)
//設定Spring環境對應的配置類
@ContextConfiguration(classes = SpringConfig.class)
public class AccountServiceTest {
    //支援自動裝配注入bean
    @Autowired
    private AccountService accountService;

    @Test
    public void testFindById(){
        System.out.println(accountService.findById(1));

    }

    @Test
    public void testFindAll(){
        System.out.println(accountService.findAll());
    }


}
           

注意:

  • 單元測試,如果測試的是注解配置類,則使用@ContextConfiguration(classes = 配置 類.class)
  • 單元測試,如果測試的是配置檔案,則使用@ContextConfiguration(locations={配置檔案 名,...})
  • Junit運作後是基于Spring環境運作的,是以Spring提供了一個專用的類運作器,這個務必要設 置,這個類運作器就在Spring的測試專用包中提供的,導入的坐标就是這個東西
  • SpringJUnit4ClassRunner
  • 上面兩個配置都是固定格式,當需要測試哪個bean時,使用自動裝配加載對應的對象,下面的工 作就和以前做Junit單元測試完全一樣了