こちらの記事で作成したアプリケーションで参照している全国医療機関の医療体制の状況のオープンデータを、ローカル表に定期的に同期してみます。
RESTデータ・ソースの定期的な実装については、以前にこちらの記事で紹介しています。今回はステップバイステップの設定手順ではなく、同期化するための異なるアプローチをいくつか紹介します。
同期化は、東京都世田谷区 - 131121、神奈川県横浜市 - 141003、神奈川県川崎市 - 141305の３つの自治体を対象とします。RESTデータ・ソースの同期化を使う
RESTデータ・ソースのREST同期化を開き、同期スケジュールとステップを定義します。
全国医療機関の医療提供体制の状況のオープンデータは午前１時頃に更新されます（こちらの記載を参照）。ですので、同期処理を午前２時に実施するよう設定します。
間隔ビルダーを開いて、頻度を日、間隔を１（頻度が日なので１日毎）、実行時間に２（午前２時）、実行分を０（０分）として実行間隔の設定を行います。その後、保存をクリックすると次の同期化が更新されます。
間隔ビルダーを開いて、頻度を日、間隔を１（頻度が日なので１日毎）、実行時間に２（午前２時）、実行分を０（０分）として実行間隔の設定を行います。その後、保存をクリックすると次の同期化が更新されます。
以下は次の同期化の表示例です。7月12日の14:30頃の画面表示です。表示は7月12、17:10 UTCとなっています。日本時間としては９時間進めて、7月13日 2:10 になります。2時ちょうどになっていません。
次回スケジュールされている同期化が発生する時点を示します。同期化は、正時から開始して10分ごとに発生します。つまり、同期化は0、10、20、30、40、50の各分に開始しますが、その間には開始しません。０分に実行される同期化は、50分(50分含む)から0分(0分含まず)の間になります。そのため、実行時間を１、実行分を50から59の間に設定すると、次の同期化は午前２時ちょうどになります。
同期スケジュールはサーバー側のタイムゾーンで設定します。ヘルプの情報から、サーバーのタイムゾーンを確認できます。
現在の時刻(サーバー上)を参照します。
RESTデータ・ソースの同期化は、それ自体はDBMS_SCHEDULERのジョブではありません。あらかじめ10分ごとに実行されるようにスケジュールされているジョブより（１度きりのDBMS_SCHEDULERのジョブとして）実行されます。
同期化の対象とする３つの自治体はそれぞれステップとして定義します。
RESTデータ・ソースに指定できるパラメータlocalGovCodeに自治体コードを指定します。sinceは前日の日付を指定します。prefNameはlocalGovCodeが指定済みなので、NULLとします。
東京都世田谷区、神奈川県横浜市、神奈川県川崎市のステップをそれぞれ追加します。
以上で毎日午前２時に対象としている自治体の情報が更新されます。
自動化を使う
プロシージャーAPEX_REST_SOURCE_SYNC.DYNAMIC_SYNCHRONIZE_DATAを呼び出すことで、RESTデータ・ソースのパラメータを動的に指定することができます。
自動化のアクションとして指定するコードは、以下のようになります。バインド変数:LOCAL_GOV_CODEに自治体コードを割り当てます。
declare
l_parameters apex_exec.t_parameters;
l_sync_id varchar2(200);
begin
l_parameters.delete;
apex_exec.add_parameter(
p_parameters => l_parameters,
p_name => 'localGovCode',
p_value => :LOCAL_GOV_CODE );
apex_exec.add_parameter(
p_parameters => l_parameters,
p_name => 'since',
p_value => to_char(sysdate-1,'YYYYMMDD') );
l_sync_id := '同期 - 自治体コード: ' || :LOCAL_GOV_CODE;
apex_rest_source_sync.dynamic_synchronize_data(
p_module_static_id => 'covid19DailySurvey',
p_sync_static_id => l_sync_id,
p_sync_parameters => l_parameters );
end;
自動化のソースのソース・タイプをSQL問合せとし、同期化の対象とする自治体コードをSELECT文の検索結果として返します。以下が自治体コードを返すSELECT文の１例です。local_gov_codeとして３件検索されるので、自動化として登録されているアクションは３回実行されます。
select column_value as local_gov_code from apex_t_varchar2('131121','141003','141305')
自動化をコードから呼び出す
自動化をコードから呼び出すことも可能です。ソースのSQL問合せを動的に変更できます。ただし、これはソース・タイプをSQLを返すファンクション本体としても可能でしょう。
以下が自動化をコードから呼び出す一例です。ファンクションAPEX_EXEC.OPEN_QUERY_CONTEXTとして定義したSQL問合せを自動化の呼び出しに指定します。
declare
l_context apex_exec.t_context;
l_columns apex_exec.t_columns;
l_sql varchar2(4000);
begin
l_sql := q'~
select column_value as local_gov_code from apex_t_varchar2('131121','141003','141305')
~';
dbms_output.put_line(l_sql);
apex_exec.add_column(
p_columns => l_columns,
p_column_name => 'LOCAL_GOV_CODE'
);
l_context := apex_exec.open_query_context(
p_location => apex_exec.c_location_local_db,
p_columns => l_columns,
p_sql_query => l_sql
);
apex_automation.execute(
p_static_id => 'syncdailysurvey',
p_query_context => l_context
);
end;
プロシージャAPEX_AUTOMATION.EXECUTEに自動化の静的IDを与えて呼び出すことにより、コード中より自動化を起動します。残念なことにOracle APEX 21.1では指定したバインド変数に値が渡らないという不具合が見つかっています。そのため、自動化の呼び出しでp_query_contextにSELECT文を指定する使い方は避けるべきです。
以上になります。
Oracle APEXのアプリケーション作成の参考になれば幸いです。
完
