以下是使用 OceanBase Connector/J 创建语句对象的基本示例:
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class OceanBaseStatementExample {
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();
// 在这里可以使用 statement 执行 SQL 查询和更新...
} catch (ClassNotFoundException | SQLException e) {
e.printStackTrace();
} finally {
// 在合适的地方关闭 statement 和 connection,释放资源
if (statement != null) {
try {
// 步骤2:关闭 Statement 对象
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (connection != null) {
try {
// 步骤3:关闭连接
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
}
上述代码中,注释标注了创建语句对象和关闭语句对象的关键步骤:
1. 创建 Statement 对象: 使用 connection.createStatement(); 创建 Statement 对象,这个对象可以执行普通的 SQL 语句。
2. 关闭 Statement 对象: 在不再需要 Statement 对象时,通过 statement.close(); 关闭它,以释放资源。
确保在使用完语句对象后及时关闭,以防止资源泄漏。此外,为了更好地处理异常,你可能需要添加更多的错误处理代码。
转载请注明出处:http://www.zyzy.cn/article/detail/11421/OceanBase