parameter_coder

package
v3.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 22, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ArrayParameter 

type ArrayParameter struct {
	BasicParameter
	// contains filtered or unexported fields
}

func (*ArrayParameter) Copy 

func (param *ArrayParameter) Copy() OracleParameterCoder

func (*ArrayParameter) Decode 

func (param *ArrayParameter) Decode(conn IConnection) (value interface{}, err error)

func (*ArrayParameter) Encode 

func (param *ArrayParameter) Encode(input interface{}, conn IConnection) (err error)

func (*ArrayParameter) FillAttrib 

func (param *ArrayParameter) FillAttrib(input interface{}, conn IConnection) error

func (*ArrayParameter) Init 

func (param *ArrayParameter) Init()

func (*ArrayParameter) Read 

func (param *ArrayParameter) Read(session network.SessionReader) error

func (*ArrayParameter) Write 

func (param *ArrayParameter) Write(session network.SessionWriter) (err error)

type BFileParameter 

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

func (*BFileParameter) Copy 

func (param *BFileParameter) Copy() OracleParameterCoder

func (*BFileParameter) Decode 

func (param *BFileParameter) Decode(conn IConnection) (output interface{}, err error)

func (*BFileParameter) Encode 

func (param *BFileParameter) Encode(input interface{}, conn IConnection) (err error)

func (*BFileParameter) Init 

func (param *BFileParameter) Init()

func (*BFileParameter) Read 

func (param *BFileParameter) Read(session network.SessionReader) error

func (*BFileParameter) SetLobStreamer 

func (param *BFileParameter) SetLobStreamer(streamer types.LobStreamer)

func (*BFileParameter) Write 

func (param *BFileParameter) Write(session network.SessionWriter) error

type BasicParameter 

type BasicParameter struct {
	TypeName    string
	Flag        uint8
	ContFlag    int
	DataType    uint16
	CharsetID   int
	CharsetForm int
	MaxLen      int64
	MaxCharLen  int64
	ToID        []byte
	ArraySize   int
	//Coder        converters.StringCoder
	IsUDTPar     bool
	IsArrayPar   bool
	BValue       []byte
	Version      int
	VectorDim    int
	VectorFormat uint8
	VectorFlag   uint8
	VectorType   types.VectorType
	PSession     network.SessionReadWriter
}

func (*BasicParameter) BasicRead 

func (basic *BasicParameter) BasicRead(session network.SessionReader) ([]byte, error)

func (*BasicParameter) Bytes 

func (basic *BasicParameter) Bytes() []byte

func (*BasicParameter) GetParameterInfo 

func (basic *BasicParameter) GetParameterInfo() BasicParameter

func (*BasicParameter) SetAQMessage 

func (basic *BasicParameter) SetAQMessage()

func (*BasicParameter) SetAsArrayPar 

func (basic *BasicParameter) SetAsArrayPar()

func (*BasicParameter) SetAsUDTPar 

func (basic *BasicParameter) SetAsUDTPar()

func (*BasicParameter) SetBytes 

func (basic *BasicParameter) SetBytes(data []byte)

func (*BasicParameter) SetDefault 

func (basic *BasicParameter) SetDefault()

func (*BasicParameter) SetLobStreamer 

func (basic *BasicParameter) SetLobStreamer(lobStreamer types.LobStreamer)

func (basic *BasicParameter) UpdateParameterInfo() {}

func (*BasicParameter) SetParameterInfo 

func (basic *BasicParameter) SetParameterInfo(data BasicParameter)

func (*BasicParameter) SetParentSession 

func (basic *BasicParameter) SetParentSession(input network.SessionReadWriter)

func (*BasicParameter) Write 

func (basic *BasicParameter) Write(session network.SessionWriter) error

type BlobParameter 

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

func (*BlobParameter) Copy 

func (param *BlobParameter) Copy() OracleParameterCoder

func (*BlobParameter) Decode 

func (param *BlobParameter) Decode(_ IConnection) (interface{}, error)

func (*BlobParameter) Encode 

func (param *BlobParameter) Encode(input interface{}, conn IConnection) (err error)

func (*BlobParameter) Init 

func (param *BlobParameter) Init()

func (*BlobParameter) Read 

func (param *BlobParameter) Read(session network.SessionReader) error

func (*BlobParameter) SetLobStreamer 

func (param *BlobParameter) SetLobStreamer(streamer types.LobStreamer)

func (*BlobParameter) Write 

func (param *BlobParameter) Write(session network.SessionWriter) error

type BoolParameter 

type BoolParameter struct {
	BasicParameter
}

func (*BoolParameter) Copy 

func (param *BoolParameter) Copy() OracleParameterCoder

func (*BoolParameter) Decode 

func (param *BoolParameter) Decode(_ IConnection) (interface{}, error)

func (*BoolParameter) Encode 

func (param *BoolParameter) Encode(input interface{}, _ IConnection) error

func (*BoolParameter) Init 

func (param *BoolParameter) Init()

func (*BoolParameter) Read 

func (param *BoolParameter) Read(session network.SessionReader) error

type ClobParameter 

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

func (*ClobParameter) Copy 

func (param *ClobParameter) Copy() OracleParameterCoder

func (*ClobParameter) Decode 

func (param *ClobParameter) Decode(conn IConnection) (interface{}, error)

func (*ClobParameter) Encode 

func (param *ClobParameter) Encode(input interface{}, conn IConnection) (err error)

func (*ClobParameter) Init 

func (param *ClobParameter) Init()

func (*ClobParameter) Read 

func (param *ClobParameter) Read(session network.SessionReader) error

func (*ClobParameter) SetLobStreamer 

func (param *ClobParameter) SetLobStreamer(streamer types.LobStreamer)

func (*ClobParameter) Write 

func (param *ClobParameter) Write(session network.SessionWriter) error

type CursorParameter 

type CursorParameter struct {
	BasicParameter
}

func (*CursorParameter) Copy 

func (param *CursorParameter) Copy() OracleParameterCoder

func (*CursorParameter) Decode 

func (param *CursorParameter) Decode(_ IConnection) (interface{}, error)

func (*CursorParameter) Encode 

func (param *CursorParameter) Encode(input interface{}, _ IConnection) error

func (*CursorParameter) Init 

func (param *CursorParameter) Init()

func (*CursorParameter) Read 

func (param *CursorParameter) Read(session network.SessionReader) error

func (*CursorParameter) Write 

func (param *CursorParameter) Write(session network.SessionWriter) error

type DateParameter 

type DateParameter struct {
	BasicParameter
}

func (*DateParameter) Copy 

func (param *DateParameter) Copy() OracleParameterCoder

func (*DateParameter) Decode 

func (param *DateParameter) Decode(_ IConnection) (interface{}, error)

func (*DateParameter) Encode 

func (param *DateParameter) Encode(input interface{}, conn IConnection) error

func (*DateParameter) Init 

func (param *DateParameter) Init()

func (*DateParameter) Read 

func (param *DateParameter) Read(session network.SessionReader) error

type IConnection 

type IConnection interface {
	converters.StringCoder
	GetSession() network.SessionReadWriter
	NewLobStreamer() types.LobStreamer
	//GetGoParameterCoder(goType reflect.Type) OracleParameterCoder
	//GetOracleParameterCoder(oracleType uint16) OracleParameterCoder
	//GetNameParameterCoder(nameType string) OracleParameterCoder
	GetParameterCoder(input interface{}) (OracleParameterCoder, error)
	SendTimeZoneAsUTC() bool
	GetMaxRawLength() int64
}

type IntervalParameter 

type IntervalParameter struct {
	BasicParameter
}

func (*IntervalParameter) Copy 

func (param *IntervalParameter) Copy() OracleParameterCoder

func (*IntervalParameter) Decode 

func (param *IntervalParameter) Decode(_ IConnection) (interface{}, error)

func (*IntervalParameter) Encode 

func (param *IntervalParameter) Encode(input interface{}, _ IConnection) error

func (*IntervalParameter) Init 

func (param *IntervalParameter) Init()

func (*IntervalParameter) Read 

func (param *IntervalParameter) Read(session network.SessionReader) error

type JsonParameter 

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

func (*JsonParameter) Copy 

func (param *JsonParameter) Copy() OracleParameterCoder

func (*JsonParameter) Decode 

func (param *JsonParameter) Decode(_ IConnection) (interface{}, error)

func (*JsonParameter) Encode 

func (param *JsonParameter) Encode(input interface{}, _ IConnection) (err error)

func (*JsonParameter) Init 

func (param *JsonParameter) Init()

func (*JsonParameter) Read 

func (param *JsonParameter) Read(session network.SessionReader) error

func (*JsonParameter) SetAQMessage 

func (param *JsonParameter) SetAQMessage()

func (*JsonParameter) SetLobStreamer 

func (param *JsonParameter) SetLobStreamer(streamer types.LobStreamer)

func (*JsonParameter) Write 

func (param *JsonParameter) Write(session network.SessionWriter) error

type NumberParameter 

type NumberParameter struct {
	BasicParameter
}

func (*NumberParameter) Copy 

func (param *NumberParameter) Copy() OracleParameterCoder

func (*NumberParameter) Decode 

func (param *NumberParameter) Decode(_ IConnection) (interface{}, error)

func (*NumberParameter) Encode 

func (param *NumberParameter) Encode(input interface{}, _ IConnection) error

func (*NumberParameter) Init 

func (param *NumberParameter) Init()

func (*NumberParameter) Read 

func (param *NumberParameter) Read(session network.SessionReader) error

type OracleParameterCoder 

type OracleParameterCoder interface {
	OracleParameterEncoder
	OracleParameterDecoder
	Init()
	Bytes() []byte
	Copy() OracleParameterCoder
	SetAsUDTPar()
	SetAsArrayPar()
	SetAQMessage()
	SetParentSession(input network.SessionReadWriter)
}

type OracleParameterDecoder 

type OracleParameterDecoder interface {
	Read(session network.SessionReader) error
	Decode(conn IConnection) (interface{}, error)
	SetLobStreamer(lobStreamer types.LobStreamer)
	SetParameterInfo(data BasicParameter)
	SetBytes(data []byte)
}

type OracleParameterEncoder 

type OracleParameterEncoder interface {
	Encode(input interface{}, conn IConnection) error
	network.ValueStreamWriter
	GetParameterInfo() BasicParameter
	SetParameterInfo(data BasicParameter)
}

type RawParameter 

type RawParameter struct {
	BasicParameter
	// contains filtered or unexported fields
}

func (*RawParameter) Copy 

func (param *RawParameter) Copy() OracleParameterCoder

func (*RawParameter) Decode 

func (param *RawParameter) Decode(_ IConnection) (interface{}, error)

func (*RawParameter) Encode 

func (param *RawParameter) Encode(input interface{}, conn IConnection) error

func (*RawParameter) Init 

func (param *RawParameter) Init()

func (*RawParameter) Read 

func (param *RawParameter) Read(session network.SessionReader) error

func (*RawParameter) SetAQMessage 

func (param *RawParameter) SetAQMessage()

func (*RawParameter) Write 

func (param *RawParameter) Write(session network.SessionWriter) error

type RowIDParameter 

type RowIDParameter struct {
	BasicParameter
	// contains filtered or unexported fields
}

func (*RowIDParameter) Copy 

func (param *RowIDParameter) Copy() OracleParameterCoder

func (*RowIDParameter) Decode 

func (param *RowIDParameter) Decode(_ IConnection) (interface{}, error)

func (*RowIDParameter) Encode 

func (param *RowIDParameter) Encode(input interface{}, _ IConnection) error

func (*RowIDParameter) Init 

func (param *RowIDParameter) Init()

func (*RowIDParameter) Read 

func (param *RowIDParameter) Read(session network.SessionReader) error

func (*RowIDParameter) Write 

func (param *RowIDParameter) Write(session network.SessionWriter) error

type StringParameter 

type StringParameter struct {
	BasicParameter
}

func (*StringParameter) Copy 

func (param *StringParameter) Copy() OracleParameterCoder

func (*StringParameter) Decode 

func (param *StringParameter) Decode(conn IConnection) (interface{}, error)

func (*StringParameter) Encode 

func (param *StringParameter) Encode(input interface{}, conn IConnection) error

func (*StringParameter) Init 

func (param *StringParameter) Init()

func (*StringParameter) Read 

func (param *StringParameter) Read(session network.SessionReader) error

type VectorParameter 

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

func (*VectorParameter) Copy 

func (param *VectorParameter) Copy() OracleParameterCoder

func (*VectorParameter) Decode 

func (param *VectorParameter) Decode(_ IConnection) (interface{}, error)

func (*VectorParameter) Encode 

func (param *VectorParameter) Encode(input interface{}, _ IConnection) error

func (*VectorParameter) Init 

func (param *VectorParameter) Init()

func (*VectorParameter) Read 

func (param *VectorParameter) Read(session network.SessionReader) error

func (*VectorParameter) SetLobStreamer 

func (param *VectorParameter) SetLobStreamer(streamer types.LobStreamer)

func (*VectorParameter) Write 

func (param *VectorParameter) Write(session network.SessionWriter) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.