Как вы получаете выходные параметры из хранимой процедуры в Python?

Question

Я немного погуглил, но, возможно, я не поместил правильное заклинание магии в окно поиска.

Кто-нибудь знает, как получить выходные параметры из хранимой процедуры в Python? Я использую pymssql для вызова хранимой процедуры, и я не уверен в правильном синтаксисе для возврата выходного параметра. Я не думаю, что могу использовать какие-либо другие модули db, так как я запускаю это из коробки Linux для подключения к базе данных mssql на MS Server.

import pymssql

con = pymssql.connect(host='xxxxx',user='xxxx',password='xxxxx',database='xxxxx')

cur = con.cursor()

query = "EXECUTE blah blah blah"

cur.execute(query)
con.commit()
con.close()

Answer 1

Я не эксперт по Python, но после краткого изучения DB-API 2.0 Я считаю, что вы должны использовать метод "callproc" для курсора, например:

cur.callproc('my_stored_proc', (first_param, second_param, an_out_param))

Тогда вы получите результат в возвращаемом значении (выходного параметра) в переменной "an_out_param".

Answer 2

Если вы не можете или не хотите изменять исходную процедуру и иметь доступ к базе данных, вы можете написать простую процедуру-обертку, которая вызывается из python.

Например, если у вас есть хранимая процедура, например:

CREATE PROC GetNextNumber
   @NextNumber int OUTPUT
AS
...

Вы можете написать обертку, которая легко вызывается из python:

CREATE PROC GetNextNumberWrap
AS
    DECLARE @RNextNumber int
    EXEC GetNextNumber @RNextNumber
    SELECT @RNextNumber
GO

Тогда вы могли бы назвать это из python так:

import pymssql
con = pymssql.connect(...)
cur = con.cursor()
cur.execute("EXEC GetNextNumberWrap")
next_num = cur.fetchone()[0]

Answer 3

Мне удалось получить выходное значение из хранимой процедуры SQL с использованием Python. Я не мог найти хорошую помощь, получая выходные значения в Python. Я сам понял синтаксис Python, поэтому я подозреваю, что это стоит опубликовать здесь:

import sys, string, os, shutil, arcgisscripting
from win32com.client import Dispatch
from adoconstants import *

#skip ahead to the important stuff

conn = Dispatch('ADODB.Connection')
conn.ConnectionString = "Provider=sqloledb.1; Data Source=NT38; Integrated Security = SSPI;database=UtilityTicket"
conn.Open()

#Target Procedure Example: EXEC TicketNumExists @ticketNum = 8386998, @exists output

Cmd = Dispatch('ADODB.Command')
Cmd.ActiveConnection = conn

Cmd.CommandType = adCmdStoredProc
Cmd.CommandText = "TicketNumExists"

Param1 = Cmd.CreateParameter('@ticketNum', adInteger, adParamInput)
Param1.Value = str(TicketNumber)
Param2 = Cmd.CreateParameter('@exists', adInteger, adParamOutput)

Cmd.Parameters.Append(Param1)
Cmd.Parameters.Append(Param2)

Cmd.Execute()

Answer = Cmd.Parameters('@exists').Value

Answer 4

Похоже, что каждая библиотека Python dbapi, реализованная поверх freetds (pymssql, pyodbc и т. Д.), Не сможет получить доступ к выходным параметрам при подключении к Microsoft SQL Server 7 SP3 и выше.

http://www.freetds.org/faq.html#ms.output.parameters

Answer 5

Если вы заставите свою процедуру создать таблицу, вы можете использовать этот результат вместо наших параметров.

Так что вместо:

CREATE PROCEDURE Foo (@Bar INT OUT, @Baz INT OUT) AS
BEGIN
   /* Stuff happens here */
   RETURN 0
END

сделать

CREATE PROCEDURE Foo (@Bar INT, @Baz INT) AS
BEGIN
   /* Stuff happens here */
   SELECT @Bar Bar, @Baz Baz
   RETURN 0
END

Answer 6

Вот как я это сделал, ключ в том, чтобы сначала объявить выходной параметр:

import cx_Oracle as Oracle

conn = Oracle.connect('xxxxxxxx')
cur = conn.cursor()

idd = cur.var(Oracle.NUMBER)
cur.execute('begin :idd := seq_inv_turnover_id.nextval; end;', (idd,))
print(idd.getvalue())

Answer 7

Вы можете попытаться переформатировать query:

import pypyodc

connstring = "DRIVER=SQL Server;"\
             "SERVER=servername;"\
             "PORT=1043;"\
             "DATABASE=dbname;"\
             "UID=user;"\
             "PWD=pwd"

conn = pypyodbc.connect(connString)
cursor = conn.cursor()

query="DECLARE @ivar INT \r\n" \
      "DECLARE @svar VARCHAR(MAX) \r\n" \
      "EXEC [procedure]" \
      "@par1=?," \
      "@par2=?," \
      "@param1=@ivar OUTPUT," \
      "@param2=@svar OUTPUT \r\n" \
      "SELECT @ivar, @svar \r\n"
par1=0
par2=0
params=[par1, par2]
result = cursor.execute(query, params)
print result.fetchall()

[1] https://amybughunter.wordpress.com/tag/pypyodbc/

Answer 8

2016 обновление (поддержка callproc в pymssql 2.x)

pymssql v2.x предлагает ограниченную поддержку callproc. Он поддерживает параметры OUTPUT с использованием синтаксиса параметра pymssql.output(). Однако обратите внимание, что параметры OUTPUT могут быть получены только с помощью callproc, если хранимая процедура не также возвращает набор результатов. Эта проблема обсуждается на GitHub здесь .

Для хранимых процедур, которые не возвращают набор результатов

С учетом хранимой процедуры T-SQL

CREATE PROCEDURE [dbo].[myDoubler] 
    @in int = 0, 
    @out int OUTPUT
AS
BEGIN
    SET NOCOUNT ON;
    SELECT @out = @in * 2;
END

код Питона

import pymssql
conn = pymssql.connect(
    host=r'localhost:49242',
    database='myDb',
    autocommit=True
    )
crsr = conn.cursor()

sql = "dbo.myDoubler"
params = (3, pymssql.output(int, 0))
foo = crsr.callproc(sql, params)
print(foo)
conn.close()

производит следующий вывод

(3, 6)

Обратите внимание, что callproc возвращает кортеж параметра со значением параметра OUTPUT, назначенным хранимой процедурой (в данном случае foo[1]).

Для хранимых процедур, которые возвращают набор результатов

Если хранимая процедура возвращает один или несколько наборов результатов , а также возвращает выходные параметры, нам нужно использовать блок анонимного кода для получения значений выходных параметров:

Хранимая процедура:

ALTER PROCEDURE [dbo].[myDoubler] 
    @in int = 0, 
    @out int OUTPUT
AS
BEGIN
    SET NOCOUNT ON;
    SELECT @out = @in * 2;
    -- now let's return a result set, too
    SELECT 'foo' AS thing UNION ALL SELECT 'bar' AS thing;
END

Код Python:

sql = """\
DECLARE @out_value INT;
EXEC dbo.myDoubler @in = %s, @out = @out_value OUTPUT;
SELECT @out_value AS out_value;
"""
params = (3,)
crsr.execute(sql, params)
rows = crsr.fetchall()
while rows:
    print(rows)
    if crsr.nextset():
        rows = crsr.fetchall()
    else:
        rows = None

Результат:

[('foo',), ('bar',)]
[(6,)]

Answer 9

Вы также можете использовать SELECT, а не EXECUTE. EXECUTE - это (iirc) в основном SELECT, который фактически ничего не извлекает (просто вызывает побочные эффекты).