package dbcp;
import org.apache.commons.dbcp.BasicDataSource;
import org.apache.commons.dbcp.BasicDataSourceFactory;
import java.io.UnsupportedEncodingException;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.Statement;
import java.util.Properties;

public class DBPool {
    private static BasicDataSource dataSource = null;

    public DBPool() {
    }

    public static void init() {
    	  String dbIp="127.0.0.1";   //數(shù)據(jù)庫Ip
      	  String dbPort="3306";		   //數(shù)據(jù)庫端口
      	  String dbName="chatdb";		   //數(shù)據(jù)庫名字
      	  String dbUserName="root";
      	  String dbPassWord="rootroot";
    	
        if (dataSource != null) {
            try {
                dataSource.close();
            } catch (Exception e) {
                //
            }
            dataSource = null;
        }
        
        try {
            Properties p = new Properties();
            p.setProperty("driverClassName", "com.mysql.jdbc.Driver");
            p.setProperty("url", "jdbc:mysql://"+dbIp+":"+dbPort+"/"+dbName);
            p.setProperty("password", dbPassWord);
            p.setProperty("username", dbUserName);
            p.setProperty("initialSize", "10");
            p.setProperty("maxActive", "30");
            p.setProperty("maxIdle", "10");
            p.setProperty("maxWait", "1000");
            p.setProperty("removeAbandoned", "false");
            p.setProperty("removeAbandonedTimeout", "120");
            p.setProperty("testOnBorrow", "true");
            p.setProperty("logAbandoned", "true");

            dataSource = (BasicDataSource) BasicDataSourceFactory.createDataSource(p);

        } catch (Exception e) {
            //
        }
    }

    public static synchronized Connection getConnection() throws  SQLException {
        if (dataSource == null) {
            init();
        }
        Connection conn = null;
        if (dataSource != null) {
            conn = dataSource.getConnection();
        }
        return conn;
    }
    
    
    public static void main(String[] args) {
    	Connection conn = null;
    	DBPool dbpool=new DBPool();
    	Statement stmt = null;
    	dbpool.init();
    	try {
			conn=dbpool.getConnection();
		} catch (SQLException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
		
		try {
			 stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			
		}
		String sql="insert into t_user values(1,'cwj','aaa',3)";

		try {
			stmt.execute(sql);
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			
		}
		
		try {
			conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
    
    }
}