（六）mybatis-spring集成完整版

mybatis-spring集成完整版

一、项目整体

1. mybatis接口层、mapper层
2. Service层
3. Test调用测试

二、自动生成代码-mybatis generator

　　主要修改：

　　　　接口、mapper、实体类的包结构

　　　　需要生成的数据库表

　　生成的包目录结构：

                            

三、配置mybatis-config.xml

1. 配置数据源：安装derby，使用网络模式连接
2. 映射器
3. 事务管理器、别名、插件之类
4. 加级联，mapper.xml和实体类
5. 配置setting懒加载
6. 详细配置见--九、mybatis-config.xml

四、整合spring，配置applicationContext.xml

1. 配置数据源
2. 配置sqlSessionFactory：DataSource、引入mybatis-config.xml
3. 自动加载映射文件
4. 配置自动扫描接口
5. 开启注解
6. 详细配置见--九、applicationContext.xml（33-89行）

　　【注】此处使用多数据源配置，详见下篇

五、配置注解方式（自动创建bean）

1. 启动aop注解
2. service实现类上添加@service，并声明private mapper接口（添加@Autowired）
3. 测试类上声明service接口（添加@Autowired）
4. applicationContext.xml配置（16-21行）

User为例：

　　接口类：

@Component("USERMAPPER")　　//配置自动生成的bean的名字
public interface UserMapper {
    。。。
}

　　service实现类

@Service("USERSERVICEIMP")
public class UserServiceImpl implements UserService{
    @Autowired
    private UserMapper userMapper;
    //...
}

　　test类

public class UserTest extends SpringTestCase{
    @Autowired
    private UserService userService;
    //...
}

　　SpringTestCase类（此类是加载applicationContext.xml文件，可直接写个初始化方法启动加载）

import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@ContextConfiguration(locations={"classpath:applicationContext.xml"})
@RunWith(SpringJUnit4ClassRunner.class)
public class SpringTestCase extends AbstractJUnit4SpringContextTests{

}

六、配置事务

　　Xml添加事务管理器配置，开启事务注解（详细配置见applicationContext.xml    91-95行）

　　在需要添加事务的方法或类上添加注解：

　　@Transactional(value="transactionManager",propagation=Propagation.REQUIRES_NEW,isolation=Isolation.READ_COMMITTED)

　　//事务名、传播方式、隔离级别

七、配置ehcache

1. ApplicationContext.xml:（1）添加cache配置；（2）引入ehcache.xml；（3）开启cache注解；（详细配置见applicationContext.xml  23-31行）
2. ehcache.xml:配置自定义缓存（需要配置属性）（见 九、ehcache.xml）
3. 添加cache注解：

　　　　@Cacheable 属性，value、key和condition

　　　　@CachePut  属性，value、key和condition检查相同key的缓存元素

　　　　@CacheEvict 属性value、key、condition、allEntries和beforeInvocation清除缓存元素

　　【注】实体类需要序列化，否则写缓存出错

事务+cache运用

@Service("USERSERVICEIMP")
public class UserServiceImpl implements UserService{
    @Autowired
    private UserMapper userMapper;

    @Transactional(value="transactionManager",propagation=Propagation.REQUIRES_NEW,isolation=Isolation.READ_COMMITTED)
    public void Transaction(){
        User user=new User();
        user.setId(14);
        user.setAccount("admin");
        user.setName("管理员");
        user.setPassword("123456");
        user.setRoleId(1);
        int i=userMapper.insert(user);
        User user1=new User();
        user1.setId(14);
        user1.setAccount("admin");
        user1.setName("管理员");
        user1.setPassword("123456");
        user1.setRoleId(2);
        int j=userMapper.insert(user1);
        System.out.println(i+"--"+j);
    }
    
    @Cacheable(value="sampleCache",key="#id")
    public User selectByPrimaryKey(Integer id) {
        User user=userMapper.selectByPrimaryKey(id);
        System.out.println(user);
        return user;
    }

    @Override
    @CacheEvict(value="sampleCache",key="#id",allEntries=true,beforeInvocation=true)
    public int updateByPrimaryKeySelective(User record) {
        // TODO Auto-generated method stub
        int i=userMapper.updateByPrimaryKeySelective(record);
        return i;
    }

}

八、配置log4j、junit4

见 九、配置文件

九、配置文件

　　applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:p="http://www.springframework.org/schema/p"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:cache="http://www.springframework.org/schema/cache"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.3.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.3.xsd
        http://www.springframework.org/schema/cache 
        http://www.springframework.org/schema/cache/spring-cache-4.2.xsd">
    
    <!-- 启动spring注解 -->
    <context:annotation-config/>
    <!-- 扫描注解所在的包 -->
    <context:component-scan base-package="com.example"/>
    <!-- 启动aop注解 -->
    <aop:aspectj-autoproxy proxy-target-class="true"/> 
       
       <!-- cache配置 -->
    <cache:annotation-driven cache-manager="cacheManager"/>
    <!-- 声明cachemanager -->
    <bean id="cacheManager" class="org.springframework.cache.ehcache.EhCacheCacheManager">
        <property name="cacheManager" ref="ehcache"></property>
    </bean>
    <bean id="ehcache" class="org.springframework.cache.ehcache.EhCacheManagerFactoryBean">
        <property name="configLocation" value="classpath:ehcache.xml"></property>
    </bean>
       
       <!-- 引入属性文件 -->
    <context:property-placeholder location="classpath:jdbc.properties"/>

     <!-- 配置数据源master -->
     <bean id="dataSourceMaster" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">   
        <property name="driverClassName" value="${driver}"/>
        <property name="url" value="${url}" />  
        <!-- 初始化连接大小 -->
        <property name="initialSize" value="0" />  
       <!-- 连接池最大使用连接数量 -->
        <property name="maxActive" value="20" />  
        <!-- 连接池最小空闲 -->
        <property name="minIdle" value="1" />  
        <!-- 连接池最大空闲 -->
        <property name="maxIdle" value="20" />  
        <!-- 获取连接最大等待时间 -->
        <property name="maxWait" value="60000" />  
    </bean>  
    <!-- 配置数据源master -->
     <bean id="dataSourceSlave" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">   
        <property name="driverClassName" value="${driver}"/>
        <property name="url" value="${url_slave}" />  
        <!-- 初始化连接大小 -->
        <property name="initialSize" value="0" />  
       <!-- 连接池最大使用连接数量 -->
        <property name="maxActive" value="20" />  
        <!-- 连接池最小空闲 -->
        <property name="minIdle" value="0" />  
        <!-- 连接池最大空闲 -->
        <property name="maxIdle" value="20" />  
        <!-- 获取连接最大等待时间 -->
        <property name="maxWait" value="60000" />  
    </bean>  
     <bean id="dataSource" class="com.example.util.ThreadLocalRountingDataSource">
         <property name="targetDataSources">
             <map key-type="com.example.enums.DataSources">
                 <entry key="MASTER" value-ref="dataSourceMaster" />
                 <entry key="SLAVE" value-ref="dataSourceSlave"/>
             </map>
         </property>
         <property name="defaultTargetDataSource" ref="dataSourceMaster"></property>
        
    </bean> 
    
    <!-- 配置SQLSessionFactory -->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource"/>  
        <property name="configLocation" value="classpath:mybatis-config.xml"></property> 
        <!-- 加载映射文件 -->
        <property name="mapperLocations" value="classpath*:/com/example/dao/*Mapper.xml"></property>  
    </bean>
    
    <!-- 接口方式 -->
    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="com.example.dao"></property>
        <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>
    </bean> 
  
    <!--  配置jdbc事务管理器，完成数据的完整性和一致性 -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>

</beans>

　　jdbc.properties

driver=org.apache.derby.jdbc.ClientDriver
url=jdbc:derby://localhost:1527/E:/my/derby/mydb
url_slave=jdbc:derby:E://shiny/DdlUtils-test/mydb

　　mybatis.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>
      <settings>
          <!-- 开启延迟加载 -->
          <setting name="lazyLoadingEnabled" value="true"/>
          <!-- 每种属性按需加载 -->
          <setting name="aggressiveLazyLoading" value="false"/>
      </settings>

  </configuration>

　　ehcache.xml

<?xml version="1.0" encoding="UTF-8"?>
<ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
 xsi:noNamespaceSchemaLocation="http://ehcache.org/ehcache.xsd"  
 updateCheck="false"> 
 
    <!-- 指定一个文件目录，当EhCache把数据写到硬盘上时，将把数据写到这个文件目录下 -->
    <diskStore path="java.io.tempdir"/>

    <!-- 设定缓存的默认数据过期策略 -->
    <defaultCache
            maxElementsInMemory="10000"   
            eternal="false"     
            overflowToDisk="true"
            timeToIdleSeconds="10"
            timeToLiveSeconds="20"
            diskPersistent="false"
            diskExpiryThreadIntervalSeconds="120"/>
            
    <cache name="sampleCache" maxElementsInMemory="1000" eternal="false" overflowToDisk="true" diskSpoolBufferSizeMB="20" 
        timeToIdleSeconds="1"
        timeToLiveSeconds="2" memoryStoreEvictionPolicy="LFU"/>
    <cache name="Test" maxElementsInMemory="1" eternal="false" overflowToDisk="true" timeToIdleSeconds="1" timeToLiveSeconds="2"
        diskPersistent="false" diskExpiryThreadIntervalSeconds="1" memoryStoreEvictionPolicy="LFU">
  
    </cache>

</ehcache>

　　log4j.properties

log4j.rootLogger=DEBUG, stdout
log4j.logger.org.mybatis=DEBUG
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p %d %C: %m%n