如何使用 Python 在 MySQL 数据库中执行存储过程
要在 Python 中执行 MySQL 存储过程,需要使用 MySQLdb 模块,并通过该模块建立数据库连接。下面是详细的代码演示:
import MySQLdb # 建立数据库连接 conn = MySQLdb.connect(host='localhost', user='root', password='123456', db='testdb', charset='utf8') # 创建游标对象 cursor = conn.cursor() # 声明要执行的存储过程 procedure = 'CALL test_procedure(%s, %s)' # 定义存储过程需要的参数 param1 = 'pidancode.com' param2 = '皮蛋编程' # 执行存储过程 cursor.execute(procedure, (param1, param2)) # 记得提交事务 conn.commit() # 关闭数据库连接 conn.close()
其中,test_procedure 是一个存储过程的名字,它接收两个参数:param1 和 param2。在代码中,我们使用字符串“pidancode.com”和“皮蛋编程”作为参数传递给存储过程。
在执行存储过程时,需要使用游标对象的 execute() 方法,并传递参数。如果存储过程有返回值,可以通过 fetchone() 或 fetchall() 方法获取结果。
最后,记得提交事务并关闭数据库连接。
相关文章