SequoiaDB安装测试报告(二)

2021-07-15 22:13:35

上接：SequoiaDB安装测试报告  地址：http://blog.chinaunix.net/uid-78707-id-3931335.html
七：Java编程访问数据库（续）
昨天建立了连接并得到了集合空间和集合，今天实现了集合查询。完整代码如下：

点击(此处)折叠或打开

  1. package com.greencloud;

  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.DBCursor;
  9. import com.sequoiadb.base.Sequoiadb;
  10. import com.sequoiadb.exception.BaseException;

  12. public class SequoiaDbDemo {

  14.     static String CS_NAME = "foo";
  15.     static String CL_NAME = "bar";
  16.     static String INDEX_NAME = "bar";

  18.     /**
  19.      * @param args
  20.      */
  21.     public static void main(String[] args) {
  22.         // TODO Auto-generated method stub
  23.         String connectStr = "192.168.8.128:50000";
  24.         Sequoiadb sdb = null;
  25.         try {
  26.             sdb = new Sequoiadb(connectStr, "sdbadmin", "sdbadmin");
  27.         } catch (BaseException be) {
  28.             System.out.println(be.toString());
  29.             be.printStackTrace();
  30.             System.exit(1);
  31.         }

  33.         CollectionSpace cs = null;
  34.         if (sdb.isCollectionSpaceExist(CS_NAME)) {
  35.             cs = sdb.getCollectionSpace(CS_NAME);
  36.             System.out.println("Select Collection Space");
  37.         } else {
  38.             cs = sdb.createCollectionSpace(CS_NAME);
  39.             System.out.println("Create Collection Space");
  40.         }

  42.         DBCollection cl = null;
  43.         if (cs.isCollectionExist(CL_NAME)) {
  44.             cl = cs.getCollection(CL_NAME);
  45.             System.out.println("Select Colleciton");
  46.         } else {
  47.             cl = cs.createCollection(CL_NAME);
  48.             System.out.println("Create Collection");
  49.         }

  51.         try {
  52.             BSONObject index = null;
  53.             DBCursor indexCursor = cl.getIndex(INDEX_NAME);
  54.             if (indexCursor.hasNext()) {
  55.                 index = indexCursor.getNext();
  56.             }
  57.             // result cursor
  58.             DBCursor dataCursor = null;
  59.             // 构建相应BSONObject，用于查询，包括：条件(query)，域选择(selector)，排序规则(orderBy)，
  60.             // 索引使用(index)，跳过记录个数(0)，返回记录个数(-1：返回所有数据)。
  61.             // query condition
  62.             BSONObject query = new BasicBSONObject();
  63.             BSONObject condition = new BasicBSONObject();
  64.             condition.put("$et", "wangcc");
  65.             // condition.put("$lte", 9);
  66.             query.put("name", condition);
  67.             // return fields
  68.             BSONObject selector = new BasicBSONObject();
  69.             selector.put("_id", null);
  70.             selector.put("name", null);
  71.             selector.put("age", 0);
  72.             // order by ASC(1)/DESC(-1)
  73.             BSONObject orderBy = new BasicBSONObject();
  74.             orderBy.put("_id", -1);
  75.             if (index == null) {
  76.                 dataCursor = cl.query(query, selector, orderBy, null, 0, -1);
  77.             }
  78.             // or
  79.             // dataCursor = cl.query("{'Id':{'$gte':0,'$lte':9}}",
  80.             // "{'Id':null,'Age':null}", "{'Id':-1}", null, 0, -1);
  81.             else {
  82.                 dataCursor = cl.query(query, selector, orderBy, index, 0, -1);
  83.             }
  84.             // or
  85.             // dataCursor = cl.query("{'Id':{'$gte':0,'$lte':9}}",
  86.             // "{'Id':null,'Age':null}", "{'Id':-1}", index, 0, -1);
  87.             // 使用Cursor游标，进行查询结果遍历
  88.             // operate data by cursor
  89.             while (dataCursor.hasNext()) {
  90.                 System.out.println(dataCursor.getNext());
  91.             }
  92.             // get count by match condition
  93.             long count = cl.getCount(query);
  94.             System.out.println("Get count by condition: " + query
  95.                     + ", count = " + count);
  96.         } catch (BaseException e) {
  97.             e.printStackTrace();
  98.         }
  99.     }
  100. }
其中从第51行到98行是查询的语句。由于创建时没有使用索引，55行和82行不会执行。执行结果会输出两行记录，和条件，总数为2（即90行和94行的输出）。上述程序的输出结果为：

点击(此处)折叠或打开

  1. Select Collection Space
  2. Select Colleciton
  3. { "_id" : { "$oid" : "52582e1547c0437e0b000001"} , "age" : 36 , "name" : "wangcc"}
  4. { "_id" : { "$oid" : "52582e0247c0437e0b000000"} , "age" : 0 , "name" : "wangcc"}
  5. Get count by condition: { "name" : { "$et" : "wangcc"}}, count = 2
BSONObject selector是查询的字段，put方法第一个是字段名，第二个是默认值。
我的Sequoiadb数据库的情况是（通过sdb查询）：

点击(此处)折叠或打开

  1. > var sdb = new Sdb("localhost",50000)
  2. Takes 1.4294179166s.
  3. > sdb.exec("select * from foo.bar")
  4. {
  5.   "_id": {
  6.     "$oid": "52582e0247c0437e0b000000"
  7.   },
  8.   "name": "wangcc"
  9. }
  10. {
  11.   "_id": {
  12.     "$oid": "52582e1547c0437e0b000001"
  13.   },
  14.   "name": "wangcc",
  15.   "age": 36,
  16.   "phone": "123456"
  17. }
  18. Return 2 row(s).
  19. Takes 1.4294724560s.
八、Java编程访问数据库（续）
昨天完成了数据库的查询，今天（11月23日）完成数据库的添加。代码是在昨天的基础上修改的，修改一：将查询部分单独提出一个方法叫Query，修改二：查询调价全部查询；代码如下：

点击(此处)折叠或打开

  1. package com.greencloud;

  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.DBCursor;
  9. import com.sequoiadb.base.Sequoiadb;
  10. import com.sequoiadb.exception.BaseException;

  12. public class SequoiaDbDemo {

  14.     static String CS_NAME = "foo";
  15.     static String CL_NAME = "bar";
  16.     static String INDEX_NAME = "bar";

  18.     /**
  19.      * @param args
  20.      */
  21.     public static void main(String[] args) {
  22.         // TODO Auto-generated method stub
  23.         String connectStr = "192.168.8.128:50000";
  24.         Sequoiadb sdb = null;
  25.         try {
  26.             sdb = new Sequoiadb(connectStr, "sdbadmin", "sdbadmin");
  27.         } catch (BaseException be) {
  28.             System.out.println(be.toString());
  29.             be.printStackTrace();
  30.             System.exit(1);
  31.         }

  33.         CollectionSpace cs = null;
  34.         if (sdb.isCollectionSpaceExist(CS_NAME)) {
  35.             cs = sdb.getCollectionSpace(CS_NAME);
  36.             System.out.println("Select Collection Space");
  37.         } else {
  38.             cs = sdb.createCollectionSpace(CS_NAME);
  39.             System.out.println("Create Collection Space");
  40.         }

  42.         DBCollection cl = null;
  43.         if (cs.isCollectionExist(CL_NAME)) {
  44.             cl = cs.getCollection(CL_NAME);
  45.             System.out.println("Select Colleciton");
  46.         } else {
  47.             cl = cs.createCollection(CL_NAME);
  48.             System.out.println("Create Collection");
  49.         }
  50.         System.out.println("Before Insert");
  51.         Query(cl);
  52.         System.out.println("\r\nStart Insert");
  53.         Insert(cl);
  54.         System.out.println("\r\nAfter Insert");
  55.         Query(cl);
  56.     }

  58.     static void Insert(DBCollection cl) {
  59.         BSONObject insertor1 = new BasicBSONObject();
  60.         insertor1.put("name", "wanghg");
  61.         insertor1.put("age", "32");
  62.         insertor1.put("sex", "nan");
  63.         BSONObject insertor2 = new BasicBSONObject();
  64.         insertor2.put("name", "hao-yu");
  65.         insertor2.put("age", "26");
  66.         insertor2.put("jiguan", "benxi");
  67.         try {
  68.             cl.insert(insertor1);
  69.             cl.insert(insertor2);
  70.         } catch (BaseException be) {
  71.             System.out.println("Failed to insert chinese record, ErrorType = "
  72.                     + be.getErrorType());
  73.         } catch (Exception e) {
  74.             e.printStackTrace();
  75.         }
  76.     }

  78.     static void Query(DBCollection cl) {
  79.         try {
  80.             BSONObject index = null;
  81.             DBCursor indexCursor = cl.getIndex(INDEX_NAME);
  82.             if (indexCursor.hasNext()) {
  83.                 index = indexCursor.getNext();
  84.             }
  85.             // result cursor
  86.             DBCursor dataCursor = null;
  87.             // 构建相应BSONObject，用于查询，包括：条件(query)，域选择(selector)，排序规则(orderBy)，
  88.             // 索引使用(index)，跳过记录个数(0)，返回记录个数(-1：返回所有数据)。
  89.             // query condition
  90.             BSONObject query = new BasicBSONObject();
  91.             // 删除查询条件，查询所有记录
  92.             //BSONObject condition = new BasicBSONObject();
  93.             //condition.put("$et", "wangcc");
  94.             // condition.put("$lte", 9);
  95.             //query.put("name", condition);
  96.             // return fields
  97.             BSONObject selector = new BasicBSONObject();
  98.             selector.put("_id", null);
  99.             selector.put("name", null);
  100.             selector.put("age", 0);
  101.             // order by ASC(1)/DESC(-1)
  102.             BSONObject orderBy = new BasicBSONObject();
  103.             orderBy.put("_id", -1);
  104.             if (index == null) {
  105.                 dataCursor = cl.query(query, selector, orderBy, null, 0, -1);
  106.             }
  107.             // or
  108.             // dataCursor = cl.query("{'Id':{'$gte':0,'$lte':9}}",
  109.             // "{'Id':null,'Age':null}", "{'Id':-1}", null, 0, -1);
  110.             else {
  111.                 dataCursor = cl.query(query, selector, orderBy, index, 0, -1);
  112.             }
  113.             // or
  114.             // dataCursor = cl.query("{'Id':{'$gte':0,'$lte':9}}",
  115.             // "{'Id':null,'Age':null}", "{'Id':-1}", index, 0, -1);
  116.             // 使用Cursor游标，进行查询结果遍历
  117.             // operate data by cursor
  118.             while (dataCursor.hasNext()) {
  119.                 System.out.println(dataCursor.getNext());
  120.             }
  121.             // get count by match condition
  122.             long count = cl.getCount(query);
  123.             System.out.println("Get count by condition: " + query
  124.                     + ", count = " + count);
  125.         } catch (BaseException e) {
  126.             e.printStackTrace();
  127.         }
  128.     }
  129. }
运行效果如下：

点击(此处)折叠或打开

  1. Select Collection Space
  2. Select Colleciton
  3. Before Insert
  4. { "_id" : { "$oid" : "52582e1547c0437e0b000001"} , "age" : 36 , "name" : "wangcc"}
  5. { "_id" : { "$oid" : "52582e0247c0437e0b000000"} , "age" : 0 , "name" : "wangcc"}
  6. Get count by condition: { }, count = 2

  8. Start Insert

  10. After Insert
  11. { "_id" : { "$oid" : "5267d1f7b5b7332e021fb117"} , "age" : "26" , "name" : "hao-yu"}
  12. { "_id" : { "$oid" : "5267d1f7b5b7332e021fb116"} , "age" : "32" , "name" : "wanghg"}
  13. { "_id" : { "$oid" : "52582e1547c0437e0b000001"} , "age" : 36 , "name" : "wangcc"}
  14. { "_id" : { "$oid" : "52582e0247c0437e0b000000"} , "age" : 0 , "name" : "wangcc"}
  15. Get count by condition: { }, count = 4
使用sdb shell在执行插入后查询结果：

点击(此处)折叠或打开

  1. > sdb.exec("select * from foo.bar")
  2. {
  3.   "_id": {
  4.     "$oid": "52582e0247c0437e0b000000"
  5.   },
  6.   "name": "wangcc"
  7. }
  8. {
  9.   "_id": {
  10.     "$oid": "52582e1547c0437e0b000001"
  11.   },
  12.   "name": "wangcc",
  13.   "age": 36,
  14.   "phone": "123456"
  15. }
  16. {
  17.   "_id": {
  18.     "$oid": "5267d1f7b5b7332e021fb116"
  19.   },
  20.   "name": "wanghg",
  21.   "age": "32",
  22.   "sex": "nan"
  23. }
  24. {
  25.   "_id": {
  26.     "$oid": "5267d1f7b5b7332e021fb117"
  27.   },
  28.   "name": "hao-yu",
  29.   "age": "26",
  30.   "jiguan": "benxi"
  31. }
  32. Return 4 row(s).
  33. Takes 0.2951s.
  34. >   
九、Java编程访问数据库（续）
之前实现了数据库的查询与插入，今天（10月24日）实现数据库的更新操作，源码如下：

点击(此处)折叠或打开

  1. package com.greencloud;

  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.DBCursor;
  9. import com.sequoiadb.base.Sequoiadb;
  10. import com.sequoiadb.exception.BaseException;

  12. public class SequoiaDbDemo {

  14.     static String CS_NAME = "foo";
  15.     static String CL_NAME = "bar";
  16.     static String INDEX_NAME = "bar";

  18.     /**
  19.      * @param args
  20.      */
  21.     public static void main(String[] args) {
  22.         // TODO Auto-generated method stub
  23.         String connectStr = "192.168.8.128:50000";
  24.         Sequoiadb sdb = null;
  25.         try {
  26.             sdb = new Sequoiadb(connectStr, "sdbadmin", "sdbadmin");
  27.         } catch (BaseException be) {
  28.             System.out.println(be.toString());
  29.             be.printStackTrace();
  30.             System.exit(1);
  31.         }

  33.         CollectionSpace cs = null;
  34.         if (sdb.isCollectionSpaceExist(CS_NAME)) {
  35.             cs = sdb.getCollectionSpace(CS_NAME);
  36.             System.out.println("Select Collection Space");
  37.         } else {
  38.             cs = sdb.createCollectionSpace(CS_NAME);
  39.             System.out.println("Create Collection Space");
  40.         }

  42.         DBCollection cl = null;
  43.         if (cs.isCollectionExist(CL_NAME)) {
  44.             cl = cs.getCollection(CL_NAME);
  45.             System.out.println("Select Colleciton");
  46.         } else {
  47.             cl = cs.createCollection(CL_NAME);
  48.             System.out.println("Create Collection");
  49.         }
  50.         System.out.println("Before Insert");
  51.         Query(cl);
  52.         // System.out.println("\r\nStart Insert");
  53.         // Insert(cl);
  54.         System.out.println("\r\nStart Update");
  55.         Update(cl);
  56.         System.out.println("\r\nAfter Insert");
  57.         Query(cl);
  58.     }

  60.     static void Insert(DBCollection cl) {
  61.         BSONObject insertor1 = new BasicBSONObject();
  62.         insertor1.put("name", "wanghg");
  63.         insertor1.put("age", "32");
  64.         insertor1.put("sex", "nan");
  65.         BSONObject insertor2 = new BasicBSONObject();
  66.         insertor2.put("name", "hao-yu");
  67.         insertor2.put("age", "26");
  68.         insertor2.put("jiguan", "benxi");
  69.         try {
  70.             cl.insert(insertor1);
  71.             cl.insert(insertor2);
  72.         } catch (BaseException be) {
  73.             System.out.println("Failed to insert chinese record, ErrorType = "
  74.                     + be.getErrorType());
  75.         } catch (Exception e) {
  76.             e.printStackTrace();
  77.         }
  78.     }

  80.     static void Update(DBCollection cl) {
  81.         BSONObject matcher = new BasicBSONObject();
  82.         BSONObject modifier = new BasicBSONObject();
  83.         BSONObject m = new BasicBSONObject();
  84.         matcher.put("name", "wangcc"); // 条件
  85.         m.put("age", 37); // 更新值
  86.         modifier.put("$set", m); // $set，设置指定字段值

  88.         // 更新操作，如果没有满足matcher的条件，则插入记录
  89.         cl.upsert(matcher, modifier, null);
  90.         DBCursor cursor = cl.query(matcher, null, null, null);
  91.         if (cursor.hasNext()) {
  92.             System.out.println(cursor.getNext());
  93.         }
  94.     }

  96.     static void Query(DBCollection cl) {
  97.         try {
  98.             BSONObject index = null;
  99.             DBCursor indexCursor = cl.getIndex(INDEX_NAME);
  100.             if (indexCursor.hasNext()) {
  101.                 index = indexCursor.getNext();
  102.             }
  103.             // result cursor
  104.             DBCursor dataCursor = null;
  105.             // 构建相应BSONObject，用于查询，包括：条件(query)，域选择(selector)，排序规则(orderBy)，
  106.             // 索引使用(index)，跳过记录个数(0)，返回记录个数(-1：返回所有数据)。
  107.             // query condition
  108.             BSONObject query = new BasicBSONObject();
  109.             // 删除查询条件，查询所有记录
  110.             // BSONObject condition = new BasicBSONObject();
  111.             // condition.put("$et", "wangcc");
  112.             // condition.put("$lte", 9);
  113.             // query.put("name", condition);
  114.             // return fields
  115.             BSONObject selector = new BasicBSONObject();
  116.             selector.put("_id", null);
  117.             selector.put("name", null);
  118.             selector.put("age", 0);
  119.             // order by ASC(1)/DESC(-1)
  120.             BSONObject orderBy = new BasicBSONObject();
  121.             orderBy.put("_id", -1);
  122.             if (index == null) {
  123.                 dataCursor = cl.query(query, selector, orderBy, null, 0, -1);
  124.             }
  125.             // or
  126.             // dataCursor = cl.query("{'Id':{'$gte':0,'$lte':9}}",
  127.             // "{'Id':null,'Age':null}", "{'Id':-1}", null, 0, -1);
  128.             else {
  129.                 dataCursor = cl.query(query, selector, orderBy, index, 0, -1);
  130.             }
  131.             // or
  132.             // dataCursor = cl.query("{'Id':{'$gte':0,'$lte':9}}",
  133.             // "{'Id':null,'Age':null}", "{'Id':-1}", index, 0, -1);
  134.             // 使用Cursor游标，进行查询结果遍历
  135.             // operate data by cursor
  136.             while (dataCursor.hasNext()) {
  137.                 System.out.println(dataCursor.getNext());
  138.             }
  139.             // get count by match condition
  140.             long count = cl.getCount(query);
  141.             System.out.println("Get count by condition: " + query
  142.                     + ", count = " + count);
  143.         } catch (BaseException e) {
  144.             e.printStackTrace();
  145.         }
  146.     }
  147. }
运行结果如下，看到age已经发生了变化：

点击(此处)折叠或打开

  1. Select Collection Space
  2. Select Colleciton
  3. Before Insert
  4. { "_id" : { "$oid" : "5267d1f7b5b7332e021fb117"} , "age" : "26" , "name" : "hao-yu"}
  5. { "_id" : { "$oid" : "5267d1f7b5b7332e021fb116"} , "age" : "32" , "name" : "wanghg"}
  6. { "_id" : { "$oid" : "52582e1547c0437e0b000001"} , "age" : 36 , "name" : "wangcc"}
  7. { "_id" : { "$oid" : "52582e0247c0437e0b000000"} , "age" : 0 , "name" : "wangcc"}
  8. Get count by condition: { }, count = 4

  10. Start Update
  11. { "Age" : 37 , "_id" : { "$oid" : "52582e0247c0437e0b000000"} , "age" : 37 , "name" : "wangcc"}

  13. After Insert
  14. { "_id" : { "$oid" : "5267d1f7b5b7332e021fb117"} , "age" : "26" , "name" : "hao-yu"}
  15. { "_id" : { "$oid" : "5267d1f7b5b7332e021fb116"} , "age" : "32" , "name" : "wanghg"}
  16. { "_id" : { "$oid" : "52582e1547c0437e0b000001"} , "age" : 37 , "name" : "wangcc"}
  17. { "_id" : { "$oid" : "52582e0247c0437e0b000000"} , "age" : 37 , "name" : "wangcc"}
  18. Get count by condition: { }, count = 4
注意了，在SequoiaDB中，字段名是区分大小写的，我第一次运行的时候代码中m.put("age", 37); 中写的是m.put("Age", 37);在我的数据中就增加了一个Age属性，并没有更新我原有的age属性，所以是区分大小写的。
十、Java编程访问数据库（续）
前两天完成了通过Java编写查询，插入和更新，今天（10月25日）完成最后一个操作，删除。源程序如下：
点击(此处)折叠或打开
  1. package com.greencloud;

  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.DBCursor;
  9. import com.sequoiadb.base.Sequoiadb;
  10. import com.sequoiadb.exception.BaseException;

  12. public class SequoiaDbDemo {

  14.     static String CS_NAME = "foo";
  15.     static String CL_NAME = "bar";
  16.     static String INDEX_NAME = "bar";

  18.     /**
  19.      * @param args
  20.      */
  21.     public static void main(String[] args) {
  22.         // TODO Auto-generated method stub
  23.         String connectStr = "192.168.8.128:50000";
  24.         Sequoiadb sdb = null;
  25.         try {
  26.             sdb = new Sequoiadb(connectStr, "sdbadmin", "sdbadmin");
  27.         } catch (BaseException be) {
  28.             System.out.println(be.toString());
  29.             be.printStackTrace();
  30.             System.exit(1);
  31.         }

  33.         CollectionSpace cs = null;
  34.         if (sdb.isCollectionSpaceExist(CS_NAME)) {
  35.             cs = sdb.getCollectionSpace(CS_NAME);
  36.             System.out.println("Select Collection Space");
  37.         } else {
  38.             cs = sdb.createCollectionSpace(CS_NAME);
  39.             System.out.println("Create Collection Space");
  40.         }

  42.         DBCollection cl = null;
  43.         if (cs.isCollectionExist(CL_NAME)) {
  44.             cl = cs.getCollection(CL_NAME);
  45.             System.out.println("Select Colleciton");
  46.         } else {
  47.             cl = cs.createCollection(CL_NAME);
  48.             System.out.println("Create Collection");
  49.         }
  50.         System.out.println("Before Insert");
  51.         Query(cl);
  52.         // System.out.println("\r\nStart Insert");
  53.         // Insert(cl);
  54.         // System.out.println("\r\nAfter Insert");
  55.         // System.out.println("\r\nStart Update");
  56.         // Update(cl);
  57.         // System.out.println("\r\nAfter Update");
  58.         System.out.println("\r\nStart Delete");
  59.         Delete(cl);
  60.         System.out.println("\r\nAfter Delete");
  61.         Query(cl);
  62.         // CLose Connection
  63.         sdb.disconnect();
  64.     }

  66.     static void Insert(DBCollection cl) {
  67.         BSONObject insertor1 = new BasicBSONObject();
  68.         insertor1.put("name", "wanghg");
  69.         insertor1.put("age", "32");
  70.         insertor1.put("sex", "nan");
  71.         BSONObject insertor2 = new BasicBSONObject();
  72.         insertor2.put("name", "hao-yu");
  73.         insertor2.put("age", "26");
  74.         insertor2.put("jiguan", "benxi");
  75.         try {
  76.             cl.insert(insertor1);
  77.             cl.insert(insertor2);
  78.         } catch (BaseException be) {
  79.             System.out.println("Failed to insert chinese record, ErrorType = "
  80.                     + be.getErrorType());
  81.         } catch (Exception e) {
  82.             e.printStackTrace();
  83.         }
  84.     }

  86.     static void Delete(DBCollection cl) {
  87.         // 构建相应BSONObject，用于设置删除的条件或者使用相对应BSON的String表示
  88.         // create the delete condition
  89.         BSONObject condition = new BasicBSONObject();
  90.         condition.put("name", "wanghg");
  91.         try {
  92.             cl.delete(condition);
  93.             // if you want to delete all the data in current collection, you can
  94.             // use like: cl.delete(null)
  95.             // or
  96.             // cl.delete("{'name':'wanghg'}");
  97.         } catch (BaseException e) {
  98.             System.out
  99.                     .println("Failed to delete data, condition: " + condition);
  100.             e.printStackTrace();
  101.         }
  102.         System.out.println("Delete data successfully");
  103.     }

  105.     static void Update(DBCollection cl) {
  106.         BSONObject matcher = new BasicBSONObject();
  107.         BSONObject modifier = new BasicBSONObject();
  108.         BSONObject m = new BasicBSONObject();
  109.         matcher.put("name", "wangcc"); // 条件
  110.         m.put("age", 37); // 更新值
  111.         modifier.put("$set", m); // $set，设置指定字段值

  113.         // 更新操作，如果没有满足matcher的条件，则插入记录
  114.         cl.upsert(matcher, modifier, null);
  115.         DBCursor cursor = cl.query(matcher, null, null, null);
  116.         if (cursor.hasNext()) {
  117.             System.out.println(cursor.getNext());
  118.         }
  119.     }

  121.     static void Query(DBCollection cl) {
  122.         try {
  123.             BSONObject index = null;
  124.             DBCursor indexCursor = cl.getIndex(INDEX_NAME);
  125.             if (indexCursor.hasNext()) {
  126.                 index = indexCursor.getNext();
  127.             }
  128.             // result cursor
  129.             DBCursor dataCursor = null;
  130.             // 构建相应BSONObject，用于查询，包括：条件(query)，域选择(selector)，排序规则(orderBy)，
  131.             // 索引使用(index)，跳过记录个数(0)，返回记录个数(-1：返回所有数据)。
  132.             // query condition
  133.             BSONObject query = new BasicBSONObject();
  134.             // 删除查询条件，查询所有记录
  135.             // BSONObject condition = new BasicBSONObject();
  136.             // condition.put("$et", "wangcc");
  137.             // condition.put("$lte", 9);
  138.             // query.put("name", condition);
  139.             // return fields
  140.             BSONObject selector = new BasicBSONObject();
  141.             selector.put("_id", null);
  142.             selector.put("name", null);
  143.             selector.put("age", 0);
  144.             // order by ASC(1)/DESC(-1)
  145.             BSONObject orderBy = new BasicBSONObject();
  146.             orderBy.put("_id", -1);
  147.             if (index == null) {
  148.                 dataCursor = cl.query(query, selector, orderBy, null, 0, -1);
  149.             }
  150.             // or
  151.             // dataCursor = cl.query("{'Id':{'$gte':0,'$lte':9}}",
  152.             // "{'Id':null,'Age':null}", "{'Id':-1}", null, 0, -1);
  153.             else {
  154.                 dataCursor = cl.query(query, selector, orderBy, index, 0, -1);
  155.             }
  156.             // or
  157.             // dataCursor = cl.query("{'Id':{'$gte':0,'$lte':9}}",
  158.             // "{'Id':null,'Age':null}", "{'Id':-1}", index, 0, -1);
  159.             // 使用Cursor游标，进行查询结果遍历
  160.             // operate data by cursor
  161.             while (dataCursor.hasNext()) {
  162.                 System.out.println(dataCursor.getNext());
  163.             }
  164.             // get count by match condition
  165.             long count = cl.getCount(query);
  166.             System.out.println("Get count by condition: " + query
  167.                     + ", count = " + count);
  168.         } catch (BaseException e) {
  169.             e.printStackTrace();
  170.         }
  171.     }
  172. }
运行结果如下：
点击(此处)折叠或打开
  1. Select Collection Space
  2. Select Colleciton
  3. Before Insert
  4. { "_id" : { "$oid" : "5267d1f7b5b7332e021fb117"} , "age" : "26" , "name" : "hao-yu"}
  5. { "_id" : { "$oid" : "5267d1f7b5b7332e021fb116"} , "age" : "32" , "name" : "wanghg"}
  6. { "_id" : { "$oid" : "52582e1547c0437e0b000001"} , "age" : 37 , "name" : "wangcc"}
  7. { "_id" : { "$oid" : "52582e0247c0437e0b000000"} , "age" : 37 , "name" : "wangcc"}
  8. Get count by condition: { }, count = 4

  10. Start Delete
  11. Delete data successfully

  13. After Delete
  14. { "_id" : { "$oid" : "5267d1f7b5b7332e021fb117"} , "age" : "26" , "name" : "hao-yu"}
  15. { "_id" : { "$oid" : "52582e1547c0437e0b000001"} , "age" : 37 , "name" : "wangcc"}
  16. { "_id" : { "$oid" : "52582e0247c0437e0b000000"} , "age" : 37 , "name" : "wangcc"}
  17. Get count by condition: { }, count = 3
至此，通过Java语言对SequoiaDB进行增删改差（ADUC）操作的列子全部完成了。其实我们还可以通过Sequoiadb类的exec（或者execUpdate）来进行类SQL操作，这里不再赘述，如果感兴趣的朋友可以自己参照信息中心文档来编写，代码很简单的。
在随后的几天，将动手讲解SequoiaDB的备份和恢复。
十一、数据库备份sdbexprt
在现在的计算机环境中，由于各种原因，如非法关机，病毒入侵都造成数据损坏是经常碰到的事情，所以数据备份就显得尤为重要了啊。SequoiaDB提供了备份命令来备份你的数据库。这个命令就是sdbexprt。详细的说明如下：
sdbexprt
sdbexprt是一个实用的工具。它可以从SequoiaDB数据库导出一个JSON格式或者CSV格式的数据存储文件。
选项
参数描述
--help,-h 返回基本帮助和用法文本 。
--hostname,-h 从指定主机名的 SequoiaDB 中导出数据。默认情况下 sdbexprt 尝试连接到
本地主机 。
--svcname,-p 指定的端口号。默认情况下 sdbexprt 尝试连接到端口号 50000 的主机 。
--type,-t 指定的导出数据格式。数据格式可以是 CSV ，或是 JSON 。
--output,-o 指定要导出的文件名。注意：不需要写扩展名 。
--delfield,-e 指定字段分隔符。默认是 ', '， JSON 格式无效。
--delrecord,-r 指定记录分隔符。默认是' \n '。
--fieldlist,-f 指定一个或多个字段来导出数据，使用逗号分隔多个字段。
--fieldincluded,-i 指定是否导出字段名，JSON格式无效。
--csname,-c 指定导出数据的集合空间名。
--clname,-l 指定导出数的的集合名。
用法
在下面的例子，sdbexprt从本地数据库端口50000中导出集合空间foo的集合bar的数据，导出类型是
csv，导出文件为contact，导出字段是 field1和field2。
点击(此处)折叠或打开
  1. sdbexprt –s localhost –p 50000 –t csv –o contace –f field1,field2 –c foo –l bar
但是我在我本机执行数据库的备份时，不管-l的参数指定为bar或者foo.bar，都报错误。我是配置的独立启动模式。
错误信息如下：

点击(此处)折叠或打开

  1. 2013-10-12-04.33.56.361760 Level:ERROR
  2. PID:9660 TID:9660
  3. Function:getCollection Line:511
  4. File:SequoiaDB/engine/pmd/sdbexprt.cpp
  5. Message:
  6. Failed to get collection foo.bar, rc = -75


  9. 2013-10-12-04.34.08.903027 Level:ERROR
  10. PID:9662 TID:9662
  11. Function:getCollection Line:511
  12. File:SequoiaDB/engine/pmd/sdbexprt.cpp
  13. Message:
  14. Failed to get collection bar, rc = -75
从信息查看，是找不到集合bar（foo.bar），可这个集合明明是存在的，请看sdb命令输出：
点击(此处)折叠或打开
  1. > sdb.listCollectionSpaces()
  2. {
  3.   "Name": "foo"
  4. }
  5. Return 1 row(s).
  6. Takes 0.94698s.
  7. > sdb.listCollections()
  8. {
  9.   "Name": "foo.bar"
  10. }
  11. Return 1 row(s).
  12. Takes 0.31478s.
  13. >
已经向官方的服务人员提出了疑问，不知道下周能不能给个解答。

11月29日，官方人员给出了解释，是因为1.3版本的导入导出程序有Bug，官方人员给了我最想新的一个版本，经测试，正常。
步骤如下，
将压缩包上传至/opt/sequoiadb/bin目录，然后执行tar -zxvf sdb.tar.gz，解压后会覆盖就的备份恢复命令。
执行过程如下：

点击(此处)折叠或打开

  1. root@ubuntu:/opt/sequoiadb/bin# ./sdbexprt --help
  2. Command options:
  3.   --help help
  4.   -h [ --hostname ] arg database host name
  5.   -s [ --svcname ] arg database service name
  6.   -a [ --delchar ] arg string delimiter ( default: " )
  7.   -e [ --delfield ] arg field delimiter ( default: , )
  8.   -r [ --delrecord ] arg record delimiter ( default: '\n' )
  9.   -f [ --fieldlist ] arg field list ( separate by , )
  10.   -i [ --fieldincluded ] arg include field names ( default: true )
  11.   -c [ --csname ] arg collection space name
  12.   -l [ --clname ] arg collection name
  13.   --file arg database load file name
  14.   --type arg type of file to load, default: json (json,csv)

  16. root@ubuntu:/opt/sequoiadb/bin# ./sdbexprt -h localhost -s 50000 --file ./foo.bar.csv --type csv -c foo -l bar
  17. Field list is required for CSV file, fields are separated by comma ( ',' )
  18. Export Failed

  20. root@ubuntu:/opt/sequoiadb/bin# ./sdbexprt -h localhost -s 50000 -e'|' -c foo -l
  21.  bar --file ./exprt.json --type json
  22. Export Successfully
  23. Detail in log path: sdbexport.log

  25. root@ubuntu:/opt/sequoiadb/bin# cat exprt.json
  26. { "Age" : 37, "_id" : { "$oid" : "52582e0247c0437e0b000000" }, "age" : 37, "name" : "wangcc" }
  27. { "Age" : 37, "_id" : { "$oid" : "52582e1547c0437e0b000001" }, "age" : 37, "name" : "wangcc", "phone" : "123456" }
  28. { "_id" : { "$oid" : "5267d1f7b5b7332e021fb117" }, "name" : "hao-yu", "age" : "26", "jiguan" : "benxi" }

  30. root@ubuntu:/opt/sequoiadb/bin# ./sdbexprt -h localhost -s 50000 -f Age,age,name,phone,jiguan -c foo -l bar --file ./exprt.csv --type csv
  31. Export Successfully
  32. Detail in log path: sdbexport.log

  34. root@ubuntu:/opt/sequoiadb/bin# cat exprt.csv
  35. "Age","age","name","phone","jiguan"
  36. 37,37,"wangcc",,
  37. 37,37,"wangcc","123456",
  38. ,"26","hao-yu",,"benxi
建议大家使用json格式，从过程中你也许看出来了，到处csv格式时，必须用-f参数明确指出要导出的字段。

导入命令sdbimprt和导出是相反的过程，导入命令的参数如下：

点击(此处)折叠或打开

  1. root@ubuntu:~# cd /opt/sequoiadb/bin
  2. root@ubuntu:/opt/sequoiadb/bin# ./sdbimprt --help
  3. Command options:
  4.   --help help
  5.   -h [ --hostname ] arg database host name
  6.   -s [ --svcname ] arg database service name
  7.   -a [ --delchar ] arg string delimiter ( default:
具体的导入过程如下图所示：
SequoiaDB安装测试报告(二)
正确的导入到处命令的下载参照如下附件：
SequoiaDB安装测试报告(二)sdb.part1.rar
SequoiaDB安装测试报告(二)sdb.part2.rar
SequoiaDB安装测试报告(二)sdb.part3.rar
SequoiaDB安装测试报告(二)sdb.part4.rar
SequoiaDB安装测试报告(二)sdb.part5.rar

总结：
至此，SequoiaDB数据的安装，配置（独立模式），通过java对数据库进行增删改查以及使用sdb shell进行查询，数据库的导入导出（备份恢复）的测试基本完成，但由于是虚拟机操作，对性能的测试受限制无法进行，同时次发布版本是社区版，企业版本没法获取，如果需要企业版本可以联系contact@sequoiadb.com以获取发行的企业版本，我没有要求企业版。由于社区版的导入导出命令有缺陷，是在官方人员给与我新的版本后测试成功的，如果需要可以从本附件下载或者联系我获取（也可以联系官方获取）。
通过本次测试，让我对NoSQL技术有了一定的了解，对SequoiaDB数据库的使用有了更进一步的掌握，如果附近的朋友有需要帮助的可以联系我，我会给予一定的支持与帮助，共同推进SequoiaDB数据库的良好发展。
上一篇：Apache Kafka常用命令


下一篇：前端笔记之JavaScript（一）初识JavaScript