Python中执行存储过程及获取存储过程返回值的方法
本文实例讲述了Python中执行存储过程及获取存储过程返回值的方法。分享给大家供大家参考,具体如下:
在Pathon中如何执行存储过程呢?可以使用如下方法:
存储过程定义基本如下:
ALTERprocedure[dbo].[mysp] @Stationvarchar(50), @SNvarchar(50), @Infovarchar(500)output, @Msgvarchar(500)output
1.使用adodbapi
fromadodbapiimportconnect server='dbserver' user='username' password='password' database='database' sp='sp' station='station' sn='sn' try: db=connect('Provider=SQLOLEDB.1;DataSource=%s;InitialCatalog=%s;/ UserID=%s;Password=%s;'%(server,database,user,password)) exceptException,e: printe else: cur=db.cursor() msg=cur.callproc(sp,(station,sn))#参数与存储过程有关 iflen(msg)>1: ifmsg[-1]isNone: print'snisok.Canbetestatthisstation' else: printmsg[-1] finally: try:db.close() except:pass
2.使用pymssql
frompymssqlimportconnect server='dbserver' user='user' password='password' database='database' sp='sp' station='station' sn='sn' sql=['setnocounton'] sql.append('declare@Msgvarchar(500)') sql.append('declare@return_valuevarchar') sql.append("exec@return_value=%s@Station='%s',@SN='%s',@Info='@Info',@Msg=@Msgoutput") sql.append('select@Msg,@return_value') sql='/n'.join(sql)%(sp,station,sn) defffchk(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) exceptException,e: printe else: cur.nextset()#要加上这句才能通过fetch函数取到值注意:这语句在Python2.7对应的pymssql版本中是错误!!! printcur.fetchone() finally: try:db.close() except:pass
总结:
1.adodbapi简单,不用写一串的sql语句,但是不能取到返回的ErrorCode,只能取到返回的错误信息,也可能是我没找到方法
2.pymssql与第一条相反,可以取到返回值和错误信息,但要写sql语句。
这里重点说明一下使用pymssql的方法
cur.execute("exec存储过程名@参数1=XXX,@参数2='YYY'......")
cur.fetchone() #如果该存储过程中有返回结果集,可以调用此句,如果存储过程是return,则pymssql不支持,无法获取,此句错误
conn.commit() #如果没有此句,则数据并没有真正生效,比如存储过程是执行insert的,没有commit的话,并不会真正插入数据
一般通过此三步即可以应对很多使用存储过程的要求
更多关于Python相关内容感兴趣的读者可查看本站专题:《Python常见数据库操作技巧汇总》、《Python编码操作技巧总结》、《Python数据结构与算法教程》、《PythonSocket编程技巧总结》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。