UltipaConfiguration

UltipaConfiguration用于配置连接嬴图数据库时所需的服务器信息。

示例：创建一个集群连接，配置时使用default图集，实例化UltipaClientDriver时使用amz图集

public class Main {
    public static void main(String[] args) {
        UltipaConfiguration configuration = UltipaConfiguration.config()
                .hosts("192.168.1.85:60061,192.168.1.86:60061,192.168.1.87:60061")
                .username("root")
                .password("root");

		UltipaClientDriver driver = null;
		try {
			driver = new UltipaClientDriver(configuration);
			Connection conn = driver.getConnection("amz");

			String reply = conn.sayHello("Hi");
			System.out.println(reply);
		} finally {
			if (driver != null) {
				driver.close();
			}
		}
    }
}

PoolConfig

PoolConfig用于配置连接嬴图数据库时所需的连接池（Apache Common-Pool）信息。

示例：创建一个连接，使用default图集，并对连接池进行配置

public class Main {
    public static void main(String[] args) {
        UltipaConfiguration configuration = UltipaConfiguration.config()
                .hosts("192.168.1.85:60061,192.168.1.86:60061,192.168.1.87:60061")
                .username("***")
                .password("***");

        PoolConfig poolConfig = configuration.getPoolConfig();
        poolConfig.setMaxIdle(50);
        poolConfig.setMinIdle(2);
        poolConfig.setMaxTotal(200);

        UltipaClientDriver driver = null;
        try {
            driver = new UltipaClientDriver(configuration);
            Connection conn = driver.getConnection();

            String reply = conn.sayHello("Hi");
            System.out.println(reply);
        } finally {
            if (driver != null) {
                driver.close();
            }
        }
    }
}

ultipa.properties

ultipa.properties为配置文件，用于存放连接嬴图数据库时所需的server、连接池信息。

ultipa.properties文件需放置于Java项目的classpath下，基于Maven架构的Java项目的classpath默认为'./src/main/resources'。

各配置项的取值顺序为：优先使用UltipaConfiguration的配置，其次为ultipa.properties文件，都没有的使用默认值。

示例：用配置文件创建一个连接

ultipa.hosts=192.168.1.85:60061,192.168.1.86:60061,192.168.1.87:60061
ultipa.username=root
ultipa.password=root
ultipa.passwordEncrypt=NOTHING
ultipa.defaultGraph=amz
# ultipa.crt=F:\\ultipa.crt
# ultipa.overrideAuthority=ultipa
# ultipa.crt=https
# ultopa.crt=
ultipa.keepAlive=180
ultipa.keepAliveWithoutCalls=true
ultipa.pool.maxIdle=50
ultipa.pool.minIdle=20
ultipa.pool.maxTotal=200
ultipa.pool.timeBetweenEvictionRunsMillis=3600000
ultipa.pool.testOnBorrow=true

public class Main {
    public static void main(String[] args) {     
        UltipaClientDriver driver = null;
        try {
            driver = new UltipaClientDriver();
            Connection conn = driver.getConnection();

            String reply = conn.sayHello("Hi");
            System.out.println(reply);
        } finally {
            if (driver != null) {
                driver.close();
            }
        }
    }
}

DataSource

DataSrouce用于配置与嬴图数据库连接时所需的信息，以及与连接池相关的信息。

使用DataSrouce创建UltipaClientDriver且同时提供了ultipa.properties文件时：

• 数据库连接的配置、连接池的配置都将以DataSrouce为准，而忽略ultipa.properties文件中的信息。

示例：创建一个连接，使用DataSource进行数据库连接配置与连接池配置

public class Main {
    public static void main(String[] args) {
        UltipaConfiguration configuration = UltipaConfiguration.config()
                .hosts("192.168.1.85:60061,192.168.1.86:60061,192.168.1.87:60061")
                .username("***")
                .password("***");

        PoolConfig poolConfig = configuration.getPoolConfig();
        poolConfig.setMaxIdle(50);
        poolConfig.setMinIdle(2);
        poolConfig.setMaxTotal(200);

        DataSource dataSource = new DataSource();
        dataSource.setUltipaConfiguration(configuration);
        dataSource.setDefaultGraph("amz");

        UltipaClientDriver driver = null;
        try {
            driver = new UltipaClientDriver(DataSource);
            Connection conn = driver.getConnection();

            String reply = conn.sayHello("Hi");
            System.out.println(reply);
        } finally {
            if (driver != null) {
                driver.close();
            }
        }
    }
}

RequestConfig

RequestConfig用于向嬴图数据库发送非插入类请求时进行相关的配置。

示例：创建连接时使用default图集，执行嬴图GQL查询时使用amz图集并发送给集群的leader

public class Main {
    public static void main(String[] args) {
        UltipaConfiguration configuration = UltipaConfiguration.config()
                .hosts("192.168.1.85:60061,192.168.1.86:60061,192.168.1.87:60061")
                .username("***")
                .password("***");

        UltipaClientDriver driver = null;
        try {
            driver = new UltipaClientDriver(configuration);
            Connection conn = driver.getConnection();

            String reply = conn.sayHello("Hi");
            System.out.println(reply);
          
            RequestConfig requestConfig = new RequestConfig();
            requestConfig.setGraphName("amz");
            requestConfig.setUseMaster(true);
        
            Response res = conn.uql("find().nodes() as nodes return nodes{*} limit 10", requestConfig);
            List<Node> nodeList = res.alias("nodes").asNodes();
            for(int i = 0; i < nodeList.size(); i ++){
                System.out.println("node " + i + " is: " + nodeList.get(i).toJson());
            }
        } finally {
            if (driver != null) {
                driver.close();
            }
        }

    }
}

InsertRequestConfig

InsertRequestConfig用于向嬴图数据库发送插入类请求时进行相关的配置。

示例：创建连接时使用default图集，执行插入点时使用test图集并进行插入覆盖操作

public class Main {
    public static void main(String[] args) {
        UltipaConfiguration configuration = UltipaConfiguration.config()
                .hosts("192.168.1.85:60061,192.168.1.86:60061,192.168.1.87:60061")
                .username("***")
                .password("***");

		UltipaClientDriver driver = null;
		Connection conn;
        try {
            driver = new UltipaClientDriver(configuration);
            conn = driver.getConnection();

            String reply = conn.sayHello("Hi");
            System.out.println(reply);
            InsertRequestConfig insertRequestConfig = new InsertRequestConfig();
            insertRequestConfig.setGraphName("test");
            insertRequestConfig.setInsertType(Ultipa.InsertType.OVERWRITE);

            List<Node> nodeList = new ArrayList<>();
            Node node1 = new Node();
            node1.setSchema("client");
            node1.setID("CLIENT00001");
            nodeList.add(node1);
            Node node2 = new Node();
            node2.setSchema("card");
            node1.setID("CARD00004");
            nodeList.add(node2);
        } finally {
            if (driver != null) {
                driver.close();
            }
        }

      
        conn.insertNodesBatchAuto(nodeList, insertRequestConfig);
    }
}