国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

使用JDBC同步數據 數據倉庫 UDW Doris

ernest.wang / 3544人閱讀

摘要：使用同步數據使用同步數據使用同步數據本篇目錄操作步驟操作步驟用戶可以通過協議，使用語句進行數據導入。

使用JDBC同步數據

本篇目錄

操作步驟

用戶可以通過 JDBC 協議，使用 INSERT 語句進行數據導入。

操作步驟

通過mysql-client連接集群
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, "王五");
JDBC示例（這里我們給出一個簡單的 JDBC 批量 INSERT 代碼示例）
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-client非交互模式查詢驗證
mysql -uroot -h<任一Frontend節點IP地址> -P9030 -p<創建集群時設置的密碼> -e "select * from ssb.example_tbl";

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/126959.html

相關文章

  • 概覽 數據倉庫 UDW Doris

    摘要：概覽概覽概覽產品動態產品介紹什么是云數據倉庫產品優勢應用場景基本概念使用限制快速上手操作指南管理集群配置升降級節點擴容重啟實例重置管理員密碼刪除集群連接集群數據導入本地數據導入數據導入通過導入開發指南數據類型語法創建庫創建表創建視圖插入數 概覽概覽產品動態產品介紹什么是云數據倉庫UDoris產品優勢應用場景基本概念使用限制快速上手操作指南管理集群Backend配置升降級Frontend節點擴...

    ernest.wang 評論0 收藏1705

  • 產品購買與使用 數據倉庫 UDW Doris

    摘要：如何連接云數據倉庫如何連接云數據倉庫如何連接云數據倉庫為保證安全，云數據倉庫僅提供內網網絡，您連接集群時可以配合同一地域的云主機或者網絡產品使用。 產品購買與使用本篇目錄為什么只提供一種云盤類型？配置升降級對集群有什么影響？配置升級有什么建議？如何連接云數據倉庫UDoris？為什么只提供一種云盤類型？Doris的存儲特性對磁盤吞吐量要求很高，為保證Doris的性能優勢， 因此僅提供RSSD云...

    ernest.wang 評論0 收藏1167

  • 重啟集群 數據倉庫 UDW Doris

    摘要：重啟集群重啟集群重啟集群當您需要重啟集群時，登錄賬號進入到用戶控制臺，在全部產品下搜索或者數據倉庫下選擇數據倉庫，進入到數據倉庫控制臺下，選擇操作重啟注意重啟集群為高危操作，集群將處于重啟中持續數秒，建議無必要時不要隨意重啟實例，這將會 重啟集群當您需要重啟集群時，登錄UCloud賬號進入到用戶控制臺，在全部產品下搜索或者數據倉庫下選擇數據倉庫 UDW Doris，進入到數據倉庫UDoris...

    ernest.wang 評論0 收藏2903

  • 聚合函數 數據倉庫 UDW Doris

    摘要：聚合函數函數名稱描述語法統計行數或者非值個數求最小值求最大值統計行數或者非值個數去重計算輸入的并集，返回新的計算輸入的并集，返回其基數計算和類型的列中不同值的個數，返回值和相同非精確快速去重列的類型不能是或者且表為模型聚合函數函數名稱描述語法 sum統計行數或者非NULL值個數sum(expr)min求最小值min(column)max求最大值max(column)count統計行數或...

    ernest.wang 評論0 收藏146

  • 建表（Create Table） 數據倉庫 UDW Doris

    摘要：數據排序使用的列數，取最前面幾列，不能超過總的列數。示例創建一個動態分區表。創建外部表創建外部表在創建外部表的目的是可以通過訪問外部數據庫。創建表時，關于和的數量和數據量的建議。 建表（Create Table）創建表語法：CREATE TABLE [IF NOT EXISTS] [database.]table ( column_definition_list, [inde...

    ernest.wang 評論0 收藏1190

  • 概覽 數據倉庫 UDW Clickhouse

    摘要：概覽概覽概覽產品動態產品介紹什么是云數據倉庫產品優勢應用場景基本概念使用限制快速上手操作指南管理集群配置升降級重啟實例重置管理員密碼刪除集群連接集群數據同步本地數據導入數據導入數據導入間數據導入開發指南數據類型語法創建庫創建表創建視圖插入 概覽概覽產品動態產品介紹什么是云數據倉庫 UClickHouse產品優勢應用場景基本概念使用限制快速上手操作指南管理集群配置升降級重啟實例重置管理員密碼刪...

    ernest.wang 評論0 收藏1076

發表評論

0條評論

ernest.wang

男|高級講師

TA的文章

閱讀更多
最新活動
閱讀需要支付1元查看
<