Updates for PR

Author: madscientist

pynuodb/encodedsession.py

@@ -161,7 +161,7 @@ def __init__(self, host, service='SQL2', options=None, **kwargs):
         super(EncodedSession, self).__init__(host, service=service,
                                              options=options, **kwargs)
 
-    def open_database(self, db_name, password, parameters):  # pylint: disable=too-many-branches
+    def open_database(self, db_name, password, parameters):  # pylint: disable=too-many-branches,too-many-statements
         # type: (str, str, Dict[str, str]) -> None
         """Perform a handshake as a SQL client with a NuoDB TE.
 
@@ -228,12 +228,12 @@ def open_database(self, db_name, password, parameters):  # pylint: disable=too-m
             self.__connectedNodeID = self.getInt()
             self.__maxNodes = self.getInt()
 
-            uuid = str(self.db_uuid)
+            dbid = str(self.db_uuid)
             with EncodedSession.__dblock:
                 if EncodedSession.__databases is None:
                     EncodedSession.__databases = {}
-                if uuid not in EncodedSession.__databases:
-                    EncodedSession.__databases[uuid] = EncodedSession.DbInfo(self.__maxNodes)
+                if dbid not in EncodedSession.__databases:
+                    EncodedSession.__databases[dbid] = EncodedSession.DbInfo(self.__maxNodes)
 
         self.__sessionVersion = protocolVersion
 
@@ -285,7 +285,10 @@ def send_close(self):
     def __set_dbinfo(self, sid, txid, seqid):
         # type: (int, int, int) -> None
         with EncodedSession.__dblock:
-            EncodedSession.__databases[str(self.db_uuid)].info[sid] = (txid, seqid)
+            info = EncodedSession.__databases[str(self.db_uuid)].info
+            lci = info.get(sid, (-1, -1))
+            if seqid > lci[1]:
+                info[sid] = (txid, seqid)
 
     def send_commit(self):
         # type: () -> int