能力说明

能力名称：写数据库

功能简介

写数据库能力

配置参数

1.数据库连接管理

  {
      "数据库jdbc连接串": "jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8",
      "用户名": "root",
      "密码": "root",
      "数据库驱动": "com.mysql.jdbc.Driver",
      "测试连接专用sql": "select 1"
  }

请以上面的json为样例，针对ip和库名以及用户名和密码进行调整。

推荐json格式化工具地址：https://www.sojson.com/

2.配置sql语句

{
    "是否自动建表": "否",
    "table": "okok",
    "sql": "insert into  \"okok\"(\"EVALUE_DATE\",\"EVALUATOR\",\"SHOP_NAME\",\"EVALUATION_SCORE\",\"PRODUCT_NAME\",\"SITE_NAME\") values(?,?,?,?,?,?)",
    "注入数据列表": "EVALUE_DATE,EVALUATOR,SHOP_NAME,EVALUATION_SCORE,PRODUCT_NAME,SITE_NAME",
    "说明": "注入数据表的顺序要和占位符对应,如果是select语句则需要批量写入条数为1",
    "一次批量写入条数": 100,
    "日期格式": ["yyyy-MM-dd HH:mm:ss", "yyyyMMdd HHmmss", "yyyy-MM-dd"],
    "batchId": 3
}

请以上面的json为样例，针对上面的参数进行调整。

更新sql语句：样例如下，需更新table、sql和注入数据列表部分，要求sql语句中的“?”与注入数据列表中的参数名称一一对应。

{
    "是否自动建表":"否",
    "table":"XX表",
    "sql":"replace into `XX表` set `crc_id`=?,`日期_年份`=?,`日期_月份`=?,`财年`=?,`预算金额`=?,`销售额`=?,`达成率`=?,update_time=now()",
    "注入数据列表":"crc_id,日期_年份,日期_月份,财年,预算金额,销售额,达成率",
    "说明":"注入数据表的顺序要和占位符对应,如果是select语句则需要批量写入条数为1",
    "一次批量写入条数":100,
    "日期格式":["yyyy-MM-dd HH:mm:ss","yyyyMMdd HHmmss","yyyy-MM-dd"],
    "批号":370
}

根据日期自动分表：

必需修改内容：

1、"table"，根据某字段自动建表的demo,请参照后面的样例修改table的值即可，XX_{yyyyMMdd(release_date)}，release_date修改为日期分表依据的时间字段。

2、sql:空

选填内容：

1、如需要按照自己定义的格式进行建表，则保留createtable_sql": "CREATE TABLE `gaga{yyyyMMdd(release_date)}(release_dateDATETIME,urlVARCHAR(100) ,idINT NOT NULL AUTO_INCREMENT, PRIMARY KEY (id`))",注意与table里的表名要保持一致。

2、如需要按照自己定义的内容进行数据插入，则保留inserttable_sql": "INSERT INTO gaga{yyyyMMdd(release_date)} ( url,release_date)VALUES (?,?)",注意与table里的表名要保持一致。

注、自动建表的【table】命名中支持:{yyyyMMdd(xxxx)}写法，xxxx为日期字段的key名称。yyyyMMdd也可以是yyyyMM

样例1：自定义格式建表省心版字段靠猜_但有截断长度的风险。

{
    "是否自动建表": "是",
    "table": "gaga_{yyyyMMdd(release_date)}",
    "sql": "",
    "注入数据列表": "",
    "一次批量写入条数": 50,
    "日期格式": ["yyyy-MM-dd HH:mm:ss", "yyyyMMdd HHmmss", "yyyy-MM-dd"],
    "批号": 404
}

样例2：自定义格式建表复杂版一次配置终生享受。

{
    "是否自动建表": "是",
    "table": "gaga_{yyyyMMdd(release_date)}",
    "sql": "",
    "注入数据列表": "url,release_date",
    "一次批量写入条数": 50,
    "日期格式": ["yyyy-MM-dd HH:mm:ss", "yyyyMMdd HHmmss", "yyyy-MM-dd"],
    "批号": 404,
    "create_table_sql": "CREATE TABLE `gaga_{yyyyMMdd(release_date)}`(`release_date` DATETIME, `url` VARCHAR(100) , `id` INT NOT NULL AUTO_INCREMENT, PRIMARY KEY (`id`))",
    "insert_table_sql": "INSERT INTO gaga_{yyyyMMdd(release_date)} ( `url`,`release_date`)VALUES (?,?)"
}

输入简介

无输入

输入数据样例

有3个输出分支：

 1.failed 用于排错。
 2.resultset sql执行后的结果数据。
 3.success 上游流入的数据顺利处理后透传的数据流。