DBMS.rar_dbms_dbms java_dbms_java_plus

import java.io.*; import java.sql.*; import java.net.URL; public class java2oracle{ public static boolean checkForWarning(SQLWarning warn) throws SQLException{ boolean rc=false; if(warn!=null){ System.out.println("\n***Warning***\n"); rc=true; while(warn!=null){ System.out.println("SQLState:"+warn.getSQLState()); System.out.println("Message:"+warn.getMessage()); System.out.println("Vendor:"+warn.getErrorCode()); warn=warn.getNextWarning(); } } return rc; } public static void dispResultSet(ResultSet rs) throws SQLException{ int i; ResultSetMetaData rsmd=rs.getMetaData(); int numCols=rsmd.getColumnCount(); for(i=1;i<=numCols;i++){ if(i>1) System.out.print(", "); System.out.print(rsmd.getColumnLabel(i)); } System.out.println(""); boolean more=rs.next(); while(more){ for(i=1;i<=numCols;i++ ){ if(i>1) System.out.print(", "); System.out.print(rs.getString(i)); } System.out.println(""); more=rs.next(); } } /** * @param args */ public static void main(String args[]) throws IOException{ // TODO 自动生成方法存根 String sUsr="system"; String sPwd="asdfgh"; while(true){ try{ System.out.print("SQL > "); BufferedReader br=new BufferedReader(new InputStreamReader(System.in)); String str=br.readLine(); if(str.equalsIgnoreCase("end")) break; if(str.equalsIgnoreCase("exit")) break; if(str.equalsIgnoreCase("quit")) break; if(str.endsWith(";")) str=str.substring(0,str.length()-1); Class.forName("oracle.jdbc.driver.OracleDriver"); Connection con=DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl","system","asdfgh"); checkForWarning(con.getWarnings()); Statement stmt=con.createStatement(); if(str.toLowerCase().startsWith("select")){ ResultSet rs=stmt.executeQuery(str); dispResultSet(rs); rs.close(); } else stmt.executeUpdate(str); stmt.close(); con.close(); } catch(SQLException ex){ System.out.println("\n***SQLException caught***\n"); while(ex!=null){ System.out.println("SQLState:"+ex.getSQLState()); System.out.println("Message:"+ex.getMessage()); System.out.println("Vendor:"+ex.getErrorCode()); ex=ex.getNextException(); System.out.println(""); } } catch(java.lang.Exception ex){ ex.printStackTrace(); } } } }