Python如何执行存储过程,获取存储过程返回值
2011-06-23 23:32
555 查看
在Pathon中如何执行存储过程呢?可以使用如下方法:
存储过程定义基本如下:
ALTER
procedure
[dbo].
[mysp]
@Station varchar
(
50),
@SN varchar
(
50),
@Info varchar
(
500)
output
,
@Msg varchar
(
500)
output
1. 使用adodbapi
Python代码
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
Python代码
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
存储过程定义基本如下:
ALTER
procedure
[dbo].
[mysp]
@Station varchar
(
50),
@SN varchar
(
50),
@Info varchar
(
500)
output
,
@Msg varchar
(
500)
output
1. 使用adodbapi
Python代码
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:
e
else
:
cur = db.cursor()
msg = cur.callproc(sp, (station, sn)) #参数与存储过程有关
if
len(msg) > 1
:
if
msg[-1
] is
None
:
'sn is ok. Can be test at this station'
else
:
msg[-1
]
finally
:
try
: db.close()
except
: pass
2. 使用pymssql
Python代码
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:
e
else
:
cur.nextset() # 要加上这句才能通过fetch函数取到值
注意:这语句在Python2.7对应的pymssql版本中是错误!!!
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
相关文章推荐
- python调用其它脚本:pig,python,shell等等 (如何获取pig脚本执行的返回值)
- python调用其它脚本:pig,python,shell等等 (如何获取pig脚本执行的返回值)
- Python中执行存储过程及获取存储过程返回值的方法
- python执行系统命令后获取返回值的几种方式集合
- EF中执行存储过程,获取output返回值
- python通过getopt模块如何获取执行的命令参数详解
- python 执行shell命令无法获取返回值的解决方法
- shell脚本执行python脚本时,python如何将返回值传给shell脚本
- ASP.NET执行存储过程,并获取存储过程的返回值
- EF中执行存储过程,获取output返回值
- asp.net/C# 执行存储过程技术要点,获取Return返回值,解决“存储过程总返回-1”的问题
- 如何获取sql的exec执行语句的返回值?
- SQL中如何获取存储过程用return返回的值与判断SQL事务是否执行成功?
- python调用存储过程,获取返回值
- golang如何执行脚本并获取返回值
- python执行系统命令后获取返回值
- SQL中如何获取存储过程用return返回的值与判断SQL事务是否执行成功?
- C#Process执行批处理后如何获取返回值?
- SQL技巧:如何获取存储过程用return返回的值与判断SQL Server事务是否执行成功?
- python执行系统命令后获取返回值的几种方式