From edd8a1a895159031d1114474e4db49e3b158b78a Mon Sep 17 00:00:00 2001
From: Pete Hunt <floydophone@gmail.com>
Date: Wed, 8 Dec 2010 05:56:29 +0000
Subject: [PATCH] Fix for issue 38, thanks google@evax.fr

---
 pymysql/connections.py       | 19 +++++++++++++++----
 pymysql/tests/test_issues.py |  2 +-
 2 files changed, 16 insertions(+), 5 deletions(-)

diff --git a/pymysql/connections.py b/pymysql/connections.py
index 6671373..fb4bcdd 100644
--- a/pymysql/connections.py
+++ b/pymysql/connections.py
@@ -46,7 +46,7 @@ UNSIGNED_INT24_LENGTH = 3
 UNSIGNED_INT64_LENGTH = 8
 
 DEFAULT_CHARSET = 'latin1'
-BUFFER_SIZE = 256*256*256-1
+MAX_PACKET_LENGTH = 256*256*256-1
 
 def dump_packet(data):
     
@@ -667,10 +667,21 @@ class Connection(object):
         return result.affected_rows
 
     def _send_command(self, command, sql):
-        send_data = struct.pack('<i', len(sql) + 1) + command + sql
+        #send_data = struct.pack('<i', len(sql) + 1) + command + sql
+        # could probably be more efficient, at least it's correct
+        buf = command + sql
+        pckt_no = 0
+        while len(buf) >= MAX_PACKET_LENGTH:
+            header = struct.pack('<i', MAX_PACKET_LENGTH)[:-1]+chr(pckt_no)
+            self.socket.send(header+buf[:MAX_PACKET_LENGTH])
+            buf = buf[MAX_PACKET_LENGTH:]
+            pckt_no += 1
+        header = struct.pack('<i', len(buf))[:-1]+chr(pckt_no)
+        self.socket.send(header+buf)
 
-        sock = self.socket
-        sock.send(send_data)
+
+        #sock = self.socket
+        #sock.send(send_data)
 
         if DEBUG: dump_packet(send_data)
 
diff --git a/pymysql/tests/test_issues.py b/pymysql/tests/test_issues.py
index d2f913e..3af30ec 100644
--- a/pymysql/tests/test_issues.py
+++ b/pymysql/tests/test_issues.py
@@ -217,7 +217,7 @@ class TestNewIssues(base.PyMySQLTestCase):
     def test_issue_38(self):
         conn = self.connections[0]
         c = conn.cursor()
-        datum = "a" * 1024 * 1024 * 64
+        datum = "a" * 1024 * 1023 # reduced size for most default mysql installs
         
         try:
             c.execute("create table issue38 (id integer, data mediumblob)")