資訊專欄INFORMATION COLUMN
摘要：使用同步數(shù)據(jù)使用同步數(shù)據(jù)使用同步數(shù)據(jù)本篇目錄操作步驟操作步驟用戶可以通過協(xié)議，使用語句進行數(shù)據(jù)導入。
用戶可以通過 JDBC 協(xié)議，使用 INSERT 語句進行數(shù)據(jù)導入。
mysql -uroot -h<任一frontend節(jié)點IP地址> -P9030 -p<創(chuàng)建集群時設置的密碼>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";//創(chuàng)建集群時設置的密碼
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節(jié)點IP地址> -P9030 -p<創(chuàng)建集群時設置的密碼> -e "select * from ssb.example_tbl";文章版權歸作者所有，未經(jīng)允許請勿轉載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉載請注明本文地址：http://systransis.cn/yun/126959.html
摘要：概覽概覽概覽產(chǎn)品動態(tài)產(chǎn)品介紹什么是云數(shù)據(jù)倉庫產(chǎn)品優(yōu)勢應用場景基本概念使用限制快速上手操作指南管理集群配置升降級節(jié)點擴容重啟實例重置管理員密碼刪除集群連接集群數(shù)據(jù)導入本地數(shù)據(jù)導入數(shù)據(jù)導入通過導入開發(fā)指南數(shù)據(jù)類型語法創(chuàng)建庫創(chuàng)建表創(chuàng)建視圖插入數(shù) 概覽概覽產(chǎn)品動態(tài)產(chǎn)品介紹什么是云數(shù)據(jù)倉庫UDoris產(chǎn)品優(yōu)勢應用場景基本概念使用限制快速上手操作指南管理集群Backend配置升降級Frontend節(jié)點擴...
摘要：如何連接云數(shù)據(jù)倉庫如何連接云數(shù)據(jù)倉庫如何連接云數(shù)據(jù)倉庫為保證安全，云數(shù)據(jù)倉庫僅提供內(nèi)網(wǎng)網(wǎng)絡，您連接集群時可以配合同一地域的云主機或者網(wǎng)絡產(chǎn)品使用。 產(chǎn)品購買與使用本篇目錄為什么只提供一種云盤類型？配置升降級對集群有什么影響？配置升級有什么建議？如何連接云數(shù)據(jù)倉庫UDoris？為什么只提供一種云盤類型？Doris的存儲特性對磁盤吞吐量要求很高，為保證Doris的性能優(yōu)勢， 因此僅提供RSSD云...
摘要：重啟集群重啟集群重啟集群當您需要重啟集群時，登錄賬號進入到用戶控制臺，在全部產(chǎn)品下搜索或者數(shù)據(jù)倉庫下選擇數(shù)據(jù)倉庫，進入到數(shù)據(jù)倉庫控制臺下，選擇操作重啟注意重啟集群為高危操作，集群將處于重啟中持續(xù)數(shù)秒，建議無必要時不要隨意重啟實例，這將會 重啟集群當您需要重啟集群時，登錄UCloud賬號進入到用戶控制臺，在全部產(chǎn)品下搜索或者數(shù)據(jù)倉庫下選擇數(shù)據(jù)倉庫 UDW Doris，進入到數(shù)據(jù)倉庫UDoris...
摘要：聚合函數(shù)函數(shù)名稱描述語法統(tǒng)計行數(shù)或者非值個數(shù)求最小值求最大值統(tǒng)計行數(shù)或者非值個數(shù)去重計算輸入的并集，返回新的計算輸入的并集，返回其基數(shù)計算和類型的列中不同值的個數(shù)，返回值和相同非精確快速去重列的類型不能是或者且表為模型聚合函數(shù)函數(shù)名稱描述語法 sum統(tǒng)計行數(shù)或者非NULL值個數(shù)sum(expr)min求最小值min(column)max求最大值max(column)count統(tǒng)計行數(shù)或...
摘要：數(shù)據(jù)排序使用的列數(shù)，取最前面幾列，不能超過總的列數(shù)。示例創(chuàng)建一個動態(tài)分區(qū)表。創(chuàng)建外部表創(chuàng)建外部表在創(chuàng)建外部表的目的是可以通過訪問外部數(shù)據(jù)庫。創(chuàng)建表時，關于和的數(shù)量和數(shù)據(jù)量的建議。 建表（Create Table）創(chuàng)建表語法：CREATE TABLE [IF NOT EXISTS] [database.]table ( column_definition_list, [inde...
摘要：概覽概覽概覽產(chǎn)品動態(tài)產(chǎn)品介紹什么是云數(shù)據(jù)倉庫產(chǎn)品優(yōu)勢應用場景基本概念使用限制快速上手操作指南管理集群配置升降級重啟實例重置管理員密碼刪除集群連接集群數(shù)據(jù)同步本地數(shù)據(jù)導入數(shù)據(jù)導入數(shù)據(jù)導入間數(shù)據(jù)導入開發(fā)指南數(shù)據(jù)類型語法創(chuàng)建庫創(chuàng)建表創(chuàng)建視圖插入 概覽概覽產(chǎn)品動態(tài)產(chǎn)品介紹什么是云數(shù)據(jù)倉庫 UClickHouse產(chǎn)品優(yōu)勢應用場景基本概念使用限制快速上手操作指南管理集群配置升降級重啟實例重置管理員密碼刪...
閱讀 836·2025-02-07 13:29
閱讀 644·2024-11-07 18:25
閱讀 131094·2024-02-01 10:43
閱讀 1060·2024-01-31 14:58
閱讀 1022·2024-01-31 14:54
閱讀 83215·2024-01-29 17:11
閱讀 3497·2024-01-25 14:55
閱讀 2217·2023-06-02 13:36
