Powershell からの Impala データ連携タスクを自動化

詳細情報をご希望ですか?

無償トライアル:

ダウンロードへ

製品の詳細情報へ:

Impala ADO.NET Provider

Impala に連携する.NET アプリケーションを素早く、簡単に開発できる便利なドライバー。



PowerShell から Impala に簡単に接続する方法をお探しですか? CData ADO.NET Provider for Impala は、PowerShell スクリプトの優位性を使い、シンプルで簡単に使えるADO.NET インターフェース を提供します。PowerShell スクリプトで、ADO.NET オブジェクトを使って簡単にImpala に接続して、同期、自動化、ダウンロードなどが可能!



CData ADO.NET Provider for Impala は、ADO.NET 標準インターフェースへ統合し、PowerShell のような. NET アプリケーションからImpala API へのデータ連携を可能にします。このプロバイダーは、Impala の認証および相互作用を簡単にします。このチュートリアルでは、PowerShell から直接SQL クエリを実行するための、いくつかの一般的なADO.NET オブジェクトの使い方を説明します。

クエリの実行

次の3つのステップに従って create、read、update、およびdelete (CRUD) のデータ連携コマンドを PowerShell からリアルタイムImpala に実行:

  1. プロバイダーのアセンブリをロード:

    [Reflection.Assembly]::LoadFile("C:\Program Files\CData\CData ADO.NET Provider for Impala\lib\System.Data.CData.ApacheImpala.dll")
  2. Impala に接続:

    In order to connect to Apache Impala, set the Server, Port, and ProtocolVersion. You may optionally specify a default Database. To connect using alternative methods, such as NOSASL, LDAP, or Kerberos, refer to the online Help documentation.

    $constr = "Server=127.0.0.1;Port=21050;" $conn= New-Object System.Data.CData.ApacheImpala.ApacheImpalaConnection($constr) $conn.Open()
  3. ApacheImpalaDataAdapter のインスタンスを生成してSQL クエリを実行し、結果を出力:

    $sql="SELECT City, CompanyName from Customers" $da= New-Object System.Data.CData.ApacheImpala.ApacheImpalaDataAdapter($sql, $conn) $dt= New-Object System.Data.DataTable $da.Fill($dt) $dt.Rows | foreach { Write-Host $_.city $_.companyname }

Impala データの更新

$cmd = New-Object System.Data.CData.ApacheImpalaCommand("UPDATE Customers SET Country='US' WHERE Id = @myId", $conn) $cmd.Parameters.Add(new System.Data.CData.ApacheImpalaParameter("myId","10456255-0015501366")) $cmd.ExecuteNonQuery()

Impala へのデータの挿入

$cmd = New-Object System.Data.CData.ApacheImpalaCommand("UPDATE Customers SET Country='US' WHERE Id = @myId", $conn) $cmd.Parameters.Add(new System.Data.CData.ApacheImpalaParameter("myId","10456255-0015501366")) $cmd.ExecuteNonQuery()

Impala データの削除

$cmd = New-Object System.Data.CData.ApacheImpalaCommand("UPDATE Customers SET Country='US' WHERE Id = @myId", $conn) $cmd.Parameters.Add(new System.Data.CData.ApacheImpalaParameter("myId","10456255-0015501366")) $cmd.ExecuteNonQuery()