package com.wx.application.nebula.graph.base;
import java.util.Arrays;
import java.util.List;
import com.vesoft.nebula.client.graph.NebulaPoolConfig;
import com.vesoft.nebula.client.graph.data.HostAddress;
import com.vesoft.nebula.client.graph.net.NebulaPool;
import com.vesoft.nebula.client.graph.net.Session;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class NebulaGraphClient1 {
NebulaPool pool;
//Session session;
public void nebulaPool() {
pool = new NebulaPool();
try {
NebulaPoolConfig nebulaPoolConfig = new NebulaPoolConfig();
nebulaPoolConfig.setMaxConnSize(100);
nebulaPoolConfig.setTimeout(1000);
nebulaPoolConfig.setWaitTime(1000);
List<HostAddress> addresses = Arrays.asList(new HostAddress("localhost", 9669));
pool.init(addresses, nebulaPoolConfig);
//session= pool.getSession("root", "123456", false);
} catch (Exception e) {
e.printStackTrace();
}
}
public Session getSession() throws Exception {
/*if(session.ping()) {
return session;
}
session.release();*/
Session session = pool.getSession("root", "123456", false);
return session;
}
}