访问oracle 的 isqlplus小工具

package com.lunatic.util; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class DB { private static final String DRIVER = "oracle.jdbc.driver.OracleDriver"; private static final String URL = "jdbc:oracle:thin:@localhost:1521:ORCL"; private String username; private String password; public static Connection conn; public static Statement stmt; private static DB db = new DB(); private DB(){ try { Class.forName(DRIVER); } catch (ClassNotFoundException e) { System.err.println("加载驱动失败 " + DRIVER + e.getMessage()); } }; public static DB getInstance(){ return db; } public static Connection getConnection(){ try { conn = DriverManager.getConnection(URL, db.getUsername(), db.getPassword()); } catch (Exception e){ e.printStackTrace(); } return conn; } public static Statement getStmt() throws SQLException{ getConnection(); if(conn != null){ stmt = conn.createStatement(); } return stmt; } public static int execute(String sql) throws SQLException{ getStmt(); if(stmt != null) { int resutl = stmt.executeUpdate(sql); commit(); return resutl; } return 0; } public static ResultSet executeQuery(String sql) throws SQLException{ getStmt(); if(stmt != null) { return stmt.executeQuery(sql); } return null; } public static int[] executeBatch(String[] sqls) throws SQLException { getStmt(); if(stmt != null) { autoFalse(); for(int i = 0; i < sqls.length; i++){ stmt.addBatch(sqls[i]); } int[] rows = stmt.executeBatch(); commit(); return rows; } return null; } public static boolean executeCreate(String sql) throws SQLException{ getStmt(); if(stmt != null){ return stmt.execute(sql); } return false; } public static void main(String args[]){ DB.getInstance().setUsername("scott"); DB.getInstance().setPassword("fengzi"); String str = "create or replace procedure AddNewDept(d_deptno dept.deptno%type,d_dname dept.dname%type,d_loc dept.loc%type)as begin insert into dept(deptno,dname,loc) values(d_deptno, d_dname, d_loc ); end AddNewDept;"; System.out.println(str); try { DB.executeCreate(str); } catch (SQLException e) { e.printStackTrace(); } } /** * @return the uSERNAME */ public String getUsername() { return username; } /** * @param username the uSERNAME to set */ public void setUsername(String username) { this.username = username; } /** * @return the pASSWORD */ public String getPassword() { return password; } /** * @param password the pASSWORD to set */ public void setPassword(String password) { this.password = password; } private static void commit() throws SQLException{ if(conn != null){ conn.commit(); } } private static void autoFalse() throws SQLException{ if(conn != null){ conn.setAutoCommit(false); } } }