数据库连接池代码,Java代码库,德仔网

代码语言
代码分类
【Java】数据库连接池
作者:冰雹猜想 / 发布于2015/6/25/ 584

	import java.sql.*;
	import java.util.*;
	
	
	public class DbConnectionManager {
	 private static int maxConnectNum = 8;
	 private static ArrayList connectPool = new ArrayList();
	 private static int flag = 0;
	 private Connection[] conn = new Connection[maxConnectNum];
	 private String user = "root";
	 private String password = "**********";//密码都是星号
	 private ResultSet rs = null;
	 private Connection conn1 = null;
	 private Statement stmt = null;
	
	 private synchronized void init() {
	 for (int i = 0; i < maxConnectNum; i++) {
	 conn[i] = getConnectionFromDatabase();
	 connectPool.add(i, conn[i]);
	 }
	 }
	
	 public synchronized Connection getConnection() {
	 Connection conn = null;
	
	 if (connectPool.size() == 0) {
	 try {
	 java.lang.Thread.sleep(100);//这里绝逼要优化 不然蛋疼了就
	 getConnection();
	 } catch (InterruptedException e) {
	 System.out.println("Connection failed");
	 }
	 } else {
	 conn = (Connection) connectPool.remove(0);
	 }
	
	 return conn;
	 }
	
	 private Connection getConnectionFromDatabase() {
	 Connection trueConn = null;
	
	 try {
	 Class.forName("com.mysql.jdbc.Driver").newInstance();
	
	 String url = "jdbc:mysql://127.0.0.1:3306/这里就是数据库的名字?useUnicode=true&characterEncoding=UTF-8";
	 trueConn = DriverManager.getConnection(url, this.user, this.password);
	 } catch (Exception e) {
	 System.out.println(e.toString());
	 }
	
	 return trueConn;
	 }
	
	 private void CreatConAndStmt() {
	 try {
	 if (flag == 0) {
	 init();
	 this.flag=1;
	 }
	
	 conn1 = getConnection();
	 stmt = conn1.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
	 ResultSet.CONCUR_UPDATABLE);
	 } catch (Exception e) {
	 e.printStackTrace();
	 System.out.println("Can't excute sql, reason:" + e.getMessage());
	 }
	 }
	
	 public ResultSet getResult(String sql) {
	 rs = null;
	
	 try {
	 CreatConAndStmt();
	 rs = stmt.executeQuery(sql);
	
	 return rs;
	 } catch (SQLException e) {
	 System.err.println("getResult: " + e.getMessage());
	
	 return null;
	 }
	 }
	
	 public boolean excuteSQL(String sql) {
	 try {
	 CreatConAndStmt();
	 stmt.executeUpdate(sql);
	
	 return true;
	 } catch (Exception e) {
	 System.err.println("executeSQL: " + e.toString());
	
	 return false;
	 }
	 }
	
	 public void Release() {
	 try {
	 if (stmt != null) {
	 stmt.close();
	 }
	
	 if (conn1 != null) {
	 release(conn1);
	 }
	 } catch (Exception e) {
	 System.out.println("can'e release :" + e.getMessage());
	 }
	
	 System.out.println(this.connectPool.size());
	for (int i=0 ;i<this.connectPool.size();i++){
	 System.out.println(this.connectPool.get(i));
	}
	 }
	
	 public boolean release(Connection conn) {
	 return connectPool.add(conn);
	 }
	}
试试其它关键字
　数据库　　连接池　
同语言下
可能有用的
冰雹猜想贡献的其它代码(6)