0

InfoMessage現在、コマンドの実行時に ADO (および SQL サーバー) からイベントによって返される完了メッセージのパーセンテージを取得しようとしていますBACKUP。（詳細については、私の以前の質問を参照してください）。

SQLサーバーに接続してSQLコマンドを発行し、イベントを取得してイベントを返すことができました。ただし、BACKUPコマンドを実行するとcmd.Execute、バックアップが完了するまでメソッドがブロックされます。

しかし、この間に 1つの InfoMessageイベント コール (「1 パーセント完了」などのメッセージが表示されます) を受信し、その後はそれ以上イベントを受信しません。

ストアド プロシージャを使用してこれを試しました。ストアド プロシージャは 3 つのメッセージを出力しますが、ここでも最初のメッセージだけが表示されます。

を呼び出す必要があると思いますpythoncom.PumpWaitingMessages()が、cmd.Execute()呼び出しがブロックされるため、何の役にも立ちません。

InfoMessage1 つのイベントだけでなく、それ以上のものを取得する方法を誰かが考え出すことはできますか?

以下は、私が現在使用しているコードです。

import win32com
import pythoncom
import adodbapi
import time
import win32gui
from win32com.client import gencache
gencache.EnsureModule('{2A75196C-D9EB-4129-B803-931327F72D5C}', 0, 2, 8)

defaultNamedOptArg=pythoncom.Empty
defaultNamedNotOptArg=pythoncom.Empty
defaultUnnamedArg=pythoncom.Empty

global connected
connected = False

class events():
    def OnInfoMessage(self, pError, adStatus, pConnection):
        print 'Info Message'
        a = pError.QueryInterface(pythoncom.IID_IDispatch)
        a = win32com.client.Dispatch(a)
        print a.Description
        print a.Number
        print a.Source
        #print 'B', adStatus
        c = pConnection.QueryInterface(pythoncom.IID_IDispatch)
        c = win32com.client.Dispatch(c)
        print c.Errors.Count
        print c.Errors.Item(0).Description
        return 1

    def OnCommitTransComplete(self, pError=defaultNamedNotOptArg, adStatus=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg): pass
    def OnWillExecute(self, Source=defaultNamedNotOptArg, CursorType=defaultNamedNotOptArg, LockType=defaultNamedNotOptArg, Options=defaultNamedNotOptArg
            , adStatus=defaultNamedNotOptArg, pCommand=defaultNamedNotOptArg, pRecordset=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg):
        print 'Execute Event'
        return Source
    def OnDisconnect(self, adStatus=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg): 
        print 'Disconnected'
    def OnExecuteComplete(self, RecordsAffected=defaultNamedNotOptArg, pError=defaultNamedNotOptArg, adStatus=defaultNamedNotOptArg, pCommand=defaultNamedNotOptArg
            , pRecordset=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg):
        print 'Execute complete'
    def OnWillConnect(self, ConnectionString=defaultNamedNotOptArg, UserID=defaultNamedNotOptArg, Password=defaultNamedNotOptArg, Options=defaultNamedNotOptArg
            , adStatus=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg):
        print 'About to connect'
    def OnConnectComplete(self, pError=defaultNamedNotOptArg, adStatus=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg):
        print 'Connected'
        global connected
        connected = True
    def OnBeginTransComplete(self, TransactionLevel=defaultNamedNotOptArg, pError=defaultNamedNotOptArg, adStatus=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg):pass
    def OnRollbackTransComplete(self, pError=defaultNamedNotOptArg, adStatus=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg): pass

if __name__ == '__main__':

    pythoncom.CoInitialize()
    conn = win32com.client.DispatchWithEvents("ADODB.Connection", events)

    conn.ConnectionString = 'Data Source=HPDX2250RAAZ\\SQLEXPRESS; Provider=SQLOLEDB; Integrated Security=SSPI'
    conn.CommandTimeout = 30
    conn.CursorLocation = 2
    conn.Open(pythoncom.Empty,pythoncom.Empty,pythoncom.Empty,0x10)

    while not connected:
        #pythoncom.PumpWaitingMessages()
        win32gui.PumpWaitingMessages()
        time.sleep(0.1)

    conn.BeginTrans()
    conn.Errors.Clear()
    cmd=win32com.client.Dispatch("ADODB.Command")
    cmd.ActiveConnection=conn
    cmd.CommandTimeout = 30  #v2.1 Simons
    cmd.CommandText="EXECUTE [test].[dbo].[Test] "
    print 'Execute'
    cmd.Execute()

    pythoncom.PumpWaitingMessages()
    print 'Called'
    print ''
    print conn.Errors.Count
    conn.RollbackTrans()
    conn.Close()
4

2 に答える 2

1

私は同じ問題を抱えていましたが、同じ問題が発生している場合、メッセージは基本的に SQL Server エンジン自体によって保持されています。これを回避するには、処理が終了するまでメッセージを送信するのではなく、メッセージが発生したときに送信するように SQL に指示する必要があります。これを試着してサイズを確認してください：

SET @message = 'My message...'
RAISERROR (@message, 10, 1) WITH NOWAIT

これによりメッセージが送信され、システムが進むにつれてフロントエンドがこれらを取得する必要があります。

お役に立てれば

于 2011-06-30T17:39:55.663 に答える
0

pymssql およびその他のドライバーと互換性のある回避策を見つけました。SQL Server のバックアップまたは復元プロセスの進行状況を確認するために使用できる SQL スクリプトはありますか? の SQL を使用していますか? さらに、X 秒ごとにそのクエリを実行するバックグラウンド スレッド。ここで、通知のためにhttp://pydispatcher.sourceforge.net/を使用して進行状況を取得します。

#This is rough extract from my actual code. Probably not work as is, but outline the idea
import dispatch #Decoupled send of messages, identical to django signals

def monitorBackup(self):
    return self.selectSql(SQL_MONITOR)

def backup(sql):
    con = self.getCon() #Get new connection, we are in another thread!
    con.execute_query("HERE THE BACKUP SQL")

result = threading.Thread(target=partial(backup, sql))

result.start()

while result.isAlive():
    time.sleep(5) # with the monitor SQL result, is possible to get a estimated time to complete and adjust this...
    rows = self.monitorBackup()

    if len(rows) > 0:
        percentage = rows[0].Percent

        self.send(
            msg="%d %%" % percentage,
            action="progress",
            progress=percentage
        )
于 2012-12-20T23:58:47.403 に答える