【入门教程】SequoiaDB Java开发入门

不念不忘少年蓝@ 2022-06-08 14:28 310阅读 0赞

# 1、背景 #

近年来，随着社会的进步和[信息][Link 1]通信[技术][Link 2]的发展，信息系统、互联网应用在各行业、各领域快速拓展。这些系统采集、处理、积累的数据越来越多，数据量增速越来越快。数据量每年以爆炸性的速度增长。在互联网出现之前，数据主要是人机会话方式产生的，以结构化数据为主。所以大家都需要传统的RDBMS来管理这些数据和应用系统。那时候的数据增长缓慢、系统都比较孤立，用传统数据库基本可以满足各类应用开发。但随着大数据时代的到来，数据逐渐地转变为以非结构、半结构化为主，人们对于数据的使用，不在仅仅局限于业务应用的需求。对信息时代所产生的海量数据进行数据挖掘和分析，已经成为了很多企业获取有价值信息常用手段。传统数据库对这类需求和应用无论在技术上还是功能上都几乎束手无策。传统数据库（OldSQL）一统天下变成了OldSQL+NewSQL+NoSQL+其他新技术（流、实时、内存等）共同支撑多类应用的局面。

# 2、产品介绍 #

SequoiaDB巨杉数据库，专注新一代大数据基础架构研发，是国内领先的新一代分布式数据库厂商。其产品SequoiaDB巨杉数据库是一款支持SQL、高并发、实时性、分布式、可扩展、灵活存储的NewSQL数据库。另外SequoiaDB支持spark、hive、hadoop、kafka、postgreSQL等多种大数据工具的对接。在应用开发方面，SequoiaDB除了提供原生的API，还提供了c驱动、c++驱动、CSharp驱动、java驱动、PHP驱动、REST接口等。开发者可以方便快速地使用SequoiaDB进行应用开发，本文将介绍如何使用javaAPI进行应用开发。

![图片 1.png][1.png]

# 3、使用SequoiaDB进行应用开发优势 #

## 3.1、存储方式灵活 ##

SequoiaDB数据库是一款文档型数据库，使用了JSON这种格式存储数据，可以有效地提高开发效率。总所周知，在开发大型应用时，会涉及到好多的表，表与表之间的关联关系会特别多，特别是在银行，互联网金融等行业中，由于业务复杂繁多，表与表的关系会极其复杂，使用传统数据库进行开发时，首先需要对表进行关联设计，而复杂表的设计需要投入大量的人力，这不但浪费了金钱，还拖慢了开发的进度。另外在后期维护升级中，经过多次的迭代更新后，表中的字段通常会有所变化，如果需要对某些字段的值进行修改或者删除，很难确定改动后的结果会不会对其他业务系统有所影响，这就要求开发的人很懂业务，提高了开发的门槛。如果使用文档型数据库，由于采用的是JSON结构存储数据。用户可以采用对象的方式，把业务系统设计的字段存储在一个表中，在涉及表关联时，可以在BSON中采用嵌套的方式，把数据存储在其中。这就使得开发者不用花费大量的精力在表的设计中，降低了开发的成本。

另外SequoiaDB是一款双引擎数据库，支持JSON格式存储数据的同时，支持分布式对象存储，可以很好支撑非结构化数据管理。

## 3.2、低成本的部署 ##

SequoiaDB可以安装在X86的机器上，相对于安装在高端存储的数据库，这无疑是一个成本的节约。SequoiaDB采用了三副本的存储方式，这有效地保证了数据的安全，另外由于使用分布式，数据被保存到多台服务器中，在查询数据时，查询任务会分发到多台机器上同时进行，最后汇总到同一台机器上汇总，这使得可以充分得利用多台服务器的资源，从而实现低成本的部署而又快速效应的效果。

## 3.3、支持复合索引 ##

在传统的数据库中，很多产品都是只支持单一索引，而SequoiaDB还能支持复合索引。在复杂的业务系统中，数据量通常都很大，在查询数据时，通常需要带上多个查询条件，而且还要求快速响应。这就使得单一的索引查询很难满足业务的需求。SequoiaDB可以有效地解决这种问题，开发者可以根据业务的查询习惯，把一些经常需要带上的查询条件统计出来，从而把这些每次查询都必须带上的条件进行复合索引的创建。业务系统在查询时，SequoiaDB便会通过索引扫描的方式进行快速查询。

## 3.4、高安全性 ##

SequoiaDB采用了多副本的存储方式，开发者通过规划，把数据散落在不同的数据组中，同一数据组的节点散落在不同的机器上，由于同一数据组的数据是一样的，这使得当服务器出现宕机等故障时，数据库可以快速地把主节点切换到其他的节点上，为业务系统提供服务，同时还能有效地防止数据的丢失。

# 4、环境搭建 #

## 4.1、软件配置 ##

操作系统：windows 8

JDK：1.7.0\_80 64位，下载地址为：http://www.oracle.com/technetwork/java/javase/downloads/java-archive-downloads-javase7-521261.html\#jdk-7u80-oth-JPR

Myeclipse：12.0.0

SequoiaDB：2.8.1。安装部署参考：

Java驱动：2.6.3，下载地址为：

http://download.sequoiadb.com/cn/ index-cat\_id-2

## 4.2、配置Eclipse环境 ##

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

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

（3）在菜单中选择“properties”菜单项；

（4）在弹出的“property for project …”窗口中，选择“Java Build Path”->“Libraries”，如下图所示：

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

（6） 点击“OK”完成环境配置。

# 5、SequoiaDB Java开发实例 #

## 5.1示例一：列举collection ##

连接数据库，列举出数据库中的所有collection。

## 5.2示例二：增加查找操作 ##

连接数据库，对数据库中的test表的记录进行增加查找的操作。

## 5.3示例三：数据连接池的使用 ##

数据库连接池的基本原理是在内部对象池中维护一定数量的数据库连接，并对外暴露数据库连接获取和返回方法。如：外部使用者可通过getConnection 方法获取连接，使用完毕后再通过releaseConnection 方法将连接返回，注意此时连接并没有关闭，而是由连接池管理器回收，并为下一次使用做好准备。

数据库连接池技术带来的优势：

1、资源复用：由于数据库连接得到重用，避免了频繁创建、释放连接引起的大量性能开销。在减少系统　　消耗的基础上，另一方面也增进了系统运行环境的平稳性（减少内存碎片以及数据库临时进程/线程的数量）。

2、更快的系统响应速度：数据库连接池在初始化过程中，往往已经创建了若干数据库连接至于池中备用。此时连接的初始化工作均已完成。对于业务请求处理而言，直接利用现有可用连接，避免了数据库连接　　初始化和释放过程的时间，从而缩减了系统整体响应时间。

3、统一的连接管理，避免数据库连接泄漏：在较为完备的数据库连接池实现中，可根据预先的连接占用超时设定，强制收回被占用连接。从而避免了常规数据库连接操作中可能出现的资源泄漏。

<table style="font-size:1.2em; width:969px; border-collapse:collapse; border:1px solid rgb(221,221,221); margin:10px 0px 20px; color:rgb(85,85,85); font-family:sans-serif,微软雅黑,华文细黑"> 
 <tbody> 
 <tr style="font-size:12px"> 
 <td style="font-size:1.2em; word-wrap:break-word; padding:0px 7px; border:1px solid rgb(221,221,221)"> package &nbsp; com.sequoiadb.demo; import &nbsp; java.util.ArrayList; import &nbsp; org.bson.BSONObject; import &nbsp; org.bson.BasicBSONObject; import &nbsp; com.sequoiadb.base.CollectionSpace; import &nbsp; com.sequoiadb.base.DBCollection; import &nbsp; com.sequoiadb.base.DBCursor; import &nbsp; com.sequoiadb.base.Sequoiadb; import &nbsp; com.sequoiadb.base.SequoiadbDatasource; import &nbsp; com.sequoiadb.datasource.ConnectStrategy; import &nbsp; com.sequoiadb.datasource.DatasourceOptions; import &nbsp; com.sequoiadb.exception.BaseException; import &nbsp; com.sequoiadb.net.ConfigOptions; public &nbsp; class Datasource { &nbsp;&nbsp;&nbsp; public static void main(String[] args) &nbsp; throws InterruptedException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ArrayList&lt;String&gt; addrs = new &nbsp; ArrayList&lt;String&gt;(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String user = ""; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String password = ""; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ConfigOptions nwOpt = new &nbsp; ConfigOptions(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DatasourceOptions dsOpt = new &nbsp; DatasourceOptions(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; SequoiadbDatasource ds = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;提供coord节点地址&nbsp; &nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp; addrs.add("192.168.43.237:11810"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; addrs.add("zxq3:11810"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;设置网络参数 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; nwOpt.setConnectTimeout(500);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;建连超时时间为500ms。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp; nwOpt.setMaxAutoConnectRetryTime(0);&nbsp;&nbsp; &nbsp; //&nbsp;建连失败后重试时间为0ms。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;设置连接池参数 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dsOpt.setMaxCount(500);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;连接池最多能提供500个连接。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dsOpt.setDeltaIncCount(20);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;每次增加20个连接。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dsOpt.setMaxIdleCount(20);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;连接池空闲时，保留20个连接。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dsOpt.setKeepAliveTimeout(0);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;池中空闲连接存活时间。单位:毫秒。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;// 0表示不关心连接隔多长时间没有收发消息。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dsOpt.setCheckInterval(60 * &nbsp; 1000);&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;每隔60秒将连接池中多于 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // MaxIdleCount限定的空闲连接关闭， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;并将存活时间过长（连接已停止收发 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;超过keepAliveTimeout时间）的连接关闭。 //&nbsp;向catalog同步coord地址的周期。单位:毫秒。&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // 0表示不同步。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dsOpt.setSyncCoordInterval(0);&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;连接出池时，是否检测连接的可用性，默认不检测。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp; dsOpt.setValidateConnection(false);&nbsp;&nbsp; &nbsp;&nbsp; //&nbsp;默认使用coord地址负载均衡的策略获取连接。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp; dsOpt.setConnectStrategy(ConnectStrategy.BALANCE);&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;建立连接池 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ds = new SequoiadbDatasource(addrs, &nbsp; user, password, nwOpt, dsOpt); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;使用连接池运行任务 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; runTask(ds); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;任务结束后，关闭连接池 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ds.close(); &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; static void runTask(SequoiadbDatasource &nbsp; ds) throws InterruptedException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String clFullName = &nbsp; "mycs.mycl"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;准备任务 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread createCLTask = new Thread(new &nbsp; CreateCLTask(ds, clFullName)); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread insertTask = new Thread(new &nbsp; InsertTask(ds, clFullName)); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread queryTask = new Thread(new &nbsp; QueryTask(ds, clFullName)); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;创建集合 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; createCLTask.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; createCLTask.join(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;往集合插记录 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; insertTask.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(3000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;从集合中查记录 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; queryTask.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;等待任务结束 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; insertTask.join(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; queryTask.join(); &nbsp;&nbsp;&nbsp; } } class &nbsp; CreateCLTask implements Runnable { &nbsp;&nbsp;&nbsp; private SequoiadbDatasource ds; &nbsp;&nbsp;&nbsp; private String csName; &nbsp;&nbsp;&nbsp; private String clName; &nbsp;&nbsp;&nbsp; public CreateCLTask(SequoiadbDatasource &nbsp; ds, String clFullName) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.ds = ds; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.csName = clFullName.split("\\.")[0]; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.clName = &nbsp; clFullName.split("\\.")[1]; &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Sequoiadb db = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; CollectionSpace cs = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DBCollection cl = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;从连接池获取连接池 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; db = ds.getConnection(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (BaseException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.exit(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.exit(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;使用连接创建集合 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if &nbsp; (db.isCollectionSpaceExist(csName)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; db.dropCollectionSpace(csName); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cs = &nbsp; db.createCollectionSpace(csName); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cl = cs.createCollection(clName); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;将连接归还连接池 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ds.releaseConnection(db); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("Suceess to &nbsp; create collection " + csName + "." + clName); &nbsp;&nbsp;&nbsp; } } class &nbsp; InsertTask implements Runnable { &nbsp;&nbsp;&nbsp; private SequoiadbDatasource ds; &nbsp;&nbsp;&nbsp; private String csName; &nbsp;&nbsp;&nbsp; private String clName; &nbsp;&nbsp;&nbsp; public InsertTask(SequoiadbDatasource ds, &nbsp; String clFullName) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.ds = ds; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.csName = &nbsp; clFullName.split("\\.")[0]; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.clName = &nbsp; clFullName.split("\\.")[1]; &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Sequoiadb db = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; CollectionSpace cs = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DBCollection cl = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; BSONObject record = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;从连接池获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; db = ds.getConnection(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (BaseException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.exit(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.exit(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;使用连接获取集合对象 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cs = db.getCollectionSpace(csName); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cl = cs.getCollection(clName); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;使用集合对象插入记录 &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;record = genRecord(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cl.insert(record); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;将连接归还连接池 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ds.releaseConnection(db); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("Suceess to &nbsp; insert record: " + record.toString()); &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; private BSONObject genRecord() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; BSONObject obj = new &nbsp; BasicBSONObject(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; obj.put("name", &nbsp; "James"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; obj.put("age", 30); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return obj; &nbsp;&nbsp;&nbsp; } } class &nbsp; QueryTask implements Runnable { &nbsp;&nbsp;&nbsp; private SequoiadbDatasource ds; &nbsp;&nbsp;&nbsp; private String csName; &nbsp;&nbsp;&nbsp; private String clName; &nbsp;&nbsp;&nbsp; public QueryTask(SequoiadbDatasource ds, &nbsp; String clFullName) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.ds = ds; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.csName = &nbsp; clFullName.split("\\.")[0]; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.clName = &nbsp; clFullName.split("\\.")[1]; &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Sequoiadb db = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; CollectionSpace cs = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DBCollection cl = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DBCursor cursor = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;从连接池获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; db = ds.getConnection(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (BaseException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.exit(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.exit(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;使用连接获取集合对象 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cs = db.getCollectionSpace(csName); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cl = cs.getCollection(clName); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;使用集合对象查询 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cursor = cl.query(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; while(cursor.hasNext()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("The &nbsp; inserted record is: " + cursor.getNext()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cursor.close(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;将连接对象归还连接池 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ds.releaseConnection(db); &nbsp;&nbsp;&nbsp; } } </td> 
 </tr> 
 </tbody> 
</table>

由于SequoiaDB的javaAPI涉及操作众多，在此不一一举例，其他的操作使用大同小异，具体可参考：

[http://doc.sequoiadb.com/cn/index/Public/Home/document/208/api/java/html/index.html][http_doc.sequoiadb.com_cn_index_Public_Home_document_208_api_java_html_index.html]

# 6、SequoiaDB对持久层框架的支持 #

在软件开发中，基本所有的大型应用使用到了框架来进行开发，框架具有复用性，这使得一个应用开发速度得到了大大的提高。类似于Mybatis、Hibernate等等这些框架对jdbc操作数据库的过程进行封装，使得开发者只需要关注sql本身，而不需要花费精力去处理例如注册驱动、创建connection、创建statement、手动设置参数、结果集检索等jdbc繁杂的过程代码。SequoiaDB数据库的套件SequoiaSql是PostgreSQL功能的扩展。通过SequoiaSql，用户可以使用sql语句访问SequoiaDB数据库，完成对数据库的增删改查等操作。SequoiaSql集成持久层框架时，只需要使用到postgreSQL的jdbc连接驱动即可，其集成过程与其它框架集成postgreSQL的过程是一样的。

# 7、小结 #

随着数据以爆炸性的速度增长，集中式数据库越来越表现出了不足，分布式数据库越来越受到了开发者的青睐。SequoiaDB是一款支持SQL、高并发、实时性、分布式、可扩展、灵活存储的NewSQL数据库，支持Spark、Hadoop、hive、等大数据产品的连接同时提供了多种语言的驱动方便开发者的使用。在选择使用分布式数据库时，SequoiaDB无疑是一个很好的选择。

[产品特性][Link 3]  
[解决方案与案例 ][Link 4]  
[数据库下载 ][Link 5]  
[技术文档 ][Link 6]

微信客服：  
sequoiadb111

![公众号图片.png][.png]

[Link 1]: http://www.chinairn.com/report/20140329/100113737.html
[Link 2]: http://www.chinairn.com/yjbg/moref15f1f4ff1.html
[1.png]: /images/20220608/5fb6d8c6493e4fecb1405aa1b7bb7e12.png
[http_doc.sequoiadb.com_cn_index_Public_Home_document_208_api_java_html_index.html]: http://doc.sequoiadb.com/cn/index/Public/Home/document/208/api/java/html/index.html
[Link 3]: http://product.sequoiadb.com/
[Link 4]: http://solution.sequoiadb.com/
[Link 5]: http://download.sequoiadb.com/
[Link 6]: http://doc.sequoiadb.com/
[.png]: /images/20220608/477289dd1f7341279f6e19f291dd6c57.png