如何在Python中连接OceanBase数据库并实现增删改查？

By adminmysql360On 2025年2月3日2025年2月2日

要在Python中连接OceanBase数据库并实现增删改查操作，你需要使用支持MySQL协议的Python库，比如 mysql-connector-python 或者 PyMySQL。OceanBase兼容MySQL协议，因此可以使用这些库来操作OceanBase。

下面是通过 mysql-connector-python 连接OceanBase数据库并实现增删改查的基本步骤。

1. 安装mysql-connector-python

首先，你需要安装 mysql-connector-python：

pip install mysql-connector-python

2. 连接OceanBase数据库

使用以下代码连接OceanBase数据库：

import mysql.connector

# 连接数据库
conn = mysql.connector.connect(
    host="your_oceanbase_host",  # OceanBase主机地址
    port=your_oceanbase_port,    # OceanBase端口
    user="your_username",        # 用户名
    password="your_password",    # 密码
    database="your_database"     # 数据库名称
)

# 创建游标对象
cursor = conn.cursor()

# 执行SQL操作

3. 增加数据 (INSERT)

通过执行INSERT语句向数据库添加数据：

# 插入数据
insert_sql = "INSERT INTO your_table (column1, column2) VALUES (%s, %s)"
values = ("value1", "value2")

cursor.execute(insert_sql, values)
conn.commit()  # 提交事务

4. 查询数据 (SELECT)

通过执行SELECT语句来查询数据：

# 查询数据
select_sql = "SELECT * FROM your_table"
cursor.execute(select_sql)

# 获取所有结果
results = cursor.fetchall()

for row in results:
    print(row)

5. 更新数据 (UPDATE)

通过执行UPDATE语句来更新数据：

# 更新数据
update_sql = "UPDATE your_table SET column1 = %s WHERE column2 = %s"
values = ("new_value1", "value2")

cursor.execute(update_sql, values)
conn.commit()  # 提交事务

6. 删除数据 (DELETE)

通过执行DELETE语句来删除数据：

# 删除数据
delete_sql = "DELETE FROM your_table WHERE column1 = %s"
values = ("value1",)

cursor.execute(delete_sql, values)
conn.commit()  # 提交事务

7. 关闭连接

操作完成后，别忘了关闭连接：

# 关闭游标和连接
cursor.close()
conn.close()

完整示例代码

import mysql.connector

# 连接数据库
conn = mysql.connector.connect(
    host="your_oceanbase_host", 
    port=your_oceanbase_port,
    user="your_username", 
    password="your_password", 
    database="your_database"
)

cursor = conn.cursor()

# 增加数据
insert_sql = "INSERT INTO your_table (column1, column2) VALUES (%s, %s)"
cursor.execute(insert_sql, ("value1", "value2"))
conn.commit()

# 查询数据
cursor.execute("SELECT * FROM your_table")
for row in cursor.fetchall():
    print(row)

# 更新数据
update_sql = "UPDATE your_table SET column1 = %s WHERE column2 = %s"
cursor.execute(update_sql, ("new_value1", "value2"))
conn.commit()

# 删除数据
delete_sql = "DELETE FROM your_table WHERE column1 = %s"
cursor.execute(delete_sql, ("value1",))
conn.commit()

# 关闭连接
cursor.close()
conn.close()