java2oracle.java

Java连接Oracle数据库实例 实现SQL*PLUS功能 带JDBC驱动 适合初学者学习参考

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();
		}
		}
	}
	

}