mirror of https://github.com/jackc/pgx.git
Value, EncodeBinary, EncodeText, and MarshalJSON on T instead of *T
Methods defined on T are also available on *T. This change makes Value consistent with database/sql Value implementations. It also makes Value, EncodeBinary, and EncodeText more convenient to use because you can pass T or *T as an argument to a query. The MarshalJSON change is even more significant because without it json.Marshal would generate the "%v" format instead of the implemented MarshalJSON. Thought this technically changes the interface, because *T will be automatically dereferenced as needed it shouldn't be a breaking change. See: https://github.com/jackc/pgx/issues/538 for initial discussion.non-blocking
parent
b1e25e4ea4
commit
a8802b16cc
|
@ -84,7 +84,7 @@ func (dst *ACLItem) DecodeText(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *ACLItem) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src ACLItem) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -115,7 +115,7 @@ func (dst *ACLItem) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *ACLItem) Value() (driver.Value, error) {
|
||||
func (src ACLItem) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return src.String, nil
|
||||
|
|
|
@ -124,7 +124,7 @@ func (dst *ACLItemArray) DecodeText(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *ACLItemArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src ACLItemArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -200,7 +200,7 @@ func (dst *ACLItemArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *ACLItemArray) Value() (driver.Value, error) {
|
||||
func (src ACLItemArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
2
array.go
2
array.go
|
@ -60,7 +60,7 @@ func (dst *ArrayHeader) DecodeBinary(ci *ConnInfo, src []byte) (int, error) {
|
|||
return rp, nil
|
||||
}
|
||||
|
||||
func (src *ArrayHeader) EncodeBinary(ci *ConnInfo, buf []byte) []byte {
|
||||
func (src ArrayHeader) EncodeBinary(ci *ConnInfo, buf []byte) []byte {
|
||||
buf = pgio.AppendInt32(buf, int32(len(src.Dimensions)))
|
||||
|
||||
var containsNull int32
|
||||
|
|
8
bit.go
8
bit.go
|
@ -22,8 +22,8 @@ func (dst *Bit) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return (*Varbit)(dst).DecodeBinary(ci, src)
|
||||
}
|
||||
|
||||
func (src *Bit) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*Varbit)(src).EncodeBinary(ci, buf)
|
||||
func (src Bit) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (Varbit)(src).EncodeBinary(ci, buf)
|
||||
}
|
||||
|
||||
// Scan implements the database/sql Scanner interface.
|
||||
|
@ -32,6 +32,6 @@ func (dst *Bit) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Bit) Value() (driver.Value, error) {
|
||||
return (*Varbit)(src).Value()
|
||||
func (src Bit) Value() (driver.Value, error) {
|
||||
return (Varbit)(src).Value()
|
||||
}
|
||||
|
|
6
bool.go
6
bool.go
|
@ -96,7 +96,7 @@ func (dst *Bool) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Bool) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Bool) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -113,7 +113,7 @@ func (src *Bool) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Bool) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Bool) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -153,7 +153,7 @@ func (dst *Bool) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Bool) Value() (driver.Value, error) {
|
||||
func (src Bool) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return src.Bool, nil
|
||||
|
|
|
@ -168,7 +168,7 @@ func (dst *BoolArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *BoolArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src BoolArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -225,7 +225,7 @@ func (src *BoolArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *BoolArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src BoolArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -288,7 +288,7 @@ func (dst *BoolArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *BoolArray) Value() (driver.Value, error) {
|
||||
func (src BoolArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
6
box.go
6
box.go
|
@ -108,7 +108,7 @@ func (dst *Box) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Box) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Box) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -125,7 +125,7 @@ func (src *Box) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Box) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Box) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -161,6 +161,6 @@ func (dst *Box) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Box) Value() (driver.Value, error) {
|
||||
func (src Box) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
16
bpchar.go
16
bpchar.go
|
@ -41,12 +41,12 @@ func (dst *BPChar) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return (*Text)(dst).DecodeBinary(ci, src)
|
||||
}
|
||||
|
||||
func (src *BPChar) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*Text)(src).EncodeText(ci, buf)
|
||||
func (src BPChar) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (Text)(src).EncodeText(ci, buf)
|
||||
}
|
||||
|
||||
func (src *BPChar) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*Text)(src).EncodeBinary(ci, buf)
|
||||
func (src BPChar) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (Text)(src).EncodeBinary(ci, buf)
|
||||
}
|
||||
|
||||
// Scan implements the database/sql Scanner interface.
|
||||
|
@ -55,12 +55,12 @@ func (dst *BPChar) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *BPChar) Value() (driver.Value, error) {
|
||||
return (*Text)(src).Value()
|
||||
func (src BPChar) Value() (driver.Value, error) {
|
||||
return (Text)(src).Value()
|
||||
}
|
||||
|
||||
func (src *BPChar) MarshalJSON() ([]byte, error) {
|
||||
return (*Text)(src).MarshalJSON()
|
||||
func (src BPChar) MarshalJSON() ([]byte, error) {
|
||||
return (Text)(src).MarshalJSON()
|
||||
}
|
||||
|
||||
func (dst *BPChar) UnmarshalJSON(b []byte) error {
|
||||
|
|
|
@ -168,7 +168,7 @@ func (dst *BPCharArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *BPCharArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src BPCharArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -225,7 +225,7 @@ func (src *BPCharArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *BPCharArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src BPCharArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -288,7 +288,7 @@ func (dst *BPCharArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *BPCharArray) Value() (driver.Value, error) {
|
||||
func (src BPCharArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
6
bytea.go
6
bytea.go
|
@ -100,7 +100,7 @@ func (dst *Bytea) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Bytea) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Bytea) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -113,7 +113,7 @@ func (src *Bytea) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Bytea) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Bytea) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -145,7 +145,7 @@ func (dst *Bytea) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Bytea) Value() (driver.Value, error) {
|
||||
func (src Bytea) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return src.Bytes, nil
|
||||
|
|
|
@ -168,7 +168,7 @@ func (dst *ByteaArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *ByteaArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src ByteaArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -225,7 +225,7 @@ func (src *ByteaArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *ByteaArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src ByteaArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -288,7 +288,7 @@ func (dst *ByteaArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *ByteaArray) Value() (driver.Value, error) {
|
||||
func (src ByteaArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
12
cid.go
12
cid.go
|
@ -42,12 +42,12 @@ func (dst *CID) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return (*pguint32)(dst).DecodeBinary(ci, src)
|
||||
}
|
||||
|
||||
func (src *CID) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*pguint32)(src).EncodeText(ci, buf)
|
||||
func (src CID) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (pguint32)(src).EncodeText(ci, buf)
|
||||
}
|
||||
|
||||
func (src *CID) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*pguint32)(src).EncodeBinary(ci, buf)
|
||||
func (src CID) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (pguint32)(src).EncodeBinary(ci, buf)
|
||||
}
|
||||
|
||||
// Scan implements the database/sql Scanner interface.
|
||||
|
@ -56,6 +56,6 @@ func (dst *CID) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *CID) Value() (driver.Value, error) {
|
||||
return (*pguint32)(src).Value()
|
||||
func (src CID) Value() (driver.Value, error) {
|
||||
return (pguint32)(src).Value()
|
||||
}
|
||||
|
|
8
cidr.go
8
cidr.go
|
@ -22,10 +22,10 @@ func (dst *CIDR) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return (*Inet)(dst).DecodeBinary(ci, src)
|
||||
}
|
||||
|
||||
func (src *CIDR) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*Inet)(src).EncodeText(ci, buf)
|
||||
func (src CIDR) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (Inet)(src).EncodeText(ci, buf)
|
||||
}
|
||||
|
||||
func (src *CIDR) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*Inet)(src).EncodeBinary(ci, buf)
|
||||
func (src CIDR) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (Inet)(src).EncodeBinary(ci, buf)
|
||||
}
|
||||
|
|
|
@ -197,7 +197,7 @@ func (dst *CIDRArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *CIDRArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src CIDRArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -254,7 +254,7 @@ func (src *CIDRArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *CIDRArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src CIDRArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -317,7 +317,7 @@ func (dst *CIDRArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *CIDRArray) Value() (driver.Value, error) {
|
||||
func (src CIDRArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
|
@ -95,7 +95,7 @@ func (dst *Circle) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Circle) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Circle) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -112,7 +112,7 @@ func (src *Circle) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Circle) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Circle) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -146,6 +146,6 @@ func (dst *Circle) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Circle) Value() (driver.Value, error) {
|
||||
func (src Circle) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
6
date.go
6
date.go
|
@ -125,7 +125,7 @@ func (dst *Date) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Date) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Date) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -147,7 +147,7 @@ func (src *Date) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return append(buf, s...), nil
|
||||
}
|
||||
|
||||
func (src *Date) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Date) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -195,7 +195,7 @@ func (dst *Date) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Date) Value() (driver.Value, error) {
|
||||
func (src Date) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
if src.InfinityModifier != None {
|
||||
|
|
|
@ -169,7 +169,7 @@ func (dst *DateArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *DateArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src DateArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -226,7 +226,7 @@ func (src *DateArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *DateArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src DateArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -289,7 +289,7 @@ func (dst *DateArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *DateArray) Value() (driver.Value, error) {
|
||||
func (src DateArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
|
@ -124,7 +124,7 @@ func (dst *EnumArray) DecodeText(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *EnumArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src EnumArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -200,7 +200,7 @@ func (dst *EnumArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *EnumArray) Value() (driver.Value, error) {
|
||||
func (src EnumArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
|
@ -117,7 +117,7 @@ func (dst *UUID) DecodeBinary(ci *pgtype.ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *UUID) EncodeText(ci *pgtype.ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src UUID) EncodeText(ci *pgtype.ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case pgtype.Null:
|
||||
return nil, nil
|
||||
|
@ -128,7 +128,7 @@ func (src *UUID) EncodeText(ci *pgtype.ConnInfo, buf []byte) ([]byte, error) {
|
|||
return append(buf, src.UUID.String()...), nil
|
||||
}
|
||||
|
||||
func (src *UUID) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src UUID) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case pgtype.Null:
|
||||
return nil, nil
|
||||
|
@ -157,6 +157,6 @@ func (dst *UUID) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *UUID) Value() (driver.Value, error) {
|
||||
func (src UUID) Value() (driver.Value, error) {
|
||||
return pgtype.EncodeValueText(src)
|
||||
}
|
||||
|
|
|
@ -257,7 +257,7 @@ func (dst *Numeric) DecodeBinary(ci *pgtype.ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Numeric) EncodeText(ci *pgtype.ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Numeric) EncodeText(ci *pgtype.ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case pgtype.Null:
|
||||
return nil, nil
|
||||
|
@ -268,7 +268,7 @@ func (src *Numeric) EncodeText(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)
|
|||
return append(buf, src.Decimal.String()...), nil
|
||||
}
|
||||
|
||||
func (src *Numeric) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Numeric) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case pgtype.Null:
|
||||
return nil, nil
|
||||
|
@ -306,7 +306,7 @@ func (dst *Numeric) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Numeric) Value() (driver.Value, error) {
|
||||
func (src Numeric) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case pgtype.Present:
|
||||
return src.Decimal.Value()
|
||||
|
|
|
@ -138,7 +138,7 @@ func (dst *Float4) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Float4) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Float4) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -150,7 +150,7 @@ func (src *Float4) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Float4) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Float4) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -185,7 +185,7 @@ func (dst *Float4) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Float4) Value() (driver.Value, error) {
|
||||
func (src Float4) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return float64(src.Float), nil
|
||||
|
|
|
@ -168,7 +168,7 @@ func (dst *Float4Array) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Float4Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Float4Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -225,7 +225,7 @@ func (src *Float4Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Float4Array) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Float4Array) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -288,7 +288,7 @@ func (dst *Float4Array) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Float4Array) Value() (driver.Value, error) {
|
||||
func (src Float4Array) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
|
@ -128,7 +128,7 @@ func (dst *Float8) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Float8) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Float8) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -140,7 +140,7 @@ func (src *Float8) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Float8) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Float8) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -175,7 +175,7 @@ func (dst *Float8) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Float8) Value() (driver.Value, error) {
|
||||
func (src Float8) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return src.Float, nil
|
||||
|
|
|
@ -168,7 +168,7 @@ func (dst *Float8Array) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Float8Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Float8Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -225,7 +225,7 @@ func (src *Float8Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Float8Array) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Float8Array) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -288,7 +288,7 @@ func (dst *Float8Array) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Float8Array) Value() (driver.Value, error) {
|
||||
func (src Float8Array) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
|
@ -24,8 +24,8 @@ func (dst *GenericBinary) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return (*Bytea)(dst).DecodeBinary(ci, src)
|
||||
}
|
||||
|
||||
func (src *GenericBinary) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*Bytea)(src).EncodeBinary(ci, buf)
|
||||
func (src GenericBinary) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (Bytea)(src).EncodeBinary(ci, buf)
|
||||
}
|
||||
|
||||
// Scan implements the database/sql Scanner interface.
|
||||
|
@ -34,6 +34,6 @@ func (dst *GenericBinary) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *GenericBinary) Value() (driver.Value, error) {
|
||||
return (*Bytea)(src).Value()
|
||||
func (src GenericBinary) Value() (driver.Value, error) {
|
||||
return (Bytea)(src).Value()
|
||||
}
|
||||
|
|
|
@ -24,8 +24,8 @@ func (dst *GenericText) DecodeText(ci *ConnInfo, src []byte) error {
|
|||
return (*Text)(dst).DecodeText(ci, src)
|
||||
}
|
||||
|
||||
func (src *GenericText) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*Text)(src).EncodeText(ci, buf)
|
||||
func (src GenericText) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (Text)(src).EncodeText(ci, buf)
|
||||
}
|
||||
|
||||
// Scan implements the database/sql Scanner interface.
|
||||
|
@ -34,6 +34,6 @@ func (dst *GenericText) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *GenericText) Value() (driver.Value, error) {
|
||||
return (*Text)(src).Value()
|
||||
func (src GenericText) Value() (driver.Value, error) {
|
||||
return (Text)(src).Value()
|
||||
}
|
||||
|
|
|
@ -151,7 +151,7 @@ func (dst *Hstore) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Hstore) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Hstore) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -186,7 +186,7 @@ func (src *Hstore) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Hstore) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Hstore) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -426,6 +426,6 @@ func (dst *Hstore) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Hstore) Value() (driver.Value, error) {
|
||||
func (src Hstore) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
|
@ -168,7 +168,7 @@ func (dst *HstoreArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *HstoreArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src HstoreArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -225,7 +225,7 @@ func (src *HstoreArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *HstoreArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src HstoreArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -288,7 +288,7 @@ func (dst *HstoreArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *HstoreArray) Value() (driver.Value, error) {
|
||||
func (src HstoreArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
6
inet.go
6
inet.go
|
@ -148,7 +148,7 @@ func (dst *Inet) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Inet) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Inet) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -160,7 +160,7 @@ func (src *Inet) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
}
|
||||
|
||||
// EncodeBinary encodes src into w.
|
||||
func (src *Inet) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Inet) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -211,6 +211,6 @@ func (dst *Inet) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Inet) Value() (driver.Value, error) {
|
||||
func (src Inet) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
|
@ -197,7 +197,7 @@ func (dst *InetArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *InetArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src InetArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -254,7 +254,7 @@ func (src *InetArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *InetArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src InetArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -317,7 +317,7 @@ func (dst *InetArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *InetArray) Value() (driver.Value, error) {
|
||||
func (src InetArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
8
int2.go
8
int2.go
|
@ -133,7 +133,7 @@ func (dst *Int2) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Int2) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Int2) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -144,7 +144,7 @@ func (src *Int2) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return append(buf, strconv.FormatInt(int64(src.Int), 10)...), nil
|
||||
}
|
||||
|
||||
func (src *Int2) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Int2) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -184,7 +184,7 @@ func (dst *Int2) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Int2) Value() (driver.Value, error) {
|
||||
func (src Int2) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return int64(src.Int), nil
|
||||
|
@ -195,7 +195,7 @@ func (src *Int2) Value() (driver.Value, error) {
|
|||
}
|
||||
}
|
||||
|
||||
func (src *Int2) MarshalJSON() ([]byte, error) {
|
||||
func (src Int2) MarshalJSON() ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return []byte(strconv.FormatInt(int64(src.Int), 10)), nil
|
||||
|
|
|
@ -196,7 +196,7 @@ func (dst *Int2Array) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Int2Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Int2Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -253,7 +253,7 @@ func (src *Int2Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Int2Array) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Int2Array) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -316,7 +316,7 @@ func (dst *Int2Array) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Int2Array) Value() (driver.Value, error) {
|
||||
func (src Int2Array) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
8
int4.go
8
int4.go
|
@ -125,7 +125,7 @@ func (dst *Int4) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Int4) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Int4) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -136,7 +136,7 @@ func (src *Int4) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return append(buf, strconv.FormatInt(int64(src.Int), 10)...), nil
|
||||
}
|
||||
|
||||
func (src *Int4) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Int4) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -176,7 +176,7 @@ func (dst *Int4) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Int4) Value() (driver.Value, error) {
|
||||
func (src Int4) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return int64(src.Int), nil
|
||||
|
@ -187,7 +187,7 @@ func (src *Int4) Value() (driver.Value, error) {
|
|||
}
|
||||
}
|
||||
|
||||
func (src *Int4) MarshalJSON() ([]byte, error) {
|
||||
func (src Int4) MarshalJSON() ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return []byte(strconv.FormatInt(int64(src.Int), 10)), nil
|
||||
|
|
|
@ -215,7 +215,7 @@ func (dst *Int4Array) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Int4Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Int4Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -272,7 +272,7 @@ func (src *Int4Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Int4Array) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Int4Array) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -335,7 +335,7 @@ func (dst *Int4Array) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Int4Array) Value() (driver.Value, error) {
|
||||
func (src Int4Array) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
8
int8.go
8
int8.go
|
@ -117,7 +117,7 @@ func (dst *Int8) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Int8) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Int8) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -128,7 +128,7 @@ func (src *Int8) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return append(buf, strconv.FormatInt(src.Int, 10)...), nil
|
||||
}
|
||||
|
||||
func (src *Int8) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Int8) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -162,7 +162,7 @@ func (dst *Int8) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Int8) Value() (driver.Value, error) {
|
||||
func (src Int8) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return int64(src.Int), nil
|
||||
|
@ -173,7 +173,7 @@ func (src *Int8) Value() (driver.Value, error) {
|
|||
}
|
||||
}
|
||||
|
||||
func (src *Int8) MarshalJSON() ([]byte, error) {
|
||||
func (src Int8) MarshalJSON() ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return []byte(strconv.FormatInt(src.Int, 10)), nil
|
||||
|
|
|
@ -196,7 +196,7 @@ func (dst *Int8Array) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Int8Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Int8Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -253,7 +253,7 @@ func (src *Int8Array) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Int8Array) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Int8Array) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -316,7 +316,7 @@ func (dst *Int8Array) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Int8Array) Value() (driver.Value, error) {
|
||||
func (src Int8Array) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
|
@ -179,7 +179,7 @@ func (dst *Interval) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Interval) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Interval) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -213,7 +213,7 @@ func (src *Interval) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
}
|
||||
|
||||
// EncodeBinary encodes src into w.
|
||||
func (src *Interval) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Interval) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -246,6 +246,6 @@ func (dst *Interval) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Interval) Value() (driver.Value, error) {
|
||||
func (src Interval) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
6
json.go
6
json.go
|
@ -120,7 +120,7 @@ func (dst *JSON) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return dst.DecodeText(ci, src)
|
||||
}
|
||||
|
||||
func (src *JSON) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src JSON) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -131,7 +131,7 @@ func (src *JSON) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return append(buf, src.Bytes...), nil
|
||||
}
|
||||
|
||||
func (src *JSON) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src JSON) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return src.EncodeText(ci, buf)
|
||||
}
|
||||
|
||||
|
@ -155,7 +155,7 @@ func (dst *JSON) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *JSON) Value() (driver.Value, error) {
|
||||
func (src JSON) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return src.Bytes, nil
|
||||
|
|
10
jsonb.go
10
jsonb.go
|
@ -43,11 +43,11 @@ func (dst *JSONB) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
|
||||
}
|
||||
|
||||
func (src *JSONB) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*JSON)(src).EncodeText(ci, buf)
|
||||
func (src JSONB) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (JSON)(src).EncodeText(ci, buf)
|
||||
}
|
||||
|
||||
func (src *JSONB) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src JSONB) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -65,6 +65,6 @@ func (dst *JSONB) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *JSONB) Value() (driver.Value, error) {
|
||||
return (*JSON)(src).Value()
|
||||
func (src JSONB) Value() (driver.Value, error) {
|
||||
return (JSON)(src).Value()
|
||||
}
|
||||
|
|
6
line.go
6
line.go
|
@ -93,7 +93,7 @@ func (dst *Line) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Line) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Line) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -110,7 +110,7 @@ func (src *Line) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Line) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Line) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -144,6 +144,6 @@ func (dst *Line) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Line) Value() (driver.Value, error) {
|
||||
func (src Line) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
6
lseg.go
6
lseg.go
|
@ -108,7 +108,7 @@ func (dst *Lseg) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Lseg) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Lseg) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -126,7 +126,7 @@ func (src *Lseg) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Lseg) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Lseg) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -161,6 +161,6 @@ func (dst *Lseg) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Lseg) Value() (driver.Value, error) {
|
||||
func (src Lseg) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
|
@ -107,7 +107,7 @@ func (dst *Macaddr) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Macaddr) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Macaddr) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -119,7 +119,7 @@ func (src *Macaddr) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
}
|
||||
|
||||
// EncodeBinary encodes src into w.
|
||||
func (src *Macaddr) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Macaddr) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -150,6 +150,6 @@ func (dst *Macaddr) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Macaddr) Value() (driver.Value, error) {
|
||||
func (src Macaddr) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
|
@ -169,7 +169,7 @@ func (dst *MacaddrArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *MacaddrArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src MacaddrArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -226,7 +226,7 @@ func (src *MacaddrArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *MacaddrArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src MacaddrArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -289,7 +289,7 @@ func (dst *MacaddrArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *MacaddrArray) Value() (driver.Value, error) {
|
||||
func (src MacaddrArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
12
name.go
12
name.go
|
@ -39,12 +39,12 @@ func (dst *Name) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return (*Text)(dst).DecodeBinary(ci, src)
|
||||
}
|
||||
|
||||
func (src *Name) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*Text)(src).EncodeText(ci, buf)
|
||||
func (src Name) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (Text)(src).EncodeText(ci, buf)
|
||||
}
|
||||
|
||||
func (src *Name) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*Text)(src).EncodeBinary(ci, buf)
|
||||
func (src Name) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (Text)(src).EncodeBinary(ci, buf)
|
||||
}
|
||||
|
||||
// Scan implements the database/sql Scanner interface.
|
||||
|
@ -53,6 +53,6 @@ func (dst *Name) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Name) Value() (driver.Value, error) {
|
||||
return (*Text)(src).Value()
|
||||
func (src Name) Value() (driver.Value, error) {
|
||||
return (Text)(src).Value()
|
||||
}
|
||||
|
|
|
@ -455,7 +455,7 @@ func nbaseDigitsToInt64(src []byte) (accum int64, bytesRead, digitsRead int) {
|
|||
return accum, rp, digits
|
||||
}
|
||||
|
||||
func (src *Numeric) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Numeric) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -469,7 +469,7 @@ func (src *Numeric) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Numeric) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Numeric) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -580,7 +580,7 @@ func (dst *Numeric) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Numeric) Value() (driver.Value, error) {
|
||||
func (src Numeric) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
|
|
|
@ -252,7 +252,7 @@ func (dst *NumericArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *NumericArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src NumericArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -309,7 +309,7 @@ func (src *NumericArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *NumericArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src NumericArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -372,7 +372,7 @@ func (dst *NumericArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *NumericArray) Value() (driver.Value, error) {
|
||||
func (src NumericArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
12
oid_value.go
12
oid_value.go
|
@ -36,12 +36,12 @@ func (dst *OIDValue) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return (*pguint32)(dst).DecodeBinary(ci, src)
|
||||
}
|
||||
|
||||
func (src *OIDValue) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*pguint32)(src).EncodeText(ci, buf)
|
||||
func (src OIDValue) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (pguint32)(src).EncodeText(ci, buf)
|
||||
}
|
||||
|
||||
func (src *OIDValue) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*pguint32)(src).EncodeBinary(ci, buf)
|
||||
func (src OIDValue) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (pguint32)(src).EncodeBinary(ci, buf)
|
||||
}
|
||||
|
||||
// Scan implements the database/sql Scanner interface.
|
||||
|
@ -50,6 +50,6 @@ func (dst *OIDValue) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *OIDValue) Value() (driver.Value, error) {
|
||||
return (*pguint32)(src).Value()
|
||||
func (src OIDValue) Value() (driver.Value, error) {
|
||||
return (pguint32)(src).Value()
|
||||
}
|
||||
|
|
6
path.go
6
path.go
|
@ -116,7 +116,7 @@ func (dst *Path) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Path) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Path) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -147,7 +147,7 @@ func (src *Path) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return append(buf, endByte), nil
|
||||
}
|
||||
|
||||
func (src *Path) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Path) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -191,6 +191,6 @@ func (dst *Path) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Path) Value() (driver.Value, error) {
|
||||
func (src Path) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
|
@ -102,7 +102,7 @@ func (dst *pguint32) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *pguint32) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src pguint32) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -113,7 +113,7 @@ func (src *pguint32) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return append(buf, strconv.FormatUint(uint64(src.Uint), 10)...), nil
|
||||
}
|
||||
|
||||
func (src *pguint32) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src pguint32) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -150,7 +150,7 @@ func (dst *pguint32) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *pguint32) Value() (driver.Value, error) {
|
||||
func (src pguint32) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return int64(src.Uint), nil
|
||||
|
|
6
point.go
6
point.go
|
@ -90,7 +90,7 @@ func (dst *Point) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Point) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Point) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -104,7 +104,7 @@ func (src *Point) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
)...), nil
|
||||
}
|
||||
|
||||
func (src *Point) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Point) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -137,6 +137,6 @@ func (dst *Point) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Point) Value() (driver.Value, error) {
|
||||
func (src Point) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
|
@ -111,7 +111,7 @@ func (dst *Polygon) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Polygon) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Polygon) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -134,7 +134,7 @@ func (src *Polygon) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return append(buf, ')'), nil
|
||||
}
|
||||
|
||||
func (src *Polygon) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Polygon) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -172,6 +172,6 @@ func (dst *Polygon) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Polygon) Value() (driver.Value, error) {
|
||||
func (src Polygon) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
2
qchar.go
2
qchar.go
|
@ -134,7 +134,7 @@ func (dst *QChar) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *QChar) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src QChar) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
|
8
text.go
8
text.go
|
@ -92,7 +92,7 @@ func (dst *Text) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return dst.DecodeText(ci, src)
|
||||
}
|
||||
|
||||
func (src *Text) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Text) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -103,7 +103,7 @@ func (src *Text) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return append(buf, src.String...), nil
|
||||
}
|
||||
|
||||
func (src *Text) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Text) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return src.EncodeText(ci, buf)
|
||||
}
|
||||
|
||||
|
@ -127,7 +127,7 @@ func (dst *Text) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Text) Value() (driver.Value, error) {
|
||||
func (src Text) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return src.String, nil
|
||||
|
@ -138,7 +138,7 @@ func (src *Text) Value() (driver.Value, error) {
|
|||
}
|
||||
}
|
||||
|
||||
func (src *Text) MarshalJSON() ([]byte, error) {
|
||||
func (src Text) MarshalJSON() ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
return json.Marshal(src.String)
|
||||
|
|
|
@ -168,7 +168,7 @@ func (dst *TextArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *TextArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src TextArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -225,7 +225,7 @@ func (src *TextArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *TextArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src TextArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -288,7 +288,7 @@ func (dst *TextArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *TextArray) Value() (driver.Value, error) {
|
||||
func (src TextArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
6
tid.go
6
tid.go
|
@ -94,7 +94,7 @@ func (dst *TID) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *TID) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src TID) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -106,7 +106,7 @@ func (src *TID) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *TID) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src TID) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -139,6 +139,6 @@ func (dst *TID) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *TID) Value() (driver.Value, error) {
|
||||
func (src TID) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
|
@ -136,7 +136,7 @@ func (dst *Timestamp) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
|
||||
// EncodeText writes the text encoding of src into w. If src.Time is not in
|
||||
// the UTC time zone it returns an error.
|
||||
func (src *Timestamp) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Timestamp) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -163,7 +163,7 @@ func (src *Timestamp) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
|
||||
// EncodeBinary writes the binary encoding of src into w. If src.Time is not in
|
||||
// the UTC time zone it returns an error.
|
||||
func (src *Timestamp) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Timestamp) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -211,7 +211,7 @@ func (dst *Timestamp) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Timestamp) Value() (driver.Value, error) {
|
||||
func (src Timestamp) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
if src.InfinityModifier != None {
|
||||
|
|
|
@ -169,7 +169,7 @@ func (dst *TimestampArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *TimestampArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src TimestampArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -226,7 +226,7 @@ func (src *TimestampArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error)
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *TimestampArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src TimestampArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -289,7 +289,7 @@ func (dst *TimestampArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *TimestampArray) Value() (driver.Value, error) {
|
||||
func (src TimestampArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
|
@ -140,7 +140,7 @@ func (dst *Timestamptz) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Timestamptz) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Timestamptz) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -162,7 +162,7 @@ func (src *Timestamptz) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return append(buf, s...), nil
|
||||
}
|
||||
|
||||
func (src *Timestamptz) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Timestamptz) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -207,7 +207,7 @@ func (dst *Timestamptz) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Timestamptz) Value() (driver.Value, error) {
|
||||
func (src Timestamptz) Value() (driver.Value, error) {
|
||||
switch src.Status {
|
||||
case Present:
|
||||
if src.InfinityModifier != None {
|
||||
|
|
|
@ -169,7 +169,7 @@ func (dst *TimestamptzArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *TimestamptzArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src TimestamptzArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -226,7 +226,7 @@ func (src *TimestamptzArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *TimestamptzArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src TimestamptzArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -289,7 +289,7 @@ func (dst *TimestamptzArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *TimestamptzArray) Value() (driver.Value, error) {
|
||||
func (src TimestamptzArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
|
@ -39,6 +39,6 @@ func (dst *Unknown) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Unknown) Value() (driver.Value, error) {
|
||||
return (*Text)(src).Value()
|
||||
func (src Unknown) Value() (driver.Value, error) {
|
||||
return (Text)(src).Value()
|
||||
}
|
||||
|
|
6
uuid.go
6
uuid.go
|
@ -139,7 +139,7 @@ func (dst *UUID) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *UUID) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src UUID) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -150,7 +150,7 @@ func (src *UUID) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return append(buf, encodeUUID(src.Bytes)...), nil
|
||||
}
|
||||
|
||||
func (src *UUID) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src UUID) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -181,6 +181,6 @@ func (dst *UUID) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *UUID) Value() (driver.Value, error) {
|
||||
func (src UUID) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
|
@ -224,7 +224,7 @@ func (dst *UUIDArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *UUIDArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src UUIDArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -281,7 +281,7 @@ func (src *UUIDArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *UUIDArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src UUIDArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -344,7 +344,7 @@ func (dst *UUIDArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *UUIDArray) Value() (driver.Value, error) {
|
||||
func (src UUIDArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
|
@ -75,7 +75,7 @@ func (dst *Varbit) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *Varbit) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Varbit) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -96,7 +96,7 @@ func (src *Varbit) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *Varbit) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src Varbit) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -128,6 +128,6 @@ func (dst *Varbit) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Varbit) Value() (driver.Value, error) {
|
||||
func (src Varbit) Value() (driver.Value, error) {
|
||||
return EncodeValueText(src)
|
||||
}
|
||||
|
|
16
varchar.go
16
varchar.go
|
@ -31,12 +31,12 @@ func (dst *Varchar) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return (*Text)(dst).DecodeBinary(ci, src)
|
||||
}
|
||||
|
||||
func (src *Varchar) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*Text)(src).EncodeText(ci, buf)
|
||||
func (src Varchar) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (Text)(src).EncodeText(ci, buf)
|
||||
}
|
||||
|
||||
func (src *Varchar) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*Text)(src).EncodeBinary(ci, buf)
|
||||
func (src Varchar) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (Text)(src).EncodeBinary(ci, buf)
|
||||
}
|
||||
|
||||
// Scan implements the database/sql Scanner interface.
|
||||
|
@ -45,12 +45,12 @@ func (dst *Varchar) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *Varchar) Value() (driver.Value, error) {
|
||||
return (*Text)(src).Value()
|
||||
func (src Varchar) Value() (driver.Value, error) {
|
||||
return (Text)(src).Value()
|
||||
}
|
||||
|
||||
func (src *Varchar) MarshalJSON() ([]byte, error) {
|
||||
return (*Text)(src).MarshalJSON()
|
||||
func (src Varchar) MarshalJSON() ([]byte, error) {
|
||||
return (Text)(src).MarshalJSON()
|
||||
}
|
||||
|
||||
func (dst *Varchar) UnmarshalJSON(b []byte) error {
|
||||
|
|
|
@ -168,7 +168,7 @@ func (dst *VarcharArray) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (src *VarcharArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src VarcharArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -225,7 +225,7 @@ func (src *VarcharArray) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
|||
return buf, nil
|
||||
}
|
||||
|
||||
func (src *VarcharArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
func (src VarcharArray) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
switch src.Status {
|
||||
case Null:
|
||||
return nil, nil
|
||||
|
@ -288,7 +288,7 @@ func (dst *VarcharArray) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *VarcharArray) Value() (driver.Value, error) {
|
||||
func (src VarcharArray) Value() (driver.Value, error) {
|
||||
buf, err := src.EncodeText(nil, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
12
xid.go
12
xid.go
|
@ -45,12 +45,12 @@ func (dst *XID) DecodeBinary(ci *ConnInfo, src []byte) error {
|
|||
return (*pguint32)(dst).DecodeBinary(ci, src)
|
||||
}
|
||||
|
||||
func (src *XID) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*pguint32)(src).EncodeText(ci, buf)
|
||||
func (src XID) EncodeText(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (pguint32)(src).EncodeText(ci, buf)
|
||||
}
|
||||
|
||||
func (src *XID) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (*pguint32)(src).EncodeBinary(ci, buf)
|
||||
func (src XID) EncodeBinary(ci *ConnInfo, buf []byte) ([]byte, error) {
|
||||
return (pguint32)(src).EncodeBinary(ci, buf)
|
||||
}
|
||||
|
||||
// Scan implements the database/sql Scanner interface.
|
||||
|
@ -59,6 +59,6 @@ func (dst *XID) Scan(src interface{}) error {
|
|||
}
|
||||
|
||||
// Value implements the database/sql/driver Valuer interface.
|
||||
func (src *XID) Value() (driver.Value, error) {
|
||||
return (*pguint32)(src).Value()
|
||||
func (src XID) Value() (driver.Value, error) {
|
||||
return (pguint32)(src).Value()
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue