Commit e347faf2 authored by 赵建伟's avatar 赵建伟

update codes

parent ddf9a088
package com.gmei.data.dqmp.pool;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.LinkedList;
import java.util.Properties;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class JdbcConnectPool {
private static final Logger logger = LoggerFactory.getLogger(JdbcConnectPool.class);
private static Properties prop;
private static int requestCount = 0;
private static LinkedList<Connection> connList = new LinkedList<Connection>();
private static final Logger logger = LoggerFactory.getLogger(JdbcConnectPool.class);
static {
prop = getProperties("jdbc.properties");
try {
......@@ -29,17 +25,8 @@ public class JdbcConnectPool {
}
public static Connection getConnection() {
Connection connection = null;
if (connList.size() > 0) {
connection = connList.getFirst();
connList.removeFirst();
} else{
connList.addLast(createConnect());
connection = getConnection();
}
logger.info("requestCount : {}",++requestCount);
logger.info("connList size : {}",connList.size());
return connection;
return createConnect();
}
/**
......@@ -62,11 +49,14 @@ public class JdbcConnectPool {
/**
* 释放连接
*
* @param connection
*/
public static void releaseConnection(Connection connection) {
connList.addLast(connection);
public static void releaseConnection(Connection conn) {
try{
conn.close();
}catch (Exception e){
conn = null;
e.printStackTrace();
}
}
/**
......
......@@ -12,9 +12,9 @@ import java.sql.SQLException;
import java.util.LinkedList;
import java.util.Properties;
public class JdbcConnectPoolBak {
public class JdbcConnectPoolBak01 {
private static final Logger logger = LoggerFactory.getLogger(JdbcConnectPoolBak.class);
private static final Logger logger = LoggerFactory.getLogger(JdbcConnectPoolBak01.class);
private static Properties prop;
private static int requestCount = 0;
private static LinkedList<Connection> connList = new LinkedList<Connection>();
......@@ -104,7 +104,7 @@ public class JdbcConnectPoolBak {
private static Properties getProperties(String path) {
Properties properties = new Properties();
try {
InputStream inputStream = JdbcConnectPoolBak.class.getClassLoader().getResourceAsStream(path);
InputStream inputStream = JdbcConnectPoolBak01.class.getClassLoader().getResourceAsStream(path);
properties.load(inputStream);
inputStream.close();
} catch (FileNotFoundException e) {
......
package com.gmei.data.dqmp.pool;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.LinkedList;
import java.util.Properties;
public class JdbcConnectPoolBak02 {
private static final Logger logger = LoggerFactory.getLogger(JdbcConnectPoolBak02.class);
private static Properties prop;
private static int requestCount = 0;
private static LinkedList<Connection> connList = new LinkedList<Connection>();
static {
prop = getProperties("jdbc.properties");
try {
Class.forName(prop.getProperty("driverClassName"));
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
public static Connection getConnection() {
Connection connection = null;
if (connList.size() > 0) {
connection = connList.getFirst();
connList.removeFirst();
} else{
connList.addLast(createConnect());
connection = getConnection();
}
logger.info("requestCount : {}",++requestCount);
logger.info("connList size : {}",connList.size());
return connection;
}
/**
* 创建连接
*
* @return
*/
private static Connection createConnect() {
Connection conn = null;
try {
conn = DriverManager.getConnection(
prop.getProperty("url"),
prop.getProperty("username"),
prop.getProperty("password"));
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
/**
* 释放连接
*
* @param connection
*/
public static void releaseConnection(Connection connection) {
connList.addLast(connection);
}
/**
* 获取属性文件对象
*
* @param path
* @return
*/
private static Properties getProperties(String path) {
Properties properties = new Properties();
try {
InputStream inputStream = JdbcConnectPoolBak02.class.getClassLoader().getResourceAsStream(path);
properties.load(inputStream);
inputStream.close();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
return properties;
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment