GOMODULES
/
pgx
mirror of https://github.com/jackc/pgx.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix NULL with extendedQueryBuilder

pull/586/head
Jack Christensen 2019-06-01 17:30:38 -05:00
parent c5a70faea6
commit be89cce214
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
extended_query_builder.go
View File

@ -72,20 +72,29 @@ func (eqb *extendedQueryBuilder) encodeExtendedParamValue(ci *pgtype.ConnInfo, o
} }
var err error var err error
var buf []byte
pos := len(eqb.paramValueBytes) pos := len(eqb.paramValueBytes)
switch arg := arg.(type) { switch arg := arg.(type) {
case pgtype.BinaryEncoder: case pgtype.BinaryEncoder:
eqb.paramValueBytes, err = arg.EncodeBinary(ci, eqb.paramValueBytes) buf, err = arg.EncodeBinary(ci, eqb.paramValueBytes)
if err != nil { if err != nil {
return nil, err return nil, err
} }
if buf == nil {
return nil, nil
}
eqb.paramValueBytes = buf
return eqb.paramValueBytes[pos:], nil return eqb.paramValueBytes[pos:], nil
case pgtype.TextEncoder: case pgtype.TextEncoder:
eqb.paramValueBytes, err = arg.EncodeText(ci, eqb.paramValueBytes) buf, err = arg.EncodeText(ci, eqb.paramValueBytes)
if err != nil { if err != nil {
return nil, err return nil, err
} }
if buf == nil {
return nil, nil
}
eqb.paramValueBytes = buf
return eqb.paramValueBytes[pos:], nil return eqb.paramValueBytes[pos:], nil
case string: case string:
return []byte(arg), nil return []byte(arg), nil