从Python执行存储过程

Question

我正在使用一个名为ceODBC的模块并试图调用SQL Server 2005中的存储过程来使用Python3。当我从Sql Server Management Studio运行存储过程（不包含Python）时，我得到正确的结果和278行被插入到所需的表中，但是在Python中它会在31之后停止。谁能告诉我为什么存储过程可能会过早停止？这里是我的Python代码：

import ceODBC 
connect=ceODBC.connect("""DSN=mydatabase;SERVER=xxx.xxx.x.xxx; 
DRIVER={SQLServer};UID=user;PWD=password""", autocommit= True) 
cursor = connect.cursor() 
cursor.execute(""" 
        CREATE TABLE mydatabase.dbo.Vision_TempTable 
        (
        CustId bigint, 
        PayProcId int, 
        WebUserId bigint, 
        SubTypeId bigint, 
        PayAmt decimal(18,2), 
        Paydate datetime, 
        PayType varchar(1), 
        DateCreated datetime, 
        PayStatus varchar(1), 
        Account varchar(30), 
        V_Account varchar(30) 
        )""")#Create a temp table which will be used in the SP insert 
connect.commit() 
f=open('F:/clients/UTA/Vision/Data/ExternalPay_Data/lbox.txt') 
CUST_ID=44 
PAYPROCID=4 
SUBTYPE_ID=64 
WEBUSER_ID=2432 
PAYTYPE='C' 
PAYSTATUS='J' 
for line in f: #parse a text file and insert values into temp table I just created 
    lineLength=len(line.strip()) 
    if lineLength>=49: 
     visionAccount=int(line[10:17]) 
     visionAccount=str(visionAccount) 
     recipientID=line[17:29] 
     invoiceAmount=line[31:39] 
     invoiceAmount=float(invoiceAmount) 
     pmtType=line[39:41]#make sure it will always be ck 
     pmtDate=line[45:47]+'/'+line[47:49]+'/'+line[41:45] 
     cursor.execute("""INSERT INTO mydatabase.dbo.Vision_TempTable 
          (CustId,PayProcId,WebUserId,SubTypeId,PayAmt,Paydate, 
          PayType,DateCreated,PayStatus,Account,V_Account) 
          VALUES 
           (?,?,?,?,?,?,?,GETDATE(),?,?,?)""", 
       CUST_ID,PAYPROCID,WEBUSER_ID,SUBTYPE_ID, 
       invoiceAmount,pmtDate,PAYTYPE,PAYSTATUS,recipientID,visionAccount) 

     connect.commit() 
cursor.callproc("mydatabase.dbo.VisionExternalPMTS")# turn over control to SP 

f.close() 
connect.close() 
print('Done') 

，只是所以我们有全面的了解，我会包括以下存储过程：

USE [mydatabase] 
GO 
/****** Object: StoredProcedure [dbo].[VisionExternalPMTS] Script Date: 06/16/2011 08:38:15 ******/ 
SET ANSI_NULLS ON 
GO 
SET QUOTED_IDENTIFIER ON 
GO 

ALTER PROCEDURE [dbo].[VisionExternalPMTS] as 

BEGIN 
declare @custid bigint, 
@payprocid int, 
@webuserid bigint, 
@subtypeid bigint, 
@payamt decimal(18,2), 
@paydate datetime, 
@paytype varchar(1), 
@datecreated datetime, 
@paystatus varchar(1), 
@account varchar(30), 
@v_account varchar(30) 

DECLARE update_webPayments CURSOR for --select from temp table created in python 
SELECT CustId,PayProcId,WebUserId,SubTypeId,PayAmt,Paydate,PayType, 
     DateCreated,PayStatus 
FROM Vision_TempTable 

OPEN update_webPayments 

FETCH NEXT FROM update_webPayments INTO @custid,@payprocid,@webuserid, 
       @subtypeid,@payamt,@paydate,@paytype,@datecreated, 
       @paystatus 

WHILE @@fetch_status = 0 --insert into target table 
    BEGIN 
     INSERT INTO WEBPAYMENTS(CUSTID,PAYPROCID,WEBUSERID,SUBTYPEID, 
           PAYAMT,PAYDATE,PAYTYPE,DATECREATED,PAYSTATUS) 
     VALUES (@custid,@payprocid,@webuserid,@subtypeid,@payamt, 
       @paydate,@paytype,@datecreated,@paystatus) 
     FETCH NEXT FROM update_webPayments INTO @custid,@payprocid,@webuserid, 
        @subtypeid,@payamt,@paydate,@paytype,@datecreated, 
        @paystatus       
    END 
--DROP TABLE VISION_TempTable 
END 

从Python中的create table语句和初始插件总是工作，我得到278行在我的临时表中，只有当我从python调用存储过程时出现错误。存储过程提前终止。我认为这是因为在程序结束之前，Python可能没有给它足够的时间来执行，所以我尝试了一些计数器到位，但最终得到数据库错误（尽管存储过程正常工作），所以我删除了计数器。我想要的是将控制权交给存储过程，并在存储过程完成之前不返回到python程序。任何帮助将不胜感激。

感谢

Answer 1

看着http://ceodbc.sourceforge.net/html/cursor.html有此评论：

Cursor.execdirect（声明）

反对使用SQLExecDirect而不是SQLExecute数据库执行语句。在某些情况下，由于ODBC驱动程序中存在错误（例如SQL Server ODBC驱动程序在调用某些存储过程时所表现的错误），因此这是必需的。

如果语句是查询，则由于游标实现了迭代器协议并且因此不需要调用其中一种适当的获取方法，所以返回游标作为方便;否则返回无。

听起来好像有一些疯狂的存储过程通过SQL Server ODBC（鉴于他们单挑出来的特殊待遇）。您可能需要尝试：

cursor.execdirect("mydatabase.dbo.VisionExternalPMTS") 

让我知道这是否有效。