如何使用OrientDB ETL工具导入整个数据库数据?
How to use the OrientDB ETL tool to import the entire database data?
希望一次导入所有数据,貌似在extractor中,JDBC查询属性可以只查询一次
ETL 工具允许您通过 returns 所有 table 字段并将它们转换为 class 的查询将数据从 RDBMS 导入 OrientDB。
要迁移数据,您必须创建 N json 个文件,其中包含导入个人 table 及其关系的说明。
这两个 json 的一个简单示例,显示如何导入两个 tables,Table-A 和 Table-B 与关系 B <- A.
从 TABLE-A
创建 class
{
"config": {
"log": "debug"
},
"extractor" : {
"jdbc": { "driver": "com.mysql.jdbc.Driver",
"url": "jdbc:mysql://localhost:3306/mysqldb",
"userName": "root",
"userPassword": "",
"query": "select * from TableA" }
},
"transformers" : [
{ "vertex": { "class": "TableA"} }
],
"loader" : {
"orientdb": {
"dbURL": "plocal:/temp/databases/orientdb",
"dbAutoCreate": true
}
}
}
从 TABLE-B 和 link table-b 和 table-a
创建 class
{
"config": {
"log": "debug"
},
"extractor" : {
"jdbc": { "driver": "com.mysql.jdbc.Driver",
"url": "jdbc:mysql://localhost:3306/mysqldb",
"userName": "root",
"userPassword": "",
"query": "select * from TableB" }
},
"transformers" : [
{ "vertex": { "class": "TableB"} },
{ "edge": { "class": "associate", "direction" : "in",
"joinFieldName": "idTableB",
"lookup":"TableA.idTableA"
}
}
],
"loader" : {
"orientdb": {
"dbURL": "plocal:/temp/databases/orientdb",
"dbAutoCreate": true
}
}
}
希望对你有所帮助
希望一次导入所有数据,貌似在extractor中,JDBC查询属性可以只查询一次
ETL 工具允许您通过 returns 所有 table 字段并将它们转换为 class 的查询将数据从 RDBMS 导入 OrientDB。 要迁移数据,您必须创建 N json 个文件,其中包含导入个人 table 及其关系的说明。 这两个 json 的一个简单示例,显示如何导入两个 tables,Table-A 和 Table-B 与关系 B <- A.
从 TABLE-A
创建 class{
"config": {
"log": "debug"
},
"extractor" : {
"jdbc": { "driver": "com.mysql.jdbc.Driver",
"url": "jdbc:mysql://localhost:3306/mysqldb",
"userName": "root",
"userPassword": "",
"query": "select * from TableA" }
},
"transformers" : [
{ "vertex": { "class": "TableA"} }
],
"loader" : {
"orientdb": {
"dbURL": "plocal:/temp/databases/orientdb",
"dbAutoCreate": true
}
}
}
从 TABLE-B 和 link table-b 和 table-a
创建 class{
"config": {
"log": "debug"
},
"extractor" : {
"jdbc": { "driver": "com.mysql.jdbc.Driver",
"url": "jdbc:mysql://localhost:3306/mysqldb",
"userName": "root",
"userPassword": "",
"query": "select * from TableB" }
},
"transformers" : [
{ "vertex": { "class": "TableB"} },
{ "edge": { "class": "associate", "direction" : "in",
"joinFieldName": "idTableB",
"lookup":"TableA.idTableA"
}
}
],
"loader" : {
"orientdb": {
"dbURL": "plocal:/temp/databases/orientdb",
"dbAutoCreate": true
}
}
}
希望对你有所帮助