dblinkを介したPL / SQL

メタリンクについては、誰もが解決策がないと言いました...

オラクルはそれができません...

カスタムソリューションを実装したことがありますか？ Oracleはどうですか？ DBMSの原理をよりよく理解し、開発者に利便性を提供するためのテクニックの使用を検討したいと思います。





単一のスペースでデータベースアプリケーションの開発を実行し、バックグラウンドでシステムのランドスケープに結果を転送し、変更を自動的に記録する方がはるかに便利です。



開発サーバーでの更新の例

プロローグ

有害なDBAに会ったことがありますか？ あなたはそのような人々と働いたことがありますか？ 実際、両方の側（開発者とDBA）は、システムの健全性という同じ結果を、異なる側から達成しています。 ただし、システムが拡張されると、分散化されますが、実装の整合性は維持されます。そのため、ソフトウェアの一貫した状態を維持すると、深刻な不便が生じ始めます。 開発、テスト、「生産的な」サーバーがあります。これらはすべてすばらしいですが、すべて更新する必要があります。

Oracleには、問題のツールと同様のツールがあります。

• 監査

• Oracle Streams

• アラート

しかし、それらはすべて他の機能を実行します。 変更の監査を提供するものもあれば、データを同期するものもあります。 そして、私はより透明に行動したいと思います、例えば：

connect developer@dev begin UpdateServer('prod'); end; / create table a as select * from dual; declare v_id char:='Y'; v_cnt number; begin select count(rownum) into v_cnt from a; if v_cnt = 1 then insert into a values (v_id); end if; end; / begin CommitUpdate; end; /
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

これで、すべてのアクションが「prod」サーバーで複製されます。 または、このように：

 begin UpdateFilials; end; /
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

そして、たとえば、7台のサーバーがテーブル「A」を作成しました。 素晴らしいですか？ それでは-行こう

準備する

次のアクションに十分な権限を持つユーザーに代わってデータベースに接続します。

 connect system/***@orcl Connected. select banner from v$version; BANNER -------------------------------------------------------------------------- Oracle Database 11g Release 11.2.0.1.0 - 64bit Production
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

更新を実行するユーザーは、更新システム自体にアクセスすることはできませんが、システム自体がターゲットスキームに関連付けられていないのと同様に、普遍的に使用できると想定されています。 したがって、新しいユーザーを作成します。

 create user upd identified by pass; User created.
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

この記事は新規ユーザーの権利を制限するものではないため：

 grant dba to upd; Grant succeded. connect upd/pass Connected.
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

研究についての議論を省略し、最も難しいことは、上記の例で示した匿名のPL / SQLブロックを取得することでした。 当然、一部のアクションは最終的に他のアクションを引き起こします。たとえば、例のすべての同じブロックが挿入を実行しますが、実際にはそうではない場合があります。 結局、別のサーバーで実行されます。 したがって、結果ではなく、匿名のPL / SQLブロックが私たちの興味を引くでしょう。 V $ SQLのパブリックシノニムまたはそれが参照するビューV_ $ SQLは、サーバーで実行されているすべてのクエリを格納します。 目標を見つけてみましょう。

 set linesize 90 begin raise_application_error(-20000, 'Find me'); end; / select sql_id from v$sql where sql_text like '%error(-20000, ''Find%'; SQL_ID ------------- 753c9f808k8hh 1 row selected.
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

実際、あるべき場所にあるのは私の匿名ブロックです。 もちろん、私の例を実行すると、SQL_IDは異なりますが、それは私に属しますか？ チェック：

 connect system/*** begin raise_application_error(-20000, 'Find me'); end; / select sql_id from v$sql where sql_text like '%error(-20000, ''Find%'; SQL_ID ------------- 753c9f808k8hh 1 row selected.
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

いいえ、所属していません。オプティマイザーはそのような式が既に実行されていることを確認し、登録済みのSQL_IDを返します。 私たちはフィールドでの研究をマークし、研究を続けます：

 connect upd/pass Connected.
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

完成したブロックを見つけることができましたが、誰がそれを実行したかを知りたいのですが、むしろ、特定の時点で何をしていたのかを正確に知りたいと思います。 V_ $ SESSIONの別のビューは、これに役立ちます。

v $セッションからsql_id、prev_sql_idを選択します。

ここでは、シノニムv $セッションがVIEWへのアクセスを提供し、ユーザーのアクセスがコマンドによって編成されていることを明確にする必要があります。

vd $セッションの選択をupdに許可します。

ここでのポイントは、ビュータイプv_ $セッションがFIXED VIEWであるため、同義語に権利を与えることは禁止されていることです。 ただし、テーブルなどのシノニムに権限を付与する場合、権限自体はシノニムではなくテーブルに対して発行されます。

それで、リクエストには何がありますか？ はい、現在のセッションに選択を制限する必要があります。

 select sid, sql_id, prev_sql_id from v$session where sid = userenv('sid'); SID SQL_ID PREV_SQL_ID ---------- ------------- ------------- 95 54mqd9bcxw8nh 753c9f808k8hh
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

どうですか、うまくいきませんか？ SQL_IDもPREV_SQL_IDにも、以前に見つかった識別子753c9f808k8hhが含まれていませんか？ 当然！ SQL_IDには、新しく実行されたクエリの識別子が含まれ、PREV_SQL_IDにはクエリの識別子が格納される可能性が最も高くなります。

 select sql_id, prev_sql_id from v$session;
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

読者が引用したとおりにリクエストを順番に実行し、期待される内容をすぐに見つけられなかったことを願っています。 結果が示されたとおりであることを確認するには、順番に匿名ブロックとビューのリクエストを実行する必要があります。 それがそうであっても、私は研究の別の段階が完了したと信じています。 これで、匿名ブロックのソーステキストが得られ、それが私たちによって実行されたことがわかりました。

残念ながら、リンクを自動化するソリューションは好きではありません。ある瞬間の後、ユーザーによって実行されたすべての可能な匿名ブロックを覚えておく必要があり、セッション履歴を保存するユーザーの表現がないからです。 それとも存在しますか？ しかし、現時点ではそれを見つけていません。次のアプローチをお勧めします。 リスニングに関心のあるセッションの識別子を保存するテーブルと、このテーブルをポーリングしてセッション履歴を保存するジョブを作成しましょう。

 CREATE TABLE UPD.UPD$SESSION_TARGETS (SID NUMBER); Table created. CREATE TABLE UPD.UPD$SESSION_DATA ( KSUSENUM NUMBER, KSUSEUNM VARCHAR2 (30 BYTE), KSUSEMNM VARCHAR2 (64 BYTE), KSUSESQI VARCHAR2 (13 BYTE), KSUSEPSI VARCHAR2 (13 BYTE) ); Table created.
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

「2番目のテーブルのフィールドの名前は何ですか？」と尋ねます。 これには良い言い訳はありませんが、ジョブによって作成される負荷を最小限にしようとしているという事実にもかかわらず、ターゲットセッションに関する十分な情報を含む高レベルのsys.x_ $ ksuseのアイデアに到達しました。 将来のブックマークを作成すると、必要なフィールドに加えて、KSUSENUM（SID）とKSUSESQI（SQL_ID）のいくつかの便利なフィールドがテーブルに保存されます。 パッケージが有効でない場合にエラーを回避するために、ジョブの本体を外部プロシージャに配置し、パッケージに追加しないことをお勧めします。

 CREATE OR REPLACE procedure UPD.UPD$JobTask is v_cnt number; begin loop select count(rownum) into v_cnt from upd.upd$session_targets; if (v_cnt = 0) then select count(ksusenum) into v_cnt from upd.upd$session_data; if (v_cnt > 0) then execute immediate 'truncate table upd.upd$session_data'; end if; continue; end if; INSERT INTO upd.upd$session_data (KSUSENUM, KSUSEUNM, KSUSEMNM, KSUSESQI, KSUSEPSI) SELECT ksusenum, ksuseunm, ksusemnm, ksusesqi, ksusepsi FROM sys.x_$ksuse WHERE ksusenum IN (SELECT ust.sid FROM upd.upd$session_targets ust) MINUS SELECT ksusenum, ksuseunm, ksusemnm, ksusesqi, ksusepsi FROM upd.upd$session_data; commit; end loop; end UPD$JobTask; / Procedure created.
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

処理のアイデアは、そのときだけセッション履歴に書き込み、更新モードでユーザーが実行したことだけに書き込むことです。 これで、ジョブを作成し、ユーザーセッションをリッスンして結果を確認できます。

 DECLARE X NUMBER; BEGIN SYS.DBMS_JOB.SUBMIT ( job => X ,what => 'begin /*UPD$SESSION_JOB*/ UPD$JobTask; end;' ,next_date => SYSDATE ,interval => 'SYSDATE + 1/1444' ,no_parse => FALSE ); COMMIT; END; / PL/SQL procedure successfully completed. insert into upd.upd$session_targets values (userenv('sid')); 1 row created. begin raise_application_error(-20000, 'Find me'); end; / Error at line 3 ORA-20000: Find me ORA-06512: at line 2 truncate table upd.upd$session_targets; Table truncated. select KSUSEPSI from upd.upd$session_data; KSUSEPSI ------------- 753c9f808k8hh 1 row selected. select sql_text from v$sql where sql_id = '753c9f808k8hh'; SQL_TEXT ---------------------------------------------------------------------------- begin raise_application_error(-20000, 'Find me'); end; 1 row selected.
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

V $ SQLへのクエリの結果からわかるように、匿名ブロックはジョブによってそこに書き込まれたログテーブルに入りました。 テストでは、リスニング時にセッションテーブルをクリアするコマンドを実行しなければならなかったため、ログ（以前の要求）のKSUSEPSI列に目を向けました。 将来的には、これも何らかの欠点になることが判明しますが、リモートサーバーで実行される結果セットからのリスニングの「中断」を排除します。

次に、アップグレード中に実行できるDLLコマンドをアセンブルする必要があります。 しかし、ここで矛盾があります。なぜDDLを収集するのですか-ジョブがそれらを収集する場合はどうでしょうか。 残念ながら、DDLはリクエストではないため、彼はそれらを収集しません。したがって、v $セッションには反映されません。 これらの目的のために、Oracleは使用可能なDBMSレベルのトリガーを提供しています。 実行されたDDLを新しいテーブルに書き込み、ジョブと同様に、プロシージャとそれを実行するトリガーを作成します。

 CREATE GLOBAL TEMPORARY TABLE upd.UPD$BUF ( ALIAS_OBJ VARCHAR2 (500 CHAR), SQLTEXT CLOB, OBJNAME VARCHAR2 (30 BYTE) ) ON COMMIT PRESERVE ROWS; Table created. CREATE OR REPLACE PROCEDURE upd.T_PROC_UPD$DDL AUTHID DEFINER AS osuser varchar2(30); machine varchar2(64); cnt number; V_SQL_OUT ORA_NAME_LIST_T; V_SQL_STATEMENT CLOB; V_NUM NUMBER; v_sqlerrm varchar2(2000); BEGIN SELECT count(rownum) INTO cnt FROM upd$session_targets ust WHERE ust.sid = userenv('sid'); if cnt = 0 then return; end if; V_NUM := ORA_SQL_TXT(V_SQL_OUT); FOR I IN 1 .. V_NUM LOOP V_SQL_STATEMENT := V_SQL_STATEMENT || V_SQL_OUT(I); END LOOP; INSERT INTO UPD$BUF (ALIAS_OBJ, SQLTEXT, OBJNAME) VALUES (NULL, V_SQL_STATEMENT, ora_dict_obj_name); EXCEPTION WHEN OTHERS THEN raise_application_error(-20000, SQLERRM); END T_PROC_UPD$DDL; / Procedure created. CREATE OR REPLACE TRIGGER upd.T_UPD$DDL AFTER DDL ON DATABASE BEGIN T_PROC_UPD$DDL; END; / Trigger created.
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

追加のテーブルとそのタイプ（切断されるまでデータを保存するGLOBAL TEMPORARY）は、次の考慮事項から選択されます：セッション情報を収集するジョブは、更新スクリプトを実行するセッションとは異なるセッションで機能するため、それに書き込まれた要求は実行者のセッションにアクセスできなくなります; Oracleにアップグレード後のテーブルのクリーニングを提供します。 DDLトリガーは、DDLが実行される同じセッションで起動します。したがって、この場合、バッファテーブルに直接書き込むことができます。 コミット後にテーブルデータを保存するのは、DDLがサイレントコミットを実行するためです。

プロシージャがAUTHID DEFINERディレクティブを使用して宣言されているという事実に注意することが重要です。これにより、呼び出し側のアクションよりも大きいUPDユーザー権限でアクションを記録できます。 次に、DDLの長さを決定し、CLOBフィールドにバッファーを保存します。

トリガーは（AFTER）DDLの後に実行されます。これは、バッファーに書き込む前に、コマンドが正常に実行されたことを意味します。

調査を要約すると、更新されたベースで実行される可能性のあるすべての種類の操作があり、最終段階である更新ツールに進むことができます。

実装

長い議論と準備を終えて「次のようなもので終わる出版物は好きではありません。今、（ばかではないにしても）、残りのゴミをどうやって仕上げるか」 もちろん、愚か者もいます-いいえ、誰もが次に何をする必要があるかを長い間理解しています。 しかし、ベータ版と見なすことができるという事実にもかかわらず、現在の実装を提供します。 今、多くのコード、そして説明：

 CREATE SEQUENCE UPD.UPD$SEQ_LOG START WITH 0 MAXVALUE 9999999999999999999999999999 MINVALUE 0 NOCYCLE NOCACHE NOORDER; Sequence created. CREATE SEQUENCE UPD.UPD$SEQ_REV START WITH 0 MAXVALUE 9999999999999999999999999999 MINVALUE 0 NOCYCLE NOCACHE NOORDER; Sequence created. CREATE TABLE UPD.UPD$LOG ( ID_LOG NUMBER, DAT_LOG DATE, FQDN_UNAME_OBJ VARCHAR2 (1000 CHAR), ALIAS_OBJ VARCHAR2 (500 CHAR), SQL_TEXT CLOB, ID_REV NUMBER, SQLERRM_LOG VARCHAR2 (2000 CHAR) ); Table created. CREATE TABLE UPD.UPD$SERVERS ( ALIAS_OBJ VARCHAR2 (500 CHAR), DBLINK_OBJ VARCHAR2 (500 CHAR), USERNAME VARCHAR2 (64 CHAR), CALLBACK_DBLINK_OBJ VARCHAR2 (500 CHAR) ); Table created. CREATE OR REPLACE PACKAGE UPD$ AUTHID CURRENT_USER AS procedure BeginUpdateChannel(u_alias varchar2); procedure PrepareUpdateChannel; procedure EndUpdateChannel; procedure CancelUpdate; END UPD$; / Package created. CREATE OR REPLACE PACKAGE BODY UPD$ AS pkg_active_alias varchar2(500); pkg_prepared_alias varchar2(500):=null; pkg_session number:=null; pkg_dblink varchar2(500):=null; pkg_callback_dblink varchar2(500):=null; procedure SetSession(u_sid number, u_remove boolean default false) as pragma autonomous_transaction; l_sid_count number; begin if u_sid is null then raise_application_error(-20550, 'Needless to set'); end if; select count(rownum) into l_sid_count from upd.upd$session_targets ust where ust.sid = u_sid; if l_sid_count = 0 then insert into upd.upd$session_targets (sid) values (u_sid); commit; pkg_session:=u_sid; elsif u_remove then delete from upd.upd$session_targets ust where ust.sid = u_sid; commit; pkg_session:=null; end if; end SetSession; function JobNumber return number as l_jobid number; begin SELECT a.job INTO l_jobid FROM dba_jobs a WHERE a.what like '%/*UPD$SESSION_JOB*/%'; return l_jobid; EXCEPTION WHEN NO_DATA_FOUND THEN return 0; WHEN OTHERS THEN raise; end JobNumber; procedure JobRun as --TODO: run job is it stopped --v_cnt number:=0; v_job number; begin v_job:=JobNumber; if v_job = 0 then raise_application_error(-20560, 'Unable to find updating job'); end if; --select count(rownum) -- into v_cnt -- from dba_jobs_running a where a.job = v_job; --if v_cnt = 0 then -- dbms_job.run(v_job); -- commit; --end if; end JobRun; procedure SetChannel(u_alias varchar2) as begin SELECT dblink_obj, callback_dblink_obj INTO pkg_dblink, pkg_callback_dblink FROM upd.upd$servers a WHERE upper(a.alias_obj) = upper(u_alias) AND upper(username) = upper(USER); exception when no_data_found then raise_application_error(-20501, 'Unable set channel. Alias '||u_alias||' not found'); when others then raise_application_error(-20500, 'Unable set channel for alias '||u_alias||SQLERRM); end SetChannel; procedure CancelUpdate is begin pkg_active_alias:=null; pkg_prepared_alias:=null; pkg_session:=null; pkg_dblink:=null; execute immediate 'truncate table upd.upd$buf'; delete from upd.upd$session_targets ust where ust.sid = userenv('sid'); end CancelUpdate; procedure BeginUpdateChannel(u_alias varchar2) is begin if pkg_active_alias is not null then raise_application_error(-20500, 'Unable begin update channel. Alias '||u_alias||' allready active.'); end if; SetChannel(u_alias); execute immediate 'truncate table upd.upd$buf'; JobRun; SetSession(userenv('sid'), false); pkg_active_alias:=u_alias; pkg_prepared_alias:=null; end BeginUpdateChannel; procedure PrepareUpdateChannel is begin if pkg_prepared_alias is not null then raise_application_error(-20500, 'Already prepared'); end if; if pkg_active_alias is null then raise_application_error(-20500, 'Needless to prepare'); end if; INSERT INTO upd.upd$buf (ALIAS_OBJ, SQLTEXT) SELECT pkg_active_alias, b.sql_fulltext FROM (select distinct ksusenum, ksusesqi from upd.upd$session_data) a, sys.v_$sql b WHERE a.ksusenum = pkg_session AND a.ksusesqi = b.sql_id AND (trim(upper(sql_text)) not like 'INSERT%' and trim(upper(sql_text)) not like 'UPDATE%' and trim(upper(sql_text)) not like 'DELETE%' and trim(upper(sql_text)) not like 'SELECT%' and trim(upper(sql_text)) not like '%UPD$%' and trim(upper(sql_text)) not like '%AW_TRUNC_PROC%' and trim(upper(sql_text)) not like '%XDB.XDB_PITRIG_PKG%' and sql_text not like '%:B%' and sql_text not like '%:1%' ); SetSession(pkg_session, true); pkg_prepared_alias:=pkg_active_alias; pkg_active_alias:=null; end PrepareUpdateChannel; procedure DropObject(object_name varchar2) is l_owner varchar2(30); l_type varchar2(19); l_purge varchar2(6); begin SELECT OWNER, OBJECT_TYPE, CASE when object_type = 'TABLE' then ' purge' else null end INTO l_owner, l_type, l_purge FROM all_objects WHERE upper(object_name) = upper(DropObject.object_name); execute immediate 'drop '||l_type||' '||DropObject.object_name||l_purge; exception when no_data_found then null; when others then raise; end DropObject; procedure ExecRemote(u_sql varchar2) is c number; r number; begin execute immediate 'begin :1:=dbms_sql.open_cursor@'||pkg_dblink||'(); end;' using out c; execute immediate 'begin dbms_sql.parse@'||pkg_dblink||'(:1, :2, dbms_sql.native); end;' using in c, in u_sql; execute immediate 'begin dbms_sql.close_cursor@'||pkg_dblink||'(:1); end;' using in out c; end ExecRemote; procedure EndUpdateChannel is l_alias varchar2(5000); l_dblink varchar2(500); l_sql varchar2(32000); l_osuser varchar2(30); l_machine varchar2(64); l_log_id number:=null; l_rev_id number:=null; l_error_stack varchar2(30000):=null; l_tmp_tab varchar2(500):=DBMS_RANDOM.STRING('', 8); l_tmp_proc varchar2(500); begin if (pkg_active_alias is null) and (pkg_prepared_alias is null) then raise_application_error(-20500, 'Needless to end'); end if; if pkg_prepared_alias is null then raise_application_error(-20500, 'You must execute PrepareUpdateChannel first'); end if; l_tmp_proc:='up_$proc_'||l_tmp_tab; l_tmp_tab:='up_$tab_'||l_tmp_tab; l_alias:=pkg_prepared_alias; pkg_prepared_alias:=null; begin execute immediate 'create table '||l_tmp_tab||' as select ub.* from upd.upd$buf ub'; execute immediate 'grant select on '||l_tmp_tab||' to '||USER; l_sql:='create table '||l_tmp_tab||' as select * from upd.'||l_tmp_tab||'@'||pkg_callback_dblink; ExecRemote(l_sql); DropObject(l_tmp_tab); l_sql:='create or replace procedure '||l_tmp_proc||' is c number; r number; l_objname varchar2(30); l_sqlforerr varchar2(200); l_error_stack varchar2(30000); begin for c_exec in (select * from '||l_tmp_tab||') loop l_objname:=c_exec.objname; l_sqlforerr:=dbms_lob.substr(c_exec.sqltext, 200); c := dbms_sql.open_cursor(); dbms_sql.parse(c, c_exec.sqltext, dbms_sql.native); r := dbms_sql.execute(c); dbms_sql.close_cursor(c); l_objname:=null; end loop; execute immediate ''drop table '||l_tmp_tab||' purge''; exception when others then execute immediate ''drop table '||l_tmp_tab||' purge''; if l_objname is not null then select replace(wm_concat(text), '','', chr(10)) into l_error_stack from user_errors where name = l_objname; end if; raise_application_error(-20000, ''Obj: ''||l_objname||chr(10)||''SQLERRM: ''||SQLERRM||chr(10)||''Show errors: ''||l_error_stack||chr(10)||''Code: ''||l_sqlforerr); end;'; ExecRemote(l_sql); begin execute immediate 'begin '||l_tmp_proc||'@'||pkg_dblink||'; end;'; commit; exception when others then l_error_stack:=SQLERRM; end; l_sql:='drop procedure '||l_tmp_proc; ExecRemote(l_sql); if l_error_stack is not null then raise_application_error(-20590, null); end if; exception when others then l_dblink:=pkg_dblink; CancelUpdate; DropObject(l_tmp_tab); if sqlcode = -20550 then raise; elsif sqlcode = -20590 then raise_application_error(-20555, 'Error when executing remote SQL'||chr(10)|| 'Compilation errors: ['||l_error_stack||']'); else raise; end if; end; SELECT distinct osuser, machine INTO l_osuser, l_machine FROM v$session WHERE sid = USERENV('sid'); l_rev_id:=UPD$SEQ_REV.NEXTVAL; INSERT INTO upd.upd$log (ID_LOG, DAT_LOG, FQDN_UNAME_OBJ, ALIAS_OBJ, SQL_TEXT, ID_REV, SQLERRM_LOG) SELECT upd$seq_log.nextval, sysdate, l_machine||'\'||l_osuser, pkg_prepared_alias, sqltext, l_rev_id, null FROM upd.upd$buf ub; execute immediate 'truncate table upd.upd$buf'; end EndUpdateChannel; procedure ErrorEnumAccess is begin null; end ErrorEnumAccess; END UPD$; / Package body created.
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

以前に作成したテーブルに、さらに2つが追加されました。1つは正常な更新を確認するために使用され、2つ目はリモートOracleデータベースへの接続をセットアップするために使用されます。

パッケージは、AUTHID CURRENT_USERディレクティブで宣言されます。これにより、パッケージの呼び出し元のユーザー権限でパッケージプロシージャが実行されます。 次に、すべてのパッケージ手順について：

procedure SetSession(u_sid number, u_remove boolean default false)



-スタンドアロントランザクションを使用して、リスニングを開始するテーブルに現在のセッション識別子を書き込みます。

function JobNumber return number



ジョブリスナーの識別子を取得します。

procedure JobRun



ジョブの存在を確認します。

procedure SetChannel(u_alias varchar2)



-リモート接続の設定を受け取り、パッケージのローカル変数に書き込みます。

procedure CancelUpdate



設定を消去し、一時テーブルをクリアします。

procedure BeginUpdateChannel(u_alias varchar2)



-準備プロシージャの呼び出しを組み合わせて、リスニングを開始します。

procedure PrepareUpdateChannel



-リスニングを終了し、ジョブによって収集されたセッションリクエストをバッファテーブルに追加します。 私自身のニーズのために、一生懸命やろうとせず、テスト中に遭遇したDML、選択、サービスコマンドを破棄し、同様にセッションログに記録されるPrepareUpdateChannelプロシージャの呼び出しを行います。

procedure DropObject



クリーニングの補助手順。

procedure ExecRemote



リモートサーバー上のブロックの実行。 この手順は、メカニズムの重要なポイントの1つを実装します。 ここでは、リモートサーバー上でdbms_sqlパッケージが呼び出されます。

procedure EndUpdateChannel



更新の適用。 そしてこれについては別に。



最初の実装オプションは、ここで示したものよりもいくぶん単純だったことを予約します。 実際、動的SQLには、varchar2（宣言に応じて32767文字またはバイト）より長いブロックを実行する機能はありません。 これは完全に真実ではありませんが。 ローカルでは、dbms_sqlはこれを許可しますが、LOBフィールドをリモートサーバーに転送することはできません。 リモートサーバー間でLOBを転送する方法を知っているTom Kite（https://asktom.oracle.com/pls/apex/f?p=100:11:07::::P11_QUESTION_ID:950029833940）に感謝します。 彼が私にもたらした最初の方法がdbms_lob.substrを介して実装され、UPD $ BUFテーブルからCLOBフィールドをループしたことを嬉しく思いました。 このタスクのために彼が提供する2番目の方法は次のようになります。ユーザーを更新する権限を持つ現在のホストでテーブルを作成し、現在のデータベースに接続してリモートテーブル作成を実行します。 ここで、特定の実装のいくつかの欠点を指摘することができます。つまり、更新を引き起こすユーザーが一時テーブルからの選択権限を持たないため、dblinkの承認者と等しくない場合にエラーを起こす可能性があります。 テーブルを動的に作成および削除します。 サーバー間でCLOBを「反転」するときにすでに発生した別の問題は、エラー「ORA-02046：分散トランザクションが既に開始されています」でした。 どうやら、テスト中に、中断されたセッションが発生したか、リモート接続の識別子が開いたままになりました。 この状況を再びシミュレートすることはできませんでしたが、繰り返しを避けるために、呼び出しを行うことを考慮する必要があります。dbms_session.close_database_link（pkg_dblink）;

コピーされたテーブルからコードを実行するために、本質的に同じコードを含む匿名ブロックを生成しようとしましたが、これにより再帰レベルでランタイムエラーが発生しました（SQLレベル2のエラーのようなエラー番号を保存しませんでした）が、プロシージャを作成しましたこの最後の問題を解決することができました。



エンドユーザーに対して、AUTHID DEFINERディレクティブを使用してラッピングプロシージャを作成し、それらを適切なユーザーに呼び出す権利を付与できます。

 create or replace procedure ChannelUpdate(u_alias varchar2) AUTHID DEFINER is begin upd$.BeginUpdateChannel(u_alias); end ChannelUpdate; create or replace procedure ChannelPrepare AUTHID DEFINER is begin upd$.PrepareUpdateChannel; end ChannelPrepare; create or replace procedure ChannelApply AUTHID DEFINER is begin upd$.EndUpdateChannel; end ChannelApply; create or replace procedure ChannelCancel AUTHID DEFINER is begin upd$.CancelUpdate; end ChannelCancel; grant execute on ChannelUpdate to developer; grant execute on ChannelPrepare to developer; grant execute on ChannelApply to developer; grant execute on ChannelCancel to developer; grant select on upd$log to developer;