1、需要使用的模块MySQLdb，下载地址为：http://sourceforge.net/projects/mysql-python/
2、实现代码如下：
|
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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
#!/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[
0
], e.args[
1
])
return
None
|
本文转自 许大树 51CTO博客，原文链接：http://blog.51cto.com/abelxu/1872988，如需转载请自行联系原作者
