Sequoiadb的SequoiaSql应用开发实践

忘是亡心i 2022-06-06 05:21 255阅读 0赞

## 1.前言    ##

Sequoiadb分布式数据库作为新一代的nosql数据库。除了拥有高性能之外对标准SQL也是支持的，Sequoiadb能够对接spark之外，还有企业级的SequoiaSql可以选择，SequoiaSql是解析sql语言，Sequoiadb来执行SequoiaSql解析出的语言并执行相关命令，SequoiaSql相当于客户端，Sequoiadb相当于后端。用户可以通过JDBC驱动连接SequoiaSql进行应用程序开发。用户通过扩展SequoiaSql功能，让开发者可以使用SQL语句访问Sequoiadb数据库,完成Sequoiadb数据库的增、删、查、改操作，本片文章介绍Sequoiadb如何对接SequoiaSql进行应用开发。

## 2、安装部署 ##

### 2.1、安装SequoiaSql ###

以下步骤需要在root下操作

1、进入安装包目录

cd/opt

2、给Sequoiasql添加执行权限

chmod  +xsequoiasql-oltp-2.8-x86\_64-enterprise-installer.run

3、验证权限，结果为：-rwxr-xr-x即可：

ls-la sequoiasql-oltp-2.8-x86\_64-enterprise-installer.run

4、安装sequoiasql选择模式为text，在安装的时候要指定安装路径，使用默认目录: /opt/SequoiaSQL。

./sequoiasql-oltp-2.8-x86\_64-enterprise-installer.run  --mode text

5、修改sequoiasql 目录及目录下的文件权限

chown-R sdbadmin:sdbadmin\_group /opt/sequoiasql

6、修改结果为：

drwxr-xr-x   sdbadmin sdbadmin\_group

以下步骤在sdbadmin下操作

7、切换sdbadmin用户

su- sdbadmin

8、备份环境变量

cp~/.bashrc  ~/.bashrc2.bak

9、添加环境变量

vi~/.bashrc

\#追加以下两行

exportpath=$path:/opt/sequoiasql/bin

exportld\_library\_path=$ld\_library\_path:/opt/sequoiasql/lib

Note：红色部分为用户自定义的安装目录

10、使配置生效

source~/.bashrc

11、检查配置

echo$\{path\}

12、进入安装目录

cd  /opt/sequoiasql

13、初始化数据目录，其中pg\_data和bin目录同一级。

./bin/initdb-D ./pg\_data/

14、备份pg\_data目录下的pg\_hba.conf和SequoiaSql.conf

cd  /opt/sequoiasql/pg\_data

cppg\_hba.conf  pg\_hba.conf.bak

cpSequoiaSql.conf  SequoiaSql.conf.bak

15、验证是否备份

ls-la

/opt/sequoiasql/pg\_data/pg\_hba.conf.bak

/opt/sequoiasql/pg\_data/SequoiaSql.conf.bak

16、修改配置文件pg\_hba.conf，增加红色这一行

\# IPV4 local connections:

host   all         all        127.0.0.1/32     trust

host   all         all        0.0.0.0/0        trust

\# IPV6 local connections:

host   all         all         ::1/128         trust

17、验证是否修改成功catpg\_hba.conf ,打印结果：

\# IPV4 local connections:

host   all         all        127.0.0.1/32      trust

host   all         all         0.0.0.0/0        trust

\# IPV6 local connections:

host   all         all         ::1/128         trust

18、修改SequoiaSql.conf，修改红色部分。

listen\_addresses = '\*'

port = 5432

Max\_connections = 100

Shared\_buffers = 128 MB

log\_connections = on

log\_disconnections = on

log\_line\_prefix = ‘%m %p %r'

log\_timezone = ‘PRC’

exit\_on\_error = on

19、检查端口是否被占用（在root用户下操作）

netstat-nap | grep 5432

Note：如果5432端口被占用或者希望修改SequoiaSql 的启动端口，则在上面的步骤中修改port端口，设置为闲置且没有用户使用的端口。

20、启动进程

cd/opt/sequoiasql

./bin/postgres-D ./pg\_data/ >> logfile 2>&1 &

21、检查端口是否已经被SequoiaSql占用，输出为如下信息表示启动成功

netstat-nap | grep 5432

tcp  0   0 127.0.0.1:5432     0.0.0.0:\*         LISTEN     20502/postgres

unix 2   \[ ACC \]   STREAM   LISTENING   40776754 20502/postgres     /tmp/.s.PGSQL.5432

22、创建 Sequoiasql 的 database

$bin/createdb -p 5432 foo

23、进入 SequoiaSql shell 环境

$bin/psql -p 5432 foo

### 2.2、检查SequoiaSql插件 ###

1、检查sdb\_fdw.so文件

切换到SequoiaSql的lib目录中

cd/opt/sequoiasql/bin

llsdb\_fdw.so\*

lrwxrwxrwx. 1 root root      22 Sep 12 20:18 sdb\_fdw.so ->sdb\_fdw.so\_e\_2.8\_27329

\-rwxr-xr-x. 1 root root 1164510 Jan 23  2017 sdb\_fdw.so\_e\_2.8\_27329

可以看到已经有软连接sdb\_fdw.so 连接的是sdb\_fdw.so\_e\_2.8\_27329，其中2.8\_27329为数据库的版本号，表示为：2.8版本的27329打包序列。如下图所示：

![20171031153819744][]

2、检查sdb\_fdw.control和sdb\_fdw--1.0.sql这两个文件

切换到SequoiaSql的/share/extension目录中

cd/opt/sequoiasql/share/extension

查看这两个文件是否已经存在

llsdb\_fdw\*

\-rw-r--r--. 1 root root 469 Jan 23  2017 sdb\_fdw--1.0.sql

\-rw-r--r--. 1 root root 153 Jan 23  2017 sdb\_fdw.control

如下图所示：

![20171031153828871][]

### 2.3、Sequoiadb连接Sequoiasql ###

1、首先加载Sequoiadb连接驱动

foo=\#create extension sdb\_fdw;

2、配置与Sequoiadb连接参数

foo=\#create server sdb\_server foreign data wrapper sdb\_fdw options(address'127.0.0.1', service '11810', user 'sdbadmin', password 'mypassword');

Note:

1）、如果没有配置数据库密码验证，可以忽略user与password字段。

2）、连接参数包括address、service 、user、password、preferedinstance 和 transaction。

3）、address和service 参数分别指的是主机名和端口号；为了避免在一个协调节点出现异常后Sequoiasql无法使用的情况，用户可以指定多个协调节点，即address可写成 ’hostname1:service1，hostname2:service2’的形式，同时用户必须指定service 为空字符串。示例如下：

foo=\# create server sdb\_server foreign datawrapper sdb\_fdw options(address'192.168.30.182:11810,192.168.30.183:11810,192.168.30.184:11810', service '',user 'sdbadmin', password 'mypassword'); ;

4）、preferedinstance参数是在指定SequoiaSql 访问Sequoiadb 数据节点时，优先选择连接哪个角色的数据节点，默认为’s’，即备节点，可配置参数为’m’/’M’/’s’/’S’/’a’/’A’/1-7，分别表示master/slave/anyone/node1-node7。

5）、transaction参数对接db的事务，默认值为false 。

3、关联Sequoiadb的集合空间与集合

foo=\#create foreign table test (name text, id numeric) server sdb\_server options (collectionspace 'cs', collection 'cl', decimal 'on' ) ;

Note：

其中是在foo这个库下操作创建的表名为test，关联的集合空间为cs ，集合为cl。

4、重启 SequoiaSql

$ bin/pg\_ctl stop -s -D pg\_data/ -m fast;bin/postgres -D pg\_data/ >> logfile 2>&1 &

5、验证是否关联成功

1）、此时在Sequoiadb的sdb中进行查询为：

![20171031153824961][]

2）、在Sequoiasql中查询test的结果：

![20171031154144367][]

发现两个查询出来的结果值相同，说明已经关联成功。

6、进入Sequoiasql的shell中常用的一些操作：

\\c切换到不同的库

\\l显示所的库

\\q退出pg

\\h：查看SQL命令的解释，比如\\h select。

\\?：查看psql命令列表。\\l：列出所有数据库。

\\c\[database\_name\]：连接其他数据库。

\\d：列出当前数据库的所有表格。

\\d\[table\_name\]：列出某一张表格的结构。

\\du：列出所有用户。

\\e：打开文本编辑器。

\\conninfo：列出当前数据库和连接的信息。

### 2.4、调整SequoiaSql配置文件 ###

1、查看pg\_shell中默认的配置

执行命令：

foo=\#set

结果为：

AUTOCOMMIT= 'on'

PROMPT1= '%/%R%\# '

PROMPT2= '%/%R%\# '

PROMPT3= '>> '

VERBOSITY= 'default'

VERSION= 'SequoiaSql 9.3.4 on x86\_64-unknown-linux-gnu, compiled by gcc (SUSE Linux)4.3.4 \[gcc-4\_3-branch revision 152973\], 64-bit'

DBNAME= 'foo'

USER= 'sdbadmin'

PORT= '5432'

ENCODING= 'UTF8'

2、调整pg\_shell查询时，每次获取记录数

foo=\#setFETCH\_COUNT 100

调整为每次ps\_shell每次获取100 条记录立即返回记录，然后再继续获取。直接在pg\_shell中修改配置文件，只能在当前pg\_shell中生效，重新登录pg\_shell需要重新设置。

3、调整pg\_shell的日志级别

$>sed -i 's/\#client\_min\_messages =notice/client\_min\_messages = debug1/g' pg\_data/SequoiaSql.conf

4、调整pg引擎的日志级别

## 1、设计概要 ##

### 3.1、设计框架图 ###

框架图如下：

![20171031154207060][]

多个应用使用JDBC连接SequoiaSql进行高并发的SQL操作，SequoiaSql连接Sequoiadb的协调节点，连接默认选择备机作为连接的机器，当有插入的操作时会在主节点进行插入。

### 3.2、数据类型对应   ###

在SequoiaSql进行表关联时数据类型需要指定。

<table> 
 <tbody> 
 <tr> 
 <td style="background:#BFBFBF"> Sequoiadb </td> 
 <td style="background:#BFBFBF"> SequoiaSql </td> 
 </tr> 
 <tr> 
 <td> string </td> 
 <td> text </td> 
 </tr> 
 <tr> 
 <td> string </td> 
 <td> char/char(N) </td> 
 </tr> 
 <tr> 
 <td> string </td> 
 <td> varchar/varchar(N) </td> 
 </tr> 
 <tr> 
 <td> int/double/long </td> 
 <td> numeric </td> 
 </tr> 
 <tr> 
 <td> int </td> 
 <td> int </td> 
 </tr> 
 <tr> 
 <td> int/double </td> 
 <td> float </td> 
 </tr> 
 <tr> 
 <td> date </td> 
 <td> date </td> 
 </tr> 
 <tr> 
 <td> binary </td> 
 <td> bytea </td> 
 </tr> 
 <tr> 
 <td> timestamp </td> 
 <td> timestamp </td> 
 </tr> 
 <tr> 
 <td> array </td> 
 <td> TYPE[] sample:text[] </td> 
 </tr> 
 <tr> 
 <td> boolean </td> 
 <td> boolean </td> 
 </tr> 
 <tr> 
 <td> null </td> 
 <td> text </td> 
 </tr> 
 </tbody> 
</table>

### 3.3、注意事项 ###

1、注意字符的大小写

Sequoiadb 中的集合空间、集合和字段名均对字母的大小写敏感

1) 集合空间、集合名大写

假设Sequoiadb 中存在名为TEST的集合空间，CHEN的集合，在SequoiaSql中建立相应的映射表

foo=\# create foreign table sdb\_upcase\_cs\_cl (name text) serversdb\_server options ( collectionspace 'TEST', collection 'CHEN' ) ;

2) 字段名大写

假设Sequoiadb 中存在名为foo的集合空间，bar的集合，而且保存的数据为：

"\_id": \{

"$oid":"53a2a0e100e75e2c53000006"

\},

"NAME": "test"

在SequoiaSql中建立相应的映射表

foo=\# create foreign table sdb\_upcase\_field (“NAME” text) serversdb\_server options ( collectionspace 'foo', collection 'bar' ) ;

执行查询命令：

foo=\# select \* from sdb\_upcase\_field;

查询结果为：

NAME

\------

test

(1 rows)

2. 映射Sequoiadb中的数据类型

假设Sequoiadb中存在foo集合空间，bar集合，保存记录为：

"\_id": \{

"$oid":"53a2de926b4715450a000001"

\},

"name": \[

\],

"id": 123

在SequoiaSql 中建立相应的映射表

foo=\# create foreign table bartest (name numeric\[\], id numeric) serversdb\_server options ( collectionspace 'foo', collection 'bar' ) ;

执行查询命令：

foo=\# select \* from bartest;

查询结果：

name  |id

\---------+-----

\{1,2,3\} | 123

3. 连接Sequoiadb 协调节点错误

如果SequoiaSql连接的Sequoiadb 协调节点重启，在查询时报错

ERROR: Unable to get collection"chen.test", rc = -15

HINT: Make sure the collectionspace and collection exist on the remotedatabase

解决方法：

退出SequoiaSql shell

foo=\# q

重新进入SequoiaSql shell

$> bin/psql -p 5432 foo

## 1、对接使用示例 ##

### 4.1、修改SequoiaSql的连接配置 ###

1、修改SequoiaSql的监听地址

$>sed -i "s/\#listen\_addresses = 'localhost'/listen\_addresses ='0.0.0.0'/g" pg\_data/SequoiaSql.conf

2、修改信任的机器列表

$>linenum=$(cat-n pg\_data/pg\_hba.conf | grep "\# IPv4 local connections:" | awk'\{print $1\}');

let "linenum=linenum+1";varStr="host   all            all            0.0.0.0/0              trust";

sed -i "$\{linenum\} a$\{varStr\}" pg\_data/pg\_hba.conf;

3、重启SequoiaSql

$>bin/pg\_ctl stop -s -D pg\_data/ -mfast; bin/postgres -D pg\_data/ >> logfile 2>&1 &

### 4.2、使用JDBC连接SequoiaSql ###

1、已经安装好Eclipse，并且创建好工程，将Sequoiadb.jar包导入。

![20171031154258326][]

2、执行如下代码进行连接：

package sdb\_test;

import java.sql.\*;

public class SequoiaSql \{

/\*static\{

try \{

Class.forName("org.SequoiaSql.Driver");

\} catch (ClassNotFoundException e) \{

e.printStackTrace();

\}\*/

public static void main( String\[\] args ) throws SQLException\{

String pghost = "机器IP";

String port = "5432";

String databaseName = "foo";

// SequoiaSql process is running in which user

String pgUser = "sdbadmin";

String url ="jdbc:SequoiaSql://"+pghost+":"+port+"/" +databaseName;

Connection conn = DriverManager.getConnection(url, pgUser, null);

//System.out.println("conn is ====> "+conn);

Statement stmt = conn.createStatement();

String sql = "select \* from test2 ";

ResultSet rs = stmt.executeQuery(sql);

boolean isHeaderPrint = false;

while (rs.next()) \{

ResultSetMetaData md = rs.getMetaData();

int col\_num = md.getColumnCount();

if (isHeaderPrint)\{

for (int i = 1; i  <= col\_num; i++) \{

System.out.print(md.getColumnName(i)+ "|");

isHeaderPrint = true;

for (int i = 1; i <= col\_num; i++) \{

System.out.print(rs.getString(i)+ "|");

System.out.println();

stmt.close();

conn.close();

3、分析执行的结果是否正确

1）、在Sequoiadb中进行这张表的查询

> db.cs2.cl2.find()

"\_id": \{

"$oid": "59c4af84622ea311aa000000"

\},

"name": "doc",

"age": 12

"\_id": \{

"$oid": "59c4af8e622ea311aa000001"

\},

"name": "Jess",

"age": 13

"\_id": \{

"$oid": "59c4af9c622ea311aa000002"

\},

"name": "dd",

"age": 14

"\_id": \{

"$oid": "59c4afa4622ea311aa000003"

\},

"name": "eer",

"age": 15

Return 4 row(s).

Takes 0.007498s.

![20171031154346735][]

2）、在SequoiaSql关联Sequoiadb的表

foo=\# create foreign table test2 (name text,age int) server sdb\_server options( collectionspace 'cs2', collection 'cl2' ) ;

![20171031154421322][]

3）、在SequoiaSql中进行查询

foo=\# select \* from test2;

name| age

\------+-----

doc |  12

Jess|  13

dd  |  14

eer |  15

(4 rows)

![20171031154537458][]

4）、通过JDBC连接查询test2这张表

![20171031154545630][]

查询出的结果完全相同，通过以上可以证明，JDBC连接已经成功，开发时可以直接进行传SQL变量进行使用。

### 4.3、使用SQl的join操作 ###

创建cs.cl 使用bulkinsert插入10000000条数据

vardb = new Sdb("localhost",11810);

var recordList = \[\];

var bulkNum = 1024;

var i = 0;

while (i<10000000)\{

recordList.push (\{name:"test",num:i,cost:i\*10\});

\++i;

if (recordList.length%bulkNum == 0)\{

db.cs.cl.insert(recordList) ;

recordList = \[\];

if (recordList.length != 0) \{

db.cs.cl.insert(recordList); recordList = \[\];

![20171031154635332][]

创建cs.cl2,使用bulkinsert插入1000000条数据

var db = newSdb("localhost",11810);

var recordList = \[\];

var bulkNum = 1024;

var i = 0;

while (i<1000000)\{

recordList.push (\{name:"hhh",num:i\*10,cost:i\*100，address:”beijing”\});

\++i;

if (recordList.length%bulkNum == 0)\{

db.cs.cl.insert(recordList) ;

recordList = \[\];

if (recordList.length != 0) \{

db.cs.cl.insert(recordList); recordList = \[\];

给cs.cl和cs.cl2创建SequoiaSql表

\#创建cs\_cl表

create foreign table cs\_cl (name text, numint ,cost int ) server

sdb\_server options ( collectionspace 'cs',collection 'cl', decimal 'on' ) ;

\#创建cs\_cl2表

createforeign table cs\_cl2 (name text, num int ,cost int,address text) serversdb\_server options ( collectionspace 'cs', collection 'cl2', decimal 'on' ) ;

效果如下图所示：

![20171031154740667][]

![20171031154750557][]

此时cs3.cl3是没有索引

![20171031154803342][]

在SequoiaSql中进行两张表的关联查询查看访问计划

foo=\# explain select a.name,b.cost fromcs\_cl2 a left join cs\_cl b on

a.num=b.cost where a.num=100;

QUERYPLAN

\----------------------------------------------------------------------------------

Hash Right Join  (cost=105774.48..14237022.97 rows=1380650000width=36)

Hash Cond: (b.cost = a.num)

\->  Foreign Scan on cs\_clb  (cost=0.00..151453.00 rows=50000width=4)

Filter: (cost = 100)

Foreign Namespace: cs.cl

\->  Hash  (cost=105213.31..105213.31 rows=27613width=36)

\->  Foreign Scan on cs\_cl2a  (cost=0.00..105213.31 rows=27613width=36)

Filter: (num = 100)

Foreign Namespace: cs.cl2

(9 rows)

显示是走Hash Right Join

![20171031154840484][]

给cs.cl的cost字段创建索引

>db.cs.cl.createIndex("cost\_index",\{"cost":1\})

Takes 32.411557s.

在Sequoiasql中进行left join 查询同时执行访问计划

foo=\# explain select a.name,b.cost fromcs\_cl2 a left join cs\_cl b on a.num=b.cost where a.num=100;

QUERYPLAN

\----------------------------------------------------------------------------

Nested Loop Left Join  (cost=0.43..317471.88 rows=1380650000width=36)

\->  Foreign Scan on cs\_cl2a  (cost=0.00..105213.31 rows=27613width=36)

Filter: (num = 100)

Foreign Namespace: cs.cl2

\->  Foreign Scan on cs\_clb  (cost=0.43..7.68 rows=1 width=4)

Filter: ((cost = 100) AND (a.num = cost))

Foreign Namespace: cs.cl

(7 rows)

显示是走 Nested Loop Left Join

![20171031154909095][]

使用JDBC显示同样的结果

![20171031154935888][]

当创建cs.cl2的num索引，删除cs.cl的cost索引。

>db.cs.cl2.createIndex("num\_index",\{"num":1\})

Takes 15.430328s.

>db.cs.cl.dropIndex("cost\_index")

Takes 1.791945s.

![20171031155005907][]

重新执行left join的访问计划可以看到

foo=\# explain select a.name,b.cost fromcs\_cl2 a left join cs\_cl b on a.num=b.cost where a.num=100;

QUERYPLAN

\----------------------------------------------------------------------------------

HashRight Join  (cost=105774.48..14237022.97rows=1380650000 width=36)

Hash Cond: (b.cost = a.num)

\->  Foreign Scan on cs\_clb  (cost=0.00..151453.00 rows=50000width=4)

Filter: (cost = 100)

Foreign Namespace: cs.cl

\->  Hash  (cost=105213.31..105213.31 rows=27613width=36)

\->  Foreign Scan on cs\_cl2a  (cost=0.00..105213.31 rows=27613width=36)

Filter: (num = 100)

Foreign Namespace: cs.cl2

(9 rows)

![20171031155047076][]

综上所述可以得出，是否是使用Nested Loop Left Join和右表的关联字段是否有索引有关。

## 5、sequoiasql和postgresql对比 ##

Sequoiasql对postgresql进行了升级和优化，两者都能够支持标准sql，支持高并发的sql操作。比较有特点是Sequoiasql重点优化了关联查询，当连接到Sequoiadb数据库时能够支持Nested Loop Left Join和left Join之间的随意切换使用。当使用Nested Loop Left Join进行查询时使得性能得到了比较高的提升，因为在Sequoiadb数据库中是进行索引读。

Sequoiasql的Nested LoopLeft Join功能由引擎配置文件的enable\_nestloop参数控制是否开启，当然该功能默认是开启的。两种join类型进行比较：

1、NL Join使用要求

Sequoiasql在做关联查询时需要执行NL Join关联策略，需要满足以下条件

1)        enable\_nestloop参数设置为on

2)        关联右表（也叫探查表、内部表）的关联字段有创建索引

3)        关联左表（也叫驱动表、外部表）的数据量相对较少

使用NL Join的效率一般来讲是最快的

2、Hash join要求

SequoiaSQL在执行关联查询时，如果不满足NL Join的要求，则自动选择使用HashJoin完成关联查询。

## 6、Sequoiasql中hint使用 ##

### 6.1、安装pg\_hint ###

1、首先解压pg\_hint.tar.gz

tar -zxvf pg\_hint.tar.gz

存在以下文件

![20171031155123217][]

2、拷贝配置文件

将以下文件拷贝到pg安装目录下share/extension/

pg\_hint\_plan.control

pg\_hint\_plan--1.1.3.sql

pg\_hint\_plan--1.0--1.1.1.sql

pg\_hint\_plan--1.1.1--1.1.2.sql

pg\_hint\_plan--1.1.2--1.1.3.sql

![20171031155153521][]

3、拷贝pg\_hint动态库

将以下文件拷贝到pg安装目录下lib/

pg\_hint\_plan.so.93.1.1.3

赋予可执行权限

chmod +x pg\_hint\_plan.so.93.1.1.3

创建软链接

>ln -s pg\_hint\_plan.so.93.1.1.3pg\_hint\_plan.so

4、修改pg配置文件（数据目录下）

>cd /opt/sequoiasql/pg\_data

>vi postgresql.conf

\#配置选项shared\_preload\_libraries

shared\_preload\_libraries = 'pg\_hint\_plan'

![20171031155235922][]

![20171031155241306][]

5、重新启动pg

$>bin/pg\_ctl stop -s -D pg\_data/ -mfast; bin/postgres -D pg\_data/ >>

logfile 2>&1 &

使用命令netstat -nap | grep 5432  出现如下信息表示5432端口启动成功

![20171031155331555][]

使用命令 ps -elf | grep postgres 出现如下信息表示启动成功

![20171031155400744][]

### 6.2、使用pg\_hint ###

1、进入Sequoiasql中

\[sdbadmin@sdb1 bin\]$ psql -p 5432 foo

psql (9.3.4)

Type "help" for help.

foo=\#

![20171031155438797][]

2、正常执行sql，查看访问计划

foo=\# explain select a.name,b.cost fromcs\_cl2 a left join cs\_cl b on a.num=b.cost where a.num=100;

QUERYPLAN

\----------------------------------------------------------------------------

Nested Loop Left Join  (cost=0.43..317471.88 rows=1380650000width=36)

\->  Foreign Scan on cs\_cl2a  (cost=0.00..105213.31 rows=27613width=36)

Filter: (num = 100)

Foreign Namespace: cs.cl2

\->  Foreign Scan on cs\_clb  (cost=0.43..7.68 rows=1 width=4)

Filter: ((cost = 100) AND (a.num = cost))

Foreign Namespace: cs.cl

(7 rows)

![20171031155529317][]

3、使用pg\_hint，改变关联方式

foo=\#  /\*+ HashJoin(a b) \*/explain selecta.name,b.cost from cs\_cl2 a left join cs\_cl b on a.num=b.cost where a.num=100;

QUERYPLAN

\----------------------------------------------------------------------------------

HashRight Join  (cost=105774.48..14237022.97rows=1380650000 width=36)

Hash Cond: (b.cost = a.num)

\->  Foreign Scan on cs\_clb  (cost=0.00..151453.00 rows=50000 width=4)

Filter: (cost = 100)

Foreign Namespace: cs.cl

\->  Hash  (cost=105213.31..105213.31 rows=27613width=36)

\->  Foreign Scan on cs\_cl2a  (cost=0.00..105213.31 rows=27613width=36)

Filter: (num = 100)

Foreign Namespace: cs.cl2

(9 rows)

![20171031155604349][]

发现已经从原来的Nested Loop Left Join变为Hash Right Join，说明配置已经生效。

4、在JDBC中执行pg\_hint

在代码中添加

String sql = "  /\*+ HashJoin(a b) \*/explain selecta.name,b.cost from cs\_cl2 a left join cs\_cl b on a.num=b.cost where a.num=100;";

和在shell中执行的结果相同

![20171031155640532][]

5、pg\_hint功能说明

<table style="background:#F9F9F9"> 
 <thead> 
 <tr> 
 <td>&nbsp;</td> 
 </tr> 
 <tr> 
 <td style="background:#F2F2F2"> Group </td> 
 <td style="background:#F2F2F2"> Format </td> 
 <td style="background:#F2F2F2"> Description </td> 
 </tr> 
 </thead> 
 <tbody> 
 <tr> 
 <td> Scan method </td> 
 <td> SeqScan(table) </td> 
 <td> Forces sequential scan on the table </td> 
 </tr> 
 <tr> 
 <td> TidScan(table) </td> 
 <td> Forces TID scan on the table. </td> 
 </tr> 
 <tr> 
 <td> IndexScan(table[ index...]) </td> 
 <td> Forces index scan on the table. Restricts to specified indexes if any. </td> 
 </tr> 
 <tr> 
 <td> IndexOnlyScan(table[ index...]) </td> 
 <td> Forces index only scan on the table. Rstricts to specfied indexes if any. Index scan may be used if index only scan is not available. Available for PostgreSQL 9.2 and later. </td> 
 </tr> 
 <tr> 
 <td> BitmapScan(table[ index...]) </td> 
 <td> Forces bitmap scan on the table. Restoricts to specfied indexes if any. </td> 
 </tr> 
 <tr> 
 <td> NoSeqScan(table) </td> 
 <td> Forces not to do sequential scan on the table. </td> 
 </tr> 
 <tr> 
 <td> NoTidScan(table) </td> 
 <td> Forces not to do TID scan on the table. </td> 
 </tr> 
 <tr> 
 <td> NoIndexScan(table) </td> 
 <td> Forces not to do index scan and index only scan (For PostgreSQL 9.2 and later) on the table. </td> 
 </tr> 
 <tr> 
 <td> NoIndexOnlyScan(table) </td> 
 <td> Forces not to do index only scan on the table. Available for PostgreSQL 9.2 and later. </td> 
 </tr> 
 <tr> 
 <td> NoBitmapScan(table) </td> 
 <td> Forces not to do bitmap scan on the table. </td> 
 </tr> 
 <tr> 
 <td> Join method </td> 
 <td> NestLoop(table table[ table...]) </td> 
 <td> Forces nested loop for the joins consist of the specifiled tables. </td> 
 </tr> 
 <tr> 
 <td> HashJoin(table table[ table...]) </td> 
 <td> Forces hash join for the joins consist of the specifiled tables. </td> 
 </tr> 
 <tr> 
 <td> MergeJoin(table table[ table...]) </td> 
 <td> Forces merge join for the joins consist of the specifiled tables. </td> 
 </tr> 
 <tr> 
 <td> NoNestLoop(table table[ table...]) </td> 
 <td> Forces not to do nested loop for the joins consist of the specifiled tables. </td> 
 </tr> 
 <tr> 
 <td> NoHashJoin(table table[ table...]) </td> 
 <td> Forces not to do hash join for the joins consist of the specifiled tables. </td> 
 </tr> 
 <tr> 
 <td> NoMergeJoin(table table[ table...]) </td> 
 <td> Forces not to do merge join for the joins consist of the specifiled tables. </td> 
 </tr> 
 </tbody> 
</table>

## 7、总结 ##

通过Sequoiadb和SequoiaSql进行对接，能够使得Sequoiadb支持标准SQl语法。JDBC 是 Sun 提供的一套数据库编程接口API 函数，由 Java 语言编写的类、界面组成。用 JDBC 写的程序能够自动地将 SQL 语句传送给相应的数据库管理系统。通过对接SequoiaSql的JDBC接口，能够使开发者尽快上手不必掌握复杂的API，降低了学习成本，是众多开发者的首选。

[20171031153819744]: /images/20220606/a126ecb14d69467d839f9d09b30b581d.png
[20171031153828871]: /images/20220606/fe41bdbeb54c4628a8c34641b5fa2a10.png
[20171031153824961]: /images/20220606/e37a5d0dcaab4c9e874abd93963b1eb4.png
[20171031154144367]: /images/20220606/bb6a6df4a6a74f9689192f539060e24f.png
[20171031154207060]: /images/20220606/a26f954b69f34ae284810b7d7f7336df.png
[20171031154258326]: /images/20220606/e071caa06ab44becbfd57e304112d581.png
[20171031154346735]: /images/20220606/13abb145bf40409a9c25ab222e20ff9f.png
[20171031154421322]: /images/20220606/4db02a0795874ea982cd5b621cbdc2a6.png
[20171031154537458]: /images/20220606/edf6be8cca734f0f97b0895cc2f7083f.png
[20171031154545630]: /images/20220606/c7a01a2f9afe4eebb5e4efefcad18de6.png
[20171031154635332]: /images/20220606/2dc8cd7f76564ae4b2ab6b0aa8ad4212.png
[20171031154740667]: /images/20220606/1feccd4bc9b54ef3b4d4a3ae6a70d026.png
[20171031154750557]: /images/20220606/94430753702d41ee80e89c0a1ff6be72.png
[20171031154803342]: /images/20220606/c6fe62f294e84f7282197398709c3c50.png
[20171031154840484]: /images/20220606/15a9f81d5e614cb29485b44ac0aca55f.png
[20171031154909095]: /images/20220606/0160e8e9e2b5461291e550ec12c7ec85.png
[20171031154935888]: /images/20220606/7010feb09d334b08b89673e6ccd103ac.png
[20171031155005907]: /images/20220606/6eecc626e6d6438bb466269455b690fe.png
[20171031155047076]: /images/20220606/6473415bc12f4707a08726f2a902309a.png
[20171031155123217]: /images/20220606/e01d3e64b9a045f89258e05a24c4b921.png
[20171031155153521]: /images/20220606/fe11d6ea0629463a9d77eee722efc196.png
[20171031155235922]: /images/20220606/1f1392849c3645e48a4a5ff88b3fa03c.png
[20171031155241306]: /images/20220606/3e8059acea014079986c200a66f79c3b.png
[20171031155331555]: /images/20220606/c49b91d13c2542329599219b53d2619b.png
[20171031155400744]: /images/20220606/dcc69e6e7bec48b58c5db5182665a451.png
[20171031155438797]: /images/20220606/1e17f92ebf4e43e9b386c9a1a6658f37.png
[20171031155529317]: /images/20220606/d3f68e9c71724b2096fa538efff5322e.png
[20171031155604349]: /images/20220606/d791647a5e11493f9ac1a376c2c2908f.png
[20171031155640532]: /images/20220606/56e0114f75d94a4ea162602082d3e499.png