pgcopy

Documentation

Index

• Constants
• Variables
• func DecodeAttr(raw []byte, buf []byte) *toolkit.RawValue
• func EncodeAttr(v *toolkit.RawValue, buf []byte) []byte
• type Row
  • func NewRow(tupleSize int) *Row
  • func (r *Row) Clean()
  • func (r *Row) Decode(raw []byte) error
  • func (r *Row) Encode() ([]byte, error)
  • func (r *Row) GetColumn(idx int) (*toolkit.RawValue, error)
  • func (r *Row) GetColumnRaw(idx int) ([]byte, error)
  • func (r *Row) Length() int
  • func (r *Row) SetColumn(idx int, v *toolkit.RawValue) error

Constants

const DefaultCopyDelimiter = '\t'

const UseDynamicSize = -1

Variables

var DefaultCopyTerminationSeq = []byte("\\.")

var DefaultNullSeq = []byte("\\N")

var ErrIndexOutOfRage = errors.New("wrong column idx: index out of range")

Functions

func DecodeAttr

func DecodeAttr(raw []byte, buf []byte) *toolkit.RawValue

func EncodeAttr

func EncodeAttr(v *toolkit.RawValue, buf []byte) []byte

EncodeAttr - encode from UTF-8 slice to transfer representation (escaped byte[])

Types

type Row

type Row struct {
	// contains filtered or unexported fields
}

Row - the row driver that works with vanilla COPY format

func NewRow

func NewRow(tupleSize int) *Row

func (*Row) Clean

func (r *Row) Clean()

func (*Row) Decode

func (r *Row) Decode(raw []byte) error

func (*Row) Encode

func (r *Row) Encode() ([]byte, error)

Encode - return encoded bytes from golang representation to COPY format. if SetColumn has never been called than original raw data will be returned

func (*Row) GetColumn

func (r *Row) GetColumn(idx int) (*toolkit.RawValue, error)

GetColumn - find raw data and encode it using DecodeAttr

func (*Row) GetColumnRaw

func (r *Row) GetColumnRaw(idx int) ([]byte, error)

func (*Row) Length

func (r *Row) Length() int

func (*Row) SetColumn

func (r *Row) SetColumn(idx int, v *toolkit.RawValue) error

SetColumn - set column (replace original) value and decode it later