將連線資料庫、關閉資料庫、增刪改查資料等對資料庫的操作封裝成操作資料庫的一個類，方便進行資料庫的操作。

一、類的原始碼

程式碼如下：

package com.operationdb;

import java.sql.*;
/**
 * 操作資料庫的類,連線SQLserver資料庫,以及對資料庫的增刪改查操作
 * @author HuDongyang
 *
 */
public class OperationDB {
    //驅動路徑
    private static final String DBDRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
 
;
    //資料庫地址
    private String DBURL = "jdbc:sqlserver://localhost:1434;DataBaseName=";
    //資料庫登入使用者名稱
    private static final String DBUSER = "sa";
    //資料庫使用者密碼
    private static final String DBPASSWORD = "123456";
    //資料庫連線
    public Connection conn = null;
    //執行SQL語句的介面
    public Statement stmt = null
 
;
    //要執行的SQL語句
    public String SQLStr = null;
    //資料容器
    public ResultSet rs = null;
    //提示資訊
    public String TempInfo = "";


    //構造方法
    public OperationDB(String DBName) {
        this.DBURL += DBName;
    }


    /**
     * 連線資料庫
     * @return 成功返回true,失敗返回false
     */
    public boolean
 
 linkDB(){
        try {
            Class.forName(DBDRIVER);
            conn = DriverManager.getConnection(DBURL,DBUSER,DBPASSWORD);
            stmt = conn.createStatement();
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            try {
                stmt.close();
                conn.close();
            } catch (Exception e1) {
                e1.printStackTrace();
            }
            return false;
        }
    }

    /**
     * 關閉資料庫連線
     * @return 成功返回true，失敗返回false
     */
    public boolean closeDB(){
        try {
            stmt.close();
            conn.close();
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }


    /**
     * 新增資料
     * @param TableName 要操作的資料庫表名
     * @param InsertValue 要增加的資料
     * @param WhereStr 查詢表中是否已存在要新增的資訊
     * @return 成功返回true,失敗返回false
     */
    public boolean insertData(String TableName, String InsertValue, String WhereStr){
        this.SQLStr = "insert into " + TableName + " values (" + InsertValue + ")";
        try {
            if(stmt.executeQuery("select * from " + TableName + " where " + WhereStr).next()){
                TempInfo = "該記錄已存在!";
                this.closeDB();
                return false;
            }else{
                stmt.executeUpdate(SQLStr);
                this.closeDB();
                return true;
            }
        } catch (Exception e) {
            e.printStackTrace();
            this.closeDB();
            return false;
        }

    }

    /**
     * 刪除資料
     * @param TableName 要操作的資料庫表名
     * @param WhereStr 刪除哪一條記錄
     * @return 成功返回true,失敗返回false
     */
    public boolean deleteData(String TableName, String WhereStr){
        this.SQLStr = "delete from " + TableName + " where " + WhereStr;
        try {
            if(stmt.executeUpdate(SQLStr) != 0){
                this.closeDB();
                return true;
            }else{
                this.closeDB();
                TempInfo = "資料不存在!";
                return false;
            }
        } catch (SQLException e) {
            e.printStackTrace();
            this.closeDB();
            return false;
        }
    }

    /**
     * 修改資料
     * @param TableName  要操作的資料庫表名
     * @param UpdateValue  要修改的屬性
     * @param WhereStr 要修改哪一條記錄
     * @return 成功返回true,失敗返回false
     */
    public boolean updateData (String TableName, String UpdateValue, String WhereStr){
        this.SQLStr = "update " + TableName + " set " + UpdateValue + " where " + WhereStr;
        try {
            if(stmt.executeUpdate(SQLStr) != 0){
                this.closeDB();
                return true;
            }else{
                this.closeDB();
                TempInfo = "資料不存在!";
                return false;
            }
        } catch (Exception e) {
            e.printStackTrace();
            this.closeDB();
            return false;
        }
    }

    /**
     * 查詢資料,該方法沒有關閉資料庫連線,因為不能關閉RS結果集
     * @param TableName 要操作的資料庫表名
     * @param QueryValue 需要查詢的資料
     * @param WhereStr 查詢哪一條記錄
     * @return 返回一個ResultSet集合
     */
    public ResultSet queryData(String TableName, String QueryValue, String WhereStr){
        if(WhereStr == ""){
            this.SQLStr = "select "+ QueryValue + " from " + TableName;
        }else{
            this.SQLStr = "select "+ QueryValue + " from " + TableName + " where " + WhereStr;
        }
        try {
            rs = stmt.executeQuery(SQLStr);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return rs;
    }

}

二、類的詳細介紹

1.構造方法

//構造方法
    public OperationDB(String DBName) {
        this.DBURL += DBName;
    }

構造方法中，初始化資料庫地址；不提供無參構造方法。

2.連線資料庫方法

    /**
     * 連線資料庫
     * @return 成功返回true,失敗返回false
     */
    public boolean linkDB(){
        try {
            Class.forName(DBDRIVER);
            conn = DriverManager.getConnection(DBURL,DBUSER,DBPASSWORD);
            stmt = conn.createStatement();
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            try {
                stmt.close();
                conn.close();
            } catch (Exception e1) {
                e1.printStackTrace();
            }
            return false;
        }
    }

該方法載入資料庫驅動；根據之前類中的“資料庫地址”、“資料庫登入使用者名稱”、“資料庫登入密碼”，初始化Connection物件；使用Connection的物件conn例項化Statement介面。

3.關閉資料庫連線方法

    /**
     * 關閉資料庫連線
     * @return 成功返回true，失敗返回false
     */
    public boolean closeDB(){
        try {
            stmt.close();
            conn.close();
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

4.新增資料方法

    /**
     * 新增資料
     * @param TableName 要操作的資料庫表名
     * @param InsertValue 要增加的資料
     * @param WhereStr 查詢表中是否已存在要新增的資訊
     * @return 成功返回true,失敗返回false
     */
    public boolean insertData(String TableName, String InsertValue, String WhereStr){
        this.SQLStr = "insert into " + TableName + " values (" + InsertValue + ")";
        try {
            if(stmt.executeQuery("select * from " + TableName + " where " + WhereStr).next()){
                TempInfo = "該記錄已存在!";
                this.closeDB();
                return false;
            }else{
                stmt.executeUpdate(SQLStr);
                this.closeDB();
                return true;
            }
        } catch (Exception e) {
            e.printStackTrace();
            this.closeDB();
            return false;
        }

    }

5.刪除資料方法

    /**
     * 刪除資料
     * @param TableName 要操作的資料庫表名
     * @param WhereStr 刪除哪一條記錄
     * @return 成功返回true,失敗返回false
     */
    public boolean deleteData(String TableName, String WhereStr){
        this.SQLStr = "delete from " + TableName + " where " + WhereStr;
        try {
            if(stmt.executeUpdate(SQLStr) != 0){
                this.closeDB();
                return true;
            }else{
                this.closeDB();
                TempInfo = "資料不存在!";
                return false;
            }
        } catch (SQLException e) {
            e.printStackTrace();
            this.closeDB();
            return false;
        }
    }

6.修改資料方法

    /**
     * 修改資料
     * @param TableName  要操作的資料庫表名
     * @param UpdateValue  要修改的屬性
     * @param WhereStr 要修改哪一條記錄
     * @return 成功返回true,失敗返回false
     */
    public boolean updateData (String TableName, String UpdateValue, String WhereStr){
        this.SQLStr = "update " + TableName + " set " + UpdateValue + " where " + WhereStr;
        try {
            if(stmt.executeUpdate(SQLStr) != 0){
                this.closeDB();
                return true;
            }else{
                this.closeDB();
                TempInfo = "資料不存在!";
                return false;
            }
        } catch (Exception e) {
            e.printStackTrace();
            this.closeDB();
            return false;
        }
    }

7.查詢資料方法

    /**
     * 查詢資料,該方法沒有關閉資料庫連線,因為RS結果集關閉後無法使用
     * @param TableName 要操作的資料庫表名
     * @param QueryValue 需要查詢的資料
     * @param WhereStr 查詢哪一條記錄
     * @return 返回一個ResultSet集合
     */
    public ResultSet queryData(String TableName, String QueryValue, String WhereStr){
        if(WhereStr == ""){
            this.SQLStr = "select "+ QueryValue + " from " + TableName;
        }else{
            this.SQLStr = "select "+ QueryValue + " from " + TableName + " where " + WhereStr;
        }
        try {
            rs = stmt.executeQuery(SQLStr);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return rs;
    }

}