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:

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

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

集群操作

  • 创建分区组
  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:

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

（2） 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）有写权限。