CREATE TABLE
语法：CREATE TABLE[db.]distributed_table_name ON CLUSTER default AS db.local_table_name ENGINE=Distributed(cluster,db,local_table_name[,sharding_key])参数说明：参数 说明 db 数据库的名称，默认为当前选择的数据库，本文以...
跨库查询
当需要查询分散在不同数据库中的数据时，您可以使用 云原生数据仓库 AnalyticDB PostgreSQL 版 的跨库查询功能方便地将数据聚合在一起，进行高效查询，提高数据访问效率。功能介绍 Database是PostgreSQL生态下数据库的最高级别，同一个实例...
数据库采集
数据库网关DG（Database Gateway）是一种支持私网数据库远程访问的数据库连接服务。通过数据库网关DG，您可以无需开通公网地址访问并管理本地IDC或其他云厂商的数据库。详情请参见 什么是数据库网关。说明 目前ADAM支持华北2（北京）、华北...
使用说明
示例：在RW1上创建一个数据库 db1 CREATE DATABASE db1 POLARDB_WRITE_NODE 1;如果需要在RW2上创建数据库 db1，把上述示例中的1换成2即可。删除在指定RW节点上创建的数据库 删除在指定RW节点上创建的数据库。语法结构如下：DROP DATABASE ...
通过SQL连接并使用搜索引擎
Lindorm搜索引擎支持SQL JDBC访问，本文介绍如何使用开源的Solr JDBC访问Lindorm搜索引擎。前提条件 已开通Lindorm搜索引擎，具体操作请参见 开通指南。已将客户端的IP地址加入到Lindorm实例的白名单中，具体操作，请参见 设置白名单。已...
概述
MaxCompute JDBC驱动是MaxCompute提供的Java数据库连接（Java Database Connectivity）接口。您可以通过标准的JDBC接口基于MaxCompute执行海量数据的分布式计算查询。MaxCompute JDBC驱动还可以用于连接MaxCompute和支持JDBC的工具。JDBC...
访问JDBC外表
云原生多模数据库Lindorm计算引擎支持访问外部JDBC数据源，您可以通过Spark SQL完成Lindorm与外部数据源之间的数据流转以及联邦计算。前提条件 已开通Lindorm实例的计算引擎服务，具体操作请参见 开通与变配。确保外部数据源已开通访问权限...
访问MongoDB数据源
本文介绍如何使用 AnalyticDB MySQL版 湖仓版（3.0）Spark访问云数据库MongoDB数据。前提条件 已创建AnalyticDB MySQL湖仓版（3.0）集群。具体操作，请参见 创建湖仓版（3.0）集群。已创建数据库账号。如果您是通过阿里云账号访问，只需...
云数据库RDS SQL Server版查看锁信息
select str(request_session_id,4,0)as spid,convert(varchar(20),db_name(resource_database_id))as DB_Name,case when resource_database_id=db_id()and resource_type='OBJECT' then convert(char(20),object_name(resource_Associated_...
数据库管理
Database的概念 每个正在运行的Lindorm时序引擎实例都管理着一个或多个数据库（简称Database）。在各个Database之间，数据会被隔离。每个Database都有若干时序数据表，结合 名词解释 的描述，我们可以对时序引擎的数据层级归纳为下图所示：...
JDBC开发实践
您可以通过JDBC方式访问Lindorm计算引擎服务，使用Spark SQL完成数据查询、数据分析和数据生产等操作。前提条件 已创建并开通Lindorm实例的宽表引擎，具体操作请参见 创建实例。已开通Lindorm实例的计算引擎服务，具体操作请参见 开通与变...
在RDS SQL Server中出现阻塞
select dtl.request_session_id as waitSID,der.blocking_session_id as blockSID,dowt.resource_description,der.wait_type,dowt.wait_duration_ms,DB_NAME(dtl.resource_database_id)as DB,dtl.resource_associated_entity_id as ...
教程：通过Druid连接池连接并访问时序引擎
JDBC访问逻辑的基础是需要创建Connection对象，如果每次连接时序引擎都创建一个新的Connection对象，会带来很大的开销。为了降低开销，可以使用连接池来执行连接的创建和管理。前提条件 已安装Java环境，要求安装JDK 1.8及以上版本。已将...
DB数据源
之后您可以通过JDBC连接数据库，并执行SQL语句获取所需的压测数据。目前PTS支持MySQL、PostgreSQL、MariaDB和SQL Server四种数据库。仅支持您自行填写 Select 开头的SQL语句。您填写的SQL执行后获取的结果集越大，压测前的准备阶段耗时就越...
mysqlclient 连接 OceanBase 数据库
database_name：需要访问的数据库名称。user_name：租户的连接账号。password：提供账户密码。更多连接串的信息，请参见 获取连接参数。示例如下：obclient-hxxx.xxx.xxx.xxx-P3306-utest_user001-p*-Dtest 步骤四：修改 config.py 文件中...
ModifyTenantUserRoles-修改租户用户角色
OceanBase MySQL 模式下,传入所有的数据库和对应的权限,如果有未传入的数据库,则视为撤销在该数据库上的权限,如果取消所有的数据库权限,则传入为空,即 UserRole:[]。OceanBase Oracle 模式下,只传入对应需要修改的数据库名、表名，以及相应...
DB数据源
之后您可以通过JDBC连接数据库，并执行SQL语句获取所需的压测数据。目前PTS支持MySQL、PostgreSQL、MariaDB和SQL Server四种数据库。仅支持您自行填写 Select 开头的SQL语句。您填写的SQL执行后获取的结果集越大，压测前的准备阶段耗时就越...
DB2数据源
jdbcUrl":"jdbc:db2:/ip:port/database",/DB2数据库的JDBC连接信息。column":["id"],"batchSize":1024,/一次性批量提交的记录数大小。table":"",/表名。username":"",/用户名。preSql":[]/执行数据同步任务之前执行的SQL语句。},"name...
通过Logstash写入数据到AnalyticDB MySQL 2.0
以日志数据为例，可以通过开源logstash output插件 logstash-output-jdbc 将log数据导入分析型数据库MySQL版中进行进一步分析（分析型数据库MySQL版支持原生JDBC方式访问）。但经过测试发现，在日志量非常大的情况下，通过jdbc方式写入分析...
SQL Server性能分析与优化
查看每个数据库的缓存页计数 SELECT COUNT(*)*8/1024 AS 'cache size(MB)',CASE database_id WHEN 32767 THEN 'ResourceDb' ELSE DB_NAME(database_id)END AS 'datebase' FROM sys.dm_os_buffer_descriptors GROUP BY DB_NAME(database_id)...
JDBC连接表格存储
本文介绍如何使用JDBC访问表格存储。注意事项 目前支持使用SQL查询功能的地域有华东1（杭州）、华东2（上海）、华北2（北京）、华北3（张家口）、华北5（呼和浩特）、华北6（乌兰察布）、华南1（深圳）、西南1（成都）、中国香港、新加坡、...
通过HTTPS协议连接ClickHouse
您可以通过HTTPS协议访问 云数据库ClickHouse。本文介绍如何通过HTTPS协议连接 云数据库ClickHouse 集群。前提条件 仅 云数据库ClickHouse 集群的20.8及以上版本支持通过HTTPS协议连接。已开通HTTPS协议并下载SSL CA证书。如何开通和下载，...
Hive数据源
您可以基于HDFS文件和Hive JDBC两种方式读取数据：基于HDFS文件读取数据 Hive Reader插件通过访问HiveMetastore服务，解析出您配置的数据表的HDFS文件存储路径、文件格式、分隔符等信息后，再通过读取HDFS文件的方式读取Hive中的表数据。...
Sqoop概述
Sqoop是一款Apache社区的开源软件，支持在Hadoop生态软件和结构化数据集（例如数据库）之间进行高效的批量数据传输。背景信息 常见数据传输场景如下：将MySQL数据导入HDFS 将HDFS数据导入MySQL 将Hive数据导入MySQL 将MySQL数据导入Hive 将...
通过Spark SQL读Lindorm数据
AnalyticDB MySQL 湖仓版（3.0）支持通过Spark SQL访问Lindorm数据库。本文主要介绍如何通过Spark SQL访问Lindorm中的Hive表和宽表的数据。前提条件 已创建Lindorm单可用区实例。具体操作，请参见 创建实例。重要 Lindorm实例需开通宽表...
连接数据库
关于数据库的超时设置的推荐实践 若您的应用使用了一些常见的ORM框架（例如SpringBoot+MyBatis+JDBC Driver等）来访问数据库，这些ORM框架通常支持从事务、SQL语句、网络收发包等多个维度对SQL查询时的客户端侧超时时间进行设置。...
通过JDBC方式连接StarRocks实例
public class ConnStarrocks {/*连接MySQL数据库 1、加载驱动程序 2、数据库连接字符串"jdbc:mysql:/localhost:9030/数据库名?3、数据库登录名 4、数据库登录密码*/static final String JDBC_DRIVER="com.mysql.jdbc.Driver";static final...
JDBC数据源
是 driver 数据库连接的JDBC驱动。例如 com.mysql.jdbc.Driver”eper.quorum":"a.b.c.d:2181"}。是 dbtable 数据表名称。是 user 连接的用户名。是 password 连接的密码。是 batchsize 每个批次更新的数据条数。仅向数据库写入数据时生效。...
ClickHouse数据源
} },"order":{"hops":[{"from":"Reader","to":"Writer"}]} } ClickHouse Writer脚本参数 参数 描述 是否必选 默认值 jdbcUrl 到对端数据库的JDBC连接信息，jdbcUrl 包含在 connection 配置单元中。在一个数据库上只能配置一个值。jdbcUrl ...
入门概览
通过Java Native SDK连接并使用Lindorm时序引擎 JDBC Driver 应用代码中已经使用JDBC标准API访问多种异构数据库。应用代码中有类似MyBatis等数据访问ORM框架的应用。通过JDBC Driver连接并使用Lindorm时序引擎 HTTP API SQL 对于非Java语言...
MongoDB
云数据库MongoDB版（ApsaraDB for MongoDB）是基于飞天分布式系统和高可靠存储引擎的在线数据库服务，完全兼容MongoDB协议，提供稳定可靠、弹性伸缩的数据库服务。本文主要介绍如何通过DLA Serverless Spark访问云数据库MongoDB。重要 云...
Python访问（2.0版）
在python中可以通过MySQLdb的module来访问 云原生数据仓库AnalyticDB MySQL版 2.0集群。usr/bin/python#-*-coding:UTF-8-*-...fetchone()方法获取一条数据 data=cursor.fetchone()print"Database version:%s"%data#关闭数据库连接 db.close()
文件存储 HDFS 版和数据库MySQL双向数据迁移
本文介绍如何使用Sqoop工具实现 文件存储 HDFS 版 和关系型数据库MySQL之间的双向数据迁移。前提条件 已开通 文件存储 HDFS 版 服务并创建文件系统实例和挂载点。具体操作，请参见 文件存储HDFS版快速入门。已搭建Hadoop集群。建议您使用的...
JDBC 连接池配置示例
在使用 JDBC 进行数据库连接的时候，需要配置相关参数来获得数据库使用的最佳性能。这里推荐一些相关参数的配置。JDBC 连接示例如下：conn=jdbc:oceanbase:/xxx.xxx.xxx.xxx:1521?rewriteBatchedStatements=TRUE&allowMultiQueries=TRUE&...
DataX Writer
是 无 database StarRocks数据库的名称。是 无 table StarRocks表的名称。是 无 loadUrl StarRocks FE的地址，用于Stream Load，可以为多个FE地址，格式为 fe_ip:fe_http_port 。是 无 column 目的表需要写入数据的字段，字段之间用英文...
Spark对接MySQL
本文介绍Spark如何访问MySQL。Spark RDD访问MySQL 示例代码如下。val input=getSparkContext.textFile(inputPath,numPartitions)input.flatMap(_.split("")).map(x=>(x,1)).reduceByKey(_+_).mapPartitions(e=>{ var conn:Connection=null ...
DataX Writer
否 无 jdbcUrl 目的数据库的JDBC连接信息，用于执行 preSql 和 postSql。否 无 maxBatchRows 单次Stream Load导入的最大行数。否 500000（50W）maxBatchSize 单次Stream Load导入的最大字节数。否 104857600（100M）flushInterval 上一次...
使用JDBC提交Presto作业
JDBC包通常都是向下兼容的，依赖版本选择社区最新版即可-><dependency><groupId>io.trino</groupId><artifactId>trino-jdbc</artifactId><version>xxx</version></dependency>JDBC访问Trino on ACK。示例TrinoSqlConnection.java内容如下。...
基本概念
数据库 database 表示数据访问代理的逻辑数据库。以这个作为访问的入口，通过分库分表、读写分离等规则可以请求到后端真实的物理数据库。数据表 data table 表示数据访问代理的逻辑表，应用访问数据访问代理时 SQL 中的表即数据表。一个...
RAM用户访问图数据库GDB
图数据库GDB支持RAM用户访问。本文介绍从创建RAM用户到RAM用户登录图数据库GDB控制台的方法。操作步骤 创建RAM用户，具体请参见 创建RAM用户。授予RAM用户访问图数据库GDB控制台的权限，具体请参见 为RAM用户授权。说明 选择权限时，在搜索...
- 产品推荐
- 这些文档可能帮助您