[oracle@hadoop102 ~]$ mysql -uroot -p000000 mysql> create database oracle; mysql> use oracle; mysql> create table student(id int,name varchar(20));2.编写 datax 配置文件
[oracle@hadoop102 ~]$ vim /opt/module/datax/job/oracle2mysql.json { "job": { "content": [ { "reader": { "name": "oraclereader", "parameter": { "column": ["*"], "connection": [ { "jdbcUrl": ["jdbc:oracle:thin:@hadoop102:1521:orcl"], "table": ["student"] } ], "password": "000000", "username": "atguigu" } }, "writer": { "name": "mysqlwriter", "parameter": { "column": ["*"], "connection": [ { "jdbcUrl": "jdbc:mysql://hadoop102:3306/oracle", "table": ["student"] } ], "password": "000000", "username": "root", "writeMode": "insert" } } } ], "setting": { "speed": { "channel": "1" } } } }3.执行命令
[oracle@hadoop102 ~]$ /opt/module/datax/bin/datax.py /opt/module/datax/job/oracle2mysql.json4.查看结果
mysql> select * from student; +------+----------+ | id | name | +------+----------+ | 1 | zhangsan | +------+----------+二、读取 Oracle 的数据存入 HDFS 中 1.编写配置文件
[oracle@hadoop102 datax]$ vim job/oracle2hdfs.json { "job": { "content": [ { "reader": { "name": "oraclereader", "parameter": { "column": ["*"], "connection": [ { "jdbcUrl": ["jdbc:oracle:thin:@hadoop102:1521:orcl"], "table": ["student"] } ], "password": "000000", "username": "atguigu" } }, "writer": { "name": "hdfswriter", "parameter": { "column": [ { "name": "id", "type": "int" }, { "name": "name", "type": "string" } ], "defaultFS": "hdfs://hadoop102:9000", "fieldDelimiter": "t", "fileName": "oracle.txt", "fileType": "text", "path": "/", "writeMode": "append" } } } ], "setting": { "speed": { "channel": "1" } } } }2.执行
[oracle@hadoop102 datax]$ bin/datax.py job/oracle2hdfs.json3.查看HDFS结果
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)