基于Python的应用开发
sql_create_table="create table if not exists test_python(c1 integer,c2 integer,primary key(c1))"print(sql_create_table)statement.execute(sql_create_table)完整示例 完整示例代码如下：#!usr/bin/python#-*-coding:UTF-8-*-import...
执行MaxCompute SQL语句
无 'seahawks' sql 需要执行的MaxCompute SQL（建议只执行DDL语句）：create table alter table desc table drop table SQL语句需要符合MaxCompute的语法，建议只执行DDL语句。如果SQL中有单引号，需要在SQL语句前后添加双美元符号（$SQL$...
JSON和JSONB类型
JSON和JSONB介绍 近年来随着移动端应用的普及，应用埋点、用户标签计算等场景开始诞生，为了更好的支撑这类场景，越来越多的大数据系统开始使用半结构化格式来存储此类数据，以获得更加灵活的开发和处理。常用的半结构化类型为JSON和JSONB...
JDBC数据源
即映射关系如下：SelectDB PostgreSQL Catalog Database Database Schema Table Table 说明 SelectDB通过SQL语句 SELECT nspname FROM pg_namespace WHERE has_schema_privilege('<UserName>',nspname,'USAGE');来获得PG user能够访问的...
SQL查询
使用SQL查询时，系统会根据SQL语句自动选择合适的方式来加速SQL访问。SQL查询功能适用于在海量数据中进行在线数据访问类型的场景，SQL访问的延时从毫秒、秒到分钟级别不等，包括基于数据表主键的Point Query（GetRow操作）、多元索引的精确...
使用SQL查询数据时如何选择查询方式
使用SQL查询数据时，您可以通过表的映射关系或者多元索引的映射关系进行数据查询，请根据实际场景选择合适的查询方式。背景信息 表格存储作为结构化大数据存储，支持不同的索引结构，便于在不同场景的查询分析加速使用。索引结构包括通过...
DM（达梦）数据源
否 无 postSql 执行数据同步任务之后执行的SQL语句，目前只允许执行一条SQL语句，例如加上某一个时间戳。说明 当有多条SQL语句时，不支持事务。否 无 batchSize 一次性批量提交的记录数大小，该值可以极大减少数据集成与DM（达梦）的网络...
表批读写
与不指定路径的内部表不同，当您使用DROP表时，不会删除外部表的文件 如果运行CREATE TABLE的位置已经包含使用Delta Lake存储的数据，Delta Lake将执行以下操作：如果只指定表名和位置，例如：SQL%sql CREATE TABLE events USING DELTA ...
ListSQLReviewOriginSQL-获取SQL审核工单的SQL详情
SQLId long SQL 语句 ID。1111 FileId long 文件 ID。858*FileName string 文件名。test.sql SQLContent string 文件中的 SQL 内容。CREATE TABLE `test_sql_review_table`(`id` bigint(20)unsigned NOT NULL AUTO_INCREMENT,`gmt_create` ...
基于C API的应用开发
}/创建表 char create_table[]="create table if not exists user_test(id int,name varchar,age int,primary key(id))";res=mysql_query(&conn,create_table);if!res){ printf("create table successfully");} else { printf("create ...
Doris数据源
DataWorks数据集成支持使用Doris Writer导入表数据至Doris。本文为您介绍DataWorks的Doris数据同步能力支持情况。支持的Doris版本 Doris Writer使用的驱动版本是MySQL Driver 5.1.47，该驱动支持的内核版本如下。驱动能力详情请参见 Doris...
CREATE TABLE AS
Hologres从V1.3.21版本开始，支持使用CREATE TABLE AS语句创建表，复制表结构的同时也可以选择复制数据。本文为您介绍在Hologres中CREATE TABLE AS的用法。背景信息 CREATE TABLE AS的功能为：创建一个与源表结构或者查询Query结果相同的新...
创建schema
在 CREATE SCHEMA 中，CREATE TABLE、CREATE VIEW 和 GRANT 都可以作为子句来使用。在模式创建完后，可以使用单独的命令创建其他类型的对象。描述 这是 CREATE SCHEMA 命令的一种用法，用于创建一个新的模式，由命令中参数 username 所指的...
批计算
通过在E-MapReduce集群中使用Spark2访问表格存储。对于批计算，Tablestore on Spark提供索引选择、分区裁剪、Projection列和Filter下推、动态指定分区大小等功能，利用表格存储的全局二级索引或者多元索引可以加速查询。前提条件 已创建E-...
SQL Server数据源
当配置此项后，数据同步系统就会忽略tables、columns配置项，直接使用这项配置的内容对数据进行筛选，例如需要进行多表join后同步数据，使用 select a,b from table_a join table_b on table_a.id=table_b.id。当您配置querySql时，SQL ...
Amazon Redshift数据源
writeMode":"insert","batchSize":2048,"column":["id","table_id","table_no","table_name","table_status"]},"name":"Writer","category":"writer"} Amazon Redshift Writer脚本参数 脚本参数名 描述 是否必选 默认值 datasource 数据源...
MariaDB数据源
如果您的表数字后缀的长度一致，例如 'table_000'、'table_001'、'table_002' 直到 'table_999'，您可以配置为 '"table":["table_00[0-9]","table_0[10-99]","table_[100-999]"]'。说明 任务会读取匹配到的所有表，具体读取这些表中 column...
访问宽表引擎数据
本文介绍如何在Lindorm计算引擎中通过SQL访问Lindorm宽表引擎数据。准备工作 通过SQL访问Lindorm宽表引擎数据前，需要了解 使用须知。根据作业的提交方式，请确保已完成了相应的初始化工作：JDBC开发实践 JAR作业开发实践 Python作业开发...
基于Go database/sql接口的应用开发
本文介绍通过Go语言的database/sql包使用SQL开发Lindorm宽表应用的方法和示例。前提条件 已下载并安装 Go环境，建议安装Go 1.17及以上版本。已将客户端IP地址添加至Lindorm实例的白名单中，具体操作，请参见 设置白名单。使用限制 本文操作...
审计日志
additionalEventData":{"Status":"Failed","ProjectName":"test_audit","TaskName":"console_query_task_1603807075919","InstanceId":"2020102713575683gc2j*","TaskType":"SQL","OperationText":"create table a(a bigstring);...
计划缓存(Auto Plan Cache)
您可以使用 PolarDB MySQL版 提供的Auto Plan Cache功能，来缓存SQL语句的执行计划信息，以缩短查询优化时间，提升SQL语句的查询性能。本文介绍了Auto Plan Cache功能的背景信息、前提条件、依赖的参数和接口等内容。背景信息 执行计划的...
迁移ClickHouse至Hologres
clickhouse-client-host="<host>"-port="<port>"-user="<username>"-password="<password>"-query="SHOW CREATE TABLE<database_name>.<table_name>">table.sql;您也可以使用如下命令直接查看 system.tables 元数据表。SELECT*FROM system....
使用Flink SQL消费实时变更数据示例
create table connected to source tableEnvironment.executeSql("CREATE TABLE test_table("+"c1 INT,"+"`f:col1` STRING,"+"`f:col2` STRING,"+"`f:col3` STRING"+")WITH("+"'connector'='kafka',"+"'topic'='"+topicName+"',"+"'...
Go
本文介绍 Go 代码示例如何通过驱动 Go-SQL-Driver/MySQL 连接并使用 OceanBase 数据库。前提条件 确保本地已部署 Go 语言环境。Go 驱动连接数据库 步骤一：获取数据库连接参数 参考 获取连接参数 文档，获取相应的租户连接参数，例如：$...
CREATE TABLE
CREATE TABLE test_newtype(c1 TINYINT,c2 SMALLINT,c3 INT,c4 BIGINT,c5 FLOAT,c6 DOUBLE,c7 DECIMAL,c8 BINARY,c9 TIMESTAMP,c10 ARRAY,BIGINT>>,c11 MAP,ARRAY<BIGINT>>,c12 STRUCT,s2:BIGINT>,c13 VARCHAR(20))LIFECYCLE 1;示例7：创建...
MySQL数据源
如果您的表数字后缀的长度一致，例如 'table_000'、'table_001'、'table_002' 直到 'table_999'，您可以配置为 '"table":["table_00[0-9]","table_0[10-99]","table_[100-999]"]'。说明 任务会读取匹配到的所有表，具体读取这些表中 column...
外部表
本文将为您介绍如何通过DataWorks创建、配置外部...CREATE EXTERNAL TABLE IF NOT EXISTS ots_table_external(odps_orderkey bigint,odps_orderdate string,odps_custkey bigint,odps_orderstatus string,odps_totalprice double)STORED BY '...
DDL逻辑复制
CREATE TABLE ALTER TABLE DROP TABLE CREATE TABLE AS all：表示复制所有的DDL语句，目前支持的DDL语句如下：ALTER INDEX ALTER SEQUENCE ALTER TABLE ALTER TYPE CREATE INDEX CREATE SCHEMA CREATE SEQUENCE CREATE TABLE CREATE TABLE ...
DDL逻辑复制
CREATE TABLE ALTER TABLE DROP TABLE CREATE TABLE AS all：表示复制所有的DDL语句，目前支持的DDL语句如下：ALTER INDEX ALTER SEQUENCE ALTER TABLE ALTER TYPE CREATE INDEX CREATE SCHEMA CREATE SEQUENCE CREATE TABLE CREATE TABLE ...
通过控制台使用SQL查询
执行SQL语句时，请选中一条所需SQL语句，否则系统默认执行第一条SQL语句。执行SQL语句时，一次只能选中一条SQL语句，否则系统会报错。步骤二：查询数据 创建映射表后，在 SQL查询 页签，执行SELECT语句查询所需数据。更多信息，请参见 查询...
列存索引常见问题
列存索引的使用方式完全兼容MySQL，但是一些不常见的查询特性，比如某些时空类型的表达式、全文索引以及某些形式的关联子查询，目前尚未完全支持，使用了这些查询特性的SQL语句无法使用列索引（会默认使用行索引进行查询）。有关列索引的...
逻辑表查询
{"tables":[{"catalog_name":"default","database_name":"item","table_version":2,"table_name":"trigger_table","table_type":"json_default","table_content_version":"0.1","table_content":{"table_name":"trigger_table","table_type...
Vertica数据源
delete from@table where db_id=-1"],"postSql":[/执行数据同步任务之后率先执行的SQL语句。update@table set db_modify_time=now()where db_id=1"]},"name":"Writer","category":"writer"}],"setting":{"errorLimit":{"record":"0"/错误...
案例三：搭建问答机器人
搭建流程 创建问答数据表 创建问答数据表的SQL语句如下：CREATE TABLE enterprise_context(id bigint(20)NOT NULL AUTO_INCREMENT COMMENT '主键id',content text DEFAULT NULL COMMENT '内容',PRIMARY KEY(id))ENGINE=InnoDB COMMENT='...
多元索引数组类型
如果要使用SQL语句查询数组类型的数据，则需要为数据表创建多元索引并创建多元索引的映射关系，然后使用SQL语句查询数组类型列的数据。具体步骤如下：创建一个多元索引。具体操作，请参见 使用控制台创建多元索引 或 使用SDK创建多元索引。...
迁移指南
Python%pyspark spark.sql("CREATE TABLE events USING DELTA LOCATION '/mnt/delta/data-pipeline/'")转换为增量表 您有两种选择将Parquet表转换为Delta表：将文件转换为Delta Lake格式并创建Delta表：SQL%sql CONVERT TO DELTA parquet.`...
建表语句
本文为您介绍Spark SQL建表语法。语法 CREATE TABLE tbName[(columnName dataType[,columnName dataType]*)]USING providerName OPTIONS(propertyName=propertyValue[,propertyName=propertyValue]*);使用CTAS语句建表语法如下，将创建表和...
MAX_PT
如果您需要获取分区表中有数据的最小分区，无法使用SQL语句 select*from table where pt=min_pt("table");实现与 max_pt 函数类似的功能，但可以使用标准SQL语句 select*from table where pt=(select min(pt)from table);实现相同的效果。...
GBase8a数据源
delete from@table where db_id=-1"],"postSql":[/执行数据同步任务之后率先执行的SQL语句。update@table set db_modify_time=now()where db_id=1"]},"name":"Writer","category":"writer"}],"setting":{"errorLimit":{"record":"0"/错误...
逻辑解码（wal2json）
结果如下：$psql-At-f/tmp/example2.sql postgres CREATE TABLE CREATE TABLE init BEGIN INSERT 0 1 INSERT 0 1 INSERT 0 1 DELETE 2 INSERT 0 1 UPDATE 1 COMMIT psql:/tmp/example2.sql:17:WARNING:table"table2_without_pk"without ...
- 产品推荐
- 这些文档可能帮助您