?? dboperator.java
字號:
package ch03.section04;
import java.sql.*;
import ch03.section03.*;
public class DBOperator {
private DBConnectionManager DBConMag = DBConnectionManager.getInstance(); //獲取聯接池事例;
private Statement stmt = null; //執行語句
private ResultSet rs = null; //結果集
private Connection conn = null; //數據庫鏈接
private ResultSetMetaData rsmd = null; //元數據
/**
** 將連接對象返回給由名字指定的連接池
** @param name 在屬性文件中定義的連接池名字
** @param con 連接對象
**/
public void freeConnection(String name, Connection con) {
if (con != null) {
DBConMag.freeConnection(name, con);
}
}
/**
** 獲得數據庫聯接。
** 無參數。以access為默認的連接池名字
**
**/
public Connection getConnection(String name) {
return DBConMag.getConnection(name);
}
/**
**實現SQL語句的執行功能,包括刪除、更新、插入。
**參數:完整的SQL語句。
**返回:SQL執行后所影響的記錄數,如果不能得到數據庫鏈接返回-9。
**如果查詢出錯返回-1。
**/
public int executeUpdate(String sql, String name) {
int i = 0;
conn = getConnection(name);
if (conn == null) {
}
try {
stmt = conn.createStatement();
i = stmt.executeUpdate(sql);
}
catch (SQLException sqle) {
}
finally {
close(name);
return i;
}
}
/**
**實現SQL語句的查詢功能。
**參數:完整的SQL語句。
**返回查詢后的結果集,如果出錯返回NULL。
**如果參數為null,則返回null。
**
**注意:在每次執行完查詢后,必須使用close()釋放鏈接。
**/
public ResultSet executeQuery(String sql, String name) {
if (sql == null) {
return null;
}
conn = getConnection(name);
if (conn == null) {
}
try {
stmt = conn.createStatement();
rs = stmt.executeQuery(sql);
return rs;
}
catch (SQLException sqle) {
return null;
}
}
public void close(String name) {
try {
if (rs != null) {
rs.close();
}
if (stmt != null) {
stmt.close();
}
if (conn != null) {
freeConnection(name, conn);
}
}
catch (SQLException sqle) {}
}
/**
** 關閉所有連接,撤銷驅動程序的注冊
**/
public void release() {
DBConMag.release();
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -