修改

81041

2020-01-09 854ce7ca4fa5447d38038c6ece853093f271202f

修改

 Device_Manage/src/com/fgkj/db/DBUtil.java

@@ -1,170 +1,171 @@
package com.fgkj.db;



import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;





import com.mchange.v2.c3p0.ComboPooledDataSource;



public class DBUtil {

    private static ComboPooledDataSource mysql_ds = new ComboPooledDataSource();

    private static String classDriver="com.mysql.jdbc.Driver";

    //private static String burl="jdbc:mysql://192.168.0.34:5306/";

    //private static String username="website";

    //private static String password="amtb3737";

	
	
    private static String username="root";

    private static String password="lmx8688139";

    //private static String url="jdbc:mysql://49.234.20.113:3360/db_user";

    //private static String url="jdbc:mysql://123.207.82.239:3360/db_user";

    //private static String url="jdbc:mysql://192.168.0.34:3360/db_user";

    private static String url="jdbc:mysql://127.0.0.1:3360/db_user";

    /*private static String username="root";

    private static String password="123456";*/

	
	
    private static int conncount_max = 500;

    private static int conncount_min=2;

    private static int MaxStatements = 0;

    private static int MaxIdleTime=60;

    private static int InitialPoolSize=2;

	
    static{

        try {

            //Thread.sleep(1000*60);

            mysql_ds.setDriverClass(classDriver);

            mysql_ds.setUser(username);

            mysql_ds.setPassword(password);

            mysql_ds.setMaxPoolSize(conncount_max);

            mysql_ds.setMinPoolSize(conncount_min);

            //mysql_ds.setIdleConnectionTestPeriod(60);

            mysql_ds.setJdbcUrl(url);

			
            // 设置连接池中的最大Statements数量！  
            mysql_ds.setMaxStatements(MaxStatements); 
			
            // 设置连接池的最大空闲时间！  
            mysql_ds.setMaxIdleTime(MaxIdleTime); 
            // 设置初始连接池的大小！  
            mysql_ds.setInitialPoolSize(InitialPoolSize);

            mysql_ds.setIdleConnectionTestPeriod(60);

            //mysql_ds.setPreferredTestQuery("SELECT 1");

            //mysql_ds.setIdleConnectionTestPeriod(1800);

			
            //mysql_ds.setMaxIdleTime(25000);

            //mysql_ds.setAcquireRetryDelay(100);

			 
            //mysql_ds.setBreakAfterAcquireFailure(false);

			
            //当连接池用完时客户端调用getConnection()后等待获取新连接的时间，超时后将抛出SQLException，如设为0则无限期等待。单位毫秒，默认为0

            //mysql_ds.setCheckoutTimeout(10000);

			
            //因性能消耗大请只在需要的时候使用它。如果设为true那么在每个connection提交的

            //时候都将校验其有效性。建议使用idleConnectionTestPeriod或automaticTestTable

            //等方法来提升连接测试的性能。Default: false

            //mysql_ds.setTestConnectionOnCheckin(false);

			
            //如果设置为true,每次从池中取一个连接，将做一下测试，使用automaticTestTable 或者 preferredTestQuery,做一条查询语句.看看连接好不好用，不好用，就关闭它，重新从池中拿一个.

            //mysql_ds.setTestConnectionOnCheckout(true);

            //System.out.println("11111111111111111111111111");

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

	
	
    public static Connection getConn(){

        /*//System.out.println(DBUtil.getUrl());

        Connection conn=null;

        try {

            Class.forName(classDriver);

            conn=DriverManager.getConnection(url+databaseName, username, password);

        } catch (ClassNotFoundException e) {

            e.printStackTrace();

        } catch (SQLException e) {

        }*/

        Connection conn = null;

        try {

            conn = mysql_ds.getConnection();

        } catch (SQLException e) {

            e.printStackTrace();

        }

        return conn;

    }

    //获取当前连接数

    public static void getConnections(){

        try {

            //System.out.println("最大连接数: "+mysql_ds.getMaxPoolSize());// 最大连接数

            //System.out.println("最小连接数: "+mysql_ds.getMinPoolSize());// 最小连接数

            System.out.println("正在使用连接数: "+mysql_ds.getNumBusyConnections());// 正在使用连接数

            System.out.println("空闲连接数: "+mysql_ds.getNumIdleConnections());// 空闲连接数

            //System.out.println("总连接数: "+mysql_ds.getNumConnections());// 总连接数

        } catch (SQLException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

       
    }

    //设置IP地址

    public static void     setUrl(String ip) {

        DBUtil.url = "jdbc:mysql://"+ip+":5306";

        //System.out.println(DBUtil.url);

    }

   
    public static String getUrl() {

        return url;

    }

    //关闭资源

    public static void close(ResultSet rs,Statement stat,Connection conn){

        try {

            if(rs != null)

                rs.close();

			
        } catch (SQLException e) {

            e.printStackTrace();

        }

        try {

            if(stat != null)

                stat.close();

        } catch (SQLException e) {

            e.printStackTrace();

        }

        try {

            if(conn != null){

                conn.close();				
            }

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

	
    /**

     * 初始化连接池

     */

    public static void initPool(){

        close(null, null, getConn());

    }

	
    public static void main(String[] args){

        //System.out.println("start...");

        //System.out.println(getConn());

        //System.out.println("end...");

        Connection conn=DBUtil.getConn();

        DBUtil.getConnections();

        DBUtil.close(null, null, conn);

        while(true){

            DBUtil.getConnections();

            try {

                Thread.sleep(1000);

            } catch (InterruptedException e) {

                // TODO Auto-generated catch block

                e.printStackTrace();

            }

        }

		
		
    }

}

package com.fgkj.db;

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


import com.mchange.v2.c3p0.ComboPooledDataSource;

public class DBUtil {
    private static ComboPooledDataSource mysql_ds = new ComboPooledDataSource();
    private static String classDriver="com.mysql.jdbc.Driver";
    //private static String burl="jdbc:mysql://192.168.0.34:5306/";
    //private static String username="website";
    //private static String password="amtb3737";
	
	
    private static String username="root";
    private static String password="lmx8688139";
    //private static String url="jdbc:mysql://49.234.20.113:3360/db_user";
    //private static String url="jdbc:mysql://123.207.82.239:3360/db_user";
    //private static String url="jdbc:mysql://192.168.0.34:3360/db_user";
    //private static String url="jdbc:mysql://127.0.0.1:3360/db_user";
    private static String url="jdbc:mysql://118.89.139.230:3360/db_user";
    /*private static String username="root";
    private static String password="123456";*/
	
	
    private static int conncount_max = 500;
    private static int conncount_min=2;
    private static int MaxStatements = 0;
    private static int MaxIdleTime=60;
    private static int InitialPoolSize=2;
	
    static{
        try {
            //Thread.sleep(1000*60);
            mysql_ds.setDriverClass(classDriver);
            mysql_ds.setUser(username);
            mysql_ds.setPassword(password);
            mysql_ds.setMaxPoolSize(conncount_max);
            mysql_ds.setMinPoolSize(conncount_min);
            //mysql_ds.setIdleConnectionTestPeriod(60);
            mysql_ds.setJdbcUrl(url);
			
            // 设置连接池中的最大Statements数量！  
            mysql_ds.setMaxStatements(MaxStatements); 
			
            // 设置连接池的最大空闲时间！  
            mysql_ds.setMaxIdleTime(MaxIdleTime); 
            // 设置初始连接池的大小！  
            mysql_ds.setInitialPoolSize(InitialPoolSize);
            mysql_ds.setIdleConnectionTestPeriod(60);
            //mysql_ds.setPreferredTestQuery("SELECT 1");
            //mysql_ds.setIdleConnectionTestPeriod(1800);
			
            //mysql_ds.setMaxIdleTime(25000);
            //mysql_ds.setAcquireRetryDelay(100);
			 
            //mysql_ds.setBreakAfterAcquireFailure(false);
			
            //当连接池用完时客户端调用getConnection()后等待获取新连接的时间，超时后将抛出SQLException，如设为0则无限期等待。单位毫秒，默认为0
            //mysql_ds.setCheckoutTimeout(10000);
			
            //因性能消耗大请只在需要的时候使用它。如果设为true那么在每个connection提交的
            //时候都将校验其有效性。建议使用idleConnectionTestPeriod或automaticTestTable
            //等方法来提升连接测试的性能。Default: false
            //mysql_ds.setTestConnectionOnCheckin(false);
			
            //如果设置为true,每次从池中取一个连接，将做一下测试，使用automaticTestTable 或者 preferredTestQuery,做一条查询语句.看看连接好不好用，不好用，就关闭它，重新从池中拿一个.
            //mysql_ds.setTestConnectionOnCheckout(true);
            //System.out.println("11111111111111111111111111");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
	
	
    public static Connection getConn(){
        /*//System.out.println(DBUtil.getUrl());
        Connection conn=null;
        try {
            Class.forName(classDriver);
            conn=DriverManager.getConnection(url+databaseName, username, password);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
        }*/
        Connection conn = null;
        try {
            conn = mysql_ds.getConnection();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }
    //获取当前连接数
    public static void getConnections(){
        try {
            //System.out.println("最大连接数: "+mysql_ds.getMaxPoolSize());// 最大连接数
            //System.out.println("最小连接数: "+mysql_ds.getMinPoolSize());// 最小连接数
            System.out.println("正在使用连接数: "+mysql_ds.getNumBusyConnections());// 正在使用连接数
            System.out.println("空闲连接数: "+mysql_ds.getNumIdleConnections());// 空闲连接数
            //System.out.println("总连接数: "+mysql_ds.getNumConnections());// 总连接数
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
       
    }
    //设置IP地址
    public static void     setUrl(String ip) {
        DBUtil.url = "jdbc:mysql://"+ip+":5306";
        //System.out.println(DBUtil.url);
    }
   
    public static String getUrl() {
        return url;
    }
    //关闭资源
    public static void close(ResultSet rs,Statement stat,Connection conn){
        try {
            if(rs != null)
                rs.close();
			
        } catch (SQLException e) {
            e.printStackTrace();
        }
        try {
            if(stat != null)
                stat.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        try {
            if(conn != null){
                conn.close();				
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
	
    /**
     * 初始化连接池
     */
    public static void initPool(){
        close(null, null, getConn());
    }
	
    public static void main(String[] args){
        //System.out.println("start...");
        //System.out.println(getConn());
        //System.out.println("end...");
        Connection conn=DBUtil.getConn();
        DBUtil.getConnections();
        DBUtil.close(null, null, conn);
        while(true){
            DBUtil.getConnections();
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
		
		
    }
}