java中連線MySQL資料庫的幾種方式
1.1概念
DBCP（DataBase Connection Pool）資料庫連線池，是java資料庫連線池的一種，由Apache開發，通過資料庫連線池，可以讓程式自動管理資料庫連線的釋放和斷開。
1.2程式碼示例
所需jar包：commons-dbcp2-2.2.1.jar、commons-pool2-2.4.2.jar、commons-logging-1.2.jar，另外還有資料庫的jdbc驅動mysql-connector-java-5.1.40-bin.jar
連線池管理類
package com.wqc.test;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.util.Properties;
import java.util.logging.Logger;
import javax.sql.DataSource;
import org.apache.commons.dbcp2.BasicDataSourceFactory;
public class DBManager {
private static final String configFile = "dbcp.properties";
private static DataSource dataSource;
static {
Properties dbProperties = new Properties();
try {
dbProperties.load(DBManager.class.getClassLoader().getResourceAsStream(configFile));
dataSource = BasicDataSourceFactory.createDataSource(dbProperties);
Connection conn = getConn();
DatabaseMetaData mdm = conn.getMetaData();
System.out.println("Connected to " + mdm.getDatabaseProductName() + " " + mdm.getDatabaseProductVersion());
if (conn != null) {
conn.close();
}
} catch (Exception e) {
System.out.println("初始化連線池失敗:" + e);
}
}
private DBManager() {
}
public static final Connection getConn() {
Connection conn = null;
try {
conn = dataSource.getConnection();
} catch (Exception e) {
System.out.println("獲取資料庫連線失敗:" + e);
}
return conn;
}
//關閉資料庫連線，將連線返還給資料庫連線池
public static void closeConn(Connection conn) {
try {
if (conn != null && !conn.isClosed()) {
conn.setAutoCommit(true);
conn.close();
}
} catch (Exception e) {
System.out.println("關閉資料庫連線失敗：" + e);
}
}
public static void main(String[] args) {
long begin = System.currentTimeMillis();
for (int i = 0; i < 10000; i++) {
Connection conn = DBManager.getConn();
System.out.println(i + "連線數：");
DBManager.closeConn(conn);
}
long end = System.currentTimeMillis();
System.out.println("用時：" + (end - begin));
}
}
1. 配置檔案需要放在src資料夾下，內容如下：
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/test
username=root
password=123456
maxActive=30
maxIdle=10
maxWait=1000
removeAbandoned=true
removeAbandonedTimeout=180
2.利用DriverManager連線資料庫
2.1最簡單粗暴的方法
public static Connection getConnection() throws ClassNotFoundException{
String url="jdbc:mysql:///jdbc";//我連的資料庫是MySQL中的jdbc資料庫
String username="root";
String password="";//我的MySQL資料庫的密碼是空字串
String driverClass="com.mysql.jdbc.Driver";
Connection ct=null;
Class.forName(driverClass);
try {
ct=DriverManager.getConnection(url, username, password);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return ct;
}
2.2利用io流讀取檔案的方式
public static Connection getConnection() throws ClassNotFoundException, IOException {
String driver = null;
String jdbcurl = null;
String user = null;
String password = null;
// 讀取類路徑下的jdbc.propreties檔案(配置檔案)
InputStream in = JDBCtool.class.getClassLoader().getResourceAsStream("jdbc.properties");
// 以上為輸入流
Properties pt = new Properties();// 建立properties
pt.load(in);// 取鍵值對（載入對應的輸入流）
driver = pt.getProperty("driver");
jdbcurl = pt.getProperty("jdbcurl");
user = pt.getProperty("user");
password = pt.getProperty("password");
Connection ct = null;
Class.forName(driver);
try {
ct = DriverManager.getConnection(jdbcurl, user, password);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return ct;
}
將diver、jdbcurl、user、password這些資訊儲存到類路徑下的jdbc.propreties檔案中（以下是該檔案中的內容）
2、利用c3p0連線池連線資料庫
準備工作：
1、匯入c3p0的jar包，切記一定要把其相依賴的jar包——mchange-commons-java-0.2.3.4.jar也導進來。
2、編寫c3p0-config.xml檔案
<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
<named-config name="helloc3p0">
<!-- 連線資料來源的基本屬性 -->
<property name="user">root</property>
<property name="password"></property>
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql:///jdbc</property>
<!-- 若資料庫中連線數不足時，一次向資料庫伺服器申請多少個連線 -->
<property name="acquireIncrement">5</property>
<!-- 初始化資料庫連線池時連線的數量 -->
<property name="initialPoolSize">5</property>
<!-- 資料庫連線池中的最小的資料庫連線數 -->
<property name="minPoolSize">5</property>
<!-- 資料庫連線池中的最大的資料庫連線數 -->
<property name="maxPoolSize">10</property>
<!-- c3p0資料庫連線可以維護的statement的個數 -->
<property name="maxStatements">20</property>
<!-- 每個連線同時可以使用的statement物件的個數 -->
<property name="maxStatementsPerConnection">5</property>
</named-config>
</c3p0-config>
獲取資料庫連線的程式碼如下：
private static DataSource ds=null;
//資料庫連線池應只被初始化一次
static{
ds=new ComboPooledDataSource("helloc3p0");
}
//獲取資料庫連線
public static Connection getConnection() throws ClassNotFoundException, SQLException, IOException{
return ds.getConnection();
}