day18（JDBC事务&连接池介绍&DBUtils工具介绍&BaseServlet作用）runningto

为了方便演示事务，我们需要创建一个account表：

CREATETABLEaccount(

idINTPRIMARYKEYAUTO_INCREMENT,

NAMEVARCHAR(30),

balanceNUMERIC(10.2)

);

INSERTINTOaccount(NAME,balance)VALUES('zs',100000);

INSERTINTOaccount(NAME,balance)VALUES('ls',100000);

INSERTINTOaccount(NAME,balance)VALUES('ww',100000);

SELECT*FROMaccount;

银行转账！张三转10000块到李四的账户，这其实需要两条SQL语句：

如果在第一条SQL语句执行成功后，在执行第二条SQL语句之前，程序被中断了（可能是抛出了某个异常，也可能是其他什么原因），那么李四的账户没有加上10000元，而张三却减去了10000元。这肯定是不行的！

你现在可能已经知道什么是事务了吧！事务中的多个操作，要么完全成功，要么完全失败！不可能存在成功一半的情况！也就是说给张三的账户减去10000元如果成功了，那么给李四的账户加上10000元的操作也必须是成功的；否则给张三减去10000元，以及给李四加上10000元都是失败的！

面试！

事务的四大特性是：

在默认情况下，MySQL每执行一条SQL语句，都是一个单独的事务。如果需要在一个事务中包含多条SQL语句，那么需要开启事务和结束事务。

在执行SQL语句之前，先执行strattransaction，这就开启了一个事务（事务的起点），然后可以去执行多条SQL语句，最后要结束事务，commit表示提交，即事务中的多条SQL语句所做出的影响会持久化到数据库中。或者rollback，表示回滚，即回滚到事务的起点，之前做的所有操作都被撤消了！

下面演示zs给li转账10000元的示例：

STARTTRANSACTION;

UPDATEaccountSETbalance=balance-10000WHEREid=1;

UPDATEaccountSETbalance=balance+10000WHEREid=2;

ROLLBACK;

COMMIT;

quit;

在jdbc中处理事务，都是通过Connection完成的！

jdbc处理事务的代码格式：

try{

con.setAutoCommit(false);//开启事务…

….

…

con.commit();//try的最后提交事务

}catch(){

con.rollback();//回滚事务

}

publicvoidtransfer(booleanb){

Connectioncon=null;

PreparedStatementpstmt=null;

con=JdbcUtils.getConnection();

//手动提交

con.setAutoCommit(false);

Stringsql="updateaccountsetbalance=balance+whereid=";

pstmt=con.prepareStatement(sql);

//操作

pstmt.setDouble(1,-10000);

pstmt.setInt(2,1);

pstmt.executeUpdate();

//在两个操作中抛出异常

if(b){

thrownewException();

pstmt.setDouble(1,10000);

pstmt.setInt(2,2);

//提交事务

con.commit();

}catch(Exceptione){

//回滚事务

if(con!=null){

con.rollback();

}catch(SQLExceptionex){}

thrownewRuntimeException(e);

}finally{

//关闭

JdbcUtils.close(con,pstmt);

保存点是JDBC3.0的东西！当要求数据库服务器支持保存点方式的回滚。

校验数据库服务器是否支持保存点！

booleanb=con.getMetaData().supportsSavepoints();

保存点的作用是允许事务回滚到指定的保存点位置。在事务中设置好保存点，然后回滚时可以选择回滚到指定的保存点，而不是回滚整个事务！注意，回滚到指定保存点并没有结束事务！！！只有回滚了整个事务才算是结束事务了！

Connection类的设置保存点，以及回滚到指定保存点方法：

/*

*李四对张三说，如果你给我转1W，我就给你转100W。

*==========================================

*

*张三给李四转1W（张三减去1W，李四加上1W）

*设置保存点！

*李四给张三转100W（李四减去100W，张三加上100W）

*查看李四余额为负数，那么回滚到保存点。

*提交事务

*/

@Test

publicvoidfun(){

Stringsql="updateaccountsetbalance=balance+wherename=";

//操作1（张三减去1W）

pstmt.setString(2,"zs");

//操作2（李四加上1W）

pstmt.setString(2,"ls");

//设置保存点

Savepointsp=con.setSavepoint();

//操作3（李四减去100W）

pstmt.setDouble(1,-1000000);

//操作4（张三加上100W）

pstmt.setDouble(1,1000000);

//操作5（查看李四余额）

sql="selectbalancefromaccountwherename=";

pstmt.setString(1,"ls");

ResultSetrs=pstmt.executeQuery();

rs.next();

doublebalance=rs.getDouble(1);

//如果李四余额为负数，那么回滚到指定保存点

if(balance<0){

con.rollback(sp);

System.out.println("张三，你上当了！");

因为并发事务导致的问题大致有5类，其中两类是更新问题，三类是读问题。

脏读

事务1：张三给李四转账100元

事务2：李四查看自己的账户

不可重复读

事务1：酒店查看两次1048号房间状态

事务2：预订1048号房间

对同一记录的两次查询结果不一致！

幻读

事务1：对酒店房间预订记录两次统计

事务2：添加一条预订房间记录

对同一表的两次查询不一致！

不可重复读和幻读的区别：

4个等级的事务隔离级别，在相同数据环境下，使用相同的输入，执行相同的工作，根据不同的隔离级别，可以导致不同的结果。不同事务隔离级别能够解决的数据并发问题的能力是不同的。

1SERIALIZABLE（串行化）

2REPEATABLEREAD（可重复读）（MySQL）

3READCOMMITTED（读已提交数据）（Oracle）

4READUNCOMMITTED（读未提交数据）

MySQL的默认隔离级别为REPEATABLEREAD，这是一个很不错的选择吧！

MySQL的默认隔离级别为Repeatableread，可以通过下面语句查看：

select@@tx_isolation

也可以通过下面语句来设置当前连接的隔离级别：

settransactionisolationlevel[4选1]

con.setTransactionIsolation(intlevel)

参数可选值如下：

事务总结：

池参数（所有池参数都有默认值）：

初始大小：10个

最小空闲连接数：3个

增量：一次创建的最小单位（5个）

最大空闲连接数：12个

最大连接数：20个

四大连接参数

连接池也是使用四大连接参数来完成创建连接对象！

实现的接口

连接池必须实现：javax.sql.DataSource接口！

连接池返回的Connection对象，它的close()方法与众不同！调用它的close()不是关闭，而是把连接归还给池！

用池来管理Connection，这可以重复使用Connection。有了池，所以我们就不用自己来创建Connection，而是通过池来获取Connection对象。当使用完Connection后，调用Connection的close()方法也不会真的关闭Connection，而是把Connection"归还"给池。池就可以再利用这个Connection对象了。

Java为数据库连接池提供了公共的接口：javax.sql.DataSource，各个厂商可以让自己的连接池实现这个接口。这样应用程序可以方便的切换不同厂商的连接池！

分析：ItcastPool需要有一个List，用来保存连接对象。在ItcastPool的构造器中创建5个连接对象放到List中！当用人调用了ItcastPool的getConnection()时，那么就从List拿出一个返回。当List中没有连接可用时，抛出异常。

我们需要对Connection的close()方法进行增强，所以我们需要自定义ItcastConnection类，对Connection进行装饰！即对close()方法进行增强。因为需要在调用close()方法时把连接"归还"给池，所以ItcastConnection类需要拥有池对象的引用，并且池类还要提供"归还"的方法。

ItcastPool.java

publicclassItcastPoolimplementsDataSource{

privatestaticPropertiesprops=newProperties();

privateListlist=newArrayList();

static{

InputStreamin=ItcastPool.class.getClassLoader()

.getResourceAsStream("dbconfig.properties");

props.load(in);

Class.forName(props.getProperty("driverClassName"));

publicItcastPool()throwsSQLException{

for(inti=0;i<5;i++){

Connectioncon=DriverManager.getConnection(

props.getProperty("url"),props.getProperty("username"),

props.getProperty("password"));

ItcastConnectionconWapper=newItcastConnection(con,this);

list.add(conWapper);

publicvoidadd(Connectioncon){

list.add(con);

publicConnectiongetConnection()throwsSQLException{

if(list.size()>0){

returnlist.remove(0);

thrownewSQLException("没连接了");

......

ItcastConnection.java

publicclassItcastConnectionextendsConnectionWrapper{

privateItcastPoolpool;

publicItcastConnection(Connectioncon,ItcastPoolpool){

super(con);

this.pool=pool;

@Override

publicvoidclose()throwsSQLException{

pool.add(this);

DBCP是Apache提供的一款开源免费的数据库连接池！

publicvoidfun1()throwsSQLException{

BasicDataSourceds=newBasicDataSource();

ds.setUsername("root");

ds.setPassword("123");

ds.setUrl("jdbc:mysql://localhost:3306/mydb1");

ds.setDriverClassName("com.mysql.jdbc.Driver");

ds.setMaxActive(20);

ds.setMaxIdle(10);

ds.setInitialSize(10);

ds.setMinIdle(2);

ds.setMaxWait(1000);

Connectioncon=ds.getConnection();

System.out.println(con.getClass().getName());

con.close();

下面是对DBCP的配置介绍：

#基本配置

driverClassName=com.mysql.jdbc.Driver

url=jdbc:mysql://localhost:3306/mydb1

username=root

password=123

#初始化池大小，即一开始池中就会有10个连接对象

默认值为0

initialSize=0

#最大连接数，如果设置maxActive=50时，池中最多可以有50个连接，当然这50个连接中包含被使用的和没被使用的（空闲）

#你是一个包工头，你一共有50个工人，但这50个工人有的当前正在工作，有的正在空闲

#默认值为8，如果设置为非正数，表示没有限制！即无限大

maxActive=8

#最大空闲连接

#当设置maxIdle=30时，你是包工头，你允许最多有20个工人空闲，如果现在有30个空闲工人，那么要开除10个

#默认值为8，如果设置为负数，表示没有限制！即无限大

maxIdle=8

#最小空闲连接

#如果设置minIdel=5时，如果你的工人只有3个空闲，那么你需要再去招2个回来，保证有5个空闲工人

#默认值为0

minIdle=0

#当设置maxWait=5000时，现在你的工作都出去工作了，又来了一个工作，需要一个工人。

#这时就要等待有工人回来，如果等待5000毫秒还没回来，那就抛出异常

#没有工人的原因：最多工人数为50，已经有50个工人了，不能再招了，但50人都出去工作了。

#默认值为-1，表示无限期等待，不会抛出异常。

maxWait=-1

#连接属性

#就是原来放在url后面的参数，可以使用connectionProperties来指定

#如果已经在url后面指定了，那么就不用在这里指定了。

#useServerPrepStmts=true，MySQL开启预编译功能

#cachePrepStmts=true，MySQL开启缓存PreparedStatement功能，

#prepStmtCacheSize=50，缓存PreparedStatement的上限

#prepStmtCacheSqlLimit=300，当SQL模板长度大于300时，就不再缓存它

connectionProperties=useUnicode=true;characterEncoding=UTF8;useServerPrepStmts=true;cachePrepStmts=true;prepStmtCacheSize=50;prepStmtCacheSqlLimit=300

#连接的默认提交方式

#默认值为true

defaultAutoCommit=true

#连接是否为只读连接

#Connection有一对方法：setReadOnly(boolean)和isReadOnly()

#如果是只读连接，那么你只能用这个连接来做查询

#如果两个并发事务，对同一行记录做增、删、改操作，是不是一定要隔离它们啊？

#如果两个并发事务，对同一行记录只做查询操作，那么是不是就不用隔离它们了？

#如果没有指定这个属性值，那么是否为只读连接，这就由驱动自己来决定了。即Connection的实现类自己来决定！

defaultReadOnly=false

#指定事务的事务隔离级别

#可选值：NONE,READ_UNCOMMITTED,READ_COMMITTED,REPEATABLE_READ,SERIALIZABLE

#如果没有指定，那么由驱动中的Connection实现类自己来决定

defaultTransactionIsolation=REPEATABLE_READ

C3P0也是开源免费的连接池！C3P0被很多人看好！

C3P0中池类是：ComboPooledDataSource。

publicvoidfun1()throwsPropertyVetoException,SQLException{

ComboPooledDataSourceds=newComboPooledDataSource();

ds.setJdbcUrl("jdbc:mysql://localhost:3306/mydb1");

ds.setUser("root");

ds.setDriverClass("com.mysql.jdbc.Driver");

ds.setAcquireIncrement(5);

ds.setInitialPoolSize(20);

ds.setMinPoolSize(2);

ds.setMaxPoolSize(50);

System.out.println(con);

配置文件要求：

c3p0也可以指定配置文件，而且配置文件可以是properties，也可骒xml的。当然xml的高级一些了。但是c3p0的配置文件名必须为c3p0-config.xml，并且必须放在类路径下。

jdbc:mysql://localhost:3306/mydb1

com.mysql.jdbc.Driver

root

123

3

10

2

10

c3p0的配置文件中可以配置多个连接信息，可以给每个配置起个名字，这样可以方便的通过配置名称来切换配置信息。上面文件中默认配置为mysql的配置，名为oracle-config的配置也是mysql的配置，呵呵。

publicvoidfun2()throwsPropertyVetoException,SQLException{

ComboPooledDataSourceds=newComboPooledDataSource("orcale-config");

JNDI（JavaNamingandDirectoryInterface），Java命名和目录接口。JNDI的作用就是：在服务器上配置资源，然后通过统一的方式来获取配置的资源。

我们这里要配置的资源当然是连接池了，这样项目中就可以通过统一的方式来获取连接池对象了。

下图是Tomcat文档提供的：

配置JNDI资源需要到元素中配置子元素：

type="org.apache.tomcat.dbcp.dbcp.BasicDataSource"

factory="org.apache.naming.factory.BeanFactory"

username="root"

password="123"

driverClassName="com.mysql.jdbc.Driver"

url="jdbc:mysql://127.0.0.1/mydb1"

maxIdle="3"

maxWait="5000"

maxActive="5"

initialSize="3"/>

type="com.mchange.v2.c3p0.ComboPooledDataSource"

user="root"

classDriver="com.mysql.jdbc.Driver"

jdbcUrl="jdbc:mysql://127.0.0.1/mydb1"

maxPoolSize="20"

minPoolSize="5"

initialPoolSize="10"

acquireIncrement="2"/>

配置资源的目的当然是为了获取资源了。只要你启动了Tomcat，那么就可以在项目中任何类中通过JNDI获取资源的方式来获取资源了。

下图是Tomcat文档提供的，与上面Tomcat文档提供的配置资源是对应的。

获取资源：

Contextcxt=newInitialContext();

DataSourceds=(DataSource)cxt.lookup("java:/comp/env/mydbcp");

ContextenvCxt=(Context)cxt.lookup("java:/comp/env");

DataSourceds=(DataSource)env.lookup("mydbcp");

上面两种方式是相同的效果。

因为已经学习了连接池，那么JdbcUtils的获取连接对象的方法也要修改一下了。

JdbcUtils.java

publicclassJdbcUtils{

privatestaticDataSourcedataSource=newComboPooledDataSource();

publicstaticDataSourcegetDataSource(){

returndataSource;

publicstaticConnectiongetConnection(){

returndataSource.getConnection();

Threadà人类

Runnableà任务类

key

value

thread1

aaa

thread2

bbb

thread3

ccc

ThreadLocal类只有三个方法：

ThreadLocal内部其实是个Map来保存数据。虽然在使用ThreadLocal时只给出了值，没有给出键，其实它内部使用了当前线程做为键。

classMyThreadLocal{

privateMapmap=newHashMap();

publicvoidset(Tvalue){

map.put(Thread.currentThread(),value);

publicvoidremove(){

map.remove(Thread.currentThread());

publicTget(){

returnmap.get(Thread.currentThread());

在开始客户管理系统之前，我们先写一个工具类：BaseServlet。

我们知道，写一个项目可能会出现N多个Servlet，而且一般一个Servlet只有一个方法（doGet或doPost），如果项目大一些，那么Servlet的数量就会很惊人。

为了避免Servlet的"膨胀"，我们写一个BaseServlet。它的作用是让一个Servlet可以处理多种不同的请求。不同的请求调用Servlet的不同方法。我们写好了BaseServlet后，让其他Servlet继承BaseServlet，例如CustomerServlet继承BaseServlet，然后在CustomerServlet中提供add()、update()、delete()等方法，每个方法对应不同的请求。

我们知道，Servlet中处理请求的方法是service()方法，这说明我们需要让service()方法去调用其他方法。例如调用add()、mod()、del()、all()等方法！具体调用哪个方法需要在请求中给出方法名称！然后service()方法通过方法名称来调用指定的方法。

无论是点击超链接，还是提交表单，请求中必须要有method参数，这个参数的值就是要请求的方法名称，这样BaseServlet的service()才能通过方法名称来调用目标方法。例如某个链接如下：

publicclassBaseServletextendsHttpServlet{

*它会根据请求中的m，来决定调用本类的哪个方法

protectedvoidservice(HttpServletRequestreq,HttpServletResponseres)

throwsServletException,IOException{

req.setCharacterEncoding("UTF-8");

res.setContentType("text/html;charset=utf-8");

StringmethodName=req.getParameter("method");//它是一个方法名称

//当没用指定要调用的方法时，那么默认请求的是execute()方法。

if(methodName==null||methodName.isEmpty()){

methodName="execute";

Classc=this.getClass();

//通过方法名称获取方法的反射对象

Methodm=c.getMethod(methodName,HttpServletRequest.class,

HttpServletResponse.class);

//反射方法目标方法，也就是说，如果methodName为add，那么就调用add方法。

Stringresult=(String)m.invoke(this,req,res);

//通过返回值完成请求转发

if(result!=null&&!result.isEmpty()){

req.getRequestDispatcher(result).forward(req,res);

thrownewServletException(e);

DBUtils是ApacheCommons组件中的一员，开源免费！

DBUtils是对JDBC的简单封装，但是它还是被很多公司使用！

DBUtils的Jar包：dbutils.jar

QueryRunner的update()方法可以用来执行insert、update、delete语句。

构造器：QueryRunner();

intupdate(Connectioncon,Stringsql,Object…params)

QueryRunnerqr=newQueryRunner();

Stringsql="insertintouservalues(,,)";

qr.update(JdbcUtils.getConnection(),sql,"u1","zhangSan","123");

还有另一种方式来使用QueryRunner

构造器：QueryRunner(DataSource)

intupdate(Stringsql,Object…params)

这种方式在创建QueryRunner时传递了连接池对象，那么在调用update()方法时就不用再传递Connection了。

publicvoidfun2()throwsSQLException{

QueryRunnerqr=newQueryRunner(JdbcUtils.getDataSource());

qr.update(sql,"u1","zhangSan","123");

我们知道在执行select语句之后得到的是ResultSet，然后我们还需要对ResultSet进行转换，得到最终我们想要的数据。你可以希望把ResultSet的数据放到一个List中，也可能想把数据放到一个Map中，或是一个Bean中。

DBUtils提供了一个接口ResultSetHandler，它就是用来ResultSet转换成目标类型的工具。你可以自己去实现这个接口，把ResultSet转换成你想要的类型。

DBUtils提供了很多个ResultSetHandler接口的实现，这些实现已经基本够用了，我们通常不用自己去实现ResultSet接口了。

Map处理器

Bean处理器

Column处理器

Scalar处理器

QueryRunner的查询方法是：

publicTquery(Stringsql,ResultSetHandlerrh,Object…params)

publicTquery(Connectioncon,Stringsql,ResultSetHandlerrh,Object…params)

query()方法会通过sql语句和params查询出ResultSet，然后通过rh把ResultSet转换成对应的类型再返回。

DataSourceds=JdbcUtils.getDataSource();

QueryRunnerqr=newQueryRunner(ds);

Stringsql="select*fromtab_studentwherenumber=";

Mapmap=qr.query(sql,newMapHandler(),"S_2000");

System.out.println(map);

Stringsql="select*fromtab_student";

List>list=qr.query(sql,newMapListHandler());

for(Mapmap:list){

publicvoidfun3()throwsSQLException{

Studentstu=qr.query(sql,newBeanHandler(Student.class),"S_2000");

System.out.println(stu);

publicvoidfun4()throwsSQLException{

Listlist=qr.query(sql,newBeanListHandler(Student.class));

for(Studentstu:list){

publicvoidfun5()throwsSQLException{

List