全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 钉钉智能硬件
流计算

创建分布式数据库结果表(DRDS)

更新时间:2017-12-29 15:20:00

DDL定义

流计算支持使用DRDS作为结果输出,示例代码如下:

  1. CREATE RESULT TABLE rds_result (
  2. name STRING,
  3. value STRING,
  4. primary key(name)
  5. ) WITH (
  6. type='drds',
  7. url='jdbc:mysql://drds-url:3306/javademo?useUnicode=true&characterEncoding=UTF8',
  8. username='username',
  9. password='password',
  10. tableName='table'
  11. );

注意:

  • DRDS设计上必然存在Primary Key,因此在流计算声明DDL必须使用Primary Key,且必须使用REPLACE INTO语法进行更新插入。

WITH参数

字段名称 说明
type 数据存储类型,这里填写drds
username 能够读写该DRDS的用户名
password 能够读写该DRDS的密码
url 该数据库jdbc连接串信息,采用jdbc格式填写,形式上和Mysql连接串类似。
tableName 该DRDS的数据表名称

类型映射

DRDS字段类型 建议流计算字段类型
float/double Double
char/varchar/tinytext/text/mediumtext/longtext String
tinyint/smallint/mediumint/int/bigint Bigint
DATE/TIME/DATETIME/TIMESTAMP/YEAR String

注意:

  • 流计算暂不支持时间类型,因此建议用户使用String类型,格式为相应数据库时间类型的字符串写入。请查看Mysql文档有关时间类型的格式说明。例如,写入Mysql的DateTime类型,可以格式化为’0000-00-00 00:00:00’进行写入。
本文导读目录