接続の確立

CData Cmdlets ユーザーは、データモジュールをインストールし、接続プロパティを設定してスクリプトを開始できます。このセクションでは、CSV インポートおよびエクスポートcmdlet などのネイティブPowerShell cmdlet でApachePhoenix Cmdlets を使用する例を示します。

インストールおよび接続

PSGet がある場合は、PowerShell Gallery から次のコマンドを使ってcmdlet をインストールできます。CData サイトからセットアップを取得することもできます。

Install-Module ApachePhoenixCmdlets

プロファイルに以下を追加すると、次のセッションでcmdlet がロードされます。

Import-Module ApachePhoenixCmdlets;

Connect-ApachePhoenix cmdlet を使って、別のcmdlet に渡すことができる接続オブジェクトを作成します。

$conn = Connect-ApachePhoenix -URL 'http://localhost:8765'

Apache Phoenix への接続

CData Cmdlets PowerShell Module for Apache Phoenix はPhoenix Query Server 経由でApache Phoenix に接続します。URL 接続プロパティを設定してApache Phoenix に接続します。

URL プロパティは通常、Apache Phoenix をホストしているサーバーのホスト名またはIP アドレスの後にポートを付けたものになります。例：http://localhost:8765。

Apache Phoenix への認証

デフォルトでは、認証は使用されません（PLAIN）。認証がサーバー用に設定されている場合、以下の認証方法の1つを設定できます。

Basic

If your instance of Apache Phoenix has set up the basic authentication layer, set the following to authenticate:

AuthScheme：Basic に設定。
User：Apache Phoenix インスタンスのユーザーに設定。
Password：Apache Phoenix インスタンスのパスワードに設定。

Azure HDInsight

To authenticate to Azure HDInsight, set the following:

AuthScheme：AzureHDInsight に設定。
User：Set this to the cluster username that you specified when creating the cluster on Azure HDInsight.
Password：Set this to the cluster password that you specified when creating the cluster on Azure HDInsight.
ClusterName：Set this to the name of the cluster containing your Azure HDInsight instance.

すべての呼び出しはゲートウェイに送信され、ゲートウェイはリクエストを処理するノードの1つを選びます。クラスタの内部仮想ネットワーク内で実行している場合は、特定のノードにアクセス可能です。

Kerberos

AuthScheme をNegotiate に設定します。Kerberos で認証する方法についての詳細は、Kerberos の使用を参照してください。

データの取得

接続の作成が完了したら、リレーショナルデータベースに対して通常行える操作を別のcmdlet を使って実行できます。 Select-ApachePhoenix cmdlet はデータを取得するためのネイティブなPowerShell インターフェースを提供します。

$results = Select-ApachePhoenix -Connection $conn -Table "[SampleCatalog_1].[SampleSchema_1].SampleTable_1" -Columns @("Id, Name") -Where "Industry='Floppy Disks'"

Invoke-ApachePhoenix cmdlet はSQL インターフェースを提供します。このcmdlet を使うと、Query パラメータを介してSQL クエリを実行できます。

cmdlet 出力のパイプ処理

cmdlet は行オブジェクトをパイプラインに一度に一行ずつ返します。以下は、結果をCSV ファイルにエクスポートします。

Select-ApachePhoenix -Connection $conn -Table [SampleCatalog_1].[SampleSchema_1].SampleTable_1 -Where "Industry = 'Floppy Disks'" | Select -Property * -ExcludeProperty Connection,Table,Columns | Export-Csv -Path c:\my[SampleCatalog_1].[SampleSchema_1].SampleTable_1Data.csv -NoTypeInformation

Select-ApachePhoenix からの結果をSelect-Object cmdlet にパイプして、Export-CSV cmdlet にパイプする前にいくつかのプロパティを実行していることがわかるでしょう。これをする理由は、CData Cmdlets は接続、テーブル、およびカラムの情報を結果セットの各行オブジェクトに追加しますが、必ずしもその情報がCSV ファイルに必要ではないからです。

ただし、これによってcmdlet の出力を別のcmdlet にパイプすることが容易になります。以下に、結果セットをJSON に変換する例を示します。

 
PS C:\> $conn  = Connect-ApachePhoenix -URL 'http://localhost:8765'
PS C:\> $row = Select-ApachePhoenix -Connection $conn -Table "[SampleCatalog_1].[SampleSchema_1].SampleTable_1" -Columns (Id, Name) -Where "Industry = 'Floppy Disks'" | select -first 1
PS C:\> $row | ConvertTo-Json
{
  "Connection":  {

  },
  "Table":  "[SampleCatalog_1].[SampleSchema_1].SampleTable_1",
  "Columns":  [

  ],
  "Id":  "MyId",
  "Name":  "MyName"
}

データの削除

以下は、抽出条件に合うあらゆるレコードを削除します。

Select-ApachePhoenix -Connection $conn -Table [SampleCatalog_1].[SampleSchema_1].SampleTable_1 -Where "Industry = 'Floppy Disks'" | Remove-ApachePhoenix

データの変更

cmdlet はデータクレンジング同様、データの変換を容易にします。次の例は、レコードがすでに存在するかどうか、挿入する前に更新が必要かどうかをチェックしてから、CSV ファイルのデータをApache Phoenix にロードします。

Import-Csv -Path C:\My[SampleCatalog_1].[SampleSchema_1].SampleTable_1Updates.csv | %{
  $record = Select-ApachePhoenix -Connection $conn -Table [SampleCatalog_1].[SampleSchema_1].SampleTable_1 -Where ("Id = `'"+$_.Id+"`'")
  if($record){
    Update-ApachePhoenix -Connection $conn -Table [SampleCatalog_1].[SampleSchema_1].SampleTable_1 -Columns @("Id","Name") -Values @($_.Id, $_.Name) -Where "Id  = `'$_.Id`'"
  }else{
    Add-ApachePhoenix -Connection $conn -Table [SampleCatalog_1].[SampleSchema_1].SampleTable_1 -Columns @("Id","Name") -Values @($_.Id, $_.Name)
  }
}

Cmdlets for Apache Phoenix