1）切换到 sdbadmin 用户；
2）在 SequoiaDB 数据库上创建集合空间 company，集合 employee，写入如下数据：
( empno: 10001, ename: 'Georgi', age: 48 )；
( empno: 10002, ename: 'Bezalel', age: 21 )；
( empno: 10003, ename: 'Parto', age: 33 )；
Note:
sdb
var db = new Sdb("localhost", 11810);
db.createDomain("company_domain", [ "group1" ]);
db.createCS("company", { Domain: "company_domain" } );
db.company.createCL("employee", { "ShardingKey": { "_id": 1 }, "ShardingType": "hash", "ReplSize": -1, "Compressed": true, "CompressionType": "lzw", "AutoSplit": true, "EnsureShardingIndex": false } );
db.company.employee.insert({"empno":10001,"ename":"Georgi","age":48});
db.company.employee.insert({"empno":10002,"ename":"Bezalel","age":21});
db.company.employee.insert({"empno":10003,"ename":"Parto","age":33});
该考试环境为单分区三副本，仅创建了数据组 group1
3）在 MySQL 实例创建数据库 company 和 数据表 employee 与 SequoiaDB 巨杉数据库存储引擎的 employee 集合映射；
/opt/sequoiasql/mysql/bin/mysql -h 127.0.0.1 -P 3306 -u root
CREATE DATABASE company;
USE company;
create table employee(
empno int,
ename varchar(128),
age int
);
select * from employee;
4）查看当前 MySQL 实例连接 SequoiaDB 巨杉数据库引擎的协调节点端口是否为11810；
/opt/sequoiasql/mysql/bin/mysql -h 127.0.0.1 -P 3306 -u root -e "SHOW VARIABLES LIKE 'sequoiadb_conn%';"
5）使用 beeline 客户端连接 SparkSQL 的 thriftserver 服务，创建对应集合空间的数据库 company，对应集合的表 employee；建表要求：
设置连接 SequoiaDB 的协调节点为 21810；
设置 SparkSQL 读取数据时优先选择备节点；
/opt/spark/bin/beeline -u 'jdbc:hive2://localhost:10000'
CREATE DATABASE company;
USE company;
CREATE TABLE employee
(
empno INT,
ename STRING,
age INT
)
USING com.sequoiadb.spark OPTIONS
(
host 'localhost:21810',
collectionspace 'company',
collection 'employee',
preferredinstance 'S',
preferredinstancemode 'random',
preferredinstancestrict true
);
6）查找年龄最小的员工信息并写入 company.result 表中（使用 Spark 结果集创建表的方式把结果存储到巨杉数据库，包含 empno，ename， age 三个字段）；
/opt/sequoiasql/mysql/bin/mysql -h 127.0.0.1 -P 3306 -u root
create table result(
empno int,
ename varchar(128),
age int
);
insert into result SELECT * FROM employee where age=(select min(age) from employee);
/opt/spark/bin/beeline -u 'jdbc:hive2://localhost:10000'
CREATE TABLE result
(
empno INT,
ename STRING,
age INT
)
USING com.sequoiadb.spark OPTIONS
(
host 'localhost:21810',
collectionspace 'company',
collection 'result'
);
7）使用 SELECT 方法查看数据；
