cx_oracle capture oracle progress messages

[linux70]

Is it possible, using cx_Oracle to capture the simple messages from oracle, for example, if I am running an insert, in most Oracle tools, it would say '100 rows inserted'. I would like to capture and print these messages in my python program. TIA.

[bartonc]

Is it possible, using cx_Oracle to capture the simple messages from oracle, for example, if I am running an insert, in most Oracle tools, it would say '100 rows inserted'. I would like to capture and print these messages in my python program. TIA.

I had the same problem with MySQL. I solved it by routing the the call to execute through my own cursor like this:

class DBServer:
    def __init__(self, master):
        self.master = master
 
    def Login(self, servername, username, password, database=""):
        try:
            self.dbconnect = connect(host=servername, user=username, passwd=password, db=database)
        except (DatabaseError, OperationalError):
            self.dbconnect = None
            self.master.write('Couldn\'t connect to the database named %s on host %s'
                              %(repr(database), repr(servername)))
            return
        self.dbcursor = self.dbconnect.cursor()
        self.Execute('SET autocommit=1')
        return self.dbconnect
 
    def DBError(self):
        """Remove the current message from the cursor
           and display it."""
        try:
            (error, message) = self.dbcursor.messages.pop()
        except AttributeError:
            (error, message) = self.dbconnect.messages.pop()
        self.master.write('%s #%d:  %s' %(str(error).split('.')[-1],
                                          message[0], message[1]))
 
    def Execute(self, query):
        try:
            cursor = self.dbcursor
            now = time()
            cursor.execute(query)
            nRows = cursor.rowcount
            self.master.write(query)
            self.master.write("%d rows affected: %.2f sec." %(nRows, time() - now))
        except (DatabaseError, OperationalError):
            self.DBError()
            return
        return cursor
 
    def DBExists(self, database):
        """Return True if database exists"""
        resultset = self.Execute("show databases").fetchall()
        ## print resultset
        return (database,) in resultset
 
    def close(self):
        self.dbconnect.close()

I haven't seen the oracle module interface, but if it comforms the the python API, this should work for you, too. You are using python, right?