Java开发基础

本文档介绍如何使用Java驱动接口编写使用 SequoiaDB 巨杉数据库的程序。为了简单起见，下面的示例不全部是完整的代码，只起示例性作用。可到安装目录/client/samples/java下获取相应的完整的代码。 更多查看 Java API

数据操作

  • 连接数据库：Connecting 如下是一个连接数据库，并列出所有集合信息的一个例子：

    1. package com.sequoiadb.samples;
    2. import com.sequoiadb.base.DBCursor;
    3. import com.sequoiadb.base.Sequoiadb;
    4. import com.sequoiadb.exception.BaseException;
    5. public class Sample {
    6.     public static void main(String[] args) {
    7.         String connString = "192.168.1.2:11810";
    8.           try {
    9.               // 建立 SequoiaDB 数据库连接
    10.               Sequoiadb sdb = new Sequoiadb(connString, "", "");
    11.               // 获取所有 Collection 信息，并打印出来
    12.               DBCursor cursor = sdb.listCollections();
    13.               try {
    14.                   while(cursor.hasNext()) {
    15.                       System.out.println(cursor.getNext());
    16.                   }
    17.               } finally {
    18.                   cursor.close();
    19.               }
    20.           } catch (BaseException e) {
    21.               System.out.println("Sequoiadb driver error, error description:" + e.getErrorType());
    22.           }
    23.      }
    24. }

    Note:

    • 本例程连接到本地数据库的11810端口是协调节点的服务端口，使用的是空的用户名和密码。用户需要根据自己的实际情况配置参数。
    • SequoiaDB 类为非线程安全类，每个线程必须单独建立自己的 SequoiaDB 对象，不能传递给多个线程同时操作。

  • 插入数据

    1. String connString = "192.168.1.2:11810";
    2. try {
    3.     Sequoiadb sdb = new Sequoiadb(connString, "", "");
    4.     CollectionSpace db = sdb.createCollectionSpace("space");
    5.     DBCollection cl = db.createCollection("collection");
    6.     // 创建一个插入的 bson 对象
    7.     BSONObject obj = new BasicBSONObject();
    8.     obj.put("name", "tom");
    9.     obj.put("age", 24);
    10.     cl.insert(obj);
    11. } catch (BaseException e) {
    12.     System.out.println("Sequoiadb driver error, error description:" + e.getErrorType());
    13. }

    Note:

    本例程连接到本地数据库的11810端口是协调节点的服务端口，使用的是空的用户名很密码。用户需要根据自己的实际情况配置参数。

  • 查询数据

    1. // 定义一个游标对象
    2. DBCursor cursor;
    3. BSONObject queryCondition = new BasicBSONObject();
    4. queryCondition = (BSONObject) JSON.parse("{age:{$ne:20}}");
    5. // 查询所有记录，并把查询结果放在游标对象中
    6. cursor = cl.query(queryCondition, null, null, null);
    7. // 从游标中显示所有记录
    8. try {
    9.     while (cursor.hasNext()) {
    10.        BSONObject record = cursor.getNext();
    11.        String name = (String) record.get("name");
    12.        System.out.println("name=" +  name);
    13.     } 
    14. } finally {
    15.  cursor.close();   
    16. }

    Note:

    • 此示例中设置了简单的查询条件，实际上还可以设置筛选条件，排序情况，及仅使用默认索引等选项。
    • 游标对象将数据表中的部分数据缓存在本地进程的内存中，如果本地数据读取完了，游标对象会通过网络从服务器再次获取部分数据缓存在本地。

集群操作

  • 创建分区组

    1. String connString = "192.168.1.2:11810";
    2. try {
    3.     Sequoiadb sdb = new Sequoiadb(connString, "", "");
    4.     ReplicaGroup rg = sdb.createRG("group1");
    5.     rg.createNode("dbserver-1", 11820, "/opt/sequoiadb/database/data/11820", null);
    6.     rg.start();
    7. } catch (BaseException e) {
    8.     System.out.println("Sequoiadb driver error, error description" + e.getErrorType());
    9. }

    Note:

    • rg.createNode() 方法的第一个参数为新增节点所在的主机名，注意这里必须是主机名（暂时不支持使用 IP 地址），第三个参数为数据文件存放路径，SequoiaDB 将自动新建该目录，但需要确保 SequoiaDB 管理员用户（默认 sdbadmin）有写权限。
    • rg.start() 方法用于启动一个分区组的所有节点，该函数一般需要等待10秒钟左右才可完成。该方法不保证分区组选举完成，为了保证分区组可以正常使用，start 完成后，还需要等待30秒时间才可以正常使用新建的分区组。

  • 在分区组增加节点

    1. String connString = "192.168.1.2:11810";
    2. try {
    3.     Sequoiadb sdb = new Sequoiadb(connString,"","");
    4.     ReplicaGroup rg = sdb.getReplicaGroup("group1");
    5.     Node node = rg.createNode("dbserver-1", 11830, "/var/sequoiadb/database/data/11830", null);
    6.     node.start();
    7. } catch (BaseException e) {
    8.     System.out.println("Sequoiadb driver error, error description" + e.getErrorType());
    9. }

    Note:

    rg.createNode() 方法的第一个参数为新增节点所在的主机名，注意这里必须是主机名（暂时不支持使用IP地址），第三个参数为数据文件存放路径，SequoiaDB将自动新建该目录，但需要确保SequoiaDB管理员用户（默认sdbadmin）有写权限。