数据库引擎tinkerpop">1,图数数据库 引擎TinkerPop
之前简单测试了下tinkerpop。 http://www.2cto.com/database/201506/406914.html http://www.2cto.com/database/201506/407588.html 现在要把数据放到mysql 数据库 ,这样更加接近线上系统使用,TinkerPop不解决数据存储的问题,需要使用扩展放到其他存储上面,通过blueprints 接口存储。 支持MongoDB,hadoop,Titan,Neo4j等存储数据。 同时也支持jpa,我使用的是hibernate实现的jpa。当然支持所有数据库了,这里使用mysql进行存储。 代码和pom 放到github上面了:(1个java类而已)
2,mysql数据库准备
使用mysql root进行操作:(创建数据库,并创建用户并赋予权限)
CREATE DATABASE tinkerpop DEFAULT CHARACTER SET utf8 COLLATE utf8_general_ci;
GRANT ALL PRIVILEGES ON tinkerpop.* TO tinkerpop@"%" IDENTIFIED BY "tinkerpop";
FLUSH PRIVILEGES;
配置pom.xml
4.0.0
tinkerpop-demo
tinkerpop-demo
1.0
wingnest-repo
wingnest repo
http://www.wingnest.com/mvn-repo/
org.apache.tinkerpop
gremlin-core
3.0.0.M9-incubating
org.apache.tinkerpop
gremlin-driver
3.0.0.M9-incubating
com.tinkerpop.blueprints
blueprints-core
2.6.0
com.wingnest.blueprints
blueprints-jpa-graph
2.5.0_01
org.slf4j
slf4j-log4j12
1.7.5
test
org.slf4j
slf4j-simple
1.6.1
test
mysql
mysql-connector-java
5.1.35
org.apache.derby
derby
10.11.1.1
test
org.apache.derby
derbytools
10.11.1.1
test
junit
junit
4.12
org.hibernate
hibernate-core
4.3.10.Final
org.hibernate
hibernate-entitymanager
4.3.10.Final
org.apache.derby
derby
10.11.1.1
src/main/java
src/main/resources
true
org.apache.maven.plugins
maven-compiler-plugin
2.5.1
1.7
1.7
UTF-8
org.apache.maven.plugins
maven-resources-plugin
2.4
java代码:
package com.tinkerpop.demo;
import com.tinkerpop.blueprints.Direction;
import com.tinkerpop.blueprints.Edge;
import com.tinkerpop.blueprints.Vertex;
import com.wingnest.blueprints.impls.jpa.JpaGraph;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.util.HashMap;
import java.util.Map;
/**
* 创建数据库:
*
* CREATE DATABASE tinkerpop DEFAULT CHARACTER SET utf8 COLLATE utf8_general_ci;
* GRANT ALL PRIVILEGES ON tinkerpop.* TO tinkerpop@"%" IDENTIFIED BY "tinkerpop";
* FLUSH PRIVILEGES;
*/
public class TinkerPopMysqlDemo {
private JpaGraph jpaGraph = null;
@Before
public void setUp() {
//初始化jpa。保存到数据库中。使用hibernate 自动创建表结构。
//如果要使用mysql,这里修改属性。
Map props = new HashMap();
props.put("javax.persistence.jdbc.driver", "com.mysql.jdbc.Driver");
props.put("javax.persistence.jdbc.url", String.format("jdbc:mysql://xxx.xxx.xxx.xxx:3306/tinkerpop?characterEncoding=UTF-8"));
props.put("javax.persistence.jdbc.user", "tinkerpop");
props.put("javax.persistence.jdbc.password", "tinkerpop");
jpaGraph = new JpaGraph("HibernateUnit", props);
}
@After
public void tearDown() throws Exception {
//关闭
jpaGraph.shutdown();
}
@Test
public void testCreate() {
//创建张三数据
Vertex zhangsan = jpaGraph.addVertex(null);
zhangsan.setProperty("name", "zhangsan");
System.out.println("zhangsan:" + zhangsan.getId());
//创建李四数据
Vertex lisi = jpaGraph.addVertex(null);
lisi.setProperty("name", "lisi");
System.out.println