转载

Neo4j创建自动索引

一、创建Neo4j的Legacy indexing

1.为节点创建索引

官方API的创建示例为：

Neo4j创建自动索引

将一节点添加至索引：

public static void AddNodeIndex(String nid) {  String txUri=SERVER_ROOT_URI+"index/node/favorites";  WebResource resource = Client.create().resource(txUri);  String entity="{/"value/" : /"n204/",/"uri/" : /"http://192.168.209.128:7474/db/data/node/"+nid+"/",/"key/" : /"n201/"}";  ClientResponse response = resource.accept(MediaType.APPLICATION_JSON)    .type(MediaType.APPLICATION_JSON).entity(entity)    .post(ClientResponse.class);  System.out.println(response.getStatus());  System.out.println(response.getEntity(String.class));  response.close(); }

ps:nid是要添加索引的节点ID value是索引值 key是索引名称

2.通过属性查找节点

public static void GetNodeByIndex() {  String txUri=SERVER_ROOT_URI+"index/node/favorites/n201/n201";  WebResource resource = Client.create().resource(txUri);  ClientResponse response = resource.accept(MediaType.APPLICATION_JSON)    .type(MediaType.APPLICATION_JSON)    .get(ClientResponse.class);  System.out.println(response.getStatus());  System.out.println(response.getEntity(String.class));  response.close(); }

txUri路径中：favorites为刚创建的索引名称，第一个n201是节点索引key，第二个n201是节点索引值

二、自动创建索引（Legacy Automatic Indexes）

What default configuration means depends on how you have configured your database. If you haven’tchanged any indexing configuration, it means the indexes will be using a Lucene-based backend.

数据库配置之后，就可以自动创建索引

1.配置文件配置

Auto-indexing must be enabled through configuration before we can create or configure them. Firstlyensure that you’ve added some config like this into your server’s conf/neo4j.properties file:

打开conf/neo4j.properties文件如图 Neo4j创建自动索引

配置下面的节点

# Enable auto-indexing for nodes, default is false. node_auto_indexing=true  # The node property keys to be auto-indexed, if enabled. node_keys_indexable=name,ki  # Enable auto-indexing for relationships, default is false. relationship_auto_indexing=true  # The relationship property keys to be auto-indexed, if enabled. relationship_keys_indexable=name,ki

Node_keys_indexable、relationship_keys_indexable对应节点、关系的属性

配置完成之后重启服务

Neo4j创建自动索引

重启三个节点的集群

2。测试索引

插入一个节点和关系

// 创建节点  @Test  public void test2() {   URI uri = CreateSimpleGraph.createNode();   CreateSimpleGraph.addProperty(uri, "name", "张三");   URI uri1 = CreateSimpleGraph.createNode();   CreateSimpleGraph.addProperty(uri1, "name", "李四");  } // 为节点设置关系  @Test  public void test6() {   for (int i = 1; i < 2; i++) {    try {     URI suri = new URI("http://192.168.209.128:7474/db/data/node/171391");     String uri1="http://192.168.209.128:7474/db/data/node/";     URI euri = new URI("http://192.168.209.128:7474/db/data/node/171392");     URI reluri= CreateSimpleGraph.addRelationship(suri, euri, "家人","{/"ki/" : /"1234567890/", /"name/" : /"无/" }");     System.out.println(reluri);    } catch (URISyntaxException e) {     // 异常信息输出该内容     e.printStackTrace();    }   }  }

3.通过属性查找节点

public static void GetNodeByAutoIndex(String ki)     { // String txUri=SERVER_ROOT_URI+"index/node/node_auto_index/name/"+ki;  String txUri=SERVER_ROOT_URI+"index/auto/node/ki/"+ki;  WebResource resource = Client.create().resource(txUri);  ClientResponse response = resource.accept(MediaType.APPLICATION_JSON)   .type(MediaType.APPLICATION_JSON)   .get(ClientResponse.class);  System.out.println(response.getStatus());  System.out.println(response.getEntity(String.class));  response.close();     }     public static void GetRelationshipByAutoIndex(String ki)     { // String txUri=SERVER_ROOT_URI+"index/node/node_auto_index/name/"+ki;  String txUri=SERVER_ROOT_URI+"index/auto/relationship/ki/"+ki;  WebResource resource = Client.create().resource(txUri);  ClientResponse response = resource.accept(MediaType.APPLICATION_JSON)   .type(MediaType.APPLICATION_JSON)   .get(ClientResponse.class);  System.out.println(response.getStatus());  System.out.println(response.getEntity(String.class));  response.close();     }

关系的输出结果为：

[ {   "extensions" : { },   "metadata" : {     "id" : 337,     "type" : "家人"   },   "data" : {     "name" : "无",     "ki" : "1234567890"   },   "property" : "http://192.168.209.128:7474/db/data/relationship/337/properties/{key}",   "start" : "http://192.168.209.128:7474/db/data/node/171391",   "self" : "http://192.168.209.128:7474/db/data/relationship/337",   "end" : "http://192.168.209.128:7474/db/data/node/171392",   "type" : "家人",   "properties" : "http://192.168.209.128:7474/db/data/relationship/337/properties" } ]

这里说明一下， 传值为中文的时候，查询不出来 ，可能需要编码，因为工作暂时没有用到，就没有再研究了

三、NEO4J批量插入和用户密码问题

1.批量操作

批量操作的官方文档地址：http://neo4j.com/docs/milestone/rest-api-batch-ops.html

public static int BatchInserterNode(String body) {   // String   // body="[{/"method/":/"POST/",/"to/":/"/node/",/"body/":{/"name/":/"aaa/",/"lead/":/"aaa1/"},/"id/":0},{/"method/":/"POST/",/"to/":/"/node/",/"body/":{/"name/":/"bbb/",/"lead/":/"bbb1/"},/"id/":1}]";   // POST {} to the node entry point URI   ClientResponse response = GetResourceInstance("batch")     .accept(MediaType.APPLICATION_JSON)     .type(MediaType.APPLICATION_JSON).entity(body)     .post(ClientResponse.class);   // System.out.println(String.format(   // "POST to [%s], status code [%d], location header [%s]",   // nodeEntryPointUri, response.getStatus(), location.toString()));   String entity = response.getEntity(String.class);   response.close();   int status = response.getStatus();   return status;  } //调用  //批量插入速度测试  @Test  public void test10()  {   StringBuilder sbody=new StringBuilder();   sbody.append("[");   for (int i = 161337; i < 171337; i++) {    if(i>161337)    {     sbody.append(",");    }    sbody.append("{");    sbody.append("/"method/":/"POST/",/"to/":/"/node/",/"body/":{/"name/":/"n"+i+"/",/"lead/":/"a"+i+"/"},/"id/":"+i+"");    sbody.append("}");   }   sbody.append("]");   long st = System.currentTimeMillis();   int status= CreateSimpleGraph.BatchInserterNode(sbody.toString());   System.out.println("插入状态:"+status);   long et = System.currentTimeMillis();   System.out.println("插入10000条数据总共耗时：" + (et - st) + "毫秒");    }

批量插入的速度10000条大概在6秒左右吧

2.NEO4J密码操作

本次用的版本是：neo4j-enterprise-2.2.0-unix，连接数据库的时候需要输入用户名称密码。上个版本好像是不用的。

使用密码时：

public void checkDatabaseIsRunning() {  // START SNIPPET: checkServer  WebResource resource = Client.create().resource(SERVER_ROOT_URI);  ClientResponse response = resource.get(ClientResponse.class);  resource.addFilter(new HTTPBasicAuthFilter("neo4j", "123456"));  if (response.getStatus() == 200) {      System.out.println("连接成功!");  } else {      System.out.println("连接失败!");  }  // System.out.println(String.format("GET on [%s], status code [%d]",  // SERVER_ROOT_URI, response.getStatus()));  response.close();  // END SNIPPET: checkServer     }