程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> 網頁編程 >> JSP編程 >> 關於JSP >> JDBC之代碼重復使用

JDBC之代碼重復使用

編輯:關於JSP

在使用JDBC連接數據庫的時,我們會采用executeQuery(String sql)獲得一個結果集。當數據庫結構變化或者獲得其他數據庫表結果集的時候我們需要將ResultSet結果集根據不同的數據結構重新遍歷。
如何才能建立一個與數據庫結構無關的JDBC連接呢?我們可以通過使用ResultSetMetaData()方法獲得表結構。然後使用Object[]數組遍歷結果集。當我們要取得相應的結果時,我們可以使用Iterator迭代器。只要遍歷迭代器就可以取出結果。
下面是我寫的一個方法:
  1import java.math.BigDecimal;
  2import java.sql.Connection;
  3import java.sql.DriverManager;
  4import java.sql.ResultSet;
  5import java.sql.ResultSetMetaData;
  6import java.sql.SQLException;
  7import java.sql.Statement;
  8import java.util.ArrayList;
  9import java.util.Iterator;
 10import java.util.List;
 11
 12public class newJdbc {
 13    private String url = "jdbc:Oracle(大型網站數據庫平台):thin:@localhost:1521:nitpro";
 14
 15    private String dbUserName = "scott";
 16
 17    private String dbUserPassword = "tiger";
 18
 19    private Connection conn = null;
 20
 21    private Statement stmt = null;
 22
 23    private ResultSet rs = null;
 24
 25    public newJdbc() {
 26        try {
 27            Class.forName("Oracle(大型網站數據庫平台).jdbc.driver.Oracle(大型網站數據庫平台)Driver");
 28        } catch (ClassNotFoundException e) {
 29            e.printStackTrace();
 30        }
 31    }
 32
 33    public Connection getConnection() {
 34        try {
 35            conn = DriverManager.getConnection(url, dbUserName, dbUserPassword);
 36        } catch (SQLException e) {
 37            e.printStackTrace();
 38        }
 39        return conn;
 40    }
 41
 42    public void close(ResultSet rs, Statement stmt, Connection conn) {
 43        if (rs != null) {
 44            try {
 45                rs.close();
 46            } catch (SQLException e) {
 47                e.printStackTrace();
 48            }
 49        }
 50        if (stmt != null) {
 51            try {
 52                stmt.close();
 53            } catch (SQLException e) {
 54                e.printStackTrace();
 55            }
 56        }
 57        if (conn != null) {
 58            try {
 59                conn.close();
 60            } catch (SQLException e) {
 61                e.printStackTrace();
 62            }
 63        }
 64    }
 65
 66    public List query(String sql) {
 67        List list = new ArrayList();
 68
 69        conn = this.getConnection();
 70        try {
 71            stmt = conn.createStatement();
 72            rs = stmt.executeQuery(sql);
 73            //獲取數據庫表結構
 74            ResultSetMetaData rsm = rs.getMetaData();
 75            //取得數據庫的列數
 76            int col = rsm.getColumnCount();
 77            //生成col長度的Object數組
 78            Object[] obj = new Object[col];
 79            //遍歷結果集,將結果存入Object數組
 80            while (rs.next()) {
 81                for (int i = 0; i < col; i++) {
 82                    obj[i] = rs.getObject(i + 1);
 83                }
 84                list.add(obj);
 85            }
 86        } catch (SQLException e) {
 87            e.printStackTrace();
 88        } finally {
 89            this.close(rs, stmt, conn);
 90        }
 91        return list;
 92    }
 93
 94    public void update(String sql) {
 95        try {
 96            conn = this.getConnection();
 97            stmt = conn.createStatement();
 98            stmt.executeUpdate(sql);
 99        } catch (SQLException e) {
100         &nbs

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved