Google Cloud Spanner Database 拡張機能

データの追加

次の例では、拡張機能の insert アクションで新しいユーザーをユーザー テーブルに追加しています。

<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
    <ConnectorCallout async="false" continueOnError="true" enabled="true" name="Insert-New-User">
        <DisplayName>Insert New User</DisplayName>
        <Connector>spanner-users-products</Connector>
        <Action>insert</Action>
        <Input><![CDATA[{
            "tableName" : "user",
            "rows" : [{
              "username": "jonesy42",
              "firstName": "Floyd",
              "lastName": "Jones",
              "address": "3695 Auctor Street",
              "city": "Gresham",
              "region": "OR",
              "postalCode": "12693",
              "email": "floydster@example.com"
          }]
      }]]></Input>
    </ConnectorCallout>
    

データの取得

この例では、クエリで user テーブルからユーザー名とメールアドレスを取得しています。

まず、AssignMessage ポリシーがクエリの WHERE 句で使用する postal.code.value 変数を割り当てています。これはサンプルです。実際のポリシーでは、クライアント リクエストのパラメータに基づいて値を設定するでしょう。

<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
    <AssignMessage async="false" continueOnError="false" enabled="true" name="Assign-Postal-Code">
        <AssignTo createNew="true" transport="http" type="request"/>
        <AssignVariable>
            <Name>postal.code</Name>
            <Value>86519</Value>
        </AssignVariable>
        <IgnoreUnresolvedVariables>true</IgnoreUnresolvedVariables>
    </AssignMessage>
    

次の ExtensionCallout ポリシーは、WHERE 句の postal.code.value 変数のコンテンツを使用して、データベースにクエリを実行しています。

<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
    <ConnectorCallout async="false" continueOnError="true" enabled="true" name="Get-User-Data">
        <DisplayName>Get User Data</DisplayName>
        <Connector>spanner-users-products</Connector>
        <Action>querySQL</Action>
        <Input><![CDATA[{
          "sql" : "SELECT username, email FROM user WHERE postalCode = @postalCode",
          "params" : {
            "postalCode" : "{postal.code.value}"
          }
        }]]></Input>
      <Output>spanner.userdata.retrieved</Output>
    </ConnectorCallout>
    

次の AssignMessage ポリシーでは、クライアントに返すレスポンスとして、spanner.userdata.retrieved 変数に保存された拡張機能のレスポンスを使用しています。

<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
    <AssignMessage async="false" continueOnError="false" enabled="true" name="Get-Query-Response-Data">
        <DisplayName>Get Query Response Data</DisplayName>
        <AssignTo type="response" createNew="false"/>
        <Set>
            <Payload contentType="application/json">{spanner.userdata.retrieved}</Payload>
        </Set>
    </AssignMessage>
    

この例では、レスポンス データが次のような JSON として返されます。

{
      "rows": [
        {
          "username": "freewill444",
          "email": "freewill@example.com"
        }
      ]
    }
    

データの更新

この例では、<Input> 要素に username（テーブルの主キー）が含まれ、email 列に新しい値が設定されています。

<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
    <ConnectorCallout async="false" continueOnError="true" enabled="true" name="Update-User-Data">
        <DisplayName>Update User Data</DisplayName>
        <Connector>spanner-users-products</Connector>
        <Action>update</Action>
        <Input><![CDATA[{
            "tableName" : "user",
            "rows": [{
                "username":"Liz456",
                "email":"lizzard@example.com"
            }]
        }]]></Input>
    </ConnectorCallout>
    

構文

<Action>insert</Action>
    <Input><![CDATA[{
      "tableName" : "table-to-insert-into",
      "rows" : "rows-to-insert"
    }]]></Input>
    

例

次の例では、拡張機能の insert アクションで新しいユーザーをユーザー テーブルに追加しています。1 行が追加されています。

<Action>insert</Action>
    <Input><![CDATA[{
        "tableName" : "user",
        "rows" : [{
          "username": "jonesy42",
          "firstName": "Floyd",
          "lastName": "Jones",
          "address": "3695 Auctor Street",
          "city": "Gresham",
          "region": "OR",
          "postalCode": "12693",
          "email": "floydster@example.com"
      }]
    }]]></Input>
    

構文

<Action>querySQL</Action>
    <Input><![CDATA[{
      "sql" : "sql-query-statement",
      "params" : {
        "param1" : "columnValue"
      }
    }]]></Input>
    

例

この例では、クエリで user テーブルから username 列と email 列の値を取得しています。SQL 文には、フロー変数 postal.code.value から設定された postalCode パラメータを指定します。

<Action>querySQL</Action>
    <Input><![CDATA[{
      "sql" : "SELECT username, email FROM user WHERE postalCode = @postalCode",
      "params" : {
        "postalCode" : "{postal.code.value}"
      }
    }]]></Input>
    

構文

<Input><![CDATA[{
      "tableName" : "table-with-rows-to-update",
      "rows" : "rows-to-update"
    }]]></Input>
    

例

この例では、username が Liz456 のメールアドレスを新しい値で更新しています。1 行が更新されています。

<Action>update</Action>
    <Input><![CDATA[{
      "tableName" : "user",
      "rows": [{
          "username":"Liz456",
          "email":"lizzard@example.com"
      }]
    }]]></Input>