UltipaConfiguration

UltipaConfiguration 用于配置连接 Ultipa 数据库时所需的 server 信息。

示例：创建一个连接，配置时使用 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("***")
                .password("***");

		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 用于配置连接 Ultipa 数据库时所需的连接池（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 为配置文件，用于存放连接 Ultipa 数据库时所需的 server、连接池信息。

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

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

• 数据库连接的配置将优先使用 ultipa.properties 中的信息，ultipa.properties 中不包含的项再以 UltipaConfiguration 的配置为准；
• 连接池的配置将以 ultipa.properties 中的信息为准，而忽略 PoolConfig 的配置。

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

ultipa.hosts=192.168.1.85:60061,192.168.1.86:60061,192.168.1.87:60061
ultipa.username=root
ultipa.password=root
ultipa.defaultGraph=amz
# ultipa.crt=F:\\ultipa.crt
# ultipa.overrideAuthority=ultipa
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 用于配置与 Ultipa 数据库连接时所需的信息，以及与连接池相关的信息。

使用 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 用于向 Ultipa 数据库发送非插入类请求时进行相关的配置。

示例：创建连接时使用 default 图集，执行 UQL 查询时使用 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 用于向 Ultipa 数据库发送插入类请求时进行相关的配置。

示例：创建连接时使用 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");
            node2.setID("CARD00004");
            nodeList.add(node2);
            conn.insertNodesBatchAuto(nodeList, insertRequestConfig);
        } finally {
            if (driver != null) {
                driver.close();
            }
        }

    }
}