dbClient组件：通过标准sql接口对数据库进行增删修改查操作。内置支持mysql和postgres数据库，可以执行SQL查询、更新、插入和删除操作。

组件基于Go标准库的database/sql接口实现，因此也支持任何实现了该接口的第三方数据库驱动。使用第三方驱动时需要在代码中导入相应的包。

例如，要使用TDengine (opens new window)时代码示例如下:

import (
    _ "github.com/taosdata/driver-go/v3/taosRestful"
)

GO第三方数据库驱动包

以下是使用第三方数据库驱动包的示例：

驱动包名称	数据库类型	导入路径	driverName配置	dsn配置
TDengine	TDengine	"github.com/taosdata/driver-go/v3/taosRestful"	taosRestful	root:root@tcp(127.0.0.1:6030)/test
Microsoft SQL Server	Microsoft SQL Server	"github.com/denisenkom/go-mssqldb"	mssql	server=127.0.0.1;user id=root;password=root;database=test
Oracle Database	Oracle Database	"github.com/godror/godror"	oracle	username/password@//127.0.0.1:1521/test
Snowflake	Snowflake	"github.com/snowflakedb/gosnowflake"	snowflake	ACCOUNT=account_name;USER=user_name;PASSWORD=password;DATABASE=database_name;WAREHOUSE=warehouse_name
ClickHouse	ClickHouse	"github.com/ClickHouse/clickhouse-go"	clickhouse	tcp://127.0.0.1:9000?username=root&password=root&database=test
Vertica	Vertica	"github.com/vertica/vertica-sql-go"	vertica	vertica://127.0.0.1:5433/test?username=root&password=root
MySQL	MySQL	"github.com/go-sql-driver/mysql"	mysql	root:root@tcp(127.0.0.1:3306)/test
PostgreSQL	PostgreSQL	"github.com/lib/pq"	postgres	user:password@tcp(127.0.0.1:5432)/test 或者 user= password= host=127.0.0.1 port=5432 dbname=test sslmode=disable

配置

该组件允许通关过dsn字段复用共享的连接客户端。参考组件连接复用 。

字段	类型	说明	默认值
sql	string	SQL语句，可以使用组件配置变量	无
params	数组	SQL语句参数列表，可以使用组件配置变量	无
getOne	bool	是否只返回一条记录，true:返回结构不是数组结构，false：返回数据是数组结构	无
poolSize	int	连接池大小	无
driverName	string	数据库驱动名称，mysql/postgres，或者其他数据库驱动类型	mysql
dsn	string	数据库连接配置，参考sql.Open参数	无

Relation Type

• Success: 执行成功，把消息发送到Success链
• Failure: 执行失败，把消息发送到Failure链

执行结果

• Select：查询结果，替换到msg.Data，流转到下一个节点。
• UPDATE, DELETE：结果存放在msg.Metadata中：
  • msg.Metadata.rowsAffected：影响多少行
  • msg.Data：内容不变
• INSERT：结果存放在msg.Metadata中：
  • msg.Metadata.rowsAffected：影响多少行
  • msg.Metadata.lastInsertId：插入ID （如果有）
  • msg.Data：内容不变

配置示例

  {
  "id": "s1",
  "type": "dbClient",
  "name": "插入1条记录",
  "configuration": {
    "driverName":"mysql",
    "dsn":"root:root@tcp(127.0.0.1:3306)/test",
    "poolSize":5,
    "sql":"insert into users (id,name, age) values (?,?,?)",
    "params":["${metadata.id}", "${metadata.name}", "${metadata.age}"]
  }
 }

应用示例

应用示例参考：dbClient (opens new window)

{
  "ruleChain": {
	"id":"rule01",
    "name": "测试规则链",
	"root": true
  },
  "metadata": {
    "nodes": [
       {
        "id": "s1",
        "type": "dbClient",
        "name": "插入1条记录",
        "configuration": {
			"driverName":"mysql",
			"dsn":"root:root@tcp(127.0.0.1:3306)/test",
			"poolSize":5,
			"sql":"insert into users (id,name, age) values (?,?,?)",
			"params":["${metadata.id}", "${metadata.name}", "${metadata.age}"]
        }
      },
     {
        "id": "s2",
        "type": "dbClient",
        "name": "查询1条记录",
        "configuration": {
			"driverName":"mysql",
			"dsn":"root:root@tcp(127.0.0.1:3306)/test",
			"sql":"select * from users where id = ?",
			"params":["${metadata.id}"],
			"getOne":true
        }
      },
	  {
        "id": "s3",
        "type": "dbClient",
        "name": "查询多条记录，参数不使用占位符",
        "configuration": {
			"driverName":"mysql",
			"dsn":"root:root@tcp(127.0.0.1:3306)/test",
			"sql":"select * from users where age >= 18"
        }
      },
	  {
        "id": "s4",
        "type": "dbClient",
        "name": "更新记录，参数使用占位符",
        "configuration": {
			"driverName":"mysql",
			"dsn":"root:root@tcp(127.0.0.1:3306)/test",
			"sql":"update users set age = ? where id = ?",
			"params":["${metadata.updateAge}","${metadata.id}"]
        }
      },
	  {
        "id": "s5",
        "type": "dbClient",
        "name": "删除记录",
        "configuration": {
			"driverName":"mysql",
			"dsn":"root:root@tcp(127.0.0.1:3306)/test",
			"sql":"delete from users"
        }
      }
    ],
    "connections": [
     {
        "fromId": "s1",
        "toId": "s2",
        "type": "Success"
      },
	 {
		"fromId": "s2",
		"toId": "s3",
		"type": "Success"
	  },
	 {
		"fromId": "s3",
		"toId": "s4",
		"type": "Success"
	  },
	{
		"fromId": "s4",
		"toId": "s5",
		"type": "Success"
	  }
    ]
  }
}