文档

关于 SequoiaDB

快速入门

快速入门之一键清理

安装

基本操作

数据模型

SQL引擎

FileSystem引擎

S3引擎

系统架构

数据库管理

连接器

驱动

参考手册

故障排除

SAC 管控中心

Web服务

版本信息

Java开发基础

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

数据操作

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

    package com.sequoiadb.samples;
    import com.sequoiadb.base.DBCursor;
    import com.sequoiadb.base.Sequoiadb;
    import com.sequoiadb.exception.BaseException;
    public class Sample {
        public static void main(String[] args) {
            String connString = "192.168.1.2:11810";
              try {
                  // 建立 SequoiaDB 数据库连接
                  Sequoiadb sdb = new Sequoiadb(connString, "", "");
                  // 获取所有 Collection 信息,并打印出来
                  DBCursor cursor = sdb.listCollections();
                  try {
                      while(cursor.hasNext()) {
                          System.out.println(cursor.getNext());
                      }
                  } finally {
                      cursor.close();
                  }
              } catch (BaseException e) {
                  System.out.println("Sequoiadb driver error, error description:" + e.getErrorType());
              }
         }
    }

    Note:

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

    (2) SequoiaDB 类为非线程安全类,每个线程必须单独建立自己的 SequoiaDB 对象,不能传递给多个线程同时操作。

  • 插入数据

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

    Note:

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

  • 查询数据

    // 定义一个游标对象
    DBCursor cursor;
    BSONObject queryCondition = new BasicBSONObject();
    queryCondition = (BSONObject) JSON.parse("{age:{$ne:20}}");
    // 查询所有记录,并把查询结果放在游标对象中
    cursor = cl.query(queryCondition, null, null, null);
    // 从游标中显示所有记录
    try {
        while (cursor.hasNext()) {
           BSONObject record = cursor.getNext();
           String name = (String) record.get("name");
           System.out.println("name=" +  name);
        } 
    } finally {
     cursor.close();   
    }

    Note:

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

集群操作

  • 创建分区组

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

    Note:

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

    (2) rg.start() 方法用于启动一个分区组的所有节点,该函数一般需要等待10秒钟左右才可完成。该方法不保证分区组选举完成,为了保证分区组可以正常使用,start 完成后,还需要等待30秒时间才可以正常使用新建的分区组。

  • 在分区组增加节点

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

    Note:

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

回到顶部