事务、连接池、开源数据源(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);
	}

}


事务、连接池、开源数据源(DBCP、C3P0),古老的榕树,5-wow.com

郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。