本文实例讲述了Python中执行存储过程及获取存储过程返回值的方法。分享给大家供大家参考,具体如下:
在Pathon中如何执行存储过程呢?可以使用如下方法:
存储过程定义基本如下:
1
2
3
4
5
|
ALTER procedure [dbo]. [mysp]
@Station varchar ( 50),
@SN varchar ( 50),
@Info varchar ( 500) output ,
@Msg varchar ( 500) output
|
1. 使用adodbapi
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
from adodbapi import connect
server = 'dbserver'
user = 'username'
password = 'password'
database = 'database'
sp = 'sp'
station = 'station'
sn = 'sn'
try :
db = connect('Provider = SQLOLEDB. 1 ;Data Source = % s;Initial Catalog = % s; /
User ID = % s;Password = % s;' % (server, database, user, password))
except Exception, e:
print e
else :
cur = db.cursor()
msg = cur.callproc(sp, (station, sn)) #参数与存储过程有关
if len (msg) > 1 :
if msg[ - 1 ] is None :
print 'sn is ok. Can be test at this station'
else :
print msg[ - 1 ]
finally :
try : db.close()
except : pass
|
2. 使用pymssql
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
|
from pymssql import connect
server = 'dbserver'
user = 'user'
password = 'password'
database = 'database'
sp = 'sp'
station = 'station'
sn = 'sn'
sql = [ 'set nocount on' ]
sql.append( 'declare @Msg varchar(500)' )
sql.append( 'declare @return_value varchar' )
sql.append( "exec @return_value = %s @Station = '%s', @SN = '%s', @Info = '@Info', @Msg = @Msg output" )
sql.append( 'select @Msg, @return_value' )
sql = '/n' .join(sql) % (sp, station, sn)
def ffchk(server, user, password, database, sql):
try :
db = connect(host = server,
database = database,
user = user,
password = password,
login_timeout = 10 )
cur = db.cursor()
cur.execute(sql)
except Exception, e:
print e
else :
cur.nextset() # 要加上这句才能通过fetch函数取到值 注意:这语句在Python2.7对应的pymssql版本中是错误!!!
print cur.fetchone()
finally :
try : db.close()
except : pass
|
总结:
1. adodbapi简单,不用写一串的sql语句,但是不能取到返回的Error Code,只能取到返回的错误信息,也可能是我没找到方法
2. pymssql与第一条相反,可以取到返回值和错误信息,但要写sql语句。
这里重点说明一下使用pymssql的方法
cur.execute("exec 存储过程名 @参数1=XXX, @参数2='YYY'......")
cur.fetchone() #如果该存储过程中有返回结果集,可以调用此句,如果存储过程是return,则pymssql不支持,无法获取,此句错误
conn.commit() #如果没有此句,则数据并没有真正生效,比如存储过程是执行insert的,没有commit的话,并不会真正插入数据
一般通过此三步即可以应对很多使用存储过程的要求
希望本文所述对大家Python程序设计有所帮助。
原文链接:http://blog.csdn.net/andoring/article/details/6564654