JDBC的代码重用[Java编程]

在利用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: 310-301 :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.OracleDriver");
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　　　　　　e.printStackTrace();
101　　　　}
102　　}
103
104　　public static void main(String args[]) {
105　　　　newJdbc nj = new newJdbc();
106　　　　String sql = "select * from users";
107　　　　List list = nj.query(sql);
108　　　　//返回list的迭代器
109　　　　Iterator it = list.iterator();
110　　　　//遍历迭代器,取出后果　1z0-147
111　　　　while (it.hasNext()) {
112　　　　　　Object[] o = (Object[]) it.next();
113　　　　　　int id = ((BigDecimal) o[0]).intValue();
114　　　　　　System.out.println(id);
115　　　　}
116
117　　}
118}