首先,确保你已经导入了 JDBC 驱动的相关库。在这个例子中,我们使用的是 Oracle 的 JDBC 驱动,因为 OceanBase 的 JDBC 驱动是基于 Oracle 的。
import java.sql.Connection;
import java.sql.SQLException;
import javax.sql.DataSource;
import oracle.jdbc.pool.OracleDataSource;
public class OceanBaseDataSourceExample {
public static void main(String[] args) {
try {
// 创建 OceanBase 数据源实例
DataSource dataSource = createOceanBaseDataSource();
// 获取连接
Connection connection = dataSource.getConnection();
// 执行数据库操作(在这里可以执行你的查询、更新等操作)
// 关闭连接
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
private static DataSource createOceanBaseDataSource() throws SQLException {
// 创建 Oracle 数据源
OracleDataSource dataSource = new OracleDataSource();
// 设置连接信息
dataSource.setURL("jdbc:oracle:thin:@your_oceanbase_host:your_oceanbase_port:your_oceanbase_sid");
dataSource.setUser("your_username");
dataSource.setPassword("your_password");
// 设置连接池属性
dataSource.setMinLimit(5); // 最小连接数
dataSource.setMaxLimit(20); // 最大连接数
dataSource.setLoginTimeout(10); // 10秒连接超时
dataSource.setMaxWaitTime(5000); // 最大等待时间为5000毫秒
return dataSource;
}
}
请替换 your_oceanbase_host、your_oceanbase_port 和 your_oceanbase_sid 为实际的 OceanBase 主机、端口和数据库 SID。此外,设置合适的用户名和密码。
在上述代码中,我们使用了 OracleDataSource,但在实际应用中,你可能会使用 OceanBase 提供的 JDBC 驱动,该驱动可能提供自己的 DataSource 实现。确保按照实际情况选择正确的数据源类型。
此外,具体的配置属性和特性可能会因 OceanBase 数据库版本的不同而有所不同。建议查阅当前版本的 OceanBase 文档以获取最准确和最新的信息。
转载请注明出处:http://www.pingtaimeng.com/article/detail/11436/OceanBase