本页介绍了基于python如何连接文档数据库服务。 安装pymongo pip install pymongo 使用SSL证书连接 from pymongo import MongoClient import ssl ​ 指定文档数据库的连接URI uri "mongodb://username:password@hostname:port/databasename?ssltrue&authSourceadmin" ​ 创建SSL上下文 context ssl.createdefaultcontext(cafile"/path/to/ca.pem") context.loadcertchain("/path/to/client.pem", keyfile"/path/to/client.key") ​ 创建客户端 client MongoClient(uri, sslcertfile"/path/to/client.pem", sslkeyfile"/path/to/client.key", sslcacerts"/path/to/ca.pem", sslcertreqsssl.CERTREQUIRED, sslcontextcontext) ​ 获取数据库实例 database client["testdb"] ​ 获取集合实例 collection database["testcollection"] ​ 插入文档 document {"name": "John Doe", "age": 30, "email": "johndoe@example.com"} collection.insertone(document) ​ 查询文档 query {"name": "John Doe"} result collection.findone(query) print(result) ​ 关闭连接 client.close() 无证书连接 from pymongo import MongoClient ​ 指定数据库的连接URI uri "mongodb://username:password@hostname:port/databasename?authSourceadmin" ​ 创建客户端 client MongoClient(uri) ​ 获取数据库实例 database client["testdb"] ​ 获取集合实例 collection database["testcollection"] ​ 插入文档 document {"name": "John Doe", "age": 30, "email": "johndoe@example.com"} collection.insertone(document) ​ 查询文档 query {"name": "John Doe"} result collection.findone(query) print(result) ​ 关闭连接 client.close()

DRDS支持直接连接DBProxy执行DDL语句，本文为您介绍dbproxy支持异步执行的DDL语句。 注意 仅V5.1.20.0.13及以后版本的实例，支持使用本文介绍的DDL语句。 异步执行DDL说明 正常客户端在执行DDL时，是同步等待服务端返回。用户DDL请求转为DdlTask（UdalDdlEventVO）提交到zk，然后等待zk任务的执行状态改变（执行完成），再将zk中的任务执行结果返回给客户端。这是一种同步等待的模式，如果DDL执行久，会话一直卡住，特别是admin执行时，会一直占用线程数量。 dbproxy支持客户端在DDL SQLl前加上HINT语法，提示dbproxy以异步方式执行DDL，dbproxy在接收到异步DDL请求时，用户DDL请求转为DdlTask（UdalDdlEventVO）提交到zk后，会立刻返回客户端成功，不等待dbproxy侧DDL执行完成返回结果。 HINT语法： plaintext / !HINT({"asyncDdlMode":true, "taskId":"{合法的uuid字符串}"})/ 注意 taskId要求是个合法的UUID，dbproxy会有校验。注意 / !HINT中间有个空格。 示例如下： plaintext / !HINT({"asyncDdlMode":true, "taskId":"9aa71832a94511ef80aa080027252449"})/CREATE TABLE IF NOT EXISTS testglobal ( k int(11) NOT NULL default 0 comment 'k', v int(11) NOT NULL DEFAULT '0' comment 'v', PRIMARY KEY (k) ) ENGINEInnoDB DEFAULT CHARSETutf8 comment'test'/sharding @@table name'testglobal' set type'global' and dn'testdb1,testdb2';/; 支持异步执行的DDL语句 支持异步执行的DDL语句如下： 管理数据表的DDL语句 设置分片规则的DDL语句 管理用户和角色的DDL语句 授权和回收权限的GRANT/REVOKE语句 全局序列和全局索引的DDL语句 索引相关的DDL语句

本章节介绍DRDS全局序列的基本使用。 使用方法 全局序列通过SEQUENCENAME.nextval获取序列值，同时支持SEQUENCENAME.nextval(int)获取批量全局序列值。 示例 select语法的用法： sql select testsequence.nextval;/testsequence是全局序列名称/ select testsequence.nextval(10); //查询当前序列值 insert语法的用法： sql insert into customer (id,companyid) values (SEQTEST.nextval,SEQTEST.nextval); 的值分别为序列的当前值和序列的下一个值

DRDS支持直接连接DBProxy执行DDL语句，本文为您介绍dbproxy索引相关的DDL语句。 注意 仅V5.1.20.0.13及以后版本的实例，支持使用本文介绍的DDL语句。 索引相关DDL语句包括：create index和drop index。create index、drop index会根据分片规则的设置在标准库和对应的分片库上执行。 create index 支持的语法： plaintext CREATE [UNIQUE FULLTEXT SPATIAL] INDEX indexname ON tablename (column1 [ASCDESC], column2 [...]); 支持索引类型有普通索引、全文索引、唯一索引，对于8.0以上的RDS版本支持空间索引。 drop index 支持的语法： plaintext DROP INDEX indexname ON tablename;

本章节介绍DRDS全局序列的创建与删除。 创建全局序列 控制台方式 具体操作，请参见全局序列管理。 DDL执行 具体操作，请参见DDL语句执行。 /序列创建语句/ seqop @@addseq name'testsequence' and value'2' and increment'1000' and min'2' and max'100000' and isCycle'false'; 删除全局序列 控制台方式 具体操作，请参见全局序列管理。 DDL执行 具体操作，请参见DDL语句执行。 /序列删除语句/ seqop @@deleteseq name'testsequence';

DRDS支持直接连接DBProxy执行DDL语句，本文为您介绍删除表的DDL语句。 注意 仅V5.1.20.0.13及以后版本的实例，支持使用本文介绍的DDL语句。 语法 plaintext DROP TABLE [IF EXISTS] tblname 参数说明 tblname：待删除的数据表名称。 IF EXISTS：如果指定此选项，则当表不存在时不会报错。 注意 默认开启表回收站功能，当您执行DROP TABLE命令后，可以在表回收站中查看、恢复或者彻底删除该表，具体语法说明，请参见表回收站的DDL语句。 若您无需使用表回收站功能，则您可以在执行DROP TABLE命令前使用HINT语法关闭回收站模式，具体语法说明，请参见回收站模式删除表。 语法示例 示例1：删除单个表 plaintext DROP TABLE mytable; 示例2：如果表存在，则删除该表 plaintext DROP TABLE IF EXISTS mytable;

本文主要介绍了DRDS特有的管理命令。 为方便用户使用和维护DRDS，DRDS提供自己特有的管理命令语句。 管理命令语句一般是UDAL开头的特殊SQL语句，只能在DBProxy上执行，DRDS特有的管理命令，主要包含如下内容： 命令 详情 SHOW 介绍DRDS管理命令中的SHOW命令，可以查看服务器状态、任务信息、连接信息等。 SET 介绍DRDS管理命令中的SET命令，可以设置连接限制、日志级别、开启或关闭监控、用户密码等。 CREATE 介绍DRDS管理命令中的CREATE命令，可以管理用户和角色。 BR 介绍DRDS管理命令中的BR命令，可以备份ZooKeeper元数据。 XA 介绍DRDS管理命令中的XA命令，可以管理XA分布式事务。 DT 介绍DRDS管理命令中的DT命令，可以管理分布式事务和分布式事务锁。 CHECK 介绍DRDS管理命令中的CHECK命令，可以检查数据库和数据库表。 RECYCLEBIN 介绍DRDS管理命令中的RECYCLEBIN命令，可以查看和管理回收站中的表。 CCL 介绍DRDS管理命令中的CCL命令，即SQL限流命令，具体的命令和使用方法，请参见SQL限流章节。 DDL 介绍DRDS管理命令中的DDL命令，即DDL统一执行框架管理命令，具体的命令和使用方法，请参见DDL统一执行框架章节。 其他命令 介绍DRDS的其他管理命令，例如终止连接、切换数据源、校验序列等命令。

本文主要介绍了DRDS组件的DML语法规则。 DELETE 常用语法 DELETE FROM tblname [WHERE wherecondition] 语法限制 原则上wherecondition部分只能允许出现简单的条件，不支持计算表达式以及子查询。 INSERT 常用语法 INSERT [INTO] tblname (colname[,colname]...) {VALUESVALUE} (valuelist)[,(valuelist)]... [ON DUPLICATE KEY UPDATE assignmentlist] 语法限制 不支持不带分片键的insert语句插入。 不支持insert set使用。 不支持 INSERT DELAYED Syntax。 SELECT 暂不支持 SELECT INTO OUTFILE/INTO DUMPFILE/INTO varname。 SELECT JOIN 语法 DRDS 的 JOIN 查询可下推的 JOIN 主要分为以下几类： 单表（即非分片表）之间的 JOIN。 参与 JOIN 的表在过滤条件中均带有分片键作为条件，并且分片算法相同（即通过分片算法计算的数据分布在相同分片上）。 参与 JOIN 的表均按照分片键作为 JOIN 条件，并且分片算法相同。 全局表与分片表之间的 JOIN。 SELECT UNION 语法 使用union关键字的sql，要求其中涉及的分片表的分片规则及配置参数一致，使用union all关键字的sql则无此要求。 分片表不支持union/union all与聚合函数、limit、groupby、having、orderby等关键字联用。 不支持分片表和全局表union。 SELECT Subquery 语法 Comparisons Using Subqueries Subqueries with ANY, IN, NOT IN, SOME,ALL,Exists,NOT Exists

函数表达式 函数描述 Addition operator Assign a value (as part of a SET statement, or as part of the SET clause in an UPDATE statement) & Bitwise AND ~ Bitwise inversion ^ Bitwise XOR BINARY Cast a string to a binary string Change the sign of the argument NOT Check whether a value is not within a range of values BETWEEN … Check whether a value is not within a range of values AND … Check whether a value is not within a range of values BETWEEN … AND … Check whether a value is within a range of value STRCMP Compare two strings / Division operator Equal operator > Greater than operator > Greater than or equal operator DIV Integer division << Left shift < Less than operator < Less than or equal operator AND, && Logical AND OR Logical OR XOR Logical XOR Minus operator %, MODModulo operator Multiplication operator NOT, ! Negates value NOT REGEXP Negation of REGEXP NOT LIKE Negation of simple pattern matching !, <> Not equal operator IS NOT NULL NOT NULL value test IS NULL NULL value test <> NULLsafe equal to perator REGEXP Pattern matching using regular expressions Coalesce Return the fifirst nonNULL argument GREATEST Return the largest argument LEAST Return the smallest argument >> Right shift LIKE Simple pattern matching RLIKE Synonym for REGEXP IS NOT Test a value against a boolean IS Test a value against a boolean

Kafka实例信息准备 实例连接地址与端口 实例创建后，从Kafka实例控制台的实例详情页签中的接入点信息栏获取。若Kafka实例为集群部署，至少有3个连接地址，在客户端配置时，建议将地址都配上。 如果开启公网访问，还可以使用实例详情页签中的接入点信息栏中的公网连接地址访问Kafka实例。 Topic名称 从Kafka实例控制台的Topic管理页签中获取Topic名称。 SASL信息 如果实例创建时开启SASL访问，则需要获得SASLSSL用户名与密码、SSL证书、Kafka安全机制和SASL认证机制。 SASL用户名在Kafka实例控制台的“用户管理”页签中查看，如果忘记密码，可以点击“修改”重置密码。 SSL证书 SSL证书，在Kafka实例控制台的实例详情页中的接入点信息栏，选择希望的接入类型，点击其右侧的“查看所有IP和端口信息”，在弹窗中点击SSL接入点右侧的“下载”按钮即可获得。 使用Java语言连接实例时，需要用jks格式的证书。使用Python语言连接实例时，需要用pem格式的证书(可通过jks格式证书转换)。

Kafka实例完全兼容开源Kafka协议，可以直接使用kafka开源客户端连接。如果使用SASL认证方式，则在开源客户端基础上使用云服务提供的证书文件。 本指南主要介绍实例连接信息的收集，如获取实例连接地址、SASL连接使用的证书、公网访问信息等，然后提供Java、Python和Go等语言的连接示例。 本指南的示例仅展示Kafka的API调用，生产与消费的API集，请参考Kafka官网。

本页介绍天翼云TeleDB数据库的序列使用方法。 序列创建与访问 创建序列 plaintext teledb create sequence tseq; CREATE SEQUENCE 建立序列，不存在时才创建 plaintext teledb create sequence if not exists tseq; NOTICE: relation "tseq" already exists, skipping CREATE SEQUENCE 查看序列当前的使用状况 plaintext teledb select from tseq; lastvalue logcnt iscalled ++ 1 0 f (1 row) 获取序列的下一个值 plaintext teledb select nextval('tseq'); nextval 1 (1 row) 获取序列的当前值，这个需要在访问nextval()后才能使用 plaintext teledb select currval('tseq'); currval 1 (1 row) 设置序列当前值 plaintext teledb select setval('tseq',2); setval 2 (1 row) 序列在DML 中使用 plaintext teledb insert into tupdate values(nextval('tseq'),'teledb'); INSERT 0 1 teledb select from tupdate; id name age ++ 3 teledb (1 row) 序列作为字段的默认值使用 plaintext teledb alter table tupdate alter column id set default nextval('tseq'); ALTER TABLE teledb insert into tupdate(name) values('seqval'); INSERT 0 1 teledb select from tupdate; id name age ++ 3 teledb 4 seqval (2 rows) 序列作为字段类型使用 plaintext teledb

insert into tupdate select t,random()::text from generateseries(1,100000) as t; INSERT 0 100000 Time: 244.021 ms teledb truncate table tupdate; TRUNCATE TABLE Time: 21.953 ms 数据表使用复合类型 plaintext teledb create table tmytype (f1 int,fmytype mytype); CREATE TABLE teledb insert into tmytype values(1,row(1,'teledb')); INSERT 0 1 teledb select from tmytype; f1 fmytype + 1 (1,teledb) (1 row)

本文为您介绍使用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)

您可使用开源CloudEvents Java SDK发布事件。 前提条件 1.您已下载IntelliJ IDEA等Java研发IDE。 2.在pom.xml中加入依赖。 plaintext io.cloudevents cloudeventscore ${cloudevents.version} io.cloudevents cloudeventshttpvertx ${cloudevents.version} io.cloudevents cloudeventsapi ${cloudevents.version} io.cloudevents cloudeventsjsonjackson ${cloudevents.version} 注：cloudevents.version使用最新里程碑版本2.0.0milestone1。 发布事件 结构化示例代码如下： java import java.net.URI; import java.util.UUID; import io.cloudevents.CloudEvent; import io.cloudevents.core.builder.CloudEventBuilder; import io.cloudevents.http.vertx.VertxMessageFactory; import io.cloudevents.jackson.JsonFormat; import io.vertx.core.Vertx; import io.vertx.core.http.HttpClient; import io.vertx.core.http.HttpClientRequest; public class SampleStructuredHTTPClient { // 填写天翼云账号的aksk，确保该账号已授权事件总线的发布权限 private static String accessKeyId System.getenv("CTYUNACCESSKEYID"); private static String accessKeySecret System.getenv("CTYUNACCESSKEYSECRET"); // 在事件总线控制台获取服务接入地址 private static String endpoint " + System.getenv("CTYUNEVENTBRIDGESERVICEHOST") + "/api/v1/putEvents"; public static void main(String[] args) throws Exception { final Vertx vertx Vertx.vertx(); final HttpClient httpClient vertx.createHttpClient(); // 创建一个事件模板来设置基本的CloudEvent属性。 CloudEventBuilder eventTemplate CloudEventBuilder.v1() .withSource(URI.create(" .withType("vertx.example"); // 创建HTTP请求。 final HttpClientRequest request httpClient.postAbs(endpoint) .handler(response > { System.out.println(response.statusMessage()); }) .exceptionHandler(System.err::println); String id UUID.randomUUID() .toString(); String data "{"name":"Eventbridge","number":100}"; // 从模板中创建事件。 final CloudEvent event eventTemplate.newBuilder() .withId(id) .withData("application/json", data.getBytes()) // 确保总线已经创建 .withExtension("ctyuneventbusname", "mybus") .withSource(URI.create(" .withType("vertx.example") .withSubject("ceb:cos:huadong1:1234567:events") .build(); request.putHeader("contenttype", "application/cloudevents+json"); request.putHeader("authorization", "ceb" + ":" + accessKeyId + ":" + SignatureHelper.getSignature(SignatureHelper.getStringToSign(request), accessKeySecret) + ""); VertxMessageFactory.createWriter(request) .writeStructured(event, new JsonFormat()); } } 二进制示例代码如下： java import java.net.URI; import java.util.UUID; import io.cloudevents.CloudEvent; import io.cloudevents.core.builder.CloudEventBuilder; import io.cloudevents.http.vertx.VertxMessageFactory; import io.vertx.core.Vertx; import io.vertx.core.http.HttpClient; import io.vertx.core.http.HttpClientRequest; public class SampleBinaryHTTPClient{ // 填写天翼云账号的aksk，确保该账号已授权事件总线的发布权限 private static String accessKeyId System.getenv("CTYUNACCESSKEYID"); private static String accessKeySecret System.getenv("CTYUNACCESSKEYSECRET"); // 在事件总线控制台获取服务接入地址 private static String endpoint " + System.getenv("CTYUNEVENTBRIDGESERVICEHOST"); + "/api/v1/putEvents"; public static void main(String[] args) throws Exception { final Vertx vertx Vertx.vertx(); final HttpClient httpClient vertx.createHttpClient(); // 创建一个事件模板来设置基本的CloudEvent属性。 CloudEventBuilder eventTemplate CloudEventBuilder.v1() .withSource(URI.create(" .withType("vertx.example"); // 创建HTTP请求。 final HttpClientRequest request httpClient.postAbs(endpoint) .handler(response > { System.out.println(response.toString()); }) .exceptionHandler(e > { System.out.println(e); }); String id UUID.randomUUID() .toString(); String data "{"name":"Eventbridge","number":100}"; // 从模板中创建事件。 final CloudEvent event eventTemplate.newBuilder() .withId(id) .withData("application/json", data.getBytes()) // 确保总线已经创建 .withExtension("ctyuneventbusname", "mybus") .withSource(URI.create(" .withType("vertx.example") .withSubject("ceb:myapp:huadong1:1234567:events") .build(); request.putHeader("contenttype", "application/json"); request.putHeader("authorization", "ceb" + ":" + accessKeyId + ":" + SignatureHelper.getSignature(SignatureHelper.getStringToSign(request), accessKeySecret) + ""); VertxMessageFactory.createWriter(request) .writeBinary(event); } }

select from toids ; id name birth city +++ 1 张三 20001201 00:00:00 北京 2 李四 19970324 00:00:00 上海 3 王五 20040901 00:00:00 广州 4 陈六 20220101 00:00:00 (4 rows) teledb select count(city) from toids; count 3 (1 row) teledb select count(1) from toids; count 4 (1 row) teledb select count() from toids; count 4 (1 row) teledb select count(id) from toids; count 4 (1 row) teledb select count((id,city)) from toids; count 4 (1 row) 4. count(distinct col) 计算某列的非 NULL 不重复数量，NULL 不被计数。 count(distinct (col1，col2，...) ) 计算多列的唯一值时，NULL 会被计数，同时 NULL 与 NULL 会被认为是相同的。 plaintext teledb select count(distinct city) from toids; count 3 (1 row) teledb select count(distinct (id, city)) from toids; count 4 (1 row) 5. 两个NULL 的对比方法。 plaintext teledb select null is not distinct from null; ?column? t (1 row)

本文介绍如何在使用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

本页介绍天翼云TeleDB数据库创建一个与函数同名的存储过程的错误提示和替换方案。 如创建一个与函数同名的存储过程会提示function xxx already exists with same argument types。 plaintext teledb CREATE OR REPLACE FUNCTION proc1() RETURNS void AS $$ begin raise notice 'Hello teledbpg'; end; $$ LANGUAGE PLPGSQL; CREATE FUNCTION teledb CREATE PROCEDURE proc1() AS $$ begin raise notice 'Hello teledbpg'; end; $$ LANGUAGE PLPGSQL; ERROR: function "proc1" already exists with same argument types teledb 如果要替换，则提示。 plaintext teledb CREATE OR REPLACE PROCEDURE proc1() AS $$ begin raise notice 'Hello teledbpg'; end; $$ LANGUAGE PLPGSQL; ERROR: cannot change routine kind DETAIL: "proc1" is a function. teledb

limit x offset 1 如果参数enableoraclecompatible配置为on，则offset 1表示从第一条提取记录。 plaintext teledb select from test1; id name + 1 test1 2 test2 3 test2 4 test2 5 test2 (5 rows) teledb select from test1 limit 5 offset 1; id name + 1 test1 2 test2 3 test2 4 test2 5 test2 teledb dml 操作加强 select支持别名不用as修饰 plaintext teledb create table student(f1 int,f2 int); CREATE TABLE teledb insert into student values(1,1); INSERT 0 1 teledb select from student as st where st.f11; f1 f2 + 1 2 (1 row) teledb select from student st where st.f11; f1 f2 + 1 2 update支持别名 需要打开enableoraclecompatible plaintext teledb set enableoraclecompatible to on; SET teledb create table student(f1 int,f2 int); CREATE TABLE teledb insert into student values(1,1); INSERT 0 1 teledb update student st set st.f22 where f11; UPDATE 1 teledb select from student ; f1 f2 + 1 2 实际 teledb UPDATE student st SET st.f2 2 WHERE st.f1 1; ERROR: column "st" of relation "student" does not exist LINE 2: SET st.f2 2

本页介绍天翼云TeleDB数据库建立存储的语法。 plaintext CREATE [OR REPLACE] PROCEDURE [模式名.]存储过程 ([参数模式 [参数名] 数据类型 [default 默认值] [,…]]) AS [标签] [DECLARE 变量定义] BEGIN 注释 /注释/ 语句执行 END; [标签] LANGUAGE PLPGSQL;

大批量的生成数据 plaintext teledb truncate table teledbpg1; TRUNCATE TABLE teledb insert into teledbpg1 select t,md5(random()::text) from generateseries(1,10000) as t; INSERT 0 10000 teledb select count(1) from teledbpg1; count 10000 (1 row) 返回插入数据，轻松获取插入记录的serial值 plaintext teledb create table teledbserial(id serial, nickname varchar); CREATE TABLE teledb insert into teledbserial(nickname) values('hello teledb') returning ; id nickname + 1 hello teledb (1 row) INSERT 0 1 指定返回的字段。 teledb insert into teledbserial(nickname) values('hello teledb') returning id; id 2 (1 row) INSERT 0 1 insert..update更新 使用on conflict plaintext teledb create table tupdate(id int unique, name varchar); CREATE TABLE teledb d+ tupdate Table "public.tupdate" Column Type Collation Nullable Default Storage Stats target Description +++++++ id integer plain name character varying extended Indexes: "tupdateidkey" UNIQUE CONSTRAINT, btree (id) Distribute By: SHARD(id) Location Nodes: ALL DATANODES teledb insert into tupdate values(1,'teledb'); INSERT 0 1 teledb insert into tupdate values(1,'teledb') on conflict(id) do update set name 'hello'; INSERT 0 1 teledb select from tupdate ; id name + 1 hello (1 row)

本页介绍天翼云TeleDB数据库PL/pgsql控制结构中的判断语句。 IF...THEN...END IF plaintext teledb CREATE OR REPLACE FUNCTION f26() RETURNS VOID AS teledb $$ teledb$ BEGIN teledb$ IF random()>0.5 THEN teledb$ RAISE NOTICE '随机数大于0.5'; teledb$ END IF; teledb$ END; teledb$ $$ teledb LANGUAGE plpgsql; CREATE FUNCTION teledb select f26(); NOTICE: 随机数大于0.5 f26 (1 row) teledb IF...THEN...ELSE...END IF plaintext teledb CREATE OR REPLACE FUNCTION f26() RETURNS VOID AS teledb $$ teledb$ BEGIN teledb$ IF random()>0.99 THEN teledb$ RAISE NOTICE '随机数大于0.99'; teledb$ ELSE teledb$ RAISE NOTICE '随机数小于或等于0.99'; teledb$ END IF; teledb$ END; teledb$ $$ teledb LANGUAGE plpgsql; CREATE FUNCTION teledb select f26(); NOTICE: 随机数小于或等于0.99 f26 (1 row) teledb IF...THEN...ELSIF...THEN...ELSE...END IF plaintext teledb CREATE OR REPLACE FUNCTION f26() RETURNS VOID AS teledb $$ teledb$ DECLARE teledb$ vfloat8 float8 : random(); teledb$ BEGIN teledb$ IF vfloat8>0.99 THEN teledb$ RAISE NOTICE '随机数大于0.99'; teledb$ ELSIF vfloat8>0.5 THEN teledb$ RAISE NOTICE '随机数大于0.50'; teledb$

本文为您介绍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)

本页介绍天翼云TeleDB数据库PL/pgsql函数的参数引用方法。 PL/pgsql函数的参数是以$1,$2这样标识符来进行传递，也支持命名参数，所以参数的定义可以用下面的方式。 无命名参数 plaintext teledb CREATE OR REPLACE FUNCTION f2(text) RETURNS TEXT AS teledb $$ teledb$ BEGIN teledb$ RETURN $1; teledb$ END; teledb$ $$ teledb LANGUAGE PLPGSQL; CREATE FUNCTION teledb SELECT FROM f2('teledb'); f2 teledb (1 row) 给标识符指定别名 plaintext teledb CREATE OR REPLACE FUNCTION f2(text) RETURNS TEXT AS teledb $$ teledb$ DECLARE teledb$ axm ALIAS FOR $1; axm是$1的别名 teledb$ BEGIN teledb$ RETURN axm; teledb$ END; teledb$ $$ teledb LANGUAGE PLPGSQL teledb ; CREATE FUNCTION teledb SELECT FROM f2('teledb'); f2 teledb (1 row) 命名参数 plaintext teledb CREATE OR REPLACE FUNCTION f2(axm text) RETURNS TEXT AS teledb $$ teledb$ DECLARE teledb$ vxm ALIAS FOR $1; teledb$ BEGIN teledb$ RAISE NOTICE 'axm % ; vxm % ; $1 %',axm,vxm,$1; teledb$ RETURN $1; teledb$ END; teledb$ $$ teledb LANGUAGE PLPGSQL; CREATE FUNCTION teledb SELECT FROM f2('teledb'); NOTICE: axm teledb ; vxm teledb ; $1 teledb f2 teledb (1 row)

本文为您介绍如何创建模式。 模式本质上是一个名字空间，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