From 718c4dfdc878667d5fa81773d9dac692283261e2 Mon Sep 17 00:00:00 2001 From: Jack Christensen Date: Mon, 30 Jun 2014 08:14:13 -0500 Subject: [PATCH] Add *RowReader.ReadInt64 --- conn.go | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/conn.go b/conn.go index d68b62cf..22e5f455 100644 --- a/conn.go +++ b/conn.go @@ -603,6 +603,17 @@ func (rr *RowReader) ReadInt32(qr *QueryResult) int32 { return decodeInt4(qr, fd, size) } +func (rr *RowReader) ReadInt64(qr *QueryResult) int64 { + fd, size := qr.NextColumn() + + // TODO - do something about nulls + if size == -1 { + panic("Can't handle nulls") + } + + return decodeInt8(qr, fd, size) +} + func (rr *RowReader) ReadTime(qr *QueryResult) time.Time { fd, size := qr.NextColumn()