|
22 | 22 |
|
23 | 23 | systemVersion = sys.version[0] |
24 | 24 | REMOVE_FORMAT = 0 |
| 25 | +maxNodes = 128 |
| 26 | + |
25 | 27 | class EncodedSession(Session): |
26 | 28 | """Class for representing an encoded session with the database. |
27 | 29 | |
@@ -86,6 +88,9 @@ def __init__(self, host, port, service='SQL2'): |
86 | 88 | self.closed = False |
87 | 89 | """ @type : boolean """ |
88 | 90 | self.__encryption = True |
| 91 | + """ @type : boolean """ |
| 92 | + self.__activeNodes = 0 |
| 93 | + """ @type : int """ |
89 | 94 |
|
90 | 95 | # Mostly for connections |
91 | 96 | def open_database(self, db_name, parameters, cp): |
@@ -115,7 +120,7 @@ def open_database(self, db_name, parameters, cp): |
115 | 120 | if protocolVersion >= protocol.PROTOCOL_VERSION17 : |
116 | 121 | connectedNodeId = self.getInt() |
117 | 122 | maxNodes = self.getInt() |
118 | | - |
| 123 | + |
119 | 124 | return protocolVersion, serverKey, salt |
120 | 125 |
|
121 | 126 | def check_auth(self): |
@@ -758,7 +763,10 @@ def getScaledDate(self): |
758 | 763 | def getUUID(self): |
759 | 764 | """Read the next UUID value off the session.""" |
760 | 765 | if self._getTypeCode() == protocol.UUID: |
761 | | - return uuid.UUID(bytes=self._takeBytes(16)) |
| 766 | + byteString = self._takeBytes(16) |
| 767 | + if systemVersion is '3': |
| 768 | + byteString = byteString.encode('latin-1') |
| 769 | + return uuid.UUID(bytes=byteString) |
762 | 770 | if self._getTypeCode() == protocol.SCALEDCOUNT1: |
763 | 771 | # before version 11 |
764 | 772 | pass |
@@ -905,3 +913,9 @@ def isASCII(self, data): |
905 | 913 | return False |
906 | 914 | else: |
907 | 915 | return True |
| 916 | + |
| 917 | + def getCommitInfo(self, nodeID): |
| 918 | + nodeIdx = nodeID % maxNodes |
| 919 | + |
| 920 | + def encodeNodes(self): |
| 921 | + self.putInt(self.__activeNodes) |
0 commit comments