java连接oceanbase

### Java 连接 OceanBase 数据库

为了通过 Java 应用程序连接至 OceanBase 数据库，通常会采用 JDBC (Java Database Connectivity) 接口来实现这一功能。JDBC 提供了一种标准方法用于执行 SQL 语句并处理结果集。

#### 准备工作

确保已下载适用于 MySQL 协议的 OceanBase JDBC 驱动程序，并将其添加到项目的类路径中[^1]。

#### 示例代码

下面是一个简单的例子，展示了如何配置以及使用 Java 来连接 OceanBase 数据库：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class OBConnectionExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://<host>:<port>/<database>?useSSL=false&serverTimezone=UTC";
        String user = "<username>";
        String password = "<password>";

        try {
            Connection conn = DriverManager.getConnection(url, user, password);
            Statement stmt = conn.createStatement();
            
            // 创建表（如果不存在）
            String createTableSQL = "CREATE TABLE IF NOT EXISTS test_table(id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255))";
            stmt.execute(createTableSQL);

            // 插入数据
            String insertDataSQL = "INSERT INTO test_table(name) VALUES('example')";
            int result = stmt.executeUpdate(insertDataSQL);
            System.out.println(result + " row(s) inserted.");

            // 查询数据
            ResultSet rs = stmt.executeQuery("SELECT * FROM test_table");
            while(rs.next()){
                System.out.print("ID: "+rs.getInt("id"));
                System.out.println(", Name: "+rs.getString("name"));
            }

            // 关闭资源
            rs.close();
            stmt.close();
            conn.close();

        } catch(Exception e){
            e.printStackTrace();
        }
    }
}

此段代码实现了创建表格、插入记录和读取数据的功能。请注意替换 `<host>`、`<port>`、`<database>`、`<username>` 和 `<password>` 成实际环境中的相应值。