1

我的要求是我需要启动一个 sqlcmd 进程，然后将 sql 语句提供给该进程并检索在该场景中生成的输出。在你们建议我使用 sql 库来运行 sqlcmd 之前，让我告诉你我不能这样做，我需要仅使用 sqlcmd 来实现它。

这是我当前的代码

from subprocess import Popen, PIPE

def ms_sql_session():
    IP = "xxxx"
    port = '1433'
    username = 'sa'
    password = 'abc'
    connString = 'sqlcmd -S tcp:%s,%s -dmaster -U%s -P%s ' %(IP, port, username, password)

    try:
        session = Popen(connString, stdin=PIPE, stdout=PIPE, stderr=PIPE)
        str_cmd = '''select @@version;
        go
        '''
        session.stdin.write(str_cmd)
        stdout, stderr = session.communicate()
        print stdout
        print stderr
        str_cmd = '''select @@version;
        go
        '''
        session.stdin.write(str_cmd)
        #stdout, stderr = session.communicate()
        print stdout
        print stderr
        str_cmd = '''select @@version;
        go'''
        session.stdin.write(str_cmd)
        #stdout, stderr = session.communicate()
        print stdout
        print stderr
        return True
    except Exception, e:
        print str(e)
        return False

ms_sql_session()

我正在尝试执行 3 语句并检索 o/p，但在第二个 stdin.write 操作时出现异常

------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Microsoft SQL Server 2005 - 9.00.5000.00 (Intel X86) 
    Dec 10 2010 10:56:29 
    Copyright (c) 1988-2005 Microsoft Corporation
    Developer Edition on Windows NT 5.2 (Build 3790: Service Pack 2)


(1 rows affected)


I/O operation on closed file

这是我的代码的输出。

4

1 回答 1

0

为什么要为此使用系统cmd？我建议为此使用 SQL 库...

于 2013-11-06T06:59:22.613 回答