java ストアド・プロシージャ

java のメソッドを公開するには、コール仕様を記述します。このコール仕様により、java のメソッド名、引数の型および戻り値の型が、対応する SQL にマップされます。

コール仕様は単に java メソッドを公開するだけで、コール仕様を通してメソッドをコールすると、ランタイム・システムは最小のオーバーヘッドでコールを処理します。

java のクラスを oracle 8i データベースに組み込むことで、 java アプリケーションは、データベース・セッションのコンテキスト内に組み込まれます。

JServer は、そのセッション内のコール全般にわたって、クライアントの java の状態を保持します。

１つのセッションのコンテキストで、クライアントは次のことを実行します。

oracle JVM が正しくインストールされていることを、以下の手順で確認してください。

> svrmgrl
Oracle Server Manager Release 3.1.6.0.0 - Production

Copyright (c) 1997, 1999, Oracle Corporation.  All Rights Reserved.

Oracle8i Enterprise Edition Release 8.1.6.1.0 - Production
With the Partitioning option
JServer Release 8.1.6.0.0 - Production

SVRMGR> connect internal

SVRMGR> SELECT count(*) FROM dba_objects WHERE object_type LIKE 'JAVA%';
SVRMGR> 
  COUNT(*)
----------
      8663

8.1.5 では最低でも 4000、 8.1.6 では最低でも 8000 が返ってこない場合は、 oracle JVM のインストールに失敗していますので、手動で再インストールする必要があります。

java ストアド・プロシージャの開発手順

Hello、Hello2 という java ストアド・プロシージャを作って見ましょう。

モード	説　　　　　　　　　　　　明
ロード後	-resolve はクラスをロードし INVALID をつけ、その後解決します。ロードされていないクラスに依存するクラスは、すべて INVALID です。
ロード時	-andresolve はクラスをロードし解決します。一般的に、このモードはお薦めしません。
解決の延期	上記２つを指定しないと、クラスをロードしますが、コンパイルも解決もしません。INVALID がついたクラスを call すると、リゾルバが実行され、解決されたものは VALID に変更されます。

JVM の例外処理

java ストアド・プロシージャが SQL 文を実行中に例外を検出すると、そのプロシージャに対して java.sql.SQLException のサブクラスとしてインスタンス化された例外が投げられます。

この例外クラスには、getErrorCode() と getMessage() メソッドがあり、これらを使って Oracle エラーコードとエラーメッセージを得られます。

SQL や PL/SQL からコールされたストアド・プロシージャでキャッチされない例外が発生した場合は、次のエラーメッセージがでます。

ORA-29532 不明な Java 例外で Java コールが終了しました：<文字列>

<文字列> には java からのエラーが入ります。

java ストアド・プロシージャの例

java でデータベースにアクセスするプログラムを作り、コール仕様を宣言し、svrmgr から呼んでみましょう。

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

class Emp {
  public static void delEmp(String cond)  throws SQLException {
     String defconn = "jdbc:default:connection:";
     Emp    e = new Emp();
     int    len;

     len = e.chkarg(cond);
     if (len == 0) return;
     Connection conn = DriverManager.getConnection(defconn);
     String sql      = "DELETE FROM EMP WHERE " + cond;
     System.out.println("SQL = " + sql);
     try {
       Statement  stmt = conn.createStatement();
       stmt.executeUpdate(sql);
       stmt.close();
     } catch (SQLException ex) {System.err.println(ex.getMessage());}
  }
  public static void main(String[] args ) throws SQLException {
     Emp e = new Emp();
     if (args.length != 0)   System.out.println("len = " + e.chkarg(args[0]));
  }
  int chkarg(String arg) {
     int len;

     try {
        len =  arg.length();
        if (len == 0 )  {
           System.out.println("chkarg : arg is null");
           return 0;
        }
     }  catch (Exception e) {
        System.out.println("chkarg : Exception= "+e.toString());
        System.out.flush();
        return 0;
     }
     return len;
   }
}

class ROWcnt {
  public static int CountROW(String tblNM)  throws SQLException {
     String defconn  = "jdbc:default:connection:";
     String sql_base = "SELECT COUNT(*) FROM ";
     String tbl_emp  = "EMP";
     String sql,tblnm  ;
     Emp    e = new Emp();
     int    rows = 0,tlen;

     tblnm = tbl_emp;
     tlen  = e.chkarg(tblNM);
     if (tlen != 0)   tblnm = tblNM;

     sql = sql_base + tblnm;
     System.out.println("SQL = " + sql + ": tblnm = "+ tblnm);
     System.out.flush();
     Connection conn = DriverManager.getConnection(defconn);
     try {
       Statement  stmt = conn.createStatement();
       ResultSet  rset = stmt.executeQuery(sql);
       while (rset.next())  { rows = rset.getInt(1);}
       rset.close();
       stmt.close();
     } catch (SQLException ex) {System.err.println(ex.getMessage());}
     return rows;
  }

  public static void main(String[] args) throws SQLException {
     Emp e = new Emp();

     if (args.length  != 0)  System.out.println("len = " + e.chkarg(args[0]));
  }
}

SVRMGR> create or replace PROCEDURE delEmp (table_name IN VARCHAR2)
     2> as language java name 'Emp.delEmp(java.lang.String)';
     3> /
文が処理されました。

SVRMGR> create or replace FUNCTION cntRow (table_name IN VARCHAR2) return NUMBER
     2> as language java name 'ROWcnt.CountROW(java.lang.String) return int';
     3> /
文が処理されました。

SVRMGR> select ename,sal from emp;
ENAME      SAL
---------- ----------
SMITH             800
ALLEN            1600
WARD             1250
JONES            2975
MARTIN           1250
BLAKE            2850
CLARK            2450
SCOTT            3000
KING             5000
TURNER           1500
ADAMS            1100
JAMES             950
FORD             3000
MILLER           1300
14 行選択されました。

SVRMGR> call delEmp('sal >1500');
文が処理されました。
SQL = DELETE FROM EMP WHERE sal >1500

SVRMGR> select ename,sal from emp;
ENAME      SAL
---------- ----------
SMITH             800
WARD             1250
MARTIN           1250
TURNER           1500
ADAMS            1100
JAMES             950
MILLER           1300
7 行選択されました。

SVRMGR> @callRow
文が処理されました。
SQL = SELECT COUNT(*) FROM emp: tblnm = emp
ROWNO
----------
         7

---- callRow.sql --------------
variable rowno NUMBER
call cntRow('emp') into :rowno;
print rowno;

JServer 用メモリ初期化パラメータ

Java はヒープをクラスのロード域とオブジェクトの格納域の両方として使用します。
(オブジェクト格納域は、一般的に new したオブジェクト用格納域です)

一方、JServer はヒープを２つに分けて使用します。クラスのロード域としては shared_pool を使用し、オブジェクトの格納域としては、専用サーバの場合は UGA を、マルチスレッドサーバの場合は java_pool を使用します。

init.ora で変更できる JServer のメモリ初期化パラメータは、以下のとおりです。

パラメータ名	説　　　　　　　　　　明
shared_pool_size	JServer のクラス・ローダがクラスのロード用として使います。
java_pool_size	JServer のメモリ・マネージャが使います。 MTS の場合は、実行時のオブジェクトを格納するのに使いますが、専用サーバの場合は、ここを使わず UGA を使います。
java_soft_sessionspace_limit	１つのセッション期間中、java のメモリ使用量がこれを超えると、警告をトレース・ファイルに書きこみます。デフォルトは 1MB です。
java_max_sessionspace_size	使用可能なセッション領域のハード・リミットを設定します。 java のメモリ使用量がセッション期間中このサイズを超えると、メモリ不足障害エラーが発生します。デフォルトは 4GB です。

これらのパラメータを確認する方法は、以下のとおりです。

svrmgrl
SVRMGR> connect internal
SVRMGR> show parameter session;
NAME                                TYPE    VALUE
----------------------------------- ------- ------------------------------
java_max_sessionspace_size          整数値  0
java_soft_sessionspace_limit        整数値  0
license_max_sessions                整数値  0
license_sessions_warning            整数値  0
mts_sessions                        整数値  0
session_cached_cursors              整数値  0
session_max_open_files              整数値  10
sessions                            整数値  60

SVRMGR> select * from v$sgastat where pool='java pool';
POOL        NAME                       BYTES
----------- -------------------------- ----------
java pool   free memory                  17989632
java pool   memory in use                 2981888
2 行選択されました。

8.1.6 では、java_max_sessionspace_size、java_soft_sessionspace_limit の値は、正しく表示されません。

ページ	誤	正
3-7	CALL proc	call proc
3-7	CALL func(?,?)	call func(?,?)
4-8		/ (最後の行に追加)
4-14	CALL balance(?)	call balance(?)

用語	意　　　　　　　　　　　　　　　味
JServer	java 対応 oracle 8i データベース・サーバ
Aurora	oracle 8i JVM の名称
セッション	java コードを実行するユーザは、サーバ上でセッションを確立する必要があります。通常、１人のユーザがサーバに接続している期間が１つのセッションになります。
コール	セッション内で java コードを実行すること。
java スキーマ・オブジェクト	java ソース、クラス、リソースの総称

ORA 番号	意　　　　　　　　　味	Page
00904	loadjava で出る場合は oracle JVM が正しくインストールされていないためです。対策：手動で JServer をインストールしてください。
04031	loadjava で出る場合は java_pool_size の不足ですから、多くしてください。メッセージには shared pool と出ますが java_pool_size のことです。
29532	java ストアド・プロシージャ実行中にエラーが検出されました。:XXXX 対策：java からのメッセージ XXX を参考にしてください。
29545	クラスファイルの形式が不正です対策：クラスファイルを作り直して dropjava/loadjava してください。	D:2-20
29549	"jdbc:default:connection:" で接続しているセッションがすでに終了しています。対策：connect しなおしてください。
29552	クラスファイルの形式が不正です対策：クラスファイルを作り直して dropjava/loadjava してください。	D:2-20

例　　　　　　外	意　　　　　　　　　味	Page
oracle.aurora.vm.DeadlockError	スレッド間でデッドロックを検出した	D:2-41
oracle.aurora.vm.LimboError	１つしかないスレッドを中断した	D:2-41
ThreadDeathException	スレッドの実行を停止した	D:2-42
oracle.aurora.awt. UnsupportedOperation	awt を使おうとした。 aurora ではサポートしていません	D:2-28
java.io.IOException	前コールの終了時にクローズした STREAM に対して IO をした。対策：open しなおしてください。	D:2-36
ClassNotFound	コール時に使用するクラスが見つからない対策：コールするクラスで使う全クラスを loadjava する	S:2-5
OutOfMemoryError	JServer が使うヒープ領域がなくなった。対策：Statement,ResultSet などで不要になったものは close() する。

項　　　　　　目	内　　　　　　　　　容
svrmgrl	Total System Global Area に表示時される値に、 java_pool_size 分が含まれていない
svrmgrl	show parameter session; の java_max_sessionspace_size、java_soft_sessionspace_limit の表示される値が正しくない
java.lang.System.arraycopy()	java.lang.NullPointerException が出て正しく動作しない

java ストアド・プロシージャ