Mercurial > hg > Members > nobuyasu > TestNeo4j
diff src/begin/MakeNode.java @ 12:bf7863a55cd6 draft
add wikigraph.Neo4jTest.java
author | one |
---|---|
date | Thu, 23 Aug 2012 03:40:48 +0900 |
parents | d8d0855bcdfd |
children |
line wrap: on
line diff
--- a/src/begin/MakeNode.java Wed Aug 22 16:18:09 2012 +0900 +++ b/src/begin/MakeNode.java Thu Aug 23 03:40:48 2012 +0900 @@ -4,15 +4,20 @@ import javax.ws.rs.core.MediaType; -import org.json.simple.JSONObject; +import org.json.JSONException; +import org.json.JSONObject; + import com.sun.jersey.api.client.Client; +import com.sun.jersey.api.client.ClientHandlerException; import com.sun.jersey.api.client.ClientResponse; +import com.sun.jersey.api.client.UniformInterfaceException; import com.sun.jersey.api.client.WebResource; public class MakeNode { final static String SERVER_ROOT_URI = "http://localhost:7474"; final static String nodeEntryPointUri = "http://localhost:7474/db/data/node"; + final static String nodeIndexEntryPointUri = "http://localhost:7474/db/data/index/node"; public static URI createNode() { WebResource resource = Client.create().resource(nodeEntryPointUri); @@ -24,7 +29,7 @@ return response.getLocation(); } - public static ClientResponse getNode(String nodeUri) { + public static ClientResponse getNode(String nodeUri) { WebResource resource = Client.create().resource(nodeUri); ClientResponse response = resource.accept(MediaType.APPLICATION_JSON).get(ClientResponse.class); System.out.println(String.format("GET on [%s], status code [%d]",nodeUri, response.getStatus() )); @@ -50,7 +55,7 @@ return "\"" + str + "\""; } - public static void createRelationship(String uri1, String uri2, String typeValue) { + public static void createRelationship(String uri1, String uri2, String typeValue) throws JSONException { String relationshipUri = uri1 + "/relationships"; WebResource resource = Client.create().resource(relationshipUri); JSONObject obj = new JSONObject(); @@ -64,17 +69,67 @@ System.out.println(String.format("POST to [%s], status code [%d]",relationshipUri , response.getStatus())); } - public static void main(String[] args) { + public static void deleteNode(String uri) { + WebResource resource = Client.create().resource(uri); + ClientResponse response = resource.accept(MediaType.APPLICATION_JSON).delete(ClientResponse.class); + System.out.println(String.format( + "DELETE to [%s], status code [%d]", uri, response.getStatus())); + } + + public static URI createIndexNode(String indexName) throws JSONException { + WebResource resource = Client.create().resource(nodeIndexEntryPointUri); + JSONObject obj = new JSONObject(); + obj.put("name",indexName); + ClientResponse response = resource.accept(MediaType.APPLICATION_JSON) + .type(MediaType.APPLICATION_JSON) + .entity(obj.toString()) + .post(ClientResponse.class); + System.out.println(String.format( + "POST to [%s], status code [%d], location header [%s]", + nodeIndexEntryPointUri, response.getStatus(), response.getLocation() + .toString())); + return response.getLocation(); + } + + public static URI addNodeToIndex(String indexUri, String value, String uri, String key) throws JSONException { + WebResource resource = Client.create().resource(indexUri); + JSONObject obj = new JSONObject(); + obj.put("value", value); + obj.put("uri",uri); + obj.put("key",key); + + ClientResponse response = resource.accept(MediaType.APPLICATION_JSON) + .type(MediaType.APPLICATION_JSON) + .entity(obj.toString()) + .post(ClientResponse.class); + System.out.println(String.format( + "POST to [%s], status code [%d], location header [%s]", + nodeIndexEntryPointUri, response.getStatus(), response.getLocation() + .toString())); + return response.getLocation(); + } + + public static void main(String[] args) throws ClientHandlerException, UniformInterfaceException, JSONException { final String uri1 = "http://localhost:7474/db/data/node/1"; final String uri2 = "http://localhost:7474/db/data/node/2"; + + final String indexUri = "http://localhost:7474/db/data/index/node/hogehoge"; + addNodeToIndex(indexUri, "test_value", uri1, "test_key"); - getNode(uri1); + ClientResponse response = getNode(uri1); + // System.out.println(response.getEntity(String.class)); + JSONObject obj = new JSONObject(response.getEntity(String.class)); + System.out.println(obj.toString()); + + +/* + getNode(uri2); createRelationship(uri1, uri2, "RELATED_TO"); +*/ - /* URI firstNode = createNode(); addProperty(firstNode, "name", "Joe Strummer");