スケーラブルデータベースサーバ HiRDB Version 8 UAP開発ガイド
FETCH文で,INTO句に配列型の埋込み変数を指定するか,又はBY句の埋込み変数に検索行数を指定すると,検索結果を一度に複数行取得できます。HiRDBクライアントからHiRDBシステムにアクセスし,大量のデータを検索する場合に有効です。ブロック転送機能とは異なり,複数行の検索結果を取得することをプログラム内で明示的に記述します。
FETCH文のINTO句に指定した埋込み変数と標識変数を,すべて配列型の変数にしてください。一括して検索する行数は,指定した埋込み変数の最小配列要素数となります。
次に示す手順で実行してください。
配列を使用したFETCH機能のコーディング例について説明します。
long sel_cnt; long data_cnt; short i; char work[17]; /* 配列型の埋込み変数の宣言 */ EXEC SQL BEGIN DECLARE SECTION; char xscode[50][5]; SQL TYPE IS VARCHAR(17) xsname[50]; char xcol[50][3]; long xtanka[50]; long xzsuryo[50]; EXEC SQL END DECLARE SECTION; EXEC SQL DECLARE CR3 CURSOR FOR SELECT SCODE,SNAME,COL,TANKA,ZSURYO FROM ZAIKO; EXEC SQL WHENEVER SQLERROR GOTO FIN; EXEC SQL OPEN CR3; /* 見出し */ printf(" ***** 在庫表 リスト *****\n\n"); printf(" 商品コード 商品名 色 単価 現在庫量\n"); printf(" ---- ---------------- -- -------- --------\n"); EXEC SQL WHENEVER SQLERROR GOTO OWARI; EXEC SQL WHENEVER NOT FOUND GOTO OWARI; /* FETCH */ sel_cnt = 0; for(;;){ EXEC SQL FETCH CR3 INTO :xscode,:xsname,:xcol,:xtanka,:xzsuryo; /* SQLERRD2にはこのカーソルで検索したトータル行数を格納 */ data_cnt = SQLERRD2 - sel_cnt; /* 取得した行数を求める */ for(i=0; i < data_cnt; i++){ memcpy(work, xsname[i].str, xsname[i].len); work[xsname[i].len] = '\0'; printf(" %4s %-16s %2s %8d %8d\n", xscode[i], work, xcol[i], xtanka[i], xzsuryo[i]); } sel_cnt = SQLERRD2; } OWARI: /* */ /* エラー発生時,及びNOT FOUND発生時でも,データが読み込まれて */ /* いるため,残りのデータを表示する */ /* */ if(sel_cnt != SQLERRD2 ){ data_cnt = SQLERRD2 - sel_cnt; for(i=0; i < data_cnt; i++){ memcpy(work, xsname[i].str, xsname[i].len); work[xsname[i].len] = '\0'; printf(" %4s %-16s %2s %8d %8d\n", xscode[i], work, xcol[i], xtanka[i], xzsuryo[i]); } } FIN: EXEC SQL WHENEVER SQLERROR CONTINUE; EXEC SQL CLOSE CR3; EXEC SQL COMMIT;
#include <pdbsqlda.h> /* ユーザ定義のSQLDAを */ /* 使用するためにincludeする。*/ long sel_cnt; long data_cnt; short i; char work[17]; /* ユーザ定義SQLDAの宣言 */ PDUSRSQLDA(5) xsqlda; /* 配列型の埋込み変数の宣言 */ EXEC SQL BEGIN DECLARE SECTION; char xscode[50][5]; SQL TYPE IS VARCHAR(17) xsname[50]; char xcol[50][3]; long xtanka[50]; long xzsuryo[50]; short arry_num; EXEC SQL END DECLARE SECTION; EXEC SQL WHENEVER SQLERROR GOTO FIN; /* 検索SQLの前処理実行 */ EXEC SQL PREPARE SEL1 FROM 'SELECT * FROM ZAIKO' ; /* 検索SQLの出力情報取得 */ PDSQLN(xsqlda) = 5 ; /* SQLVAR数を設定 */ EXEC SQL DESCRIBE SEL1 INTO :xsqlda ; EXEC SQL DECLARE CR3 CURSOR FOR SEL1 ; EXEC SQL OPEN CR3; /* SQLVARの設定:本来であれば,I/O領域をSQLDAから動的に確保した */ /* 方がよいが,例題のため省略する */ /* SQLLEN,SQLXDIM,SQLSYSはDESCRIBE時に設定される値を使用する。 */ /* SCODE列情報設定 */ PDSQLDATA(xsqlda, 0) = (void *)xscode ; /* アドレス設定 */ PDSQLIND(xsqlda, 0) = NULL ; /* 標識変数NULLクリア */ PDSQLCOD(xsqlda, 0) = PDSQL_CHAR ; /* データコード設定 */ /* SNAME列情報設定 */ PDSQLDATA(xsqlda, 1) = (void *) xsname; /* アドレス設定 */ PDSQLIND(xsqlda, 1) = NULL ; /* 標識変数NULLクリア */ PDSQLCOD(xsqlda, 1) = PDSQL_VARCHAR ; /* データコード設定 */ PDSQLSYS(xsqlda, 1) = sizeof(xsname[0]) ; /* 可変長なのでSQLSYSを*/ /* 設定 */ /* COL列情報設定 */ PDSQLDATA(xsqlda, 2) = (void *) xcol; /* アドレス設定 */ PDSQLIND(xsqlda, 2) = NULL ; /* 標識変数NULLクリア */ PDSQLCOD(xsqlda, 2) = PDSQL_NCHAR ; /* データコード設定 */ /* TANKA列情報設定 */ PDSQLDATA(xsqlda, 3) = (void *) xtanka; /* アドレス設定 */ PDSQLIND(xsqlda, 3) = NULL ; /* 標識変数NULLクリア */ PDSQLCOD(xsqlda, 3) = PDSQL_INTEGER ; /* データコード設定 */ /* GSURYO列情報設定 */ PDSQLDATA(xsqlda, 4) = (void *) xzsuryo; /* アドレス設定 */ PDSQLIND(xsqlda, 4) = NULL ; /* 標識変数NULLクリア */ PDSQLCOD(xsqlda, 4) = PDSQL_ INTEGER; /* データコード設定 */ /* 見出し */ printf(" ***** 在庫表 リスト *****\n\n"); printf(" 商品コード 商品名 色 単価 現在庫量\n"); printf(" ---- ---------------- -- -------- --------\n"); EXEC SQL WHENEVER SQLERROR GOTO OWARI; EXEC SQL WHENEVER NOT FOUND GOTO OWARI; /* FETCH */ sel_cnt = 0; for(;;){ arry_num = 50 ; EXEC SQL FETCH CR3 USING DESCRIPTOR :xsqlda BY :arry_num ROWS ; /* SQLERRD2にはこのカーソルで検索したトータル行数を格納 */ data_cnt = SQLERRD2 - sel_cnt; /* 取得した行数を求める */ for(i=0; i < data_cnt; i++){ memcpy(work, xsname[i].str, xsname[i].len); work[xsname[i].len] = '\0'; printf(" %4s %-16s %2s %8d %8d\n", xscode[i], work, xcol[i], xtanka[i], xzsuryo [i]); } sel_cnt = SQLERRD2; } OWARI: /* */ /* エラー発生時,及びNOT FOUND発生時でも,データが読み込まれて */ /* いるため,残りのデータを表示する */ /* */ if(sel_cnt != SQLERRD2 ){ data_cnt = SQLERRD2 - sel_cnt; for(i=0; i < data_cnt; i++){ memcpy(work, xsname[i].str, xsname[i].len); work[xsname[i].len] = '\0'; printf(" %4s %-16s %2s %8d %8d\n", xscode[i], work, xcol[i], xtanka[i], xzsuryo [i]); } } FIN: EXEC SQL WHENEVER SQLERROR CONTINUE; EXEC SQL CLOSE CR3; EXEC SQL COMMIT;
long sel_cnt; long data_cnt; short i; /* 配列型の埋込み変数の宣言 */ EXEC SQL BEGIN DECLARE SECTION; long xcode[50]; /* BINARY型の配列を使用したFETCHを行う場合は, */ /* 領域長を4の倍数で定義すること */ SQL TYPE IS BINARY(3004) xrow_data[50]; EXEC SQL END DECLARE SECTION; EXEC SQL DECLARE CR3 CURSOR FOR SELECT * FROM T_BINARY; EXEC SQL WHENEVER SQLERROR GOTO FIN; EXEC SQL OPEN CR3; /* 見出し */ printf(" ***** バイナリデータ表 *****\n\n"); EXEC SQL WHENEVER SQLERROR GOTO OWARI; EXEC SQL WHENEVER NOT FOUND GOTO OWARI; /* FETCH */ sel_cnt = 0; for(;;){ EXEC SQL FETCH CR3 INTO : xcode,: xrow_data; /* SQLERRD2にはこのカーソルで検索したトータル行数を格納 */ data_cnt = SQLERRD2 - sel_cnt; /* 取得した行数を求める */ for(i=0; i < data_cnt; i++){ printf(" CODE=%8d\n",xcode[i]); printf(" DATA_LENGTH=%d\n", xrow_data [i].len); /* BINARYデータ部の表示は例題のため行わない。 */ /* xrow_data[i].strを各UAP固有の形式に変換すること */ } sel_cnt = SQLERRD2; } OWARI: /* */ /* エラー発生時,及びNOT FOUND発生時でも,データが読み込まれて */ /* いるため,残りのデータを表示する */ /* */ if(sel_cnt != SQLERRD2 ){ data_cnt = SQLERRD2 - sel_cnt; for(i=0; i < data_cnt; i++){ printf(" CODE=%8d\n",xcode[i]); printf(" DATA_LENGTH=%d\n", xrow_data [i].len); /* BINARYデータ部の表示は例題のため行わない。 */ /* xrow_data[i].strを各UAP固有の形式に変換すること */ } } FIN: EXEC SQL WHENEVER SQLERROR CONTINUE; EXEC SQL CLOSE CR3; EXEC SQL COMMIT;
#include <pdbsqlda.h> /* ユーザ定義のSQLDAを使用するために */ /* includeする。 */ long sel_cnt; long data_cnt; short i; /* ユーザ定義SQLDAの宣言 */ PDUSRSQLDA(2) xsqlda; /* 配列型の埋込み変数の宣言 */ EXEC SQL BEGIN DECLARE SECTION; long xcode[50]; /* BINARY型の配列を使用したFETCHを行う場合は, */ /* 領域長を4の倍数で定義すること */ SQL TYPE IS BINARY(3004) xrow_data[50]; short arry_num; EXEC SQL END DECLARE SECTION; EXEC SQL WHENEVER SQLERROR GOTO FIN; /* 検索SQLの前処理実行 */ EXEC SQL PREPARE SEL1 FROM 'SELECT * FROM T_BINARY ; /* 検索SQLの出力情報取得 */ PDSQLN(xsqlda) = 2 ; /* SQLVAR数を設定 */ EXEC SQL DESCRIBE SEL1 INTO :xsqlda ; EXEC SQL DECLARE CR3 CURSOR FOR SEL1 ; EXEC SQL OPEN CR3; /* SQLVARの設定:本来であれば,I/O領域をSQLDAから動的に確保した*/ /* 方がよいが,例題のため省略する */ /* SQLLEN,SQLXDIM,SQLSYSはDESCRIBE時に設定される値を使用する。 */ /* XCODE列情報設定 */ PDSQLDATA(xsqlda, 0) = (void *)xcode ; /* アドレス設定 */ PDSQLIND(xsqlda, 0) = NULL ; /* 標識変数NULLクリア */ PDSQLCOD(xsqlda, 0) = PDSQL_INTEGER ; /* データコード設定 */ /* R_DATA列情報設定 */ PDSQLDATA(xsqlda, 1) = (void *) xrow_data; /* アドレス設定 */ PDSQLIND(xsqlda, 1) = NULL ; /* 標識変数NULLクリア */ PDSQLCOD (xsqlda, 1) = PDSQL_BINARY ; /* データコード設定*/ PDSQLLEN (xsqlda, 1) = 3004 ; /* 定義長が4の倍数で */ /* ないため再設定する */ /* 見出し */ printf(" ***** バイナリデータ表 *****\n\n"); EXEC SQL WHENEVER SQLERROR GOTO OWARI; EXEC SQL WHENEVER NOT FOUND GOTO OWARI; /* FETCH */ sel_cnt = 0; for(;;){ arry_num = 50 ; EXEC SQL FETCH CR3 USING DESCRIPTOR :xsqlda BY :arry_num ROWS ; /* SQLERRD2にはこのカーソルで検索したトータル行数を格納 */ data_cnt = SQLERRD2 - sel_cnt; /* 取得した行数を求める */ for(i=0; i < data_cnt; i++){ printf(" CODE=%8d\n",xcode[i]); printf(" DATA_LENGTH=%d\n", xrow_data [i].len); /* BINARYデータ部の表示は例題のため行わない。 */ /* xrow_data[i].strを各UAP固有の形式に変換すること */ } sel_cnt = SQLERRD2; } OWARI: /* */ /* エラー発生時,及びNOT FOUND発生時でも,データが読み込まれて */ /* いるため,残りのデータを表示する */ /* */ if(sel_cnt != SQLERRD2 ){ data_cnt = SQLERRD2 - sel_cnt; for(i=0; i < data_cnt; i++){ printf(" CODE=%8d\n",xcode[i]); printf(" DATA_LENGTH=%d\n", xrow_data [i].len); /* BINARYデータ部の表示は例題のため行わない。 */ /* xrow_data[i].strを各UAP固有の形式に変換すること */ } } FIN: EXEC SQL WHENEVER SQLERROR CONTINUE; EXEC SQL CLOSE CR3; EXEC SQL COMMIT;
All Rights Reserved. Copyright (C) 2006, 2016, Hitachi, Ltd.