事务、连接池、开源数据源(DBCP、C3P0)
事务的概念
事务指逻辑上的一组操作,组成这组操作的各个单元,要么全部成功,要么全部不成功。
例如:A——B转帐,对应于如下两条sql语句
update account set money=money-100 where name=‘a’;
update account set money=money+100 where name=‘b’;
数据库开启事务命令DTL
start transaction 开启事务
Rollback 回滚事务
Commit 提交事务
一、事务
a、数据库中的DTL:Database Transaction Language
开启事务:start transaction
提交事务:commit
回滚事务:rollback
数据库:MySQL,一般情况下,事务是自动开启和关闭的。
手工控制事务:使用DTL
b、JDBC中控制事务的执行
开启事务:start transaction Connection.setAutocommit(false)
提交事务:commit Connection.commit()
回滚事务:rollback Connection.rollback()
c、事务的特性:(理论)
A原子性:比喻处于同一个事务中的多条语句是不可分割的单位
C一致性:比如:A1000 B1000 执行事务前:A+B=2000 执行事务后A+B=2000
I隔离性:事务执行过程中不应该被其他线程的事务所干扰。
D持久性:事务结束后,操作的数据应该被永久性的保存起来(磁盘上)
********************************************************************************************
专题:隔离性(很重要)
前提:多线程并发操作数据库中的数据
不考虑事务隔离性,会出现以下问题:
1、脏读:A线程读取到了B线程未提交的数据
2、不可重复读:A线程读到了B线程提交的更新(update)后的数据
3、虚读:A线程读到了B线程提交的插入(insert)后的数据
a、MySQL控制事务的隔离级别
READ UNCOMMITTED:脏读、不可重复读、虚读都有可能发生
READ COMMITTED:防止脏读的发生,不可重复读、虚读都有可能发生(Oracle默认的级别)
REPEATABLE READ:防止脏读、不可重复读,虚读有可能发生(MySQL默认的级别)
SERIALIZABLE:防止脏读、不可重复读、虚读
MySQL:
查看当前事务的隔离级别:select @@tx_isolation;
更改当前线程事务的隔离级别:set transaction isolation level 四个级别之一;
b、JDBC控制事务的隔离级别
Connection:TRANSACTION_READ_UNCOMMITTED
Connection:TRANSACTION_READ_COMMITTED
Connection:TRANSACTION_REPEATABLE_READ
Connection:TRANSACTION_SERIALIZABLE
Connection.setTransactionIsolation(int level):开启事务之前调用。
conn.setTransactionIsolation(Connection.TRANSACTION_REPEATABLE_READ);
//开启事务
conn.setAutoCommit(false);
二、数据库连接池
1、标准的连接池要实现javax.sql.DataSource接口
2、编程核心:
当用户调用Connection.close()(实际上是调用的数据库驱动中的对应实现方法),把当前用到的连接换回原来的连接池中,已达到复用的目的。
不能去该数据库的驱动的实现。改写已知类的某个或某些方法的原有行为。
解决方案:
a、继承(行不通):MyConnection extends ?(不能与具体数据库有关) com.mysql.jdbc.Connection
b、包装(装饰):
1、编写一个类,实现与被包装类相同的接口 public class MyConnection implements Connection{}
2、定义一个成员变量,引用被包装的对象的实例 private Connection conn;
3、定义构造方法,传入被包装的对象的实例 public MyConnection(Connection conn){this.conn = conn;}
4、对于不需要改变的方法,调用原有对象的对应方法 public void commit(){conn.commit();}
5、对于需要改变的方法,你该就完了。 public void close(){//把连接放回池中}
变化:
1、编写一个类,继承已经实现了被包装对象接口的类
2、定义一个成员变量,引用被包装的对象的实例
3、定义构造方法,传入被包装的对象的实例
4、对于需要改变的方法,覆盖就完了
c、动态代理:
实现拦截功能:方法执行前,方法执行后,方法遇到异常,方法中的finally,从而实现AOP(Aspect-Oriented Programming面向切面)编程
1、基于接口的动态代理:借助JDK中的reflect.Proxy
2、基于子类的动态代理:借助第三方的开源项目。CGLIB
使用前提:被代理对象的类
a、必须是public的,有默认的构造方法
b、不能是final的
三、开源数据源的使用
1、DBCP(常用)
Commons-dbcp.jar:连接池的实现
Commons-pool.jar:连接池实现的依赖库
dbcpconfig.properties配置文件如下:
#连接设置 driverClassName=com.mysql.jdbc.Driver url=jdbc:mysql://localhost:3306/day16 username=root password=sorry #<!-- 初始化连接 --> initialSize=10 #最大连接数量 maxActive=50 #<!-- 最大空闲连接 --> maxIdle=20 #<!-- 最小空闲连接 --> minIdle=5 #<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 --> maxWait=60000 #JDBC驱动建立连接时附带的连接属性属性的格式必须为这样:[属性名=property;] #注意:"user" 与 "password" 两个属性会被明确地传递,因此这里不需要包含他们。 connectionProperties=useUnicode=true;characterEncoding=utf8 #指定由连接池所创建的连接的自动提交(auto-commit)状态。 defaultAutoCommit=true #driver default 指定由连接池所创建的连接的只读(read-only)状态。 #如果没有设置该值,则“setReadOnly”方法将不被调用。(某些驱动并不支持只读模式,如:Informix) defaultReadOnly= #driver default 指定由连接池所创建的连接的事务级别(TransactionIsolation)。 #可用值为下列之一:(详情可见javadoc。)NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE defaultTransactionIsolation=REPEATABLE_READ
import java.io.InputStream; import java.sql.Connection; import java.sql.SQLException; import java.util.Properties; import javax.sql.DataSource; import org.apache.commons.dbcp.BasicDataSourceFactory; public class DBCPUtil { private static DataSource dataSource; static{ try { InputStream inStream = DBCPUtil.class.getClassLoader().getResourceAsStream("dbcpconfig.properties"); Properties props = new Properties(); props.load(inStream); dataSource = BasicDataSourceFactory.createDataSource(props); } catch (Exception e) { throw new ExceptionInInitializerError("初始化数据库配置文件失败"); } } public static Connection getConnection() throws SQLException{ return dataSource.getConnection(); } }
2、C3P0
发行包\lib\全考
c3p0-config.xml配置文件:文件名是固定的写法
<?xml version="1.0" encoding="UTF-8"?> <c3p0-config> <default-config> <property name="driverClass">com.mysql.jdbc.Driver</property> <property name="jdbcUrl">jdbc:mysql:///day16</property> <property name="user">root</property> <property name="password">sorry</property> <property name="initialPoolSize">15</property> <property name="maxPoolSize">20</property> <property name="minPoolSize">5</property> <property name="maxStatements">200</property> </default-config> <!-- <named-config name="intergalactoApp"> <property name="initialPoolSize">10</property> <property name="maxIdleTime">30</property> <property name="maxPoolSize">100</property> <property name="minPoolSize">10</property> <property name="maxStatements">200</property> </named-config> --> </c3p0-config>
import java.sql.Connection; import java.sql.SQLException; import com.mchange.v2.c3p0.ComboPooledDataSource; public class C3P0Util { private static ComboPooledDataSource dataSource = new ComboPooledDataSource(); public static Connection getConnection() throws SQLException{ return dataSource.getConnection(); } }
3、用服务器提供的数据源的配置(具体参考服务器的文档)
以Tomcat为例(用的就是DBCP)
a、拷贝数据库驱动jar到Tomcat\lib目录下
b、在你应用的META-INF目录下建立一个context.xml配置文件
<?xml version="1.0" encoding="UTF-8"?>
<Context>
<!-- 配置一个资源。name=大名字/小名字
auth:Container,说明该资源由容器创建
-->
<Resource name="jdbc/day16" auth="Container" type="javax.sql.DataSource"
maxActive="100" maxIdle="30" maxWait="10000" username="root"
password="sorry" driverClassName="com.mysql.jdbc.Driver"
url="jdbc:mysql://localhost:3306/day16" />
</Context>
c、重新启动Tomcat,服务器就按照配置创建好了数据源,在JNDI容器中。
JNDI:JavaEE技术之一。Java Naming and Directory Interface
(就是一个Map<String,Object>,Map的key是一个String,是一个目录, value就是绑定的对象。 类似Window系统的注册表)
API存在JDK的javax.naming.*包中。
d、在Tomcat管理的web应用中才能使用,不能在main方法中运行,不是同一个虚拟机。
Context initContext = new InitialContext();
DataSource ds = (DataSource)initContext.lookup("java:/comp/env/jdbc/day16");
Connection conn = ds.getConnection();
import java.sql.Connection; import javax.naming.Context; import javax.naming.InitialContext; import javax.sql.DataSource; public class JndiDsTest { //和Tomcat不是一个虚拟机 public static void main(String[] args) throws Exception { Context initContext = new InitialContext(); DataSource ds = (DataSource)initContext.lookup("java:/comp/env/jdbc/day16"); Connection conn = ds.getConnection(); System.out.println(conn); } }
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。