("lisi:" + lisi.getId());
//创建王五数据
Vertex wangwu = jpaGraph.addVertex(null);
wangwu.setProperty("name", "wangwu");
System.out.println("wangwu:" + wangwu.getId());
//设置李四和王五朋友关系，friend是连接的名字，可以随意取。
Edge friend1 = jpaGraph.addEdge(null, zhangsan, lisi, "friend");
//设置王五和李四朋友关系
Edge friend2 = jpaGraph.addEdge(null, wangwu, lisi, "friend");
System.out.println("create finish");
}
@Test
public void testQuery() {
//查询全部数据。
queryAll();
queryZhansanFriends();
System.out.println("query finish");
}
private void queryAll() {
Iterable allVertex = jpaGraph.getVertices();
System.out.println("######################query all######################");
for (Vertex vertex : allVertex) {
System.out.print("name:" + vertex.getProperty("name"));
System.out.println(",id:" + vertex.getId());
}
}
private void queryZhansanFriends() {
Vertex zhangsan = jpaGraph.getVertex(1);
System.out.println("######################query zhangsan friends######################");
Iterable zhansanFriends = zhangsan.getVertices(Direction.OUT, "friend");
for (Vertex vertex : zhansanFriends) {
System.out.print("name:" + vertex.getProperty("name"));
System.out.println(",id:" + vertex.getId());
}
}
@Test
public void testDelete() {
Vertex lisi = jpaGraph.getVertex(2);
jpaGraph.removeVertex(lisi);
//删除之后，查询全部。
queryAll();
queryZhansanFriends();
}
}
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("lisi:" + lisi.getId());
//创建王五数据
Vertex wangwu = jpaGraph.addVertex(null);
wangwu.setProperty("name", "wangwu");
System.out.println("wangwu:" + wangwu.getId());
//设置李四和王五朋友关系，friend是连接的名字，可以随意取。
Edge friend1 = jpaGraph.addEdge(null, zhangsan, lisi, "friend");
//设置王五和李四朋 |