Don't send text query larger than maxPacketAllowed

methane · methane · commit cac6129f8a5c · 2015-01-20T12:17:21.000+09:00
diff --git a/connection.go b/connection.go
@@ -265,6 +265,13 @@ func (mc *mysqlConn) buildQuery(query string, args []driver.Value) (string, erro
 			return "", driver.ErrSkip
 		}
 	}
+	pktSize := len(query) + 4 // 4 bytes for header.
+	for _, p := range parts {
+		pktSize += len(p)
+	}
+	if pktSize > mc.maxPacketAllowed {
+		return "", driver.ErrSkip
+	}
 	return strings.Join(parts, ""), nil
 }
 

Original file line number	Diff line number	Diff line change
`@@ -265,6 +265,13 @@ func (mc *mysqlConn) buildQuery(query string, args []driver.Value) (string, erro`
`265`	`265`	`return "", driver.ErrSkip`
`266`	`266`	`}`
`267`	`267`	`}`
	`268`	`+ pktSize := len(query) + 4 // 4 bytes for header.`
	`269`	`+ for _, p := range parts {`
	`270`	`+ pktSize += len(p)`
	`271`	`+ }`
	`272`	`+ if pktSize > mc.maxPacketAllowed {`
	`273`	`+ return "", driver.ErrSkip`
	`274`	`+ }`
`268`	`275`	`return strings.Join(parts, ""), nil`
`269`	`276`	`}`
`270`	`277`