Python操作Mysql数据库的实现
#!/usr/bin/env python# encoding: utf-8
import MySQLdb
# 数据操作类
class DBHelper:
"""
数据操作类,提供数据操作的方法
"""
def __init__(self, host, user, password, port, database):
self.host = host
self.user = user
self.port = port
self.password = password
self.database = database
def call_procedure(self, procedure_name, tuple_parameters):
"""
procedure_name: 被调用的存储过程
tuple_parameters: 使用的参数
返回结果:
"""
try:
conn = MySQLdb.connect(host=self.host,
user=self.user,
passwd=self.password,
port=self.port,
db=self.database)
conn.autocommit(True)
cur = conn.cursor()
cur.callproc(procedure_name, tuple_parameters)
data = cur.fetchall()
cur.close()
conn.close()
return data
except MySQLdb.Error, e:
print "存储过程执行出错: %d: %s" % (e.args, e.args)
return None
页:
[1]