代码拉取完成,页面将自动刷新
类型:writer
名称:postgresqlReader
PostgreSql 9.4及以上
column
1.读取全部字段,如果字段数量很多,可以使用下面的写法:
"column":["*"]
2.只指定字段名称:
"column":["id","name"]
3.指定具体信息:
"column": [{
"name": "col",
"type": "datetime"
}]
属性说明:
必选:是
字段类型:Array
默认值:无
不支持浮点、字符串、日期等其他类型
。pollingInterval
轮询间隔时间周期性的从数据库拉取数据。开启间隔轮询还需配置参数pollingInterval
,increColumn
,可以选择配置参数startLocation
。若不配置参数startLocation
,任务启动时将会从数据库中查询增量字段最大值作为轮询的开始位置。{
"job": {
"content": [
{
"postgresqlReader1": {
"type" : "reader",
"pluginName" : "postgresqlReader",
"parameter": {
"jdbcUrl" : "jdbc:postgresql://0.0.0.1:5432/postgres",
"username" : "username",
"password" : "password",
"table" : "student",
"column": ["*"],
"customSql": "",
"where": "id < 100",
"splitPk": "",
"queryTimeOut": 1000
}
},
"mysqlWriter2" : {
"type" : "writer",
"pluginName" : "mysqlWriter",
"parameter" : {
"jdbcUrl" : "jdbc:postgresql://0.0.0.1:5432/postgres",
"username" : "username",
"password" : "password",
"table" : "student1",
"column" : [ "id", "name", "sex" ],
"writeMode" : "INSERT"
}
}
}
],
"setting": {
"name": "myJob",
"speed": {
"channel": 1
},
"restore": {
"isRestore": false
}
}
}
}
{
"job": {
"content": [
{
"postgresqlReader1": {
"type" : "reader",
"pluginName" : "postgresqlReader",
"parameter": {
"jdbcUrl" : "jdbc:postgresql://0.0.0.1:5432/postgres",
"username" : "username",
"password" : "password",
"table" : "student",
"column": ["*"],
"customSql": "",
"where": "id < 100",
"splitPk": "id",
"queryTimeOut": 1000
}
},
"mysqlWriter2" : {
"type" : "writer",
"pluginName" : "mysqlWriter",
"parameter" : {
"jdbcUrl" : "jdbc:postgresql://0.0.0.1:5432/postgres",
"username" : "username",
"password" : "password",
"table" : "student1",
"column" : [ "id", "name", "sex" ],
"writeMode" : "INSERT"
}
}
}
],
"setting": {
"name": "myJob",
"speed": {
"channel": 2
},
"restore": {
"isRestore": false,
"restoreColumnName": "",
"restoreColumnIndex": 0
}
}
}
}
customSql
{
"job": {
"content": [
{
"postgresqlReader1": {
"type" : "reader",
"pluginName" : "postgresqlReader",
"parameter": {
"jdbcUrl" : "jdbc:postgresql://0.0.0.1:5432/postgres",
"username" : "username",
"password" : "password",
"table" : "",
"column": ["id","name","sex"],
"customSql": "select id,name,sex from table where id < 100",
"splitPk": "",
"queryTimeOut": 1000
}
},
"mysqlWriter2" : {
"type" : "writer",
"pluginName" : "mysqlWriter",
"parameter" : {
"jdbcUrl" : "jdbc:postgresql://0.0.0.1:5432/postgres",
"username" : "username",
"password" : "password",
"table" : "student1",
"column" : [ "id", "name", "sex" ],
"writeMode" : "INSERT"
}
}
}
],
"setting": {
"name": "myJob",
"speed": {
"channel": 1
},
"restore": {
"isRestore": false
}
}
}
}
startLocation
{
"job": {
"content": [
{
"postgresqlReader1": {
"type" : "reader",
"pluginName" : "postgresqlReader",
"parameter": {
"jdbcUrl" : "jdbc:postgresql://0.0.0.1:5432/postgres",
"username" : "username",
"password" : "password",
"table" : "student",
"column": [{
"name": "id",
"type": "int"
},{
"name": "name",
"type": "varchar"
},{
"name": "sex",
"type": "int"
}],
"where": "id < 100",
"splitPk": "id",
"queryTimeOut": 1000,
"increColumn": "id",
"startLocation": "20"
}
},
"mysqlWriter2" : {
"type" : "writer",
"pluginName" : "mysqlWriter",
"parameter" : {
"jdbcUrl" : "jdbc:postgresql://0.0.0.1:5432/postgres",
"username" : "username",
"password" : "password",
"table" : "student1",
"column" : [ "id", "name", "sex" ],
"writeMode" : "INSERT"
}
}
}
],
"setting": {
"name": "myJob",
"speed": {
"channel": 2
},
"restore": {
"isRestore": false,
"restoreColumnName": "",
"restoreColumnIndex": 0
}
}
}
}
{
"job": {
"content": [
{
"postgresqlReader1": {
"type" : "reader",
"pluginName" : "postgresqlReader",
"parameter": {
"jdbcUrl" : "jdbc:postgresql://0.0.0.1:5432/postgres",
"username" : "username",
"password" : "password",
"table" : "student",
"column": [{
"name": "id",
"type": "int"
},{
"name": "name",
"type": "varchar"
},{
"name": "sex",
"type": "int"
}],
"where": "id < 100",
"splitPk": "id",
"queryTimeOut": 1000,
"increColumn": "id",
"startLocation": "20",
"polling": true,
"pollingInterval": 3000
}
},
"mysqlWriter2" : {
"type" : "writer",
"pluginName" : "mysqlWriter",
"parameter" : {
"jdbcUrl" : "jdbc:postgresql://0.0.0.1:5432/postgres",
"username" : "username",
"password" : "password",
"table" : "student1",
"column" : [ "id", "name", "sex" ],
"writeMode" : "INSERT"
}
}
}
],
"setting": {
"name": "myJob",
"speed": {
"channel": 2
},
"restore": {
"isRestore": false
}
}
}
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。