1. 连接到 OceanBase 数据库
在 Java 中使用 OceanBase Connector/J 连接到 OceanBase 数据库：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class OceanBaseExample {
public static void main(String[] args) {
// 配置数据库连接信息
String url = "jdbc:oceanbase://your_oceanbase_server:your_port/your_database";
String user = "your_username";
String password = "your_password";
try {
// 加载驱动程序
Class.forName("com.mysql.cj.jdbc.Driver");
// 建立连接
Connection connection = DriverManager.getConnection(url, user, password);
// 在这里可以执行其他数据库操作...
// 关闭连接
connection.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
2. 创建表
使用 SQL 语句创建表：
CREATE TABLE your_table (
column1 INT,
column2 VARCHAR(255),
-- 其他列的定义...
);
3. 插入数据
使用 INSERT INTO 语句插入数据：
INSERT INTO your_table (column1, column2) VALUES (1, 'value1');
INSERT INTO your_table (column1, column2) VALUES (2, 'value2');
-- 可以插入更多的数据...
4. 查询数据
使用 SELECT 语句查询数据：
SELECT * FROM your_table;
5. 更新数据
使用 UPDATE 语句更新数据：
UPDATE your_table SET column2 = 'new_value' WHERE column1 = 1;
6. 删除数据
使用 DELETE FROM 语句删除数据：
DELETE FROM your_table WHERE column1 = 2;
7. 事务操作
使用事务进行一系列操作，保证原子性、一致性、隔离性和持久性（ACID 特性）：
try {
connection.setAutoCommit(false); // 开启事务
// 执行一系列数据库操作
connection.commit(); // 提交事务
} catch (SQLException e) {
connection.rollback(); // 发生异常时回滚事务
} finally {
connection.setAutoCommit(true); // 恢复自动提交模式
}
以上是一些基本的 OceanBase 操作示例，具体的操作和语法可能会根据实际业务需求和数据模型而有所不同。在实际使用中，建议查阅 OceanBase 官方文档以获取更详细和最新的信息。
转载请注明出处：http://www.zyzy.cn/article/detail/11419/OceanBase