JDBC的封裝類構建

作者：rommel1 2012-03-09 10:58:23

在JAVA中JDBC的訪問是比較麻煩的，為此可以使用封裝的方法構建一個封裝性較好的JDBC工具類，提高編程的可復用性。

具體的想法是：可以生成一個類封裝JDBC的connection和statement的構建，使用Property配置文件來保存JDBC訪問的路徑以及驅動，這樣可以有較好的可維護性，再使用反射特性構建一個DataUtil類封裝JDBC獲取的結果集，并把其顯示出來。

1.首先新建一個jdbc.property文件存放jdbc的相關屬性

jdbc.driver=com.mysql.jdbc.Driver  
jdbc.url=jdbc:mysql://localhost:3306/user  
jdbc.user=root  
jdbc.pass=123456

通過PropertyUtil類可以獲得jdbc的屬性

package jdbc;  
 
import java.io.IOException;  
import java.io.InputStream;  
import java.util.Properties;  
 
/**  
 * 屬性工具類  
 */ 
public class PropertiesUtil {  
    //屬性列表  
    private static Properties properties = new Properties();  
    //配置文件的路徑  
    private static String CONFIG = "/cfg/jdbc.properties";  
    //讀取資源文件, 設置輸入流  
    private static InputStream is = PropertiesUtil.class.getResourceAsStream(CONFIG);  
    //數據庫驅動  
    public static String JDBC_DRIVER;  
    //jdbc連接url  
    public static String JDBC_URL;  
    //數據庫用戶名  
    public static String JDBC_USER;  
    //數據庫密碼  
    public static String JDBC_PASS;  
    static {  
        try {  
            //加載輸入流  
            properties.load(is);  
            //獲得配置的各個屬性  
            JDBC_DRIVER = properties.getProperty("jdbc.driver");  
            JDBC_URL = properties.getProperty("jdbc.url");  
            JDBC_USER = properties.getProperty("jdbc.user");  
            JDBC_PASS = properties.getProperty("jdbc.pass");  
        } catch (IOException e) {  
            e.printStackTrace();  
        }  
    }  
}

2.建立JDBCExecutor類來封裝JDBC的數據源獲取工作，其中通過單例模式獲取數據庫的連接

package jdbc;  
 
import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.ResultSet;  
import java.sql.Statement;  
 
public class JDBCExecutor{  
    //獲得驅動  
    private static String DRIVER = PropertiesUtil.JDBC_DRIVER;  
    //獲得url  
    private static String URL = PropertiesUtil.JDBC_URL;  
    //獲得連接數據庫的用戶名  
    private static String USER = PropertiesUtil.JDBC_USER;  
    //獲得連接數據庫的密碼  
    private static String PASS = PropertiesUtil.JDBC_PASS;  
    //連接對象  
    private Connection connection;  
    //維護一個本類型的對象  
    private static JDBCExecutor jdbcExecutor;  
    //Statement對象,可以執行SQL語句并返回結果  
    private Statement stmt;  
      
    //私有構造器  
    private JDBCExecutor() {  
        try {  
            //初始化JDBC驅動并讓驅動加載到jvm中  
            Class.forName(DRIVER);  
            //創建數據庫連接  
            connection = DriverManager.getConnection(URL, USER, PASS);  
            //創建Statement對象  
            stmt = connection.createStatement();  
        } catch (Exception e) {  
            throw new JDBCException(e.getMessage());  
        }  
    }  
      
    //提供一個靜態方法返回本類的實例  
    public static JDBCExecutor getJDBCExecutor() {  
        //如果本類所維護jdbcExecutor屬性為空,則調用私有的構造器獲得實例  
        if (jdbcExecutor == null) {  
            jdbcExecutor = new JDBCExecutor();  
        }  
        return jdbcExecutor;  
    }  
      
    /*  
     * 執行一句查詢的sql  
     */ 
    public ResultSet executeQuery(String sql) {  
        try {  
            //利用Statement對象執行參數的sql  
            ResultSet result = stmt.executeQuery(sql);  
            return result;  
        } catch (Exception e) {  
            throw new QueryException(e.getMessage());  
        }  
    }  
      
    //執行單句INSERT、UPDATE 或 DELETE 語句, 如果執行INSERT時, 返回主鍵  
    public int executeUpdate(String sql) {  
        int result = -1;  
        try {  
            //執行SQL語句  
            stmt.executeUpdate(sql);  
            //獲得主鍵  
            ResultSet rs = stmt.getGeneratedKeys();  
            while(rs.next()) {  
                //返回最后一個主鍵  
                result = rs.getInt(1);  
            }  
            rs.close();  
            return result;  
        } catch (Exception e) {  
            throw new QueryException(e.getMessage());  
        }  
    }  
}

3.為了將JDBC查詢操作的數據獲取，封裝數據獲取的類

package jdbc;  
 
 
import java.lang.reflect.Field;  
import java.lang.reflect.Method;  
import java.sql.ResultSet;  
import java.util.ArrayList;  
import java.util.Collection;  
 
import vo.User;  
import dao.impl.UserDAOImpl;  
 
 
/**  
 * 數據轉換工具類  
 */ 
public class DataUtil {  
 static UserDAOImpl us=new UserDAOImpl();  
 //將rs中的值封裝成一個集合  
 public static Collection getDatas(Collection result, ResultSet rs, Class clazz) {  
  try {  
   while (rs.next()) {  
    //創建類的實例  
    Object vo = clazz.newInstance();  
    //獲取本對象的屬性  
    Field[] fields = clazz.getDeclaredFields();  
    //獲取父類的屬性  
//    Field[] superFields = clazz.getSuperclass().getDeclaredFields();  
//    //父類的屬性和自己的屬性相加  
//    Field[] allFields = addFields(superFields, fields);  
    //遍歷所有的屬性  
    for (Field field : fields) {  
     //獲得setter方法的方法名  
     String setterMethodName = getSetterMethodName(field.getName());  
     //獲得setter方法  
     Method setterMethod = clazz.getMethod(setterMethodName, field.getType());  
     invokeMethod(rs, field, vo, setterMethod);  
    }  
    result.add(vo);  
   }  
   rs.close();  
  } catch (Exception e) {  
   e.printStackTrace();  
   throw new DataException(e.getMessage());  
  }  
  return result;  
 }  
   
 //執行一個方法, 從ResultSet中獲取一個字段的數據, 調用vo的setter方法  
 private static void invokeMethod(ResultSet rs, Field field, Object vo,   
   Method setterMethod) {  
  try {  
   //當使用ResultSet獲取某個字段的時候, 如果沒有該字段, 會出現SQLException, 在這里忽略該異常  
   String value = rs.getString(field.getName());  
   //從ResultSet中獲取與該對象屬性名一致的字段, 并執行setter方法  
   setterMethod.invoke(vo, value);  
  } catch (Exception e) {  
   //忽略異常  
  }  
 }  
   
 //根據屬性名獲得setter方法的方法名  
 private static String getSetterMethodName(String fieldName) {  
  String begin = fieldName.substring(0, 1).toUpperCase();  
  String end = fieldName.substring(1, fieldName.length());  
  String methodName = "set" + begin + end;  
  return methodName;  
 }  
   
 //測試方法  
 public static void main(String[] args) {  
  JDBCExecutor executor = JDBCExecutor.getJDBCExecutor();  
  us.AddUser(new User("111",12,"333"));  
//  ResultSet rs = executor.executeQuery("select * from user");  
//  Collection<User> result = DataUtil.getDatas(new ArrayList<User>(), rs,   
//    User.class);  
//  for (User user : result) {  
//   System.out.println(user.getName());  
//  }  
 }  
}

通過上面Main方法中的調用，可以看出能夠很輕易的操縱JDBC連接了。

原文鏈接：http://blog.csdn.net/rommel1/article/details/7294501

【編輯推薦】

Java并發編程之同步互斥問題
Java中String.format的用法
郵件功能開發：JavaMail
6個提高Java開發者效率的工具
關于讀寫鎖算法的Java實現及思考

責任編輯：林師授來源： rommel1的博客

Java JDBC