Я пытаюсь подключиться к SQL-серверу, используя приведенный ниже код. Я получаю сообщение об ошибке с недопустимым аргументом. Я пытаюсь прочитать из файла sql и выполнить запрос в сеансе, созданном popen с помощью sqlcmd.
Мой файл SQL содержит этот код -
select @@version;
GO
это мой код Python для подключения и запуска команды. Я получаю сообщение "[Errno 22] Неверный аргумент"
import os
import subprocess
from subprocess import Popen, PIPE, STDOUT
def ms_sql_session():
ip_addr = "xxx.xxx.xxx.xxx,1433"
user = 'sa'
password = 'password'
connection_string = 'sqlcmd -S %s -U %s -P %s' %(ip_addr, user, password)
try:
session = Popen(connection_string, stdin=PIPE, stdout=PIPE, stderr=PIPE)
f = open('abc.sql','r')
str_cmd = f.read()
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()
Как я могу дегугировать такую ситуацию. Я новичок в sql, поэтому я не уверен, что это проблема с моим кодом или с тем, как работает stdin.
Я могу запустить команду с помощью утилиты sqlcmd в командной строке. Я использую sqlcmd для sql 2005