ページの先頭行へ戻る
Big Data Integration ServerV1.4.0 検索編アプリケーション開発ガイド
FUJITSU Software

G.1.5 検索条件に一致するXML文書の値を集計して取得する

検索操作において、検索した結果をある特定の要素の値を集計して取得したい場合があります。


日付と場所を検索条件式に指定して、条件に一致するホテルの件数と、最も高い宿泊費、最も安い宿泊費、宿泊費の平均値を取得する例を用いて、C APIの使用例を示します。


検索条件

「2006年7月18日に宿泊可能なホテルのうち、最も高い宿泊費、最も安い宿泊費、宿泊費の平均値を県別に集計して欲しい。」

年月日(2006年7月18日)を条件に検索を行います。


APIの使用例


以下にC APIを使用したプログラミング例を示します。

#include <stdio.h>

#include "libshun.h"

/* 検索条件に一致するXML文書の値を集計して取得する */
int main()
{
  /* ハンドル変数群 */
  SHUNHCON  connectionHandle;
  SHUNHSTMT statementHandle;

  /* 作業用変数群 */
  int status;
  int i, k;

  /* 入力パラメタ群 */
  char *hostName;
  int portNo;
  char *ShunFileName;
  int startNo;
  int returnRequestCount;
  char *queryForm;
  char *returnForm;
  char *sortForm;

  /* 出力パラメタ群*/
  int hitCount;
  int returnCount;
  int returnableCount;
  SHUNRECID *recID;
  SHUNDATA  *dataInfo;
  SHUNPOS *firstPosition, *lastPosition;

  /* エラー用変数群 */
  SHUNHANDLE errorHandle;
  int errorLevel;
  char *errorMessage;


  /* 変数の初期化 */
  connectionHandle = NULL;
  statementHandle = NULL;

  /* コネクションハンドルの割当て */
  status = ShunAllocHandle( NULL, &connectionHandle );
  if ( status != SHUN_SUCCESS ) {
    errorHandle = (SHUNHANDLE)connectionHandle;
    goto ErrorEnd;
  }

  /* ホスト名・ポート番号、Shunsakuファイル名を指定してコネクションを確立 */
  hostName = "DirSvr1";
  portNo = 23101;
  ShunFileName = "shunsakuFile1";
  status = ShunConnect( connectionHandle, hostName, portNo, ShunFileName );
  if ( status != SHUN_SUCCESS ) {
    errorHandle = (SHUNHANDLE)connectionHandle;
    goto ErrorEnd;
  }

  /* データ操作ハンドルの割当て */
  status = ShunAllocHandle( connectionHandle, &statementHandle );
  if ( status != SHUN_SUCCESS ) {
    errorHandle = (SHUNHANDLE)connectionHandle;
    goto ErrorEnd;
  }

  /* 検索件数、検索式などの指定*/
  startNo = 1;
  returnRequestCount = 30;
  queryForm = "/document/information/date == '2006年07月18日'";
  returnForm =  "/document/base/prefecture/text(),"
    "count(/document/base/prefecture/text()),"
    "max(/document/base/price/text()),"
    "min(/document/base/price/text()),"
    "avg(/document/base/price/text())";
  sortForm = "/document/base/prefecture/text()";

  /* API呼出し データ検索 */
  status = ShunSearch(
    statementHandle,
    startNo,
    NULL,
    0,
    returnRequestCount,
    queryForm,
    returnForm,
    sortForm,
    &hitCount,
    &returnCount,
    &returnableCount,
    &recID,
    &dataInfo,
    &firstPosition,
    &lastPosition );
  if ( status != SHUN_SUCCESS ) {
    errorHandle = (SHUNHANDLE)statementHandle;
    goto ErrorEnd;
  }

  /* ヒット件数の取出し */
  printf( "ヒット件数                = %d\n", hitCount );


  /* 検索したデータの表示 */
  if ( hitCount > 0 ) {
    for (i = 0; i < returnCount; ++i) {
      if ( dataInfo[i].Data_Len > 0 ) {
        /* 検索したデータの整形 \001or\002を空白に変換 */
        for (k = 0; k < dataInfo[i].Data_Len; ++k) {
          switch ( dataInfo[i].Data[k] ) {
          case '\001': dataInfo[i].Data[k] = ' '; break;
          case '\002': dataInfo[i].Data[k] = ' '; break;
          default: break;
          }
        }
        printf( "[結果]%d件目 =%s\n", startNo + i, dataInfo[i].Data);
      }
      else {
        printf( "[結果]%d件目 = データなし\n", startNo + i );
      }
    }
  }

  /* データ操作ハンドルの解放 */
  status = ShunFreeHandle( statementHandle );
  if ( status != SHUN_SUCCESS ) {
    errorHandle = (SHUNHANDLE)statementHandle;
    goto ErrorEnd;
  }

  /* コネクションの切断 */
  status = ShunDisconnect( connectionHandle );
  if ( status != SHUN_SUCCESS ) {
    errorHandle = (SHUNHANDLE)connectionHandle;
    goto ErrorEnd;
  }

  /* コネクションハンドルの解放 */
  status = ShunFreeHandle( connectionHandle );
  if ( status != SHUN_SUCCESS ) {
    errorHandle = (SHUNHANDLE)connectionHandle;
    goto ErrorEnd;
  }

  return 0;



ErrorEnd: /* エラーが発生した際のエラー処理 */

  /* エラー情報の取得 */
  status = ShunGetErrorMessage(errorHandle,
                               &errorLevel, &errorMessage);

  if ( status == SHUN_SUCCESS ) {
    switch ( errorLevel ) {
    case SHUN_ERROR_CONNECTION:
      printf("エラーレベル              = SHUN_ERROR_CONNECTION\n");
      break;
    case SHUN_ERROR_DATA:
      printf("エラーレベル              = SHUN_ERROR_DATA\n");
      break;
    }
    printf("エラーメッセージ          = %s\n", errorMessage);
  }
  else {
    printf("エラーメッセージ取得エラー : %d\n", status);
  }

  /* データ操作ハンドルの解放 */
  if ( statementHandle != NULL ) {
    status = ShunFreeHandle( statementHandle );
    if ( status != SHUN_SUCCESS ) {
      printf("データ操作ハンドル解放エラー : %d\n", status);
    }
  }

  /* コネクションの切断 */
  if ( connectionHandle != NULL) {
    status = ShunDisconnect( connectionHandle );
    if ( status != SHUN_SUCCESS ) {
      printf("コネクション切断エラー : %d\n", status);
     }
  }

  /* コネクションハンドルの解放 */
  if ( connectionHandle != NULL) {
    status = ShunFreeHandle( connectionHandle );
    if ( status != SHUN_SUCCESS ) {
      printf("コネクションハンドル解放エラー : %d\n", status);
    }
  }

  return 1;
}

実行結果


ヒット件数              = 6
[結果]1件目 = 神奈川 3 8000 6000 7000
[結果]2件目 = 大阪 3 9000 6000 7500