import java.sql.*;
import oracle.jdbc.*;

public class OracleJavaProc ...{

// Add a salgrade to the database.
public static void addSalGrade(int grade, int losal, int hisal) ...{

System.out.println("Creating new salgrade for EMPLOYEE...");

try ...{
Connection conn =
DriverManager.getConnection("jdbc:default:connection:");

String sql =
"INSERT INTO salgrade " +
"(GRADE,LOSAL,HISAL) " +
"VALUES(?,?,?)";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setInt(1,grade);
pstmt.setInt(2,losal);
pstmt.setInt(3,hisal);
pstmt.executeUpdate();
pstmt.close();
}
catch(SQLException e) ...{
System.err.println("ERROR! Adding Salgrade: "
+ e.getMessage());
}
}

public static int getHiSal(int grade)
...{
try ...{
Connection conn =
DriverManager.getConnection("jdbc:default:connection:");
String sql = "SELECT hisal FROM salgrade WHERE grade = ?";
PreparedStatement pstmt = conn.prepareStatement(sql);pstmt.setInt(1, grade);
ResultSet rset = pstmt.executeQuery();
int res = 0;
if (rset.next())
...{
res = rset.getInt(1);
}
rset.close();
return res;
}
catch (SQLException e)
...{
System.err.println("ERROR! Querying Salgrade: "
+ e.getMessage());
return -1;
}
}

}

SQL> create or replace function query_hisal(grade number) return number as langu
age java name 'OracleJavaProc.getHiSal(int) return int';
2 /

函數(shù)已創(chuàng)建。

SQL> set serveroutput on size 2000
SQL> call dbms_java.set_output(2000);

調(diào)用完成。
SQL> select query_hisal(5) from dual;

QUERY_HISAL(5)
--------------
9999