图数数据库引擎tinkerpop（3）使用java调用tinkerpop，存储到mysql数据库 - 数据库编程

("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");

        //设置王五和李四朋

图数数据库引擎tinkerpop（3）使用java调用tinkerpop，存储到mysql数据库(二)