public void storeOrUpdate() throws Exception {
Map<String, Object> param = new HashMap<String, Object>();
param.put("userName", userName);
param.put("email", email);
param.put("createdTime", createdTime);
ResultSet rs = RexsterClientUtil.getInstance().getClient().submit("get_or_create_user(g, userName, email, createdTime)", param);
Result result = rs.one();
DetachedVertex dv = (DetachedVertex) result.getObject();
Iterator<VertexProperty<Object>> queryIter = dv.properties();
while( queryIter.hasNext()){
VertexProperty p = queryIter.next();
LOGGER.debug("User object : " + p.key() + ":" + p.value());
}
}
def get_or_create_user(g, userName, email, createdTime) {
nv = g.V().has('email', email);
if( !nv.hasNext())
{
ret = g.addV(label,'user', 'userName', userName, 'email', email, 'createdTime', createdTime).iterate();
g.tx().commit()
}
else{
ret = nv.next();
}
ret = g.V().has('email', email).next()
ret
}
def get_or_create_device(g, deviceIdentifier, deviceRegistrationStatus, serviceOffering, type, deviceToken){
nv = g.V().has('deviceIdentifier', deviceIdentifier);
if( !nv.hasNext())
{
ret = g.addV(label, 'device', 'deviceIdentifier', deviceIdentifier, 'deviceRegistrationStatus', deviceRegistrationStatus, 'serviceOffering', serviceOffering, 'type', type, 'deviceToken', deviceToken).iterate();
g.tx().commit()
}
else{
ret = nv.next();
}
ret = g.V().has('deviceIdentifier', deviceIdentifier).next()
ret
}
def addOwnerEdge(g, email, deviceId, toLabel){
d = g.V().has("deviceIdentifier", deviceId).as('x').match(__.as('x').not(__.in(toLabel).has('email', email))).select('x').next()
e = g.V().has('email', email).next()
e.addEdge(toLabel, d); null;
g.tx().commit()
}
To view this discussion on the web visit https://groups.google.com/d/msgid/aureliusgraphs/d0ab631c-3315-46e3-bcb5-08ad54a9d82f%40googlegroups.com.--
You received this message because you are subscribed to the Google Groups "Aurelius" group.
To unsubscribe from this group and stop receiving emails from it, send an email to aureliusgraph...@googlegroups.com.
GryoMapper mapper = GryoMapper.build().addRegistry(TitanIoRegistry.INSTANCE).create();
cluster = Cluster.build().serializer(new GryoMessageSerializerV1d0(mapper)).create();
client = cluster.connect();
client.init();
To view this discussion on the web visit https://groups.google.com/d/msgid/aureliusgraphs/6fb98592-42fb-45e6-ae8e-0b55b429577e%40googlegroups.com.
GryoMapper mapper = GryoMapper.build().addRegistry(TitanIoRegistry.INSTANCE).create();
cluster = Cluster.build().serializer(new GryoMessageSerializerV1d0(mapper)).create();
client = cluster.connect();
client.init();
ResultSet rs = client.submit("get_or_create_user(g, userName, email, createdTime)", param);
Result result = rs.one();
DetachedVertex dv = (DetachedVertex) result.getObject();
Iterator<VertexProperty<Object>> queryIter = dv.properties();
while( queryIter.hasNext()){
VertexProperty p = queryIter.next();
LOGGER.debug("User object : " + p.key() + ":" + p.value());
}
To view this discussion on the web visit https://groups.google.com/d/msgid/aureliusgraphs/cb3b8bbe-d5f4-42b8-ae59-6e494570cf45%40googlegroups.com.