Kittle中将mysql数据导入Neo4j中

总共分为这几步：环境搭建，安装kittle,添加Neo4j插件，编写测试用例

1.环境要求：jdk1.8，mysql 和neo4j服务均已起来

2.kittle安装：

2.1下载地址：https://community.hitachivantara.com/docs/DOC-1009855

2.2打开后会自动下载，如果没有自动下载，点击Download按钮

　　2.3解压文件到自定义的目录，进入data-integration目录，直接在命令行启动 ./spoon.sh （如果为window环境，则启动Spoon.bat)

　　2.4启动后会出现如下窗口

3.安装neo4j插件

3.1下载地址：https://github.com/knowbi/knowbi-pentaho-pdi-neo4j-output/releases/

　　3.2解压Neo4JOutput-4.0.0.zip并将解压后的文件夹放入刚才安装的kittle的plugins文件夹下

　　3.3重新启动kittle，你会发现核心对象Table多了个Neo4j工具文件夹

4.将Mysql中数据导入Neo4j

4.1 新建一个转换，可以点击窗口左边的加号或者在主对象树标签中双击转换文件夹

　　4.2在核心对象标签页 选择 输入->表输入 和 Neo4j-> Neo4j Graph Output 两个图标拖入新建的转换面板，然后单击转换流程中的 “表输入”按钮，按住 shift 键将鼠标移动到“Neo4j Graph Output”  按钮上，你会发现新建了一条连线。

　　4.3编辑表输入：双击表输入，输入步骤名称和数据库连接和Sql语句，因为我们是从mysql中获取数据，所以要新建一个数据库连接，输入mysql连接的信息，然后选择对应的mysql数据库,输入要查询的sql语句，这里查询的结果会自动在Neo4j Graph Output中显示，为了简单，可以点击 获取SQL查询语句... 按钮，直接生成sql

　　4.4编辑Neo4j Graph Output: 双击Neo4j Graph Output，输入 Connection:neo4j数据库连接对象，Model:导入的模板映射对象

 

　　4.5编辑neo4j的label和Model的映射：点击Map fields

5.运行：点击左上角的三角按钮

5.1运行

　　5.2查看执行步骤

　　5.3查看结果

　　5.4 Mysql中原始数据

原文地址：https://www.cnblogs.com/ikcai/p/10427901.html

时间： 2024-10-18 08:27:32

Kittle中将mysql数据导入Neo4j中的相关文章

利用Sqoop将MySQL数据导入Hive中

参考 http://www.cnblogs.com/iPeng0564/p/3215055.html http://www.tuicool.com/articles/j2yayyj http://blog.csdn.net/jxlhc09/article/details/16856873 1.list databases sqoop list-databases --connect jdbc:mysql://192.168.2.1:3306/ --username sqoop --passwor

使用sqoop将mysql数据导入到hive中

首先准备工具环境:hadoop2.7+mysql5.7+sqoop1.4+hive3.1 准备一张数据库表: 接下来就可以操作了... 一.将MySQL数据导入到hdfs 首先我测试将zhaopin表中的前100条数据导出来,只要id.jobname.salarylevel三个字段. 再Hdfs上创建目录 hadoop fs -mkdir -p /data/base #用于存放数据 我们cd到sqoop目录下执行命令 # \ 用于换行bin/sqoop import --connect jdbc

使用 sqoop 将mysql数据导入到hive（import）

Sqoop 将mysql 数据导入到hive(import) 1.创建mysql表 CREATE TABLE `sqoop_test` ( `id` int(11) DEFAULT NULL, `name` varchar(255) DEFAULT NULL, `age` int(11) DEFAULT NULL ) ENGINE=InnoDB DEFAULT CHARSET=latin1 插入数据 2.hive 建表 hive> create external table sqoop_test

Sqoop将mysql数据导入hbase的血与泪

Sqoop将mysql数据导入hbase的血与泪(整整搞了大半天)  版权声明:本文为yunshuxueyuan原创文章.如需转载请标明出处: https://my.oschina.net/yunshuxueyuan/blogQQ技术交流群:299142667 一. 问题如何产生 庞老师只讲解了mysql和hdfs,mysq与hive的数据互导,因此决定研究一下将mysql数据直接导入hbase,这时出现了一系列问题. 心酸史: 二. 开始具体解决问题 需求:(将以下这张表数据导入mysql)

mysql数据导入到sqlite数据

在做程序时,sqlite数据很方便.用mysql数据导出到sqlite的步骤:(用csv文件过渡) -------------------------------  先导出到csv文件  ------------------------- 1.用navicat软件将mysql数据导出到txt文件. 2.注意选择“包含列标题”(字段名).“栏位定界符”(csv文件使用逗号). 3.把所有的txt文件转换为utf-8编码. 4.写一个rename.bat(ren *.txt *.csv),全部统一改

C#将SQL数据库中数据导入Excel中，并将Excel中反导入SQL数据库中

实际的开发中,我们会经常遇到数据的转化的需要,将Excel中的数据转入到SQL中,或将SQL在数据库表中的数据导入到Excel中.代码如下: Code using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windo

将Execl中的数据导入Sqlite3中

获取CVS文件:          选择Execl的文件菜单,选择save as选项,出现保存文件对话框,在保存文件类型中选择Text CVS(.cvs)文件类型, 勾选Edit Filter settings选项,按save按钮,会出现一个对话框,这个对话框可以对保存文件的格式进行设定, 字体自己选(Unicode ,Weatern Europe等等),区域分割符可以选择','(逗号)也可以选择';'(分号),前提是 Execl源文件中不包含该符号,其它选项自己选择想要的格式,然后点击'OK'

详解Mysql数据导入到SQLServer数据库中

本地方法不仅限定于Mysql,也可以将Excel.Oracle数据导入到SQLServer中. 这种方法是整个表批量导入和大数据中的sqoop工具差不多. 选择好数据源,例如:Mysql.Excel.Oracle等 编辑映射的时候,找好对应的数据类型,例如:varchar

Logstash：把MySQL数据导入到Elasticsearch中

前提条件 需要安装好Elasticsearch及Kibana. MySQL安装 根据不同的操作系统我们分别对MySQL进行安装.我们可以访问网页来对MySQL进行安装.等我们安装完我们的MySQL后,在我们的terminal中,打入如下的命令来检查MySQL的版本: $ /usr/local/mysql/bin/mysql -V /usr/local/mysql/bin/mysql Ver 8.0.17 for macos10.14 on x86_64 (MySQL Community Serv