跳到主要内容

Databend Java JDBC 驱动

官方 JDBC 驱动,提供标准 JDBC 4.0 兼容性,可与 Java 应用程序无缝集成。

安装

Maven

<dependency>
<groupId>com.databend</groupId>
<artifactId>databend-jdbc</artifactId>
<version>0.3.7</version>
</dependency>

Gradle

implementation 'com.databend:databend-jdbc:0.3.7'

连接字符串:关于 DSN 格式和连接示例,请参见 驱动程序概述


主要特性

  • 兼容 JDBC 4.0:支持标准 JDBC 接口
  • 连接池 (Connection Pooling):内置连接管理
  • 预处理语句 (Prepared Statements):高效的参数化查询
  • 批处理操作 (Batch Operations):支持批量插入和更新

数据类型映射

DatabendJava说明
整数
TINYINTByte
SMALLINTShort
INTInteger
BIGINTLong
TINYINT UNSIGNEDShort
SMALLINT UNSIGNEDInteger
INT UNSIGNEDLong
BIGINT UNSIGNEDBigInteger
浮点数
FLOATFloat
DOUBLEDouble
DECIMALBigDecimal精度保留
其他类型
BOOLEANBoolean
STRINGString
DATEDate
TIMESTAMPTimestamp
ARRAY(T)StringJSON 编码
TUPLE(...)StringJSON 编码
MAP(K,V)StringJSON 编码
VARIANTStringJSON 编码
BITMAPStringBase64 编码

基本用法

import java.sql.*;

// 连接到 Databend
Connection conn = DriverManager.getConnection("<your-dsn>");

// DDL:创建表
Statement stmt = conn.createStatement();
stmt.execute("CREATE TABLE users (id INT, name STRING, email STRING)");

// 写入:插入数据
PreparedStatement pstmt = conn.prepareStatement("INSERT INTO users VALUES (?, ?, ?)");
pstmt.setInt(1, 1);
pstmt.setString(2, "Alice");
pstmt.setString(3, "alice@example.com");
pstmt.executeUpdate();

// 查询:选择数据
ResultSet rs = stmt.executeQuery("SELECT id, name, email FROM users WHERE id = 1");
while (rs.next()) {
System.out.println("User: " + rs.getInt("id") + ", " +
rs.getString("name") + ", " +
rs.getString("email"));
}

// 关闭连接
rs.close();
stmt.close();
pstmt.close();
conn.close();

配置参考

关于 databend-jdbc 驱动的完整配置选项,包括:

  • 连接字符串参数
  • SSL/TLS 配置
  • 身份验证方法
  • 性能调优参数

请参考 官方 databend-jdbc 连接指南

相关资源

开始使用 Databend Cloud
低成本
快速分析
多种数据源
弹性扩展
注册