在Pathon中如何执行存储过程呢?可以使用如下方法:
存储过程定义基本如下:
ALTER procedure [dbo]. [mysp]
@Station varchar ( 50),
@SN varchar ( 50),
@Info varchar ( 500) output ,
@Msg varchar ( 500) output
1. 使用adodbapi
- 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
- 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的话,并不会真正插入数据
一般通过此三步即可以应对很多使用存储过程的要求
对于存储过程传出数据的方法还有如下的讨论:
http://zh-cn.w3support.net/index.php?db=so&id=191644