Merge pull request #7713 from planetscale/prepare-resp-packets

COM_PREPARE - Single TCP response packet with all MySQL Packets
vitessio · Mar 19, 2021 · ef31a7a · ef31a7a
2 parents 289d44b + a55523d
commit ef31a7a
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/go/mysql/conn.go b/go/mysql/conn.go
@@ -1071,7 +1071,15 @@ func (c *Conn) handleComStmtExecute(handler Handler, data []byte) (kontinue bool
  return true
 }
 
-func (c *Conn) handleComPrepare(handler Handler, data []byte) bool {
+func (c *Conn) handleComPrepare(handler Handler, data []byte) (kontinue bool) {
+ c.startWriterBuffering()
+ defer func() {
+ if err := c.endWriterBuffering(); err != nil {
+ log.Errorf("conn %v: flush() failed: %v", c.ID(), err)
+ kontinue = false
+ }
+ }()
+
  query := c.parseComPrepare(data)
  c.recycleReadPacket()