分区类型

水平分区 水平分区又称为数据库分区或横向分区。

在 SequoiaDB 集群环境中，用户可以通过将一个集合中的数据切分到多个复制组中，以达到并行计算的目的。这种数据切分的方式称为水平分区。水平分区是按一定的条件把全局关系的所有元组划分成若干不相交的子集，每个子集为关系的一个片段，称为分区。对于水平分区后的每一个分区，该分区只存在于集群的某一个复制组中。但一个复制组却可以承载水平分区后的多个分区。分区在复制组之间可以通过水平切分操作进行移动。

sh3

垂直分区 垂直分区又称为集合分区或纵向分区。

在 SequoiaDB 集群环境中，用户也可以将一个集合全局关系的属性分成若干子集，并在这些子集上作投影运算，将这些子集映射到另外的集合上，从而实现集合关系的垂直切分。该集合称之为主集合，每个切分的子集称为分区，分区映射的集合称为子集合。一个分区只能映射到一个子集合中，但一个子集合可以承载多个分区。分区在子集合之间可以通过垂直切分操作进行重映射。

sh4

混合分区 在 SequoiaDB 集群环境中，可以将集合先通过垂直分区映射到多个子集合中，再通过水平分区将子集合切分到多个复制组中，从而实现混合分区。

分区方式

数据分区有两种方式：范围分区（Range）和散列分区（Hash）。水平分区既可使用 Hash 方式也可使用 Range 方式进行数据分区；垂直分区只能使用 Range 方式进行数据分区。Hash 及 Range 这两种分区方式判定分区划分所依据的字段称为“分区键”。分区键基于集合定义，每个分区键可以包含一个或多个字段。

Range 方式和 Hash 方式主要区别如下： Range 方式下依据记录中分区键的范围选择所要插入的分区，而 Hash 方式下则根据记录中分区键生成的 Hash 值选择所要插入的分区。ShardingType 如果不填则默认为 Hash 分区。

sharding_concept

在所示图中，为一个 Range 方式分区，方形区域为三个分别位于不同数据组的数据节点，椭圆形为协调节点。每个数据节点各自定义了所包含数据的范围。例如对于节点 1 包含了大于等于 0 切小于 10 的数据。

当用户插入一条数据时，协调节点首先判定该数据的分区键应当坐落于哪个分区。如果分区键不存在则定义为 Undefined 类型（Undefined 类型也可以与普通数据类型进行对比）。

当查询到该数据所在的分区后，协调节点会将请求直接下发给指定的分区。

而在 Hash 方式分区中，用户不指定每个分区的范围，而是指定集合切分的分区个数（Partition），其值必须是 2 的幂，范围在[ 23 , 220 ]，默认为 4096 个，代表我们将整个范围平均划分为 4096 个分区。设计 Hash 分区的目的是让数据分布更灵活，可以根据需要自由设置每个数据分区承担 Hash 分区的范围。

水平分区示例

使用 Hash 分区方式进行水平分区，分区键为 age 字段，分区个数为 4096。

  1. > db.foo.createCL( "bar", { ShardingKey: { age: 1 }, ShardingType: "hash", Partition: 4096 } )

垂直分区示例

1.创建主表

主表必须用 Range 切分

  1. > db.createCS( "maincs" ).createCL( "maincl", { IsMainCL: true, ShardingKey: { a: 1 }, ShardingType: "range" } )

2.创建子表1

子表既可用 Range，也可用 Hash，ShardingKey 也不必和主表的一致

  1. > db.createCS( "year2015" ).createCL( "month01", { ShardingKey: { a: 1 }, ShardingType: "hash", Partition: 1024 } )

3.创建子表2

  1. > db.year2015.createCL( "month02", { ShardingKey: { a: 1 }, ShardingType: "hash", Partition: 1024 } )

4.将子表 1、子表 2 关联到主表中

将子表附到主表中去，每个子表都有一个范围

  1. > db.maincs.maincl.attachCL( "year2015.month01", { LowBound: { a: 0 }, UpBound: { a: 100 } } )
  2. > db.maincs.maincl.attachCL( "year2015.month02", { LowBound: { a: 100 }, UpBound: { a: 200 } } )

5.可以通过快照命令查看主子表情况

  1. > db.snapshot(SDB_SNAP_CATALOG)
  2. {
  3.   "CataInfo": [
  4.     {
  5.       "ID": 1,
  6.       "SubCLName": "year2015.month01",
  7.       "LowBound": {
  8.         "a": 0
  9.       },
  10.       "UpBound": {
  11.         "a": 100
  12.       }
  13.     },
  14.     {
  15.       "ID": 2,
  16.       "SubCLName": "year2015.month02",
  17.       "LowBound": {
  18.         "a": 100
  19.       },
  20.       "UpBound": {
  21.         "a": 200
  22.       }
  23.     }
  24.   ],
  25.   "EnsureShardingIndex": true,
  26.   "IsMainCL": true,
  27.   "Name": "maincs.maincl",
  28.   "ShardingKey": {
  29.     "a": 1
  30.   },
  31.   "ShardingType": "range",
  32.   "Version": 3,
  33.   "_id": {
  34.     "$oid": "56c180b419ca59d5c29afb20"
  35.   }
  36. }
  37. {
  38.   "CataInfo": [
  39.     {
  40.       "GroupID": 1003,
  41.       "GroupName": "datagroup",
  42.       "LowBound": {
  43.         "": 0
  44.       },
  45.       "UpBound": {
  46.         "": 1024
  47.       }
  48.     }
  49.   ],
  50.   "EnsureShardingIndex": true,
  51.   "InternalV": 3,
  52.   "MainCLName": "maincs.maincl",
  53.   "Name": "year2015.month01",
  54.   "Partition": 1024,
  55.   "ShardingKey": {
  56.     "a": 1
  57.   },
  58.   "ShardingType": "hash",
  59.   "Version": 2,
  60.   "_id": {
  61.     "$oid": "56c180c219ca59d5c29afb25"
  62.   }
  63. }
  64. {
  65.   "CataInfo": [
  66.     {
  67.       "GroupID": 1003,
  68.       "GroupName": "datagroup",
  69.       "LowBound": {
  70.         "": 0
  71.       },
  72.       "UpBound": {
  73.         "": 1024
  74.       }
  75.     }
  76.   ],
  77.   "EnsureShardingIndex": true,
  78.   "InternalV": 3,
  79.   "MainCLName": "maincs.maincl",
  80.   "Name": "year2015.month02",
  81.   "Partition": 1024,
  82.   "ShardingKey": {
  83.     "a": 1
  84.   },
  85.   "ShardingType": "hash",
  86.   "Version": 2,
  87.   "_id": {
  88.     "$oid": "56c180ce19ca59d5c29afb28"
  89.   }
  90. }

6.插数据

  1. > db.maincs.maincl.insert( { a: 1 } )  // 数据落到子表1中
  2. > db.maincs.maincl.insert( { a: 101 } ) // 数据落到子表2中

7.查看数据落表的情况

  1. > db.year2015.month01.find()
  2. {
  3.   "_id": {
  4.     "$oid": "564968bb5fc84bb828000000"
  5.   },
  6.   "a": 1
  7. }
  8. > db.year2015.month02.find()
  9. {
  10.   "_id": {
  11.     "$oid": "564968be5fc84bb828000001"
  12.   },
  13.   "a": 101
  14. }

8.解除主子表之间的关联

  1. > db.maincs.maincl.detachCL( "year2015.month01" )
  2. > db.maincs.maincl.detachCL( "year2015.month02" )