第58章 MySQL Sink

MySQL データベースにデータを送信します。

パイプファイルでは、spec→integration→dependencies: で SQL Server ドライバーの依存関係を明示的に宣言する必要があります。

spec:
  ...
  integration:
      ...
      dependencies:
      - "mvn:mysql:mysql-connector-java:<version>"

spec:
  ...
  integration:
      ...
      dependencies:
      - "mvn:mysql:mysql-connector-java:<version>"

Copy to Clipboard

Toggle word wrap

この Kamelet では JSON 形式の本文を指定する必要があります。キーと値のペアを使用して、JSON フィールドとパラメーターをマッピングします。たとえば、次のクエリーがあります。

'INSERT INTO accounts (username,city) VALUES (:#username,:#city)'

以下はサンプルクエリーの入力例です。

'{ "username":"oscerd", "city":"Rome"}'

58.1. 設定オプション
リンクのコピー

次の表は、mysql-sink Kamelet で利用できる設定オプションをまとめたものです。

Expand

プロパティー	名前	説明	型	デフォルト	例
databaseName *	Database Name	MySQL データベースの名前。	string
password*	Password	保護された MySQL データベースにアクセスするためのパスワード。	string
query*	Query	MySQL データベースに対して実行するクエリー。	string		INSERT INTO accounts (username,city) VALUES (:#username,:#city)
serverName*	Server Name	データソースのサーバー名。	string		localhost
username*	Username	セキュリティー保護された MySQL データベースにアクセスするためのユーザー名。	string
serverPort	Server Port	データソースのサーバーポート。	string	3306

* = アスタリスクの付いたフィールドは必須です。