package cn.edu.rjxy.dao;

import java.sql.*;
import org.apache.commons.dbcp.BasicDataSource;
import javax.sql.DataSource;

public class ConnectDBBean implements ConnectDBInterface {

	BasicDataSource oneDataSourceImple = null;

	String DBDriver = "com.mysql.jdbc.Driver";

	String URL = "jdbc:mysql://localhost:3306/bbsdb?useUnicode=true&characterEncoding=UTF-8";

	private java.sql.Connection con = null;

	public ConnectDBBean() {
		oneDataSourceImple = new BasicDataSource();
		oneDataSourceImple.setDriverClassName(DBDriver);
		oneDataSourceImple.setUrl(URL);
		oneDataSourceImple.setUsername("root");
		oneDataSourceImple.setPassword("123456");
		oneDataSourceImple.setMaxActive(10); //最大的連接數目
		oneDataSourceImple.setDefaultAutoCommit(true);
		try {
			con = oneDataSourceImple.getConnection();
		} catch (java.sql.SQLException e) {
			System.out.println("不能正確地連接數據庫并且出現SQLException");
		}
	}

	public void closeDBCon() {
		try {
			con.close();
		} catch (SQLException e) {
			e.printStackTrace();
			System.out.println("不能正確地關閉數據庫連接");
		}
	}

	public Connection getConnection() {
		if (con == null) {
			System.out.println("在DBCPConnectDBBean類中的getConnection方法中con對象為空");
		}
		return this.con;

	}

}