Bytes

Author: technige

neo4j/bolt/connection.py

@@ -111,6 +111,13 @@ def supports_statement_reuse(self):
             return False
         return self.version_info() >= (3, 2)
 
+    def supports_bytes(self):
+        if not self.version:
+            return False
+        if self.product() != "Neo4j":
+            return False
+        return self.version_info() >= (3, 2)
+
 
 class Connection(object):
     """ Server connection for Bolt protocol v1.
@@ -177,6 +184,7 @@ def __init__(self, sock, **config):
         self.sync()
 
         self._supports_statement_reuse = self.server.supports_statement_reuse()
+        self.packer.supports_bytes = self.server.supports_bytes()
 
     def __del__(self):
         self.close()

neo4j/bolt/io.py

@@ -254,4 +254,4 @@ def view(self):
         if chunk_size == 0:
             return memoryview(self._data[:self._header])
         else:
-            return memoryview(self._data[:end])
+            return memoryview(self._data[:end])