使用 Java 连接到 OceanBase 数据库的示例:
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;
public class OceanBaseConnectionExample {
public static void main(String[] args) {
// OceanBase数据库连接信息
String url = "jdbc:OceanBase://your_oceanbase_server:your_oceanbase_port/your_database";
String user = "your_username";
String password = "your_password";
// 加载OceanBase JDBC驱动
try {
Class.forName("com.mysql.cj.jdbc.Driver");
} catch (ClassNotFoundException e) {
System.err.println("无法加载OceanBase JDBC驱动");
e.printStackTrace();
return;
}
// 设置连接属性
Properties props = new Properties();
props.setProperty("user", user);
props.setProperty("password", password);
// 建立连接
try (Connection connection = DriverManager.getConnection(url, props)) {
System.out.println("成功连接到OceanBase数据库");
// 在这里可以执行你的SQL操作
} catch (SQLException e) {
System.err.println("连接过程中发生错误");
e.printStackTrace();
}
}
}
请注意替换示例中的占位符(your_oceanbase_server、your_oceanbase_port、your_database、your_username、your_password)为实际的OceanBase服务器信息。
使用 Python 连接到 OceanBase 数据库的示例:
import pymysql
# OceanBase数据库连接信息
host = "your_oceanbase_server"
port = your_oceanbase_port
user = "your_username"
password = "your_password"
database = "your_database"
# 建立连接
connection = pymysql.connect(host=host, port=port, user=user, password=password, database=database)
try:
with connection.cursor() as cursor:
# 在这里可以执行你的SQL操作
sql = "SELECT * FROM your_table"
cursor.execute(sql)
result = cursor.fetchall()
print(result)
finally:
connection.close()
同样,请确保替换示例中的占位符为实际的OceanBase服务器信息和你要查询的表的信息。
上述示例中使用的是Java和Python,你可以根据自己的需求选择其他编程语言,并查阅相应语言的数据库连接库文档以获取详细信息。
转载请注明出处:http://www.zyzy.cn/article/detail/11318/OceanBase