摘要：使用同步数据使用同步数据使用同步数据本篇目录操作步骤操作步骤用户可以通过协议，使用语句进行数据导入。
用户可以通过 JDBC 协议，使用 INSERT 语句进行数据导入。
mysql -uroot -h<任一frontend节点IP地址> -P9030 -p<创建集群时设置的密码>CREATE DATABASE IF NOT EXISTS ssb;
CREATE TABLE IF NOT EXISTS example_tbl
(
id INT,
age TINYINT,
name VARCHAR(50)
)
unique key(id)
DISTRIBUTED BY HASH(id) BUCKETS 3;INSERT INTO example_tbl VALUES
(1, 18, "张三")
(2, 19, "李四")
(3, 20, "王五");package demo.doris;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class DorisJdbcLoader {
private static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
private static final String DB_URL_PATTERN = "jdbc:mysql://%s:%d/%s?rewriteBatchedStatements=true";
private static final String HOST = "your_host"; //集群详情给出的连接地址，也就是Frontend的master角色对应的ip
private static final int PORT = 8030;
private static final String DB = "ssb";
private static final String TBL = "example_tbl";
private static final String USER = "root";
private static final String PASSWD = "my_pass";//创建集群时设置的密码
private static final int INSERT_BATCH_SIZE = 10000;
public static void main(String[] args) throws Exception {
insert();
}
private static void insert() throws Exception {
String query = "insert into " + TBL + " values(?, ?)";
String dbUrl = String.format(DB_URL_PATTERN, HOST, PORT, DB);
Class.forName(JDBC_DRIVER);
try (Connection conn = DriverManager.getConnection(dbUrl, USER, PASSWD)) {
PreparedStatement stmt = conn.prepareStatement(query);
for (int i =0; i < INSERT_BATCH_SIZE; i++) {
stmt.setInt(1, i);
stmt.setInt(2, i * 100);
stmt.addBatch();
}
int[] res = stmt.executeBatch();
System.out.println(res);
} catch (Exception e) {
e.printStackTrace();
}
}
}mysql -uroot -h<任一Frontend节点IP地址> -P9030 -p<创建集群时设置的密码> -e "select * from ssb.example_tbl";文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。
转载请注明本文地址：https://www.ucloud.cn/yun/126959.html
摘要：概览概览概览产品动态产品介绍什么是云数据仓库产品优势应用场景基本概念使用限制快速上手操作指南管理集群配置升降级节点扩容重启实例重置管理员密码删除集群连接集群数据导入本地数据导入数据导入通过导入开发指南数据类型语法创建库创建表创建视图插入数 概览概览产品动态产品介绍什么是云数据仓库UDoris产品优势应用场景基本概念使用限制快速上手操作指南管理集群Backend配置升降级Frontend节点扩...
摘要：如何连接云数据仓库如何连接云数据仓库如何连接云数据仓库为保证安全，云数据仓库仅提供内网网络，您连接集群时可以配合同一地域的云主机或者网络产品使用。 产品购买与使用本篇目录为什么只提供一种云盘类型？配置升降级对集群有什么影响？配置升级有什么建议？如何连接云数据仓库UDoris？为什么只提供一种云盘类型？Doris的存储特性对磁盘吞吐量要求很高，为保证Doris的性能优势， 因此仅提供RSSD云...
摘要：重启集群重启集群重启集群当您需要重启集群时，登录账号进入到用户控制台，在全部产品下搜索或者数据仓库下选择数据仓库，进入到数据仓库控制台下，选择操作重启注意重启集群为高危操作，集群将处于重启中持续数秒，建议无必要时不要随意重启实例，这将会 重启集群当您需要重启集群时，登录UCloud账号进入到用户控制台，在全部产品下搜索或者数据仓库下选择数据仓库 UDW Doris，进入到数据仓库UDoris...
摘要：聚合函数函数名称描述语法统计行数或者非值个数求最小值求最大值统计行数或者非值个数去重计算输入的并集，返回新的计算输入的并集，返回其基数计算和类型的列中不同值的个数，返回值和相同非精确快速去重列的类型不能是或者且表为模型聚合函数函数名称描述语法 sum统计行数或者非NULL值个数sum(expr)min求最小值min(column)max求最大值max(column)count统计行数或...
摘要：数据排序使用的列数，取最前面几列，不能超过总的列数。示例创建一个动态分区表。创建外部表创建外部表在创建外部表的目的是可以通过访问外部数据库。创建表时，关于和的数量和数据量的建议。 建表（Create Table）创建表语法：CREATE TABLE [IF NOT EXISTS] [database.]table ( column_definition_list, [inde...
摘要：概览概览概览产品动态产品介绍什么是云数据仓库产品优势应用场景基本概念使用限制快速上手操作指南管理集群配置升降级重启实例重置管理员密码删除集群连接集群数据同步本地数据导入数据导入数据导入间数据导入开发指南数据类型语法创建库创建表创建视图插入 概览概览产品动态产品介绍什么是云数据仓库 UClickHouse产品优势应用场景基本概念使用限制快速上手操作指南管理集群配置升降级重启实例重置管理员密码删...
阅读 130091·2024-02-01 10:43
阅读 758·2024-01-31 14:58
阅读 733·2024-01-31 14:54
阅读 82539·2024-01-29 17:11
阅读 2821·2024-01-25 14:55
阅读 1896·2023-06-02 13:36
阅读 2771·2023-05-23 10:26
阅读 835·2023-05-23 10:25
