python连接oceanbase库

准备

python没有直接的轮子去连接oceanbase，需要借助OceanBase JDBC 驱动程序。
别外还需要安装python包jaydebeapi（pip install jaydebeapi）

创建oceanbase连接

官文文档

注意用户名参数，租户和集群名也要给到

import jaydebeapi

# OceanBase JDBC 驱动程序，指定文件路径
ob_jar = r'.\oceanbase-client-2.4.1.jar'
# oceanbase要连的数据库地址
url = r'jdbc:oceanbase://ip:port/dbname'
# oceanbase用户名
user = r'用户名@租户名#集群名'
# 用户密码
password = r'password'
# 驱动，固定值
driver = r'com.alipay.oceanbase.jdbc.Driver'

# 创建连接对象
conn = jaydebeapi.connect(driver, url, [user, password], ob_jar)

# 创建一个游标
cursor = conn.cursor()
sql = 'SELECT * FROM tbname;'
cursor.execute(sql)		# 执行sql语句
result = cursor.fetchall()	# 获取sql执行结果

# 关闭连接
cursor.close()
conn.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25