c3p0联接死锁

c3p0连接死锁

      笔主今天遇到了c3p0连接池死锁的问题，c3p0发生死锁大多跟配置文件有关。如果c3p0连接池设置过小。当连接池满时。由于没有对各个线程设置优先级。导致后面的线程一直等待连接。造成死锁。

       解决办法:把max_statements设置为0。

       说点题外话：当两个用户（或会话）具有不同对象的锁，并且每个用户需要另一个对象的锁时，就会出现死锁。每个用户都等待另一个用户释放他的锁。当两个连接陷入死锁时，Microsoft？ SQL Server？ 会进行检测。其中一个连接被选作死锁牺牲品。该连接的事务回滚，同时应用程序收到错误。

使用分布式事务时，也可能发生死锁或阻塞。任何基于锁的并发系统都不可避免地具有可能在某些情况下发生阻塞的特征。当一个连接控制了一个锁，而另一个连接需要冲突的锁类型时，将发生阻塞。其结果是强制第二个连接等待，或在第一个连接上阻塞。
　　术语"连接"是指数据库的单个登录会话。每个连接都作为系统进程 ID （SPID） 出现。尽管每一个 SPID 一般都不是单独的进程上下文，但这里常常用来指一个进程。更确切的说，每个 SPID 都是由服务器资源和数据结构（为 给定客户单个连接的请求提供服务）组成。单个客户应用程序可能有一个或多个连接。就 SQL Server 而言，从单个客户机上的单个客户应用程序来的多个连接和从多个客户应用程序或多个客户机来的多个连接是没有区别的。不管是来自同一应用程序还是来自两台不 同客户机上单独的应用程序，一个连接都可以阻塞另一个连接。）

import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public final class ConnectionManager {

    private ComboPooledDataSource ds;
    private ConnectionManager connManger;

    private ConnectionManager() throws PropertyVetoException {
        ds = new ComboPooledDataSource();
        // 设置c3p0连接池的数据库驱动类
        ds.setDriverClass("com.mysql.jdbc.Driver");
        // 设置c3p0连接池数据库连接URL
        ds.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/school");
        // 设置c3p0连接池数据库用户名
        ds.setUser("root");
        // 设置c3p0连接池数据库密码
        ds.setPassword("root");
        // 当连接池中的连接用完时，C3P0一次性创建新连接的数目2
        ds.setAcquireIncrement(2);
        // acquireRetryAttempts：定义在从数据库获取新连接失败后重复尝试获取的次数，默认为30秒
        ds.setAcquireRetryAttempts(30);
        // 两次连接中间隔时间，单位毫秒，默认为1000;
        ds.setAcquireRetryDelay(3000);
        // 连接关闭时默认将所有未提交的操作回滚。默认为false；
        ds.setAutoCommitOnClose(false);
        /**
         * C3P0将建一张名为Test的空表，并使用其自带的查询语句进行测试。如果定义了这个参数，那么属性preferredTestQuery将被忽略。
         * 你不能在这张Test表上进行任何操作，它将中为C3P0测试所用，默认为null；
         */
        // ds.setAutomaticTestTable("teacher");
        /**
         * 获取连接失败将会引起所有等待获取连接的线程抛出异常。但是数据源仍有效保留， 并在下次调 用getConnection()的时候继续尝试获取连接。如果设为true，
         * 那么在尝试获取连接失败后该数据源将申明已断开并永久关闭。默认为 false；
         */
        ds.setBreakAfterAcquireFailure(false);
        /**
         * 当连接池用完时客户端调用getConnection()后等待获取新连接的时间，超时后将抛出SQLException， 如设为0则无限期等待。单位毫秒，默认为0；
         */
        ds.setCheckoutTimeout(1000);
        /**
         * 通过实现ConnectionTester或QueryConnectionTester的类来测试连接，类名需设置为全限定名。 默认为
         * com.mchange.v2.C3P0.impl.DefaultConnectionTester；
         */
        ds.setConnectionTesterClassName(new DefaultConnectionTester().getClass().getName());
        // hook方法，在对相关资源做操作的时候，''他所操作的connection是真实的数据库连接，而不是proxy过的connection''
        // ds.setConnectionCustomizerClassName("");
        // 连接池数据源
        // ds.setConnectionPoolDataSource(ConnectionPoolDataSource 对象);
        // idleConnectionTestPeriod：隔多少秒检查所有连接池中的空闲连接，默认为0表示不检查
        ds.setIdleConnectionTestPeriod(10);
        // 初始化时创建的连接数，应在minPoolSize与maxPoolSize之间取值。默认为3；
        ds.setInitialPoolSize(5);
        // 最大空闲时间，超过空闲时间的连接将被丢弃。为0或负数则永不丢弃。默认为0；
        ds.setMaxIdleTime(3);
        // 连接池中保留的最大连接数。默认为15；
        ds.setMaxPoolSize(100);
        /**
         * JDBC的标准参数，用以控制数据源内加载的PreparedStatement数量。 但由于预缓存的Statement属 于单个Connection而不是整个连接池。
         * 所以设置这个参数需要考虑到多方面的因素，如果maxStatements与 maxStatementsPerConnection均为0， 则缓存被关闭。默认为0；
         */
        ds.setMaxStatements(1000);
        // 连接池内单个连接所拥有的最大缓存Statement数。默认为0；
        ds.setMaxStatementsPerConnection(100);
        // C3P0是异步操作的，缓慢的JDBC操作通过帮助进程完成。扩展这些操作可以有效的提升性能，通过多线程实现多个操作同时被执行。默认为3；
        ds.setNumHelperThreads(5);
        /**
         * preferredTestQuery：定义所有连接测试都执行的测试语句。 在使用连接测试的情况下这个参数能显著提高测试速度。测试的表必须在初始数据源的时候就存在。默认为null； propertyCycle：
         * 用户修改系统配置参数执行前最多等待的秒数。默认为300； testConnectionOnCheckout：因性能消耗大请只在需要的时候使用它。 如果设为true那么在每个connection提交的时候都
         * 将校验其有效性。 建议使用idleConnectionTestPeriod或automaticTestTable 等方法来提升连接测试的性能。默认为false；
         * testConnectionOnCheckin：如果设为true那么在取得连接的同时将校验连接的有效性。默认为false。
         * 
         */
    }

    public static void main(String[] args) {

        try {
            ConnectionManager connManger = new ConnectionManager();
            Connection conn = connManger.ds.getConnection();
            Statement st = conn.createStatement();
            String sql = "select * from teacher";
            ResultSet rs = st.executeQuery(sql);
            while (rs.next()) {
                System.out.println(rs.getInt("id") + "," + rs.getString("name"));
            }
        }
        catch (PropertyVetoException e) {
            e.printStackTrace();
        }
        catch (SQLException e) {
            e.printStackTrace();
        }

    }
}

参考文献： ****  c3p0实力和参数详解