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

public class OceanBaseSQLExceptionExample {

    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";

        Connection connection = null;
        Statement statement = null;

        try {
            // 加载驱动程序
            Class.forName("com.mysql.cj.jdbc.Driver");

            // 建立连接
            connection = DriverManager.getConnection(url, user, password);

            // 步骤1：创建 Statement 对象
            statement = connection.createStatement();

            // 步骤2：执行 SQL 语句
            statement.executeUpdate("INSERT INTO your_table (column1, column2) VALUES (1, 'value1')");

        } catch (ClassNotFoundException | SQLException e) {
            // 处理 SQL 异常
            e.printStackTrace();
        } finally {
            // 在合适的地方关闭资源
            if (statement != null) {
                try {
                    statement.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

try {
    // 执行数据库操作...
} catch (SQLException e) {
    if (e.getSQLState().equals("XYZ")) {
        // 处理特定的 SQL 异常
    } else {
        // 处理其他 SQL 异常
    }
}

try {
    connection.setAutoCommit(false);  // 开启事务

    // 执行一系列数据库操作

    connection.commit();  // 提交事务
} catch (SQLException e) {
    connection.rollback();  // 发生异常时回滚事务
} finally {
    connection.setAutoCommit(true);  // 恢复自动提交模式
}