SDK驱动开发

SequoiaDB 巨杉数据库为应用提供通过SDK驱动进行数据库操作和集群操作的接口。目前支持SDK驱动开发的语言如下：

  • C 驱动
  • C++ 驱动
  • CSharp 驱动
  • JAVA 驱动
  • PHP 驱动
  • Python 驱动
  • REST 驱动

JAVA SDK驱动开发

本章节以 JAVA SDK 驱动开发实现数据库增、删、改、查功能为例，本示例程序使用 Eclipse 工具开发，数据库用户名/密码默认为 sdbadmin，192.168.81.134 是数据库的服务IP，11810 端口是数据库协调节点的服务端口。

获取 JAVA 驱动开发包

从 SequoiaDB 巨杉数据库官网下载对应操作系统版本的 JAVA 驱动开发包；解压驱动开发包，从目录中获取 sequoiadb-driver.jar 文件。

配置 Eclipse 开发环境

  1. 将 SequoiaDB 驱动开发包中的 sequoiadb-driver.jar 文件拷贝到工程文件目录下（建议将其放置在其他所有依赖库目录，如 lib 目录）

  2. 在 Eclipse 界面中，创建/打开开发工程

  3. 在 Eclipse 主窗口左侧的“Package Explore”窗口中，选择开发工程，并点击鼠标右键

  4. 在菜单中选择“properties”菜单项

  5. 在弹出的“property for project …”窗口中，选择“Java Build Path”->“Libraries”

  6. 点击“Add External JARs..”按钮，选择添加 sequoiadb.jar 到工程中；

  7. 点击“OK”完成环境配置。

连接数据库

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

插入数据

  1. package com.sequoiadb.util;
  3. import org.bson.BSONObject;
  4. import org.bson.BasicBSONObject;
  6. import com.sequoiadb.base.CollectionSpace;
  7. import com.sequoiadb.base.DBCollection;
  8. import com.sequoiadb.base.Sequoiadb;
  9. import com.sequoiadb.exception.BaseException;
  11. public class Sample {
  12.     public static void main(String[] args) {
  13.         String connString = "192.168.81.134:11810";
  14.         try {
  15.             Sequoiadb sdb = new Sequoiadb(connString, "sdbadmin", "sdbadmin");
  16.             //创建school集合空间
  17.             CollectionSpace cs = sdb.createCollectionSpace("school");
  18.             //创建student集合
  19.             DBCollection cl = cs.createCollection("student");
  20.             // 创建一个插入的 bson 对象
  21.             BSONObject obj = new BasicBSONObject();
  22.             obj.put("id", 1);
  23.             obj.put("name", "tom");
  24.             obj.put("age", 24);
  25.             cl.insert(obj);
  26.         } catch (BaseException e) {
  27.             System.out.println("Sequoiadb driver error, error description:" + e.getErrorType());
  28.         }
  29.     }
  30. }

查询数据

  1. package com.sequoiadb.util;
  3. import org.bson.BSONObject;
  4. import org.bson.util.JSON;
  6. import com.sequoiadb.base.CollectionSpace;
  7. import com.sequoiadb.base.DBCollection;
  8. import com.sequoiadb.base.DBCursor;
  9. import com.sequoiadb.base.Sequoiadb;
  10. import com.sequoiadb.exception.BaseException;
  12. public class Sample {
  13.     public static void main(String[] args) {
  14.         String connString = "192.168.81.134:11810";
  15.         // 定义一个游标对象
  16.         DBCursor cursor = null;
  17.         try {
  18.             Sequoiadb sdb = new Sequoiadb(connString, "sdbadmin", "sdbadmin");
  19.             //获取school集合空间对象
  20.             CollectionSpace cs = sdb.getCollectionSpace("school");
  21.             //获取student集合对象
  22.             DBCollection cl = cs.getCollection("student");
  23.             //查询id为1的记录
  24.             BSONObject queryCondition = (BSONObject) JSON.parse("{id:1}");
  25.             //查询所有记录，并把查询结果放在游标对象中
  26.             cursor = cl.query(queryCondition, null, null, null);
  27.             //从游标中显示所有记录
  28.             try {
  29.                 while (cursor.hasNext()) {
  30.                    BSONObject record = cursor.getNext();
  31.                    String name = (String) record.get("name");
  32.                    int age = (int) record.get("age");
  33.                    System.out.println("name = " +  name);
  34.                    System.out.println("age = " +  age);
  35.                 } 
  36.             } finally {
  37.                 if(cursor != null){
  38.                     cursor.close();   
  39.                 }
  40.             }
  41.         } catch (BaseException e) {
  42.             System.out.println("Sequoiadb driver error, error description:" + e.getErrorType());
  43.         }
  44.     }
  45. }

修改数据

  1. package com.sequoiadb.util;
  3. import org.bson.BSONObject;
  4. import org.bson.util.JSON;
  6. import com.sequoiadb.base.CollectionSpace;
  7. import com.sequoiadb.base.DBCollection;
  8. import com.sequoiadb.base.Sequoiadb;
  9. import com.sequoiadb.exception.BaseException;
  11. public class Sample {
  12.     public static void main(String[] args) {
  13.         String connString = "192.168.81.134:11810";
  14.         try {
  15.             Sequoiadb sdb = new Sequoiadb(connString, "sdbadmin", "sdbadmin");
  16.             //获取school集合空间对象
  17.             CollectionSpace cs = sdb.getCollectionSpace("school");
  18.             //获取student集合对象
  19.             DBCollection cl = cs.getCollection("student");
  20.             //修改id为1记录的age值为30
  21.             BSONObject queryCondition = (BSONObject) JSON.parse("{id:1}");
  22.             BSONObject modifier = (BSONObject) JSON.parse("{$set:{age:30}}");
  23.             cl.update(queryCondition, modifier, null);
  24.         } catch (BaseException e) {
  25.             System.out.println("Sequoiadb driver error, error description:" + e.getErrorType());
  26.         }
  27.     }
  28. }

删除数据

  1. package com.sequoiadb.util;
  3. import org.bson.BSONObject;
  4. import org.bson.util.JSON;
  6. import com.sequoiadb.base.CollectionSpace;
  7. import com.sequoiadb.base.DBCollection;
  8. import com.sequoiadb.base.Sequoiadb;
  9. import com.sequoiadb.exception.BaseException;
  11. public class Sample {
  12.     public static void main(String[] args) {
  13.         String connString = "192.168.81.134:11810";
  14.         try {
  15.             Sequoiadb sdb = new Sequoiadb(connString, "sdbadmin", "sdbadmin");
  16.             //获取school集合空间对象
  17.             CollectionSpace cs = sdb.getCollectionSpace("school");
  18.             //获取student集合对象
  19.             DBCollection cl = cs.getCollection("student");
  20.             //删除id为1记录
  21.             BSONObject queryCondition = (BSONObject) JSON.parse("{id:1}");
  22.             cl.delete(queryCondition);
  23.         } catch (BaseException e) {
  24.             System.out.println("Sequoiadb driver error, error description:" + e.getErrorType());
  25.         }
  26.     }
  27. }