我正在使用一个名为ceODBC的模块处理Python3,并试图在SQL Server 2005中调用一个存储过程。当我在sqlservermanagementstudio之外运行存储过程(不涉及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
create table语句和来自Python的初始insert总是有效的,我在temp表中得到278行,只有当我从Python调用存储过程时,才会出错。存储过程提前终止。我认为这是因为Python可能没有给它足够的时间在程序结束前执行,所以我尝试了放置某种计数器,但最终得到了数据库错误(尽管存储过程工作正常),所以我删除了计数器。我想要的是将控制权传递给存储过程,并且在存储过程完成之前不返回到python程序。任何帮助都将不胜感激。
谢谢
看着http://ceodbc.sourceforge.net/html/cursor.html有这样的评论:
Cursor.execdirect(语句)
使用SQLExecDirect而不是SQLExecute对数据库执行语句。这在某些情况下是必要的,因为ODBC驱动程序中存在错误,例如在调用某些存储过程时,sqlserverodbc驱动程序所显示的错误。
如果语句是一个查询,那么返回游标是为了方便起见,因为游标实现了迭代器协议,因此不需要调用适当的fetch方法之一;否则不返回任何方法。
听起来,通过SQL Server ODBC的存储过程有点疯狂(考虑到它们是为了特殊处理而单独使用的)。您可能必须尝试:
如果可以的话告诉我。
相关问题 更多 >
编程相关推荐