Sql Sink

The sink will write the result to the database.

Compile & deploy plugin

This plugin must be used in conjunction with at least a database driver. We are using build tag to determine which driver will be included. This repository lists all the supported drivers.

This plugin supports sqlserver\postgres\mysql\sqlite3\oracle drivers by default. User can compile plugin that only support one driver by himself, for example, if he only wants mysql, then he can build with build tag mysql.

Default build command

  1. # cd $eKuiper_src
  2. # go build -trimpath -modfile extensions.mod --buildmode=plugin -o plugins/sinks/Sql.so extensions/sinks/sql/sql.go
  3. # cp plugins/sinks/Sql.so $eKuiper_install/plugins/sinks

MySql build command

  1. # cd $eKuiper_src
  2. # go build -trimpath -modfile extensions.mod --buildmode=plugin -tags mysql -o plugins/sinks/Sql.so extensions/sinks/sql/sql.go
  3. # cp plugins/sinks/Sql.so $eKuiper_install/plugins/sinks

Properties

Property name Optional Description
url false The url of the target database
table false The table name of the result
fields false The fields to be inserted to. The result map and the database should both have these fields. If not specified, all fields in the result map will be inserted.

Sample usage

Below is a sample for using sql to get the target data and set to mysql database 

  1. {
  2.   "id": "rule",
  3.   "sql": "SELECT stuno as id, stuName as name, format_time(entry_data,\"YYYY-MM-dd HH:mm:ss\") as registerTime FROM SqlServerStream",
  4.   "actions": [
  5.     {
  6.       "log": {
  7.       },
  8.       "sql": {
  9.         "url": "mysql://user:test@140.210.204.147/user?parseTime=true",
  10.         "table": "test",
  11.         "fields": ["id","name","registerTime"]
  12.       }
  13.     }
  14.   ]
  15. }