From 81cc33f1edfc7a7545cb75c51c6fa1974a467f52 Mon Sep 17 00:00:00 2001 From: Jack Christensen Date: Fri, 4 Jul 2014 13:29:23 -0500 Subject: [PATCH] Use writeBuf more --- conn.go | 30 +++++++++++------------------- 1 file changed, 11 insertions(+), 19 deletions(-) diff --git a/conn.go b/conn.go index 9b7514f7..ccd2b593 100644 --- a/conn.go +++ b/conn.go @@ -416,29 +416,21 @@ func (c *Conn) Prepare(name, sql string) (ps *PreparedStatement, err error) { }() // parse - buf := c.getBuf() - buf.WriteString(name) - buf.WriteByte(0) - buf.WriteString(sql) - buf.WriteByte(0) - binary.Write(buf, binary.BigEndian, int16(0)) - err = c.txMsg('P', buf) - if err != nil { - return nil, err - } + wbuf := newWriteBuf(c.wbuf[0:0], 'P') + wbuf.WriteCString(name) + wbuf.WriteCString(sql) + wbuf.WriteInt16(0) // describe - buf = c.getBuf() - buf.WriteByte('S') - buf.WriteString(name) - buf.WriteByte(0) - err = c.txMsg('D', buf) - if err != nil { - return nil, err - } + wbuf.startMsg('D') + wbuf.WriteByte('S') + wbuf.WriteCString(name) // sync - err = c.txMsg('S', c.getBuf()) + wbuf.startMsg('S') + wbuf.closeMsg() + + _, err = c.conn.Write(wbuf.buf) if err != nil { return nil, err }