Skip to content

datasource desc

qifeng dai edited this page Aug 16, 2017 · 23 revisions

本文档主要说明当前系统支持的数据源类型及其相关协议。

当前支持的数据源类型包括:

  • MYSQL
  • POSTGRES
  • ORACLE
  • MONGODB
  • HBASE
  • FTP

1.MYSQL/POSTGRES 的数据源结构

说明:这里主要描述了关系型数据库的连接参数。

参数 类型 是否必选 描述 说明
address string 数据源的 jdbc 地址 jdbc:mysql://{ip-address}:{port}, jdbc:postgresql://host:port
database string 该数据源对应的数据库名 test
user string 数据库对应的用户名 root
password string 数据库对应的密码 123456
extendParams string 扩展字段 形如:autoReconnect=true&useUnicode=true 形式,对链接参数进行补充

示例:

{
  "address": "jdbc:mysql://host:3306", # 对 POSTGRES 是 "jdbc:postgresql://host:port"
  "database": "test",
  "user": "root",
  "password": "123456"
}

2.ORACLE 的数据源结构

说明:这里主要描述了关系型数据库的连接参数。

参数 类型 是否必选 描述 说明
host string 数据库所在域名或者ip 例如192.168.1.1
port string 数据库所在端口号 例如:1000
service string oracle数据库的server名称
user string 数据库连接用户名
password string 数据库连接的用户密码

示例:

{
  "host": "localhost",
  "port": "1521",
  "service": "oracl",
  "user": "root",
  "password": "123456",
}

3.MONGODB 的数据源结构

说明:这里主要描述了 mongodb 的连接参数。

参数 类型 是否必选 描述 说明
address string 数据源的地址 mongodb://[username:password@]{ip-address1}:{port},{ip-address2}:{port}/[db]?[authMechanism=MONGODB-CR][&replicaSet=rs0][&maxPoolSize=200]
database string 数据库名 test

示例:

{
  "address": "mongodb://host1:20170,host2:20170,host3:20170/?maxPoolSize=200",
  "database": "test"
}

{
  "address": "mongodb://user:password@host1:20170,host2:20170,host3:20170/?authMechanism=MONGODB-CR&maxPoolSize=200",
  "database": "test"
}

4.HBASE 的数据源结构

说明:这里主要描述了 hbase 的连接参数,为 hbase 的连接参数,当前支持版本是 1.1+。

参数 类型 是否必选 描述 说明
zkQuorum string HBase的zookeeper地址 ``
zkZnodeParent string zk根路径 /hbase
zkPort string zk端口 2181

示例:

{
  "zkQuorum": "zk-host1,zk-host2,zk-host3",
  "zkZnodeParent": "/hbase",
  "zkPort":2181
}

5.FTP 的数据源结构

说明:这里主要描述了 ftp 的连接参数。

参数 类型 是否必选 描述 说明
host string ftp地址 127.0.0.1
port int 端口号 21
user string 用户名 ftpuser
password string 密码 ftppassword

示例:

{
  "host": "127.0.0.1",
  "port":21,
  "user":"ftpuser",
  "password":"ftppassword"
}
Clone this wiki locally