Jetty の接続プールから Snowflake のデータ に接続

Jerod Johnson
Jerod Johnson
Senior Technology Evangelist
Snowflake JDBC Driver は接続プールをサポートしています。この記事では、Jetty の Web アプリから Snowflake のデータ に高速に接続する方法を説明します。

CData JDBC Driver for Snowflake は、Java Web アプリケーションへの統合が簡単です。この記事では、接続プールを設定することで Jetty から Snowflake のデータ に効率的に接続する方法を説明します。Jetty で Snowflake 用の JNDI リソースを設定していきましょう。

Snowflake データ連携について

CData は、Snowflake のライブデータへのアクセスと統合を簡素化します。お客様は CData の接続機能を以下の目的で活用しています:

  • Snowflake データを迅速かつ効率的に読み書きできます。
  • 指定された Warehouse、Database、Schema のメタデータを動的に取得できます。
  • OAuth、OKTA、Azure AD、Azure マネージド サービス ID、PingFederate、秘密鍵など、さまざまな方法で認証できます。

多くの CData ユーザーは、CData ソリューションを使用して、お気に入りのツールやアプリケーションから Snowflake にアクセスし、さまざまなシステムからデータを Snowflake にレプリケートして、包括的なウェアハウジングと分析を行っています。

CData ソリューションとの Snowflake 統合についての詳細は、ブログをご覧ください:https://jp.cdata.com/blog/snowflake-integrations


はじめに


Salesforce 用の JDBC Driver を JNDI データソースとして設定

以下のステップで Jetty から Salesforce に接続します。

  1. Jetty ベースで JNDI モジュールを有効にします。次のコマンドは、コマンドラインから JNDI を有効にします。

    java -jar ../start.jar --add-to-startd=jndi
    
  2. インストールディレクトリの lib サブフォルダにある CData およびライセンスファイルを、コンテキストパスの lib サブフォルダに追加します。
  3. リソースとそのスコープを宣言します。リソース宣言に必要な接続プロパティを入力します。次の例では、WEB-INF\jetty-env.xml に Web アプリレベルで Snowflake データソースを宣言しています。

    
    <Configure id='snowflakedemo' class="org.eclipse.jetty.webapp.WebAppContext">
        <New id="snowflakedemo" class="org.eclipse.jetty.plus.jndi.Resource">
        <Arg><Ref refid="snowflakedemo"/></Arg>
        <Arg>jdbc/snowflakedb</Arg>
        <Arg>
          <New class="cdata.jdbc.snowflake.SnowflakeDriver">
            <Set name="url">jdbc:snowflake:</Set>
            <Set name="User">Admin</Set>
            <Set name="Password">test123</Set>
            <Set name="Server">localhost</Set>
            <Set name="Database">Northwind</Set>
            <Set name="Warehouse">TestWarehouse</Set>
            <Set name="Account">Tester1</Set>
          </New>
        </Arg>
      </New>
    </Configure>
    

    それでは、Snowflake データベースに接続していきましょう。認証に加えて、以下の接続プロパティを設定します。

    • Url:お使いのSnowflake URL を指定します。例:https://orgname-myaccount.snowflakecomputing.com
      • Legacy URL を使用する場合:https://myaccount.region.snowflakecomputing.com
      • ご自身のURL は以下のステップで確認できます。
        1. Snowflake UI の左下にあるユーザー名をクリックします
        2. Account ID にカーソルを合わせます
        3. Copy Account URL アイコンをクリックして、アカウントURL をコピーします
    • Database(オプション):CData 製品によって公開されるテーブルとビューを、特定のSnowflake データベースのものに制限したい場合に設定します
    • Schema(オプション):CData 製品によって公開されるテーブルとビューを、特定のSnowflake データベーススキーマのものに制限したい場合に設定します

    Snowflakeへの認証

    CData 製品では、Snowflake ユーザー認証、フェデレーション認証、およびSSL クライアント認証をサポートしています。認証するには、UserPassword を設定し、AuthScheme プロパティで認証方法を選択してください。

    キーペア認証

    ユーザーアカウントに定義されたプライベートキーを使用してセキュアなトークンを作成し、キーペア認証で接続することも可能です。この方法で接続するには、AuthSchemePRIVATEKEY に設定し、以下の値を設定してください。

    • User:認証に使用するユーザーアカウント
    • PrivateKey:プライベートキーを含む.pem ファイルへのパスなど、ユーザーに使用されるプライベートキー
    • PrivateKeyType:プライベートキーを含むキーストアの種類(PEMKEY_FILE、PFXFILE など)
    • PrivateKeyPassword:指定されたプライベートキーのパスワード

    その他の認証方法については、ヘルプドキュメントの「Snowflakeへの認証」セクションをご確認ください。

  4. Web.xml でリソースを設定します。

    
      jdbc/snowflakedb
      javax.sql.DataSource
      Container
    
    
  5. これで、java:comp/env/jdbc/snowflakedb をルックアップして Snowflake にアクセスできます。

    InitialContext ctx = new InitialContext();
    DataSource mysnowflake = (DataSource)ctx.lookup("java:comp/env/jdbc/snowflakedb");
    

Jetty 統合の詳細

上記のステップでは、シンプルな接続プールのシナリオでドライバーを設定する方法を説明しました。その他のユースケースや詳細については、Jetty ドキュメントのWorking with Jetty JNDI の章を参照してください。

はじめる準備はできましたか?

Snowflake Driver の無料トライアルをダウンロードしてお試しください:

 ダウンロード

詳細:

Snowflake Enterprise Data Warehouse Icon Snowflake JDBC Driver お問い合わせ

驚くほど簡単にJDBC でJava アプリケーションからSnowflake にデータ連携!