Spring-Mybatis整合学习笔记1
将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&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&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
序列化读
细节:
- oracle只支持了 读提交(默认)和 序列化读
- mysql 都支持了 默认 可重复读
事物并发时的安全问题:- 脏读:一个事务中读到了其他事务中未提交的数据
- 不可重复读:一个事物中多次读取相同的数据行,但是,结果不一致
- 幻读:一个事物中,多次读取同一张表,但是,数据行数不一致;查询室没有某数据,但是操作时,却提示存在此数据
2> propagation=传播性
support = 如果已经有事务,则融入这个事务;如果没事务,以非事务环境运行
required = 如果已经有事务,则融入这个事务;如果没事务,开启自己的事务 (默认值)
3> read-only :读写性
true:只读事物,事物中只出现查询行为
false:读写事物,事物中可以出现curd行为(默认值)
4> rollback-for:会滚是可
- 如果事务中抛出 运行时异常(RuntimeExeception),则自动回滚
- 如果事务中抛出,已检查异常(非运行时异常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整合常用连接池
下一篇: c3p0数据源配置