CREATE TABLE tableName(
colName colType,
...
colNameX colType
)WITH(
type ='sqlserver',
url ='jdbcUrl',
userName ='userName',
password ='pwd',
tableName ='tableName',
parallelism ='parllNum'
);
sqlserver-5.6.35
参数名称 | 含义 |
---|---|
tableName | sqlserver表名称 |
colName | 列名称 |
colType | 列类型 colType支持的类型 |
参数名称 | 含义 | 是否必填 | 默认值 |
---|---|---|---|
type | 表名 输出表类型[mysq|hbase|elasticsearch] | 是 | |
url | 连接sqlserver数据库 jdbcUrl | 是 | |
userName | sqlserver连接用户名 | 是 | |
password | sqlserver连接密码 | 是 | |
tableName | sqlserver表名称 | 是 | |
parallelism | 并行度设置 | 否 | 1 |
CREATE TABLE MyResult(
channel VARCHAR,
pv VARCHAR
)WITH(
type ='sqlserver',
url ='jdbc:jtds:sqlserver://172.16.8.104:1433;DatabaseName=mytest',
userName ='dtstack',
password ='abc123',
tableName ='pv2',
parallelism ='1'
)