欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Spring-Mybatis整合学习笔记1

程序员文章站 2022-05-24 12:29:13
...

将Model层管理在工厂中,势必要将Service和DAO的对象纳入工厂,而Service和DAO中还依赖着Mybatis的相关封装功能,所以,只有将Mybatis的相关功能组件也纳入工厂,才可以让Service和DAO正常运行

需要纳入工厂的Mybatis的相关功能组件有:

  • DataSource 负责管理数据库连接
  • SqlSessionFactory Mybatis使用的核心组件
  • MapperScannerConfigurer 负责创建DAO实现(Mapper)

1.DataSource

数据源,即连接池
作用:减少请求执行过程中,创建数据库连接的时间消耗,提高执行性能
常见连接池:dbcp,c3p0,druid

首先需要导入相应的依赖

<!-- druid依赖 -->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.1.12</version>
</dependency>

<!-- dbcp依赖 -->
<dependency>
    <groupId>commons-dbcp</groupId>
    <artifactId>commons-dbcp</artifactId>
    <version>1.4</version>
</dependency>

<!-- c3p0依赖 -->
<dependency>
    <groupId>com.mchange</groupId>
    <artifactId>c3p0</artifactId>
    <version>0.9.5.2</version>
</dependency>

<!-- Spring-jdbc(会传递tx),context-supper,aspects -->
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-jdbc</artifactId>
    <version>4.3.6.RELEASE</version>
</dependency>
<!-- spring+mybatis集成依赖 -->
<dependency>
    <groupId>org.mybatis</groupId>
    <artifactId>mybatis-spring</artifactId>
    <version>1.3.1</version>
</dependency>

不同连接池对应不同的连接池配置
dbcp连接池:

<!-- 连接池:dbcp -->
<bean id="dbcp_pool" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
    <!-- 基本参数 -->
    <property name="url" value="jdbc:mysql://localhost:3306/db1?useUnicode=true&amp;characterEncoding=utf8"/>
    <property name="username" value="root"></property>
    <property name="password" value="111111"></property>
    <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
    <!-- 详细参数 -->
    <!-- 连接池的最大连接对象 数量 -->
    <property name="maxActive" value="3"></property>
    <!-- 最少要空闲 1 个连接对象 -->
    <property name="minIdle" value="1"></property>
    <!-- 初始化连接池  要创建1个连接对象 -->
    <property name="initialSize" value="1"></property>
    <!-- 当向连接池索要连接时,如果没有空闲连接,最大等待的时长:毫秒 -->
    <property name="maxWait" value="3000"></property>
</bean>

c3p0连接池对应的配置:

<bean id="c3p0" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
        <property name="user" value="root"/>
        <property name="password" value="111111"/>
        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/db04?useUnicode=true&amp;characterEncoding=utf8"/>
        <property name="driverClass" value="com.mysql.jdbc.Driver"/>
        <!-- 详细参数 -->
        <!-- 连接池的最大连接对象 数量 -->
        <property name="maxPoolSize" value="3"></property>
        <!-- 最少连接数 -->
        <property name="minPoolSize" value="1"></property>
        <!-- 初始化连接池  要创建1个连接对象 -->
        <property name="initialPoolSize" value="1"></property>
        <!-- 当向连接池索要连接时,如果没有空闲连接,最大等待的时长:毫秒 -->
        <property name="checkoutTimeout" value="3000"></property>
    </bean>

也可以将配置文写在一个单独的properties文件中,然后在配置文件中导入properties文件

 <!-- 导入外部参数文件 -->
    <context:property-placeholder location="classpath:db.properties"/>

    <!-- 连接池:druid -->
    <bean id="druid" class="com.alibaba.druid.pool.DruidDataSource" init-method="init"
          destroy-method="close">
        <!-- 基本属性 url、user、password -->
        <property name="url" value="${druid.url}"/>
        <property name="username" value="${druid.username}"/>
        <property name="password" value="${druid.password}"/>

        <!-- 配置初始化大小、最小、最大 -->
        <property name="initialSize" value="10"/>
        <property name="minIdle" value="1"/>
        <property name="maxActive" value="${druid.maxActive}"/>

        <!-- 配置获取连接等待超时的时间 -->
        <property name="maxWait" value="3000"/>

        <!-- 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒 -->
        <property name="timeBetweenEvictionRunsMillis" value="60000"/>

        <!-- 配置一个连接在池中最小空闲的时间,单位是毫秒 -->
        <property name="minEvictableIdleTimeMillis" value="300000"/>

        <property name="validationQuery" value="SELECT 'x'"/>
        <property name="testWhileIdle" value="true"/>
        <property name="testOnBorrow" value="false"/>
        <property name="testOnReturn" value="false"/>
    </bean>

2. SqlSessionFactoryBean

这是一个工厂bean,用于生产SqlSessionFactory(内容相当于之前的mybatis的配置文件)
依赖点:
1. dataSource 数据库连接池
2. dao映射文件文职
3. 别名

分页插件需要导入的依赖:

	<!-- 分页 -->
    <dependency>
      <groupId>com.github.pagehelper</groupId>
      <artifactId>pagehelper</artifactId>
      <version>RELEASE</version>
    </dependency>
 <bean id="sqlSessionFactory04" class="org.mybatis.spring.SqlSessionFactoryBean">
        <!--<property name="configLocation" value="classpath:configuration.xml"/>-->
        <!-- 连接池 -->
        <property name="dataSource" ref="druid"/>
        <!-- mapper文件
             如果和dao接口在同包且同名,则如**入可以省略
         -->
        <!--<property name="mapperLocations" value="classpath:com/qianfeng/dao/*.xml"/>-->
        <!-- 别名 -->
        <property name="typeAliasesPackage" value="com.qf.domain"/>
        <!-- 分页插件 -->
        <property name="plugins">
            <list>
                <bean class="com.github.pagehelper.PageInterceptor">
                    <!--<property name="properties">
                        <props>
                            <prop key="reasonable">true</prop>
                        </props>
                    </property>-->
                    <property name="properties">
                        <value>
                            reasonable=true
                        </value>
                    </property>
                </bean>
            </list>
        </property>
    </bean>

3. MapperScannerConfigurer

<!-- mapperScannerConfigurer
		生产DAO实现类的对象,纳入工厂管理
		行为:
			1. 扫描所有DAO接口,去构建DAO实现
			2. 将DAO实现纳入工厂,且DAO实现对象在工厂中的id是:“首字母小写的-接口的类名” 比如:UserDAO=userDAO
-->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <!-- 如果当前工厂中 只有一个SqlSessionFactory,则此项注入可以省略 -->
        <!--<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory04"/>-->
        <!-- DAO接口位置 -->
        <!--<property name="basePackage" value="com.qianfeng.dao,com.qianfeng2.dao2"/>-->
        <property name="basePackage" value="com.qianfeng.dao"/>
    </bean>

测试如下:

之前在配置文件中设置最大连接数是3,这是测试如果超过最大连接会出现什么异常

ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
SqlSessionFactory factory = (SqlSessionFactory)context.getBean("sqlSessionFactory");
//获取SqlSession,其中会需要一个Connection
SqlSession session1 = factory.openSession();
session1.getConnection();
SqlSession session2 = factory.openSession();
session2.getConnection();
SqlSession session3 = factory.openSession();
session3.getConnection();
SqlSession session4 = factory.openSession();
session4.getConnection();
System.out.println("test----------");

这里测试的是整个后的dao的功能是否能够正常运行

ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
//获取DAO对象
UserDAO ud = (UserDAO)context.getBean("userDAO");
List<User> users = ud.queryAll();
for(User user:users){
    System.out.println(user);
}
ud.insertUser(new User());//注意:此时事务是自动提交的

4. 事物控制

4.1 DataSourceTransactionManager

事务管理器,其中持有DataSource,可以控制事物功能

<!-- 1.引入事物管理器,其中依赖DataSource,借以获得连接,进而控制事物逻辑 -->
<bean id="tx" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="druid_pool"></property>
</bean>

注意:DataSourceTransactionManager和SqlSessionFactoryBean要注入同一个DataSource的bean,佛则事物控制失败。

4.2 进一步控制

基于事物管理器,进一步定制,生成额外功能:Advice。
此Advice可以切入任何需要事物的方法,通过事物管理器为方法控制事物
此时需要在最上面的beans中修改为:

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       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.xsd
                           http://www.springframework.org/schema/tx
                           http://www.springframework.org/schema/tx/spring-tx.xsd">
</beans>
<tx:advice id="txManager" transaction-manager="tx">
	<tx:attributes>
		<!-- 如果 此事务管理可能切入此方法,则可以为此方法,单独定制事务属性 -->
		<!-- 以User结尾的方法
			<tx:method name="*User" rollback-for="Exception" isolation="DEFAULT"    
              	propagation="REQUIRED" read-only="false"/> 
		-->
        <!-- 以save开头的方法 -->
        <tx:method name="save*" rollback-for="Exception"/>
        <!-- 以query开头的方法 -->
        <tx:method name="query*" propagation="SUPPORTS"/>
        <!-- 剩余所有方法 -->
        <tx:method name="*"/>
    </tx:attributes>
</tx:advice>

4.3 编织

将事物管理的Advice切入需要事物的业务方法中

<aop:config>
	<aop:pointcut expression="execution(* com.service.UserServiceImpl.*(..))" id="pc"/>
    <!-- 组织切面 -->
    <aop:advisor advice-ref="txManager" pointcut-ref="pc"/>
</aop:config>

4.4 事物属性补充

1>isolation = 隔离级别隔离级别由近到远,则并发性降低,安全性提高

  • default(默认值==采用数据库的默认设置)
  • read-uncommited 读取未提交
  • read-commited 读取提交
  • repeatable-read 可重复读
  • serialized-read 序列化读
    细节:
  1. oracle只支持了 读提交(默认)和 序列化读
  2. mysql 都支持了 默认 可重复读
    事物并发时的安全问题:
  3. 脏读:一个事务中读到了其他事务中未提交的数据
  4. 不可重复读:一个事物中多次读取相同的数据行,但是,结果不一致
  5. 幻读:一个事物中,多次读取同一张表,但是,数据行数不一致;查询室没有某数据,但是操作时,却提示存在此数据

2> propagation=传播性
support = 如果已经有事务,则融入这个事务;如果没事务,以非事务环境运行
required = 如果已经有事务,则融入这个事务;如果没事务,开启自己的事务 (默认值)

3> read-only :读写性
true:只读事物,事物中只出现查询行为
false:读写事物,事物中可以出现curd行为(默认值)

4> rollback-for:会滚是可

  1. 如果事务中抛出 运行时异常(RuntimeExeception),则自动回滚
  2. 如果事务中抛出,已检查异常(非运行时异常Exception),不自动回滚,而是默认提交事务
    rollback-for=“SQLException”
    rollback-for=“Exception”

5. 更新丢失

5.1 概述

多事务并发,且存在多个事务更新相同数据时。

t_user

id name age

1 zhj 17

事务1: age+1

1> select age from t_user where id=1;

age=17;

3> update t_user set age = 18 where id=1;

commit;

age=18;

事务2:age+2

2> select age from t_user where id=1;

age=17;

4> update t_user set age = 19 where id=1;

commit;

age=19;

5.2 悲观锁 : for update

t_user

id name age

1 zhj 17

事务1: age+1

1> select age from t_user where id=1 for update;

age=17;

2> update t_user set age = 18 where id=1;

commit;

age=18;

事务2:age+2

3> select age from t_user where id=1 for update;

age=18;

4> update t_user set age = 20 where id=1;

commit;

age=20;

5.3 乐观锁 : version

t_user

id name age version

1 zhj 17 0

事务1: age+1

1> select age,version from t_user where id=1;

age=17; version=0

3> update t_user set age = 18,version=1 where id=1 and version=0;

commit;

age=18; version=1;

事务2:age+2

2> select age,version from t_user where id=1;

age=17; version=0

4> update t_user set age = 19,version=1 where id=1 and version=0;

commit;

未更新到任何行,重试即可

相关标签: spring整合持久层