本章节主要介绍如何创建自定义拓扑集群。 MRS当前提供的“分析集群”、“流式集群”和“混合集群”采用固定模板进行部署集群的进程，无法满足用户自定义部署管理角色和控制角色在集群节点中的需求。如需自定义集群部署方式，可在创建集群时的“集群类型”选择“自定义”，实现用户自主定义集群的进程实例在集群节点中的部署方式。仅MRS 3.x及之后版本支持创建自定义拓扑集群。 自定义集群可实现以下功能： 管控分离部署，管理角色和控制角色分别部署在不同的Master节点中。 管控合设部署，管理角色和控制角色共同部署在Master节点中。 ZooKeeper单独节点部署，增加可靠性。 组件分开部署，避免资源争抢。 MRS集群中角色类型： 管理角色：Management Node(MN)，安装Manager，即MRS集群的管理系统，提供统一的访问入口。Manager对部署在集群中的节点及服务进行集中管理。 控制角色：Control Node(CN)，控制监控数据角色执行存储数据、接收数据、发送进程状态及完成控制节点的公共功能。 MRS的控制节点包括HMaster、HiveServer、ResourceManager、NameNode、JournalNode、SlapdServer等。 数据角色：Data Node(DN)，执行管理角色发出的指示，上报任务状态、存储数据，以及执行数据节点的公共功能。MRS的数据节点包括DataNode、RegionServer、NodeManager等。 创建自定义集群 1.登录MRS管理控制台。 2.单击“创建集群”，进入“创建集群”页面。 3.在创建集群页面，选择“自定义创建”页签。 4.参考下列参数说明配置集群软件信息，参数详细信息请参考创建自定义集群章节中的MRS集群软件配置表。 区域：默认即可。 集群名称：可以设置为系统默认名称，但为了区分和记忆，建议带上项目拼音缩写或者日期等。例如：“mrs20180321”。 集群版本：目前仅MRS 3.x版本支持。 集群类型：选择“自定义”并根据需要勾选对应组件。 5.单击“下一步”，并配置硬件信息。 可用区：默认即可。 虚拟私有云：默认即可。如果没有虚拟私有云，请单击“查看虚拟私有云”进入虚拟私有云，创建一个新的虚拟私有云。 子网：默认即可。 安全组：选择“自动创建”。 弹性公网IP：选择“暂不绑定”。 CPU架构：默认即可。MRS 3.x版本无该参数。 常用模板：具体说明请参见下方“自定义集群模板说明”。 实例规格：单击配置实例规格、系统盘和数据盘存储类型和存储空间。 实例数量：请根据业务量调整集群实例数量。具体可参考下方“MRS自定义集群节点部署方案”。 拓扑调整：若常用模板中的部署方式不满足需求或者需要手动安装部分默认安装不部署的实例或者需要手动安装部分实例时，请设置“拓扑调整”为“开启”，然后根据业务需要调整实例部署方式，具体说明请参见下方“自定义集群拓扑调整说明”。 6.单击“下一步”进入高级配置页签。 参数说明请参见创建自定义集群章节中的“高级配置（可选）”。 7.单击“立即创建”。 当集群开启Kerberos认证时，需要确认是否需要开启Kerberos认证，若确认开启请单击“继续”，若无需开启Kerberos认证请单击“返回”关闭Kerberos认证后再创建集群。 8.单击“返回集群列表”，可以查看到集群创建的状态。 集群创建需要时间，所创集群的初始状态为“启动中”，创建成功后状态更新为“运行中”，请您耐心等待。

本章节主要介绍如何配置Ranger数据连接。 本指导旨在指导用户将现有集群的Ranger元数据切换为RDS数据库中存储的元数据。该操作可以使多个MRS集群共用同一份元数据，且元数据不随集群的删除而删除。也能够避免集群迁移时Ranger元数据的迁移。 前置条件 已创建RDS服务MySQL数据库的实例，请参考 管理数据连接章节配置数据连接 中的 创建数据连接。 说明 对于MRS 3.x之前版本，当用户选择的数据连接为“RDS服务MySQL数据库”时，请确保使用的数据库用户为root用户。如果为非root用户，请参考 管理数据连接章节[配置数据连接]（ ） 中的 数据连接前置操作，新建用户并为该用户进行赋权。 对于MRS 3.x及之后版本，当用户选择的数据连接为“RDS服务MySQL数据库”时，数据库用户不允许为root用户，请参考 管理数据连接章节[配置数据连接]（ ）中的 数据连接前置操作，新建用户并为该用户进行赋权。 Ranger元数据外置到Mysql前置操作 该前置操作仅在MRS 3.1.0及之后版本需要执行。 1.登录FusionInsight Manager页面，具体请参见访问FusionInsight Manager（MRS 3.x及之后版本）。选择“集群 > 服务 > 服务名称 ”。 当前MRS 3.1.x集群支持Ranger鉴权的组件为: HDFS、HBase、Hive、Spark、Impala、Storm、Kafka组件。 2.在服务“概览”页面右上角单击“更多 > 停用Ranger鉴权”，如果“停用Ranger鉴权”是灰色，则表示未开启Ranger鉴权无需停用Ranger鉴权，如下图所示。 3.（可选）如需使用已有鉴权策略请执行该步骤在Ranger Web页面导出已有组件的鉴权策略，切换Ranger元数据完成后可重新导入已有的鉴权策略。此处以Hive为例，导出后会生成本地的json格式的策略文件。 a.登录FusionInsight Manager页面。 b.选择“集群 > 服务 > Ranger”，进入Ranger服务概览页面。 c.单击“基本信息”区域中的“RangerAdmin”，进入Ranger WebUI界面。 admin用户在Ranger中的用户类型为“User”，如需查看所有管理页面，可点击右上角用户名后，选择“Log Out”，退出当前用户。 d.使用rangeradmin用户（默认密码为Rangeradmin@123）或者其他具有Ranger管理员权限用户重新登录。 e.单击Hive组件对应行的导出按钮，导出鉴权策略。 详见下图：导出鉴权策略 f.单击“Export”，导出后会生成本地的json格式的策略文件。 详见下图： 导出Hive鉴权策略

本章节主要介绍如何快速创建Hadoop分析集群。 本章节为您介绍如何快速创建一个Hadoop分析集群，Hadoop完全使用开源Hadoop生态，采用YARN管理集群资源，提供Hive、Spark离线大规模分布式数据存储和计算，SparkStreaming、Flink流式数据计算，Presto交互式查询，Tez有向无环图的分布式计算框架等Hadoop生态圈的组件，进行海量数据分析与查询。 快速创建Hadoop分析集群 1.登录MRS管理控制台。 2.单击“创建集群”，进入“创建集群”页面。 3.在创建集群页面，选择“快速创建”页签。 4.参考下列参数说明配置集群基本信息，参数详细信息请参考创建自定义集群。 区域：默认即可。 集群名称：可以设置为系统默认名称，但为了区分和记忆，建议带上项目拼音缩写或者日期等。例如：“mrs20180321”。 版本类型：默认选择普通版（不同版本提供的组件有所不同，请根据需要选择版本类型）。 集群版本：默认选择最新版本即可（不同版本集群提供的组件有所不同，请根据需要选择集群版本）。 组件选择：选择“Hadoop分析集群”。 可用区：默认即可。 虚拟私有云：默认即可。如果没有虚拟私有云，请单击“查看虚拟私有云”进入虚拟私有云，创建一个新的虚拟私有云。 子网：默认即可。 CPU架构：默认即可。 集群节点：请根据自身需要选择集群节点规格数量等。MRS 3.x及之后版本集群Master节点规格不能小于64GB。 集群高可用：默认即可。MRS 3.x版本暂时不支持该参数。 用户名：默认为“root/admin”，root用于远程登录ECS机器，admin用于登录集群管理页面。 密码：设置root用户和admin用户密码。 确认密码：再次输入设置的root用户和admin用户密码。 5.勾选“确认授权”开通通信安全授权，通信安全授权详情请参考授权安全通信。 6.单击“立即申请”。 当集群开启Kerberos认证时，需要确认是否需要开启Kerberos认证，若确认开启请单击“继续”，若无需开启Kerberos认证请单击“返回”关闭Kerberos认证后再创建集群。 7.单击“返回集群列表”，可以查看到集群创建的状态。单击“访问集群”，可以查看集群详情。 集群创建的状态过程请参见 集群概览章节查看集群状态部分 集群列表参数中的“状态”参数说明。 集群创建需要时间，所创集群的初始状态为“启动中”，创建成功后状态更新为“运行中”，请您耐心等待。 MRS系统界面支持同一时间并发创建10个集群，且最多支持管理100个集群。

策略类别 IAM策略 同步后用户在MRS对应默认权限 是否有权限执行同步操作 是否有权限提交作业 细粒度 MRS ReadOnlyAccess Managerviewer 否 否 细粒度 MRS CommonOperations lManagerviewer default launcherjob 否 是 细粒度 MRS FullAccess Manageradministrator Managerauditor Manageroperator Managertenant Managerviewer Systemadministrator default launcherjob 是 是 RBAC MRS Administrator Manageradministrator Managerauditor Manageroperator Managertenant Managerviewer Systemadministrator default launcherjob 否 是 RBAC Server Administrator、Tenant Guest和MRS Administrator Manageradministrator Managerauditor Manageroperator Managertenant Managerviewer Systemadministrator default launcherjob 是 是 RBAC Tenant Administrator Manageradministrator Managerauditor Manageroperator Managertenant Managerviewer Systemadministrator default launcherjob 是 是 自定义 Custom policy（自定义策略） Managerviewer default launcherjob 自定义策略以RBAC策略为模板则参考RBAC策略。 自定义策略以细粒度策略为模板则参考细粒度策略，建议使用细粒度策略。 是

本章节主要介绍如何创建MRS操作用户。 如果您需要对您所拥有的MapReduce服务（MapReduce Service）进行精细的权限管理，您可以使用统一身份认证服务（Identity and Access Management，简称IAM），通过IAM，您可以： 根据企业的业务组织，在您的云帐号中，给企业中不同职能部门的员工创建IAM用户，让员工拥有唯一安全凭证，并使用MRS资源。 根据企业用户的职能，设置不同的访问权限，以达到用户之间的权限隔离。 将MRS资源委托给更专业、高效的其他云帐号或者云服务，这些帐号或者云服务可以根据权限进行代运维。 如果云帐号已经能满足您的要求，不需要创建独立的IAM用户，您可以跳过本章节，不影响您使用MRS服务的其它功能。 本章节为您介绍对用户授权的方法，操作流程如下图所示。 前提条件 给用户组授权之前，请您了解用户组可以添加的MRS权限，并结合实际需求进行选择。 示例流程 详见下图： 给用户授权MRS权限流程 1.创建用户组并授权 在IAM控制台创建用户组，并授予MRS服务对应权限。 2.创建用户并加入用户组 在IAM控制台创建用户，并将其加入上述创建用户组并授权中创建的用户组。 3.用户登录并验证权限 新创建的用户登录控制台，切换至授权区域，验证权限： −在“服务列表”中选择MRS服务，进入MRS主界面，单击右上角“创建集群”，尝试创建MRS集群，如果无法创建MRS集群（假设当前权限仅包含MRS ReadOnlyAccess），表示“MRS ReadOnlyAccess”已生效。 −在“服务列表”中选择除MRS服务外（假设当前策略仅包含MRS ReadOnlyAccess）的任一服务，若提示权限不足，表示“MRS ReadOnlyAccess”已生效。

平台提供了多个进入打开表页面的入口，包括： 查询窗口主界面，表Tab页右键单击表名称选择打开表进入。 选择数据资产 > 元数据管理 > 库列表 > 对象列表 ，在操作 列单击打开按钮进入。

本文为您介绍使用SELECT语法查询记录所在的DN。 plaintext teledb select xcnodeid, from teledbpg1; xcnodeid id nickname ++ 1085152094 5 test 1085152094 6 teledb, teledb1 506537247 3 pg (3 rows) teledb select t1.xcnodeid, pgxcnode.nodename, t1. from teledbpg1 t1, pgxcnode where t1.xcnodeid pgxcnode.nodeid; xcnodeid nodename id nickname +++ 1085152094 dn01 5 test 1085152094 dn01 6 teledb, teledb1 506537247 dn02 3 pg (3 rows)

本文介绍如何在使用SELECT语法时添加all条件。 需要大于所有值才为真。 plaintext teledb select from teledbpg where id > all (select 1 union select 3); id nickname + 4 (1 row)

select from tnew; f1 f2new f3 ++ 1 20230822 11:06:16.9783 1 3 20230822 11:06:16.9783 100 2 20230822 11:06:16.9783 50 2 20230822 11:06:16.9783 110 5 20230822 11:16:06.712109 10 (5 rows) teledb select from trangemv; f1 f2new + 1 20230822 3 20230822 2 20230822 2 20230822 (4 rows) teledb REFRESH MATERIALIZED VIEW trangemv; REFRESH MATERIALIZED VIEW teledb select from trangemv; f1 f2new + 1 20230822 2 20230822 2 20230822 5 20230822 3 20230822 (5 rows) 注意 物化视图数据存储在CN节点上面，每个CN节点各有一份相同的数据。 plaintext teledb explain select from trangemv; QUERY PLAN Seq Scan on trangemv (cost0.00..22.70 rows1270 width12) (1 row)

本文介绍如何在使用SELECT语法时，返回两个结果的差集。 plaintext teledb select from teledbpg except select from teledbpg1; id nickname + 2 TELEDB 4 1 teledb 1 hello,pgxc (4 rows)

本文介绍如何在使用SELECT语法时添加any条件。 只需要大于其中一个值即为真。 plaintext teledb select from teledbpg where id > any (select 1 union select 3); id nickname + 3 pg 4 2 TELEDB (3 rows)

本文为您介绍如何删除索引。 plaintext teledb drop index tmulidxidx; DROP INDEX

truncate功能用于对表数据进行快速清除，truncate 属于ddl级别，会给truncate表加上 ACCESS EXCLUSIVE 最高级别的锁。本文为您介绍具体的使用方法。 truncate 普通表 使用语法：truncate table xx yy zz； 具体例子如下所示： plaintext teledb truncate table teledbpg1; TRUNCATE TABLE 也可以一次truncate 多个数据表。 plaintext teledb truncate table tupdate, teledbserial; TRUNCATE TABLE truncate 分区表 不允许truncate主表 plaintext teledb truncate table trange; ERROR: trancate a partitioned table is forbidden, trancate a partition is allowed 使用语法：truncate xx partition for(x)，具体例子如下所示： truncate 一个时间分区表。 plaintext teledb d+ ttimerange Table "public.ttimerange" Column Type Collation Nullable Default Storage Stats target Description +++++++ f1 bigint plain f2 timestamp without time zone plain f3 bigint plain Distribute By: SHARD(f1) Location Nodes: ALL DATANODES Partition By: RANGE(f2) Of Partitions: 12 Start With: 20170901 Interval Of Partition: 1 MONTH teledb select from ttimerange; f1 f2 f3 ++ 1 20170901 00:00:00 100 1 20171001 00:00:00 100 1 20171101 00:00:00 100 (3 rows) teledb

当安装包与系统版本不匹配导致安装失败时，您可以参考本文，查看问题现象、原因和解决方案。 问题现象 安装dcp控制体出现安装报错，执行删除冲突的安装包，但删除不了。 原因分析 安装包与操作系统版本不一致，操作系统版本过高导致的。 解决方案 升级安装包，使其匹配操作系统版本。

本文为您介绍SELECT语法的特殊应用场景，例如多行变成单行和一列变成多行。 多行变成单行 plaintext teledb select arraytostring(array(select nickname from teledbpg1),','); arraytostring test,pg (1 row) 一列变成多行 plaintext teledb insert into teledbpg1 values(6, 'teledb, teledb1'); INSERT 0 1 teledb select regexpsplittotable((select nickname from teledbpg1 where id6 limit 1), ','); regexpsplittotable teledb teledb1 (2 rows)

本文为您介绍实例主机手动创建了teledbx用户导致开通实例失败的问题原因和解决方案。 问题现象 创建实例开通失败。 原因分析 经过查看错误日志，发现其手动创建teledbx用户。由于在开通创建实例时，系统会自动创建teledbx用户，无需手动创建。 解决方案 1. 执行如下命令删除实例主机teledbx用户。 plaintext userdel teledbx 2. 在管控台中选择实例管理 > 工单管理 ，单击所创建实例行所在的操作列的重新施工即可。

该任务用于指导用户如何给实例授权。 操作场景 由于目前PaaS平台和组件控制台的数据权限未统一，可能会出现两边查询的实例列表情况不一致的情况，基于此目的新增了数据权限查询接口。 操作步骤 1. 进入控制台，在左侧导航树选择我的租户 > 数据权限管理 ，进入数据权限授权页面。 2. 单击按角色 页签，勾选实例授权给相应用户。 3. 授权后，该用户可以查看该实例信息。 4. 取消授权，用户无法查看该实例信息。

该任务用于指导用户开通实例。 本文档用于指导如何在非独立部署(依赖统一PaaS平台)的环境上开通TelePG实例。 前提条件 已部署好telepg后端控制台。 已部署好telepg前端。 已在统一PaaS平台上配置了Postgresql数据库应用的资源池版本。 操作步骤 1. 使用系统管理员登录到统一PaaS平台。 2. 单击管控面板 ，在左侧导航树上选择系统管理与审批 > 系统配置 > 组件应用管理 ，进入组件应用管理页面。 3. 在搜索框中搜索postgresql ，单击更多 > 资源板池， 在对应资源池上配置telepg的后端服务访问地址。 4. 统一PaaS平台上存在租户、租户管理员(租户拥有者)。 1. 租户管理员：使用系统管理员登录到统一PaaS平台，选择管理面板 > 租户管理 > 账号管理 ，新建账号。 2. 租户：使用系统管理员登录到统一PaaS平台，选择管理面板 > 租户管理 > 租户管理 ，新建租户，设置上面创建的用户为租户拥有者。 5. 对应租户对应资源池上已配置了可用的主机，且配置的主机的系统ssh账号有sudo权限。 如果使用非物理机模式开通组件，则可以忽略此步骤。 新增主机：使用租户管理员(租户拥有者)登录到统一PaaS平台，单击管理面板 ，选择我的资源 > 我的主机 ，单击新增 ，新增主机。 6. 对应租户对应资源池上已配置了虚拟ip。 7. 如果使用非物理机模块开通组件，则可以忽略此步骤(2) 如果没有配置虚ip，使用物理机开通时，只能开通基础版的pg实例，无法开通高可用版(一主一从)。 新增虚拟ip：使用租户管理员(租户拥有者)登录到统一PaaS平台，单击管理面板 ，选择我的资源 > 虚IP资源管理 ，单击新增 ，新增虚拟ip。 8. 对应资源池内的Postgresql组件已上架。 使用系统管理员登录到paas平台，单击管理面板 ，选择资源池管理> 池内组件上架 ，单击上架 ，上架待开通的telepg实例。 9. 开通实例 1. 使用租户管理员(租户拥有者) 登录到统一PaaS平台，单击控制台。 2. 在PaaS平台上，选择组件产品 > RDSPostgresql版。 3. 在Postgresql数据库开通页面上，选择资源池、网络、版本、系列、实例规格，录入实例名称和实例的root用户密码、以及磁盘大小，开启高级设置，单击检测 。(1) 开通时的版本是根据postgresql的后端资源池版本确定的。这里只会显示一个小于等于后端资源池版本的最新的版本 (2) 不开启高级设置，则使用新建虚机的方式开通实例 (3) 如果不手工选择主机，则检测成功后，会自动分配主机，如果分配的主机不是用户想要的，则可以重新选择主机。 4. 单击订购 ，弹出订购预览对话框，查看相关的产品和部署信息。 5. 单击确认，提示提交成功，会生成一个开通的订单。 6. 查看订单详情。 1. 单击管理面板，选择订单中心> 我的订单 ，查看生成的订单。若订单处理失败，则可以单击订单上的更多 > 作废，作废此订单，释放响应端口。 2. 单击订单详情，可查看订单详情。 3. 单击订单流程，可查看订单的各个流程。 7. 查看工单详情 1. 单击管理面板 ，选择订单中心> 我的订单，可查看已开通生成的订单。 2. 进入我的工单页面，单击工单ID，可查看工单详情，包含参数信息、施工过程和施工流程。 3. 若开通失败时，可单击查看流程，查看具体的报错信息。 4. 若开通失败，可单击更多 > 重新施工 。 paas平台施工时默认会进行3次重试，若3次都重试失败，才会将工单的施工结果标注为失败。 8. 查看开通的实例 1. 选择管理面板 ，单击我的云服务 > 我的组件，即可查看已开通的实例信息。 2. 单击控制台，可跳转至TelePG控制台。

该任务用于指导软件工程师安装部署PG控制台。 该任务用于指导软件工程师安装部署PG控制台。 操作步骤 上传组件模块程序包。 将获取PG二进制程序包(teledbx1.1.08k.x8664.tar.gz telepgconsole1.5.9.zip)程序包(直接使用下载后的程序包，不要修改程序包名)拷贝至已部署后端服务的主机的目录，如/app/pg/localpackage。

本文为您介绍如何创建模式。 模式本质上是一个名字空间，Oracle里一般叫用户，SQL Server中叫框架，MySQL 中叫数据库，模式里面包含表、数据类型、函数以及操作符，对象名称可以与在其他模式中存在的对象重名，访问某个模式中的对象时可以使用模式名.对象名 。 您可参考如下操作创建模式。 标准语法 plaintext teledb create schema teledbschema; CREATE SCHEMA 扩展语法，不存在时才创建 plaintext teledb create schema if not exists teledbschema; NOTICE: schema "teledbschema" already exists, skipping CREATE SCHEMA 指定所属用户 plaintext teledb create schema teledbschemaowner AUTHORIZATION teledbuser; CREATE SCHEMA teledb dn teledbschemaowner List of schemas Name Owner + teledbschemaowner teledbuser (1 row)

项目 备注 encoding 编码 lccollate 排序规则 lcctype 分组规则

本文为您介绍如何指定模式创建表。 plaintext teledb create table public.t1(id int,mc text); CREATE TABLE

本文为您介绍如何通过SELECT语法访问函数。 plaintext teledb select md5(random()::text); md5 ed5b356234979a63efc6c4f6537c4853 (1 row)

您可以参考本文，配置用户访问模式权限。 普通用户对于某个模式下的对象访问除了访问对象要授权外，模式也需要授权。 plaintext [teledb@localhost bin]$ ./telesql p 11111 U teledb d teledb Password for user teledb: telesql (TeleDB V6) Type "help" for help. 创建shema teledb create schema test; CREATE SCHEMA 创建表 teledb create table test.t1(id int); CREATE TABLE 创建用户user1 teledb create role user1 with login password 'User@184'; CREATE ROLE 授权表访问权限给用户user1 teledb grant select on test.t1 to user1; GRANT 切换到普通用户user1，尝试访问test.t1表，由于没有授权test模式，仍然无法访问 plaintext teledb c user1 Password for user user1: You are now connected to database "teledb" as user "user1". teledb> select from test.t1; ERROR: permission denied for schema test LINE 1: select from test.t1; ^ 切换到teledb用户，将test模式的访问权限授权给user1，重新用user1访问t1表 plaintext teledb> c teledb Password for user teledb: You are now connected to database "teledb" as user "teledb". 授权schema teledb grant usage on schema test to user1; GRANT teledb c user1 Password for user user1: You are now connected to database "teledb" as user "user1". teledb> select from test.t1; id (0 rows)

本文为您介绍如何修改模式属性。 修改模式名 plaintext teledb alter schema teledbschema rename to teledbschemanew; ALTER SCHEMA 修改所有者 plaintext teledb dn teledbschemanew List of schemas Name Owner + teledbschemanew teledb (1 row) teledb alter schema teledbschemanew owner to teledbuser; ALTER SCHEMA teledb dn teledbschemanew List of schemas Name Owner + teledbschemanew teledbuser (1 row)

本文为您介绍如何管理普通索引。 plaintext teledb create index tididx on t1 using btree(id); CREATE INDEX

当安装包与系统版本不匹配导致安装失败时，您可以参考本文，查看问题现象、原因和解决方案。 问题现象 安装dcp控制体出现安装报错，执行删除冲突的安装包，但删除不了。 原因分析 安装包与操作系统版本不一致，操作系统版本过高导致的。 解决方案 升级安装包，使其匹配操作系统版本。

本文为您介绍json应用的相关操作。 创建json 类型字段表 plaintext teledb create table tjson(id int,fjson json); CREATE TABLE 插入数据 plaintext teledb insert into tjson values(1,'{"col1":1,"col2":"teledb"}'); INSERT 0 1 teledb insert into tjson values(2,'{"col1":1,"col2":"teledb","col3":"pgxz"}'); INSERT 0 1 teledb select from tjson; id fjson + 1 {"col1":1,"col2":"teledb"} 2 {"col1":1,"col2":"teledb","col3":"pgxz"} (2 rows) 通过键获得json对象域 plaintext teledb select fjson >'col2' as col2 ,fjson > 'col3' as col3 from tjson; col2 col3 + "teledb" "teledb" "pgxz" (2 rows) 以文本形式获取对象值 plaintext teledb select fjson >>'col2' as col2 ,fjson >> 'col3' as col3 from tjson; col2 col3 + teledb teledb pgxz (2 rows) teledb select fjson >>'col2' as col2 ,fjson >> 'col3' as col3 from tjson where fjson >> 'col3' is not null; col2 col3 + teledb pgxz (1 row)

本文介绍使用SELECT语法时，not in中包含了null，结果全为真的场景。 plaintext teledb select from teledbpg where id not in (1,3); id nickname + 2 TELEDB 4 (2 rows) teledb select from teledbpg where id not in (1,3,null); id nickname + (0 rows)

本文为您介绍合并多个查询结果的方法。 不过滤重复的记录。 plaintext teledb create table teledbpg1(id int, nickname varchar); CREATE TABLE teledb insert into teledbpg1 values(3, 'pg'),(5,'test'); COPY 2 teledb select from teledbpg union all select from teledbpg1; id nickname + 1 teledb 1 hello,pgxc 2 TELEDB 3 pg 4 5 test 3 pg (7 rows) 过滤重复的记录。 plaintext teledb select from teledbpg union select from teledbpg1; id nickname + 1 teledb 1 hello,pgxc 4 5 test 2 TELEDB 3 pg (6 rows) 每个子查询分布在合并结果中的使用。 plaintext teledb select from (select from teledbpg limit 2) as t union all select from (select from teledbpg1 limit 2) teledb ; id nickname + 1 teledb 1 hello,pgxc 5 test 3 pg (4 rows)

本文为您介绍如何在使用SELECT语法时进行分页查询。 默认从第一条开始，返回一条记录。 plaintext teledb select from teledbpg limit 1; id nickname + 1 teledb (1 row) 使用offset指定从第几条开始，0表示第一条开始，返回1条记录。 plaintext teledb select from teledbpg limit 1 offset 0; id nickname + 1 teledb (1 row) 从第3条开始，返回二条记录。 plaintext teledb select from teledbpg limit 2 offset 2; id nickname + 2 TELEDB 3 pg (2 rows) 上面的语句没有使用排序，返回结果不可预知，使用order by 可以获得一个有序的结果。 plaintext teledb select from teledbpg order by nickname; id nickname + 1 hello,pgxc 3 pg 1 teledb 2 TELEDB 4 (5 rows) teledb select from teledbpg order by nickname limit 2 offset 2; id nickname + 1 teledb 2 TELEDB (2 rows)

本文为您介绍如何在使用SELECT语法时进行排序。 按某一列排序 plaintext teledb create table teledbpg(id int, nickname text); CREATE TABLE teledb insert into teledbpg values(1,'teledb'),(3,'pg'),(1,'hello,pgxc'); COPY 3 teledb select from teledbpg order by nickname; id nickname + 1 hello,pgxc 3 pg 1 teledb (3 rows) 按第一列排序 plaintext teledb select from teledbpg order by 1; id nickname + 1 teledb 1 hello,pgxc 3 pg 按ID 升级排序，再按 nickname 降序排序 plaintext teledb select from teledbpg order by id,nickname desc; id nickname + 1 teledb 1 hello,pgxc 3 pg (3 rows) 效果与上面的语句一样 plaintext teledb select from teledbpg order by 1,2 desc; id nickname + 1 teledb 1 hello,pgxc 3 pg (3 rows) 随机排序 plaintext teledb select from teledbpg order by random(); id nickname + 1 teledb 3 pg 1 hello,pgxc (3 rows) teledb select from teledbpg order by random(); id nickname + 1 hello,pgxc 1 teledb 3 pg (3 rows) 计算排序 plaintext teledb