象的具体类型（如Ｇ摄像识别传感器、温ＰＳ、ＲＦＩＤ、、度传感器等）部署者、部署时间，ＨｏｓｔＯｂｊ是该监控如太湖中的传感器的宿主对象为对象的宿主对象（
，太湖）Ｓａｍｌｉｎｓ是该监控对象的采样数据序列．ｐｇ此外，ＩｏＴ－ＮｏｄｅＤＢ中每个监控对象的元组还隐式地包含一个Ｓ其ＣＰＳｅｔ属性和一个ＳｔａｔｉｃＭｏｖ属性，中ＳＣＰＳｅｔ中存放该监控对象的原始采样数据的而Ｓ用ＳＣＰ集合，ｔａｔｉｃＭｏｖ是一个Ｂｏｏｌ型的标记，于区分静止监控对象和移动监控对象．４．２ 查询操作
上述数据类型允许我们在数据库内核中以统一的数据格式表示异构的传感器采样数据流．为了对传感器数据进行查询，我们还需要在这些数据类型的基础上定义一系列的查询操作．
４．２．１ 针对ＳａｍｌｉｎＳｅｕｅｎｃｅ数据类型的操作ｐｇｑ
针对ＳａｍｌｉｎＳｅｕｅｎｃｅ数据类型的最重要的ｐｇｑ查询操作是ａ该操作用于计算监控对ｔＩｎｓｔａｎｔ操作，象在某个给定时间ｔ其语法格式如下（在ｑ的状态值，操作的语法格式定义中，符号“两边分别是该操作→”的输入数据和输出数据的数据类型；如果操作有多个：输入数据，则输入数据类型之间用“进行连接）×”
：ａｔＩｎｓｔａｎｔ
ＳａｍｌｉｎＳｅｕｅｎｃｅ×Ｉｎｓｔａｎｔ→ＳａｍｌｉｎＶａｌｕｅ．ｐｇｑｐｇ假设ａｔＩｎｓｔａｎｔ操作的两个输入分别是ｓｅｕ∈ｑ，其中ｓＳａｍｌｉｎＳｅｕｅｎｃｅ和ｔｎｓｔａｎｔｅｕ＝ｐｇｑｑｑ∈Ｉ
ｎ（（））如果ｓｃｈｅｍａ，（ｔｌｏｃｎｏｓｖａｌｕｅｌａｐｆｇｉ，ｉ，ｉ，ｉ，ｉ）ｉ＝１．
ＳａｍｌｉｎＳｅｕｅｎｃｅ×Ｐｅｒｉｏｄｓ→ＳａｍｌｉｎＳｅｕｅｎｃｅ．ｐｇｑｐｇｑ
为了支持新采样值到采样数据序列的插入，我们定义ｓ该操作将一个新的ａｍｌｉｎＡｅｎｄ操作．ｐｇｐｐ采样值（连同表示是否为间断点的ｆ附加ｌａｇ标识）到采样数据序列的末尾，同时根据系统中预定义的监控时间长度（如３个月）淘汰采样数据序列中过时
即ｔｔｔｑ正好为某个关键采样值所对应的时间，ｑ＝ｊ
（），则ａ１，ｎ］ｔＩｎｓｔａｎｔ操作直接将该关键采样值ｊ∈［
（作为结果返回，否则ｔｌｏｃｎｏｓｓｃｈｅｍａ，ｖａｌｕｅｐｊ，ｊ，ｊ，ｊ）
６期丁治明等：面向物联网海量传感器采样数据管理的数据库集群系统框架
１１８３
的采样数据．该操作的语法格式如下：
：ｓａｍｌｉｎＡｅｎｄｐｇｐｐ
组均隐含一个Ｓ用以表示存放该监控对ＣＰＳｅｔ属性，象原始采样数据的Ｓ为了获得ＳＣＰ的标识．ＣＰＳｅｔ属，性的值，我们定义操作Ｇ该操作的输入ｅｔＲａｗＳｉｔｅｓ输出为Ｓ为监控对象的标识ＯｂＩＤ∈ＳｔｒｉｎＣＰ的ｊｇ，
标识集合．ＧｅｔＲａｗＳｉｔｅｓ操作的语法格式如下：
：（ＧｅｔＲａｗＳｉｔｅｓＳｔｒｉｎｅｔＳｔｒｉｎ．ｇ→ｓｇ）
查询用户通过ＧｅｔＲａｗＳｉｔｅｓ操作获得相应ＳＣＰ的标识之后，可以直接与相应的Ｓ并ＣＰ进行通信，通过原始采样数据浏览接口进行相关数据的存取与访问．
４．２．４ 对传感器采样数据进行查询的例子
本节前部分定义的所有数据类型和查询操作均因此查询语言（包括实现为数据库系统的内嵌形式，
数据定义语言Ｄ是扩充ＤＬ和数据操纵语言ＤＭＬ）后的Ｓ下面给出一些查询的例子：ＱＬ语言形式．［查询Ｑ通过关键字查询获得监控对象１］
ｏｂＩＤ１的采样数据序列ｊ
（）ＳＥＬＥＣＴｋｅＳｅａｒｃｈｏｂＩＤ１．Ｓａｍｌｉｎｓ ｙｐｇｊ；ＦＲＯＭＩｏＴＤａｔａ
ＳａｍｌｉｎＳｅｕｅｎｃｅ×ＳａｍｌｉｎＶａｌｕｅ×Ｂｏｏｌ→ｐｇｑｐｇＳａｍｌｉｎＳｅｕｅｎｃｅ．ｐｇｑ
４．２．２ 针对ＳａｍｌｉｎＶａｌｕｅ数据类型的操作ｐｇ
针对ＳａｍｌｉｎＶａｌｕｅ的操作主要包括对采样ｐｇ、、值的投影操作ｖＰｒｏｅｃｔＴｉｍｅｖＰｒｏｅｃｔＰｏｉｎｔｖＰｒｏ－ｊｊｅｃｔＲｅｉｏｎ和ｖＰｒｏｅｃｔＮｅｔＰｏｓ以及数据提取操作ｊｇｊ
它们的语法格式如下：ｅｔＣｏｍｏｎｅｎｔ．ｇｐ
：；ｖＰｒｏｅｃｔＴｉｍｅＳａｍｌｉｎＶａｌｕｅ→Ｉｎｓｔａｎｔｊｐｇ：ｖＰｒｏｅｃｔＰｏｉｎｔＳａｍｌｉｎＶａｌｕｅ→Ｐｏｉｎｔｊｐｇ；针对ｌｏｃ∈Ｐｏｉｎｔ的监控对象） （
ｖＰｒｏｅｃｔＲｅｉｏｎ：ＳａｍｌｉｎＶａｌｕｅ→Ｒｅｉｏｎｊｇｐｇｇ；针对ｌｏｃ∈Ｒｅｉｏｎ的监控对象） （ｇ
：ｖＰｒｏｅｃｔＮｅｔＰｏｓＳａｍｌｉｎＶａｌｕｅ→Ｓｔｒｉｎｊｐｇｇ；：ｅｔＣｏｍｏｎｅｎｔｇｐ
ＳａｍｌｉｎＶａｌｕｅ×ｉｎｔｅｅｒ→ＳａｍｌｉｎＣｏｍｏｎｅｎｔ．ｐｇｇｐｇｐ
如果将ＳａｍｌｉｎＳｅｕｅｎｃｅ看成监控对象的状ｐｇｑ则一个Ｓ态曲线，ａｍｌｉｎＶａｌｕｅ值实际上对应于监ｐｇ、因此，控对象状态曲线中的一个点．ｖＰｒｏｅｃｔＴｉｍｅｊｖＰｒｏｅｃｔＰｏｉｎｔ和ｖＰｒｏｅｃｔＮｅｔＰｏｓ操作的结果分别ｊｊ
、／是ＩｎｓｔａｎｔＰｏｉｎｔＲｅｉｏｎ和Ｓｔｒｉｎｇｇ型的值．
由于ＳａｍｌｉｎＶａｌｕｅ型的值可以有多个分量，ｐｇ，取出采ｅｔＣｏｍｏｎｅｎｔ操作根据指定的分量序号ｉｇｐ
样值的第ｉ个分量．
４．２．３ 其它操作
为了实现ＳａｍｌｉｎＣｏｍｏｎｅｎｔ数据类型与数ｐｇｐ据库中其它数据类型的交互操作，还需要通过
［２７－２８］
“”的方式，对数据库中的各种标准查询ｌｉｆｔｉｎｇ
／、操作（如＋、和空间查询操作－、×、＝、＜、＞等）
在上述查询中，ｋｅＳｅａｒｃｈ操作返回一组元ｙ组的集合（由于ｏ因此该ｂＩＤ１只对应一个元组，ｊ，而ｋ集合中只含一个元素）ｅＳｅａｒｃｈ（ｏｂＩＤ１）．ｙｊ
”属性值．Ｓａｍｌｉｎｓ返回这些元组的“Ｓａｍｌｉｎｓｐｇｐｇ［查询Ｑ２］通过关键字查询获得所有由
“”部署的监控对象的采样数据序列ＢｅｉｉｎＴｒａｆｆｉｃｊｇ
（“”）ＳＥＬＥＣＴｋｅＳｅａｒｃｈＢｅｉｉｎＴｒａｆｆｉｃ．Ｓａｍｌｉｎｓ ｙｊｇｐｇ；ＦＲＯＭＩｏＴＤａｔａ
［］查询Ｑ通过属性约束条件实现查询Ｑ３２
