問合せでのタイムスタンプ関数の使用

タイムスタンプおよび期間の値に対して様々な算術演算を実行できます。

例に従う場合は、「問合せを実行するサンプル・データ」を参照してサンプル・データを表示し、スクリプトを使用してテスト用のサンプル・データをロードします。このスクリプトにより、例で使用する表が作成され、表にデータがロードされます。

例に従う場合は、問合せを実行するサンプル・データを参照してサンプル・データを表示し、OCIコンソールを使用してサンプル表を作成し、JSONファイルを使用してデータをロードする方法を学習します。

式を抽出

EXTRACT式は、タイムスタンプからコンポーネントを抽出します。

extract_expression ::= EXTRACT "(" id FROM expression ")"

FROMキーワードの後の式は、最大で1つのタイムスタンプまたはNULLを返す必要があります。この式の結果がNULLまたは空の場合、EXTRACTの結果もそれぞれNULLまたは空になります。それ以外場合は、そのidで指定されたコンポーネントが返されます。このIDは、YEAR、MONTH、DAY、HOUR、MINUTE、SECOND、MILLISECOND、MICROSECOND、NANOSECOND、WEEK、ISOWEEKのいずれかのキーワードである必要があります。

例1:チケット番号が1762383911861の顧客のフルネームおよび手荷物到着年は何ですか。

SELECT fullName,
EXTRACT (YEAR FROM CAST (bag.bagInfo.bagArrivalDate AS Timestamp(0)))
AS YEAR FROM BaggageInfo bag
WHERE ticketNo=1762383911861

説明:最初にCASTを使用してbagArrivalDateをTIMESTAMに変換してから、タイムスタンプからYEARコンポーネントをフェッチします。

出力:

{"fullName":"Joanne Diaz","YEAR":2019}

例2: 2019年2月の午前10時と午後10時までの間にMIAを経由して移動したすべての手荷物を取得します。

SELECT bag.bagInfo[].tagNum,bag.bagInfo[].flightLegs[].fltRouteSrc,
$t1 AS HOUR FROM BaggageInfo bag,
EXTRACT(HOUR FROM CAST (bag.bagInfo[0].bagArrivalDate AS Timestamp(0))) $t1,
EXTRACT(YEAR FROM CAST (bag.bagInfo[0].bagArrivalDate AS Timestamp(0))) $t2,
EXTRACT(MONTH FROM CAST (bag.bagInfo[0].bagArrivalDate AS Timestamp(0))) $t3
WHERE bag.bagInfo[].flightLegs[].fltRouteSrc=any "MIA" AND
$t2=2019 AND $t3=02 AND ($t1>10 AND $t1<20)

説明:2019年2月の午前10:00から午後10:00の間にMIAを経由して移動したフライトの詳細を知る必要があります。ここでは、多数のフィルタ条件を使用します。まず、フライトはMIAから出発またはMIAを経由して移動しました。到着年は2019年、到着月は2 (2月)です。次に、到着時刻が午前10時から午後10時の間(20時間)であるかどうかでフィルタ処理します。

出力:

{"tagNum":"17657806255240","fltRouteSrc":["MIA","LAX"],"HOUR":16}
{"tagNum":"17657806292518","fltRouteSrc":["MIA","LAX"],"HOUR":16}

例3: 予約コードPQ1M8Nの乗客が手荷物を受け取った年と月がいつですか。

SELECT fullName,
EXTRACT(YEAR FROM CAST (bag.bagInfo.bagArrivalDate AS Timestamp(0))) AS YEAR,
EXTRACT(MONTH FROM CAST (bag.bagInfo.bagArrivalDate AS Timestamp(0))) AS MONTH
FROM BaggageInfo bag WHERE bag.confNo="PQ1M8N"

説明:最初にCASTを使用してbagArrivalDateをTIMESTAMに変換してから、タイムスタンプからYEARコンポーネントとMONTHコンポーネントをフェッチします。

出力:

{"fullName":"Kendal Biddle","YEAR":2019,"MONTH":3}

例4:到着月に基づいて手荷物のデータをグループ化し、その月およびその月に到着した手荷物の数を表示します。

SELECT EXTRACT(MONTH FROM CAST ($bag_arr_date AS Timestamp(0))) AS MONTH,
count(EXTRACT(MONTH FROM CAST ($bag_arr_date AS Timestamp(0)))) AS COUNT
FROM BaggageInfo $bag, $bag.bagInfo[].bagArrivalDate $bag_arr_date
GROUP BY EXTRACT(MONTH FROM CAST ($bag_arr_date AS Timestamp(0)))

説明:手荷物の到着月に基づいて、データをグループ化します。ネストされていない配列を使用して、データをフラット化します。bagInfo配列はフラット化され、手荷物到着日の値が配列からフェッチされます。次に、CASTを使用してbagArrivalDateをTIMESTAMPに変換してから、タイムスタンプからYEARコンポーネントとMONTHコンポーネントをフェッチします。次に、count関数を使用して、各月に対応する合計手荷物を取得します。

ノート:データでは、すべての手荷物が同じ年に届いたという前提があります。したがって、月に基づいてのみデータをグループ化します。

出力:

{"MONTH":2,"COUNT":11}
{"MONTH":3,"COUNT":10}

timestamp_add()関数

タイムスタンプ値に期間を追加し、新しいタイムスタンプを返します。期間は、プラスまたはマイナスにすることができます。結果型はTIMESTAMP(9)です。

構文:

TIMESTAMP(9) timestamp_add(TIMESTAMP timestamp, STRING duration)

セマンティクス:

TIMESTAMP: TIMESTAMP値、またはTIMESTAMにキャストできる値。
duration: [-](<n> <UNIT>)+という形式の文字列。ここで、nは数値で、UNITはYEAR、MONTH、DAY、HOUR、MINUTE、SECOND、MILLISECOND、NANOSECONDまたはこれらのキーワードの複数形(YEARSなど)です。

ノート: UNITキーワードの大/小文字は区別されません。

戻り値: TIMESTAMP(9)

例1: 航空会社アプリケーションにおいて、5分の遅延のバッファを定時とみなします。チケット番号1762399766476の乗客に関して、5分のバッファを含んで最初の区間の推定到着時間を出力します。

SELECT timestamp_add(bag.bagInfo.flightLegs[0].estimatedArrival, "5 minutes")
AS ARRIVAL_TIME FROM BaggageInfo bag
WHERE ticketNo=1762399766476

説明:航空会社アプリケーションでは、発送元と着信先に応じて顧客にフライト区間にいくつあげてもかまいません。前述の問合せでは、移動の第1区間での推定到着をフェッチしています。そのため、flightsLeg配列の最初のレコードがフェッチされ、その配列からestimatedArrival時間がフェッチされ、その時間のバッファに5分のバッファが追加されて表示されます。

出力:

{"ARRIVAL_TIME":"2019-02-03T06:05:00.000000000Z"}

ノート:

列estimatedArrivalはSTRINGです。STRING値がISO-8601形式で含まれている場合は、SQLランタイムによってTIMESTAMデータ型に自動的に変換されます。

ISO8601は、日付、時刻および継続時間を表すために国際的に受け入れられている方法について説明しています。

構文:日付と時刻: YYYY-MM-DDThh:mm:ss[.s[s[s[s[s[s]]]]][Z|(+|-)hh:mm]

説明

YYYYは、4桁の10進数で年を指定します
MMは、00から12までの2桁の10進数で月を指定します
DDは、00から31までの2桁の10進数で日を指定します
hhは、00から23までの2桁の10進数で時間を指定します
mmは、00から59までの2桁の10進数で分を指定します
ss[.s[s[s[s[s]]]]]は、00から59までの2桁の10進数で秒を指定します。オプションで、小数点と1から6桁の10進数(秒の小数部を表す)を続けます。
Zは、UTC時間(タイムゾーン0)を指定します。(-00:00ではなく、+00:00で指定することもできます。)
(+|-)hh:mmは、タイムゾーンをUTCとの差として指定します。(+または- のいずれか1つは必須です。)

例1a:チケット番号が1762399766476の乗客に関して、5分間での推定到着時刻を印刷します。

SELECT $s.ticketno, $value as estimate,
timestamp_add($value, '5 minute') AS add5min
FROM baggageinfo $s,
$s.bagInfo.flightLegs.estimatedArrival as $value
WHERE ticketNo=1762399766476

説明:各区間での estimatedArrival時間を表示します。区間の数は顧客ごとに異なる可能性があります。したがって、前述の問合せでは変数参照が使用され、baggageInfo配列およびflightLegs配列はネストされずに問合せが実行されます。

出力:

{"ticketno":1762399766476,"estimate":"2019-02-03T06:00:00Z",
"add5min":"2019-02-03T06:05:00.000000000Z"}
{"ticketno":1762399766476,"estimate":"2019-02-03T08:22:00Z",
"add5min":"2019-02-03T08:27:00.000000000Z"}

例2:先週到着した手荷物の数はいくつのですか。

SELECT count(*) AS COUNT_LASTWEEK FROM baggageInfo bag
WHERE EXISTS bag.bagInfo[$element.bagArrivalDate < current_time()
AND $element.bagArrivalDate > timestamp_add(current_time(), "-7 days")]

説明:先週に航空会社アプリケーションによって処理された荷物の数を把握します。顧客は、複数の手荷物を所持できます(つまり、bagInfo配列には複数のレコードが含まれる場合があります)。bagArrivalDateには、本日から過去7日間までの値が含まれます。bagInfo配列の各レコードについて、手荷物到着時刻が現在から1週間前までの間であるかどうかを判断しますcurrent_time関数により、現在時間が返されます。EXISTS条件は、手荷物が先週到着日であるかどうかを判断するためのフィルタとして使用されます。count関数は、この期間の手荷物の合計数を決定します。

出力:

{"COUNT_LASTWEEK":0}

例3:次の6時間以内に到着する手荷物の数を確認します。

SELECT count(*) AS COUNT_NEXT6HOURS FROM baggageInfo bag
WHERE EXISTS bag.bagInfo[$element.bagArrivalDate > current_time()
AND $element.bagArrivalDate < timestamp_add(current_time(), "6 hours")]

説明:今後6時間に航空会社アプリケーションによって処理される荷物の数を把握します。顧客は、複数の手荷物を所持できます(つまり、bagInfo配列には複数のレコードが含まれる場合があります)。bagArrivalDateは、現在時間から次の6時間までである必要があります。bagInfo配列の各レコードについて、手荷物到着時刻が現在時刻と6時間後までの間であるかどうかを判断しますcurrent_time関数により、現在時間が返されます。EXISTS条件は、手荷物に今後6時間以内の到着日があるかどうかを判断するためのフィルタとして使用されます。count関数は、この期間の手荷物の合計数を決定します。

出力:

{"COUNT_NEXT6HOURS":0}

timestamp_diff()関数およびget_duration()関数

timestamp_diff()

2つのタイムスタンプ値の間のミリ秒数を返します。結果型はLONGです。

構文:

LONG timestamp_diff(TIMESTAMP timestamp1, TIMESTAMP
      timestamp2)

セマンティクス:

timestamp1: TIMESTAMP値またはTIMESTAMにキャストできる値。
timestamp2: TIMESTAMP値、またはTIMESTAMにキャストできる値
returnvalue:LONG

取得期間()

指定されたミリ秒数を期間文字列に変換します。結果タイプはSTRINGです。

構文:

STRING get_duration(LONG duration_millis)

セマンティクス:

duration_millis:期間(ミリ秒単位)
returnvalue: STRING。返される期間文字列書式は[-](<n> <UNIT>)+です。ここで、UNITはDA Y、HOUR、MINUTE、SECONDおよびMILLISECONDです(例: "1 DAY 2 hours"または"-10 minutes 0 SECOND 500 milliseconds")。

例:

例1:チケット番号が1762355527825の乗客に関して、ある区間で荷物を積載せてから次の区間に到着するための期間はどのくらいですか。

SELECT $s.ticketno, $bagInfo.bagArrivalDate, $flightLeg.flightDate,
get_duration(timestamp_diff($bagInfo.bagArrivalDate, $flightLeg.flightDate)) AS diff
FROM baggageinfo $s,
$s.bagInfo[] AS $bagInfo, $bagInfo.flightLegs[] AS $flightLeg
WHERE ticketNo=1762355527825

説明:航空会社アプリケーションでは、顧客ごとに、発信元と着信先の間のホップ数または区間の数が異なる可能性があります。この問合せでは、各飛行区間の所要時間を特定します。これは、各飛行区間のbagArrivalDateとflightDateの間の差異によって決まります。日数、時間数または分数で期間を確認するには、timestamp_diff関数の結果をget_duration関数に渡します。

出力:

{"bagArrivalDate":"2019-03-22T10:17:00Z","flightDate":"2019-03-22T07:00:00Z",
"diff":"3 hours 17 minutes"}
{"bagArrivalDate":"2019-03-22T10:17:00Z","flightDate":"2019-03-22T07:23:00Z",
"diff":"2 hours 54 minutes"}
{"bagArrivalDate":"2019-03-22T10:17:00Z","flightDate":"2019-03-22T08:23:00Z",
"diff":"1 hour 54 minutes"}

ミリ秒単位で期間を決定するには、timestamp_diff関数のみを使用します。

SELECT $s.ticketno, $bagInfo.bagArrivalDate, $flightLeg.flightDate,
timestamp_diff($bagInfo.bagArrivalDate, $flightLeg.flightDate) AS diff
FROM baggageinfo $s,
$s.bagInfo[] AS $bagInfo,
$bagInfo.flightLegs[] AS $flightLeg
WHERE ticketNo=1762355527825

例2:チケット番号が176234463813の乗客に関して、チェック時点から、搭乗時に荷物がスキャンされるまでにかかる時間はどのくらいですか。

SELECT $flightLeg.flightNo,
$flightLeg.actions[contains($element.actionCode, "Checkin")].actionTime AS checkinTime,
$flightLeg.actions[contains($element.actionCode, "BagTag Scan")].actionTime AS bagScanTime,
get_duration(timestamp_diff(
    $flightLeg.actions[contains($element.actionCode, "Checkin")].actionTime,
    $flightLeg.actions[contains($element.actionCode, "BagTag Scan")].actionTime
)) AS diff
FROM baggageinfo $s,
$s.bagInfo[].flightLegs[] AS $flightLeg
WHERE ticketNo=176234463813 AND
starts_with($s.bagInfo[].routing, $flightLeg.fltRouteSrc)

説明:手荷物データでは、それぞれのflightLegに1つのアクション配列があります。action配列には3つの異なるアクションがあります。配列の最初の要素のアクション・コードは、Checkin/Offloadです。最初の区間ではアクション・コードがCheckinとなり、他の区間ではアクション・コードが中継点でのOffloadとなります。配列の2番目の要素のアクション・コードは、BagTag Scanです。前述の問合せでは、バッグ・タグ・スキャンとチェックイン時間の間のアクション時間の差異を確認します。アクション・コードがCheckinまたはBagScanの場合のみ、contains関数を使用してアクション時間をフィルタ処理します。最初の飛行区間にのみチェックインおよび手荷物スキャンの詳細が含まれるため、starts_with関数を使用してさらにデータをフィルタ処理し、ソース・コードfltRouteSrcのみをフェッチします。日数、時間数または分数で期間を確認するには、timestamp_diff関数の結果をget_duration関数に渡します。

ミリ秒単位で期間を決定するには、timestamp_diff関数のみを使用します。

SELECT $flightLeg.flightNo,
$flightLeg.actions[contains($element.actionCode, "Checkin")].actionTime AS checkinTime,
$flightLeg.actions[contains($element.actionCode, "BagTag Scan")].actionTime AS bagScanTime,
timestamp_diff(
   $flightLeg.actions[contains($element.actionCode, "Checkin")].actionTime,
   $flightLeg.actions[contains($element.actionCode, "BagTag Scan")].actionTime
) AS diff
FROM baggageinfo $s,
$s.bagInfo[].flightLegs[] AS $flightLeg
WHERE ticketNo=176234463813 AND
starts_with($s.bagInfo[].routing, $flightLeg.fltRouteSrc)

出力:

{"flightNo":"BM572","checkinTime":"2019-03-02T03:28:00Z",
"bagScanTime":"2019-03-02T04:52:00Z","diff":"- 1 hour 24 minutes"}

例3:チケット番号が1762320369957の顧客の荷物が最初のトランジット・ポイントに到達するまでにかかる時間はどのくらいですか。

SELECT  $bagInfo.flightLegs[1].actions[2].actionTime,
$bagInfo.flightLegs[0].actions[0].actionTime,
get_duration(timestamp_diff($bagInfo.flightLegs[1].actions[2].actionTime,
                            $bagInfo.flightLegs[0].actions[0].actionTime)) AS diff
FROM baggageinfo $s, $s.bagInfo[] AS $bagInfo
WHERE ticketNo=1762320369957

説明:航空会社アプリケーションでは、顧客ごとに、発信元と着信先の間のホップ数または区間の数が異なる可能性があります。前述の例では、荷物が最初のトランジット・ポイントに到着するまでの所要時間を決定します。手荷物データでは、flightLegは配列です。配列内の最初のレコードは、最初のトランジット・ポイントの詳細を示します。最初のレコードのflightDateは荷物が発信元を出る時間であり、最初のフライト区間レコード内のestimatedArrivalは最初のトランジット・ポイントに到着する時間を示します。2つの間の差異は、手荷物が最初のトランジット・ポイントに到着するまでの所要時間を示します。日数、時間数または分数で期間を確認するには、timestamp_diff関数の結果をget_duration関数に渡します。

期間(ミリ秒数)を特定するには、timestamp_diff関数を使用します。

SELECT  $bagInfo.flightLegs[0].flightDate,
$bagInfo.flightLegs[0].estimatedArrival,
timestamp_diff($bagInfo.flightLegs[0].estimatedArrival,
             $bagInfo.flightLegs[0].flightDate) AS diff
FROM baggageinfo $s, $s.bagInfo[] AS $bagInfo
WHERE ticketNo=1762320369957

出力:

{"flightDate":"2019-03-12T03:00:00Z","estimatedArrival":"2019-03-12T16:00:00Z","diff":"13 hours"}
{"flightDate":"2019-03-12T03:00:00Z","estimatedArrival":"2019-03-12T16:40:00Z","diff":"13 hours 40 minutes"}

QueryRequest APIの使用例

QueryRequest APIを使用し、SQL関数を適用してNoSQL表からデータをフェッチできます。

問合せを実行するには、NoSQLHandle.query() APIを使用します。

こちらにあるサンプル中からフル・コードSQLFunctions.javaをダウンロードします。

 //Fetch rows from the table
private static void fetchRows(NoSQLHandle handle,String sqlstmt) throws Exception {
   try (
      QueryRequest queryRequest = new QueryRequest().setStatement(sqlstmt);
      QueryIterableResult results = handle.queryIterable(queryRequest)){
      for (MapValue res : results) {
         System.out.println("\t" + res);
      }
   }
}

String ts_func1="SELECT timestamp_add(bag.bagInfo.flightLegs[0].estimatedArrival, "5 minutes")"+
                         " AS ARRIVAL_TIME FROM BaggageInfo bag WHERE ticketNo=1762341772625";
System.out.println("Using timestamp_add function ");
fetchRows(handle,ts_func1);
String ts_func2="SELECT $s.ticketno, $bagInfo.bagArrivalDate, $flightLeg.flightDate, "+
                "get_duration(timestamp_diff($bagInfo.bagArrivalDate, $flightLeg.flightDate)) AS diff "+
                 "FROM baggageinfo $s, $s.bagInfo[] AS $bagInfo, $bagInfo.flightLegs[] AS $flightLeg "+
                 "WHERE ticketNo=1762344493810";
System.out.println("Using get_duration and timestamp_diff function ");
fetchRows(handle,ts_func2);

問合せを実行するには、borneo.NoSQLHandle.query()メソッドを使用します。

こちらにあるサンプル中からフル・コードSQLFunctions.pyをダウンロードします。

# Fetch data from the table
def fetch_data(handle,sqlstmt):
   request = QueryRequest().set_statement(sqlstmt)
   print('Query results for: ' + sqlstmt)
   result = handle.query(request)
   for r in result.get_results():
      print('\t' + str(r))

 ts_func1 = '''SELECT timestamp_add(bag.bagInfo.flightLegs[0].estimatedArrival, "5 minutes")
                 AS ARRIVAL_TIME FROM BaggageInfo bag WHERE ticketNo=1762341772625'''
print('Using timestamp_add function:')
fetch_data(handle,ts_func1)

ts_func2 = '''SELECT $s.ticketno, $bagInfo.bagArrivalDate, $flightLeg.flightDate,
              get_duration(timestamp_diff($bagInfo.bagArrivalDate, $flightLeg.flightDate)) AS diff
              FROM baggageinfo $s,
              $s.bagInfo[] AS $bagInfo, $bagInfo.flightLegs[] AS $flightLeg
              WHERE ticketNo=1762344493810'''
print('Using get_duration and timestamp_diff function:')
fetch_data(handle,ts_func2)

問合せを実行するには、Client.Query関数を使用します。

こちらにあるサンプル中からフル・コードSQLFunctions.goをダウンロードします。

 //fetch data from the table
func fetchData(client *nosqldb.Client, err error, tableName string, querystmt string)(){
   prepReq := &nosqldb.PrepareRequest{
		Statement: querystmt,
   }
   prepRes, err := client.Prepare(prepReq)
   if err != nil {
      fmt.Printf("Prepare failed: %v\n", err)
      return
   }
   queryReq := &nosqldb.QueryRequest{
		 PreparedStatement: &prepRes.PreparedStatement,   }
   var results []*types.MapValue
   for {
      queryRes, err := client.Query(queryReq)
      if err != nil {
         fmt.Printf("Query failed: %v\n", err)
  	return
      }
      res, err := queryRes.GetResults()
      if err != nil {
         fmt.Printf("GetResults() failed: %v\n", err)
  	return
      }
      results = append(results, res...)
      if queryReq.IsDone() {
         break
      }
   }
   for i, r := range results {
      fmt.Printf("\t%d: %s\n", i+1, jsonutil.AsJSON(r.Map()))
   }
}

ts_func1 := `SELECT timestamp_add(bag.bagInfo.flightLegs[0].estimatedArrival, "5 minutes")
                AS ARRIVAL_TIME FROM BaggageInfo bag WHERE ticketNo=1762341772625`
fmt.Printf("Using timestamp_add function::\n")
fetchData(client, err,tableName,ts_func1)

ts_func2 := `SELECT $s.ticketno, $bagInfo.bagArrivalDate, $flightLeg.flightDate,
             get_duration(timestamp_diff($bagInfo.bagArrivalDate, $flightLeg.flightDate)) AS diff
             FROM baggageinfo $s,
             $s.bagInfo[] AS $bagInfo, $bagInfo.flightLegs[] AS $flightLeg
             WHERE ticketNo=1762344493810`
fmt.Printf("Using get_duration and timestamp_diff function:\n")
fetchData(client, err,tableName,ts_func2)

問合せを実行するには、queryメソッドを使用します。

JavaScript: こちらのサンプルの中からフル・コードSQLFunctions.jsをダウンロードします。

  //fetches data from the table
async function fetchData(handle,querystmt) {
   const opt = {};
   try {
      do {
         const result = await handle.query(querystmt, opt);
         for(let row of result.rows) {
            console.log('  %O', row);
         }
         opt.continuationKey = result.continuationKey;
      } while(opt.continuationKey);
   } catch(error) {
      console.error('  Error: ' + error.message);
   }
}

TypeScript: こちらのサンプルの中からフル・コードSQLFunctions.tsをダウンロードします。

interface StreamInt {
   acct_Id: Integer;
   profile_name: String;
   account_expiry: TIMESTAMP;
   acct_data: JSON;
}

/* fetches data from the table */
async function fetchData(handle: NoSQLClient,querystmt: string) {
   const opt = {};
   try {
      do {
         const result = await handle.query<StreamInt>(querystmt, opt);
         for(let row of result.rows) {
            console.log('  %O', row);
         }
         opt.continuationKey = result.continuationKey;
      } while(opt.continuationKey);
   } catch(error) {
      console.error('  Error: ' + error.message);
   }
}

const ts_func1 = `SELECT timestamp_add(bag.bagInfo.flightLegs[0].estimatedArrival, "5 minutes")
                  AS ARRIVAL_TIME FROM BaggageInfo bag WHERE ticketNo=1762341772625`
console.log("Using timestamp_add function:");
await fetchData(handle,ts_func1);

const ts_func2 = `SELECT $s.ticketno, $bagInfo.bagArrivalDate, $flightLeg.flightDate,
                  get_duration(timestamp_diff($bagInfo.bagArrivalDate, $flightLeg.flightDate)) AS diff
                  FROM baggageinfo $s,
                  $s.bagInfo[] AS $bagInfo, $bagInfo.flightLegs[] AS $flightLeg
                  WHERE ticketNo=1762344493810`
console.log("Using get_duration and timestamp_diff function:");
await fetchData(handle,ts_func2);

問合せを実行するには、QueryAsyncメソッドをコールするか、GetQueryAsyncEnumerableメソッドをコールして、結果の非同期列挙可能性に対して反復処理します。

こちらにあるサンプルの中にフル・コードSQLFunctions.csをダウンロードします。

private static async Task fetchData(NoSQLClient client,String querystmt){
   var queryEnumerable = client.GetQueryAsyncEnumerable(querystmt);
   await DoQuery(queryEnumerable);
}

private static async Task DoQuery(IAsyncEnumerable<QueryResult<RecordValue>> queryEnumerable){
   Console.WriteLine("  Query results:");
   await foreach (var result in queryEnumerable) {
      foreach (var row in result.Rows)
      {
         Console.WriteLine();
         Console.WriteLine(row.ToJsonString());
      }
   }
}

private const string ts_func1 =@"SELECT timestamp_add(bag.bagInfo.flightLegs[0].estimatedArrival, ""5 minutes"")
                                       AS ARRIVAL_TIME FROM BaggageInfo bag WHERE ticketNo=1762341772625";
Console.WriteLine("\nUsing timestamp_add function!");
await fetchData(client,ts_func1);

private const string ts_func2 =@"SELECT $s.ticketno, $bagInfo.bagArrivalDate, $flightLeg.flightDate,
                                       get_duration(timestamp_diff($bagInfo.bagArrivalDate, $flightLeg.flightDate)) AS diff
                                       FROM baggageinfo $s,
                                       $s.bagInfo[] AS $bagInfo, $bagInfo.flightLegs[] AS $flightLeg
                                       WHERE ticketNo=1762344493810";
Console.WriteLine("\nUsing get_duration and timestamp_diff function!");
await fetchData(client,ts_func2);

問合せでのタイムスタンプ関数の使用

式を抽出

timestamp_add()関数

timestamp_diff()関数およびget_duration()関数

QueryRequest APIの使用例

関連トピック