通過JDBC連接到Serverless StarRocks實例,您可以享受到跨平臺的統一數據接入體驗,并顯著簡化應用程序的集成流程。本文為您介紹如何使用JDBC方式連接Serverless StarRocks實例。
前提條件
已創建Serverless StarRocks實例,詳情請參見創建實例。
操作步驟
添加依賴至pom.xml。
<dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.47</version> </dependency>
說明mysql-connector-java
為MySQL Driver版本,請根據實際情況修改。連接StarRocks實例,示例代碼如下。
public class ConnStarrocks { /**連接MySQL數據庫 1、加載驅動程序 2、數據庫連接字符串"jdbc:mysql://localhost:9030/數據庫名?" 3、數據庫登錄名 4、數據庫登錄密碼 **/ static final String JDBC_DRIVER = "com.mysql.jdbc.Driver"; static final String DB_URL = "jdbc:mysql://localhost:9030/yourDatabaseName?useSSL=false&serverTimezone=UTC"; /**數據庫的用戶名與密碼,需要根據實際情況設置。**/ static final String USER = "****"; static final String PASSWORD = "1234*****"; public static void main(String[] args) { Connection conn = null; Statement stmt = null; try{ // 注冊JDBC驅動。 Class.forName(JDBC_DRIVER); // 建立數據庫連接。 System.out.println("連接數據庫..."); conn = DriverManager.getConnection(DB_URL,USER,PASSWORD); // 創建Statement對象執行查詢。 System.out.println(" 實例化Statement對象..."); stmt = conn.createStatement(); String sql; sql = "SELECT id, name, url FROM websites"; //獲取查詢結果集。 ResultSet rs = stmt.executeQuery(sql); // 完成后關閉。 rs.close(); stmt.close(); conn.close(); }catch(SQLException se){ // 處理JDBC錯誤。 se.printStackTrace(); }catch(Exception e){ // 處理Class.forName錯誤。 e.printStackTrace(); }finally{ // 關閉資源。 if(stmt!=null) { stmt.close(); } if(conn!=null) { conn.close(); } } System.out.println("Goodbye!"); } }
涉及參數如下表所示。
參數
說明
JDBC_DRIVER
數據庫連接的JDBC驅動。例如,
com.mysql.jdbc.Driver
。DB_URL
數據庫連接字符串,用于在StarRocks中執行查詢操作。
格式為
jdbc:mysql://<FE地址>:<fe_http_port>/<database>
,其中涉及參數如下:<FE地址>
:Serverless StarRocks實例中FE的內網地址。您可以在實例詳情頁面的FE詳情區域查看。<fe_http_port>
:Serverless StarRocks實例中FE的查詢端口(默認為9030)。您可以在實例詳情頁面的FE詳情區域查看。<database>
:Serverless StarRocks實例中的數據庫名稱。
USER
數據庫的用戶名。
PASSWORD
數據庫的密碼。
相關文檔
您可以通過Serverless StarRocks提供的SQL Editor直接在Web界面編寫、執行和管理SQL查詢,以便高效地操作StarRocks實例,詳情請參見通過SQL Editor操作StarRocks實例。
文檔內容是否對您有幫助?