创建datax job json文件:
{
"job": {
"setting": {
"speed": {
"channel": 1
}
},
"content": [
{
"reader": {
"name": "mysqlreader",
"parameter": {
"username": "数据库用户名",
"password": "密码",
"connection": [
{
"querySql": [
"select * from table;"
],
"jdbcUrl": [
"jdbc:mysql://127.0.0.1/数据库"
]
}
]
}
},
"writer": {
"name": "txtfilewriter",
"parameter": {
"print": true,
"encoding": "UTF-8",
"path": "csv文件存放位置",
"fileName": "csv文件名",
"writeMode": "truncate",
"dateFormat": "YYYY-MM-dd hh:mm:ss",
"header": [
"id",
"**",
"**",
"**(需要保存的字段)"
]
}
}
}
]
}
}
执行完后,得到csv数据文件。
2.将csv文件数据导入数据库
{
"job": {
"setting": {
"speed": {
"channel": 2
}
},
"content": [
{
"reader": {
"name": "txtfilereader",
"parameter": {
"path": [
"G:/result/result.csv"
],
"encoding": "UTF-8",
"column": [
{
"index": 0,
"name": "id",
"type": "long"
},
{
"index": 1,
"name": "**",
"type": "string"
},
{
"index": "字段索引",
"name": "字段名",
"type": "字段类型"
},
********
],
"skipHeader": "true"
}
},
"writer": {
"name": "mysqlwriter",
"parameter": {
"writeMode": "update",
"username": "root",
"password": "密码",
"column": [
"id",
"code",
*****
],
"connection": [
{
"jdbcUrl": "jdbc:mysql://127.0.0.1:3306/数据库",
"table": [
"table表"
]
}
]
}
}
}
]
}
}
3.执行成功数据同步完成



