dbClient组件：通过标准sql接口对数据库进行增删修改查操作。内置支持mysql和postgres数据库。 也支持实现了database/sql接口的第三方数据库驱动包，但需要自行导入，例如TDengine (opens new window) 驱动：

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

//配置使用
//driverName:taosRestful

GO第三方数据库驱动包

• github.com/taosdata/driver-go：TDengine (opens new window) 驱动。
• github.com/denisenkom/go-mssqldb：Microsoft SQL Server驱动。
• github.com/godror/godror：Oracle Database驱动。
• github.com/snowflakedb/gosnowflake：Snowflake驱动。
• github.com/ClickHouse/clickhouse-go：ClickHouse驱动。
• github.com/vertica/vertica-sql-go：Vertica驱动。

配置

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

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

sql参数 v0.23.0版本之后，不再支持通过替换${}变量，请使用占位符和params参数

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"
	  }
    ]
  }
}