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(大型網(wǎng)站數(shù)據(jù)庫平臺):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(大型網(wǎng)站數(shù)據(jù)庫平臺).JDBC.DRIVER.ORACLE(大型網(wǎng)站數(shù)據(jù)庫平臺)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            //獲取數(shù)據(jù)庫表結(jié)構(gòu)
 74            RESULTSETMETADATA RSM = RS.GETMETADATA();
 75            //取得數(shù)據(jù)庫的列數(shù)
 76            INT COL = RSM.GETCOLUMNCOUNT();
 77            //生成COL長度的OBJECT數(shù)組
 78            OBJECT[] OBJ = NEW OBJECT[COL];
 79            //遍歷結(jié)果集，將結(jié)果存入OBJECT數(shù)組
 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        //遍歷迭代器，取出結(jié)果
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}