sqldata

Documentation

Index

• type ChannelSQLResultStream
  • func (srs *ChannelSQLResultStream) Close() error
  • func (srs *ChannelSQLResultStream) Read() (ISQLResult, error)
  • func (srs *ChannelSQLResultStream) Write(r ISQLResult) error
• type ISQLColumn
  • func NewSQLColumn(table ISQLTable, name string, attrNum int16, objectID uint32, width int16, ...) ISQLColumn
• type ISQLResult
  • func NewSQLResult(columns []ISQLColumn, rowsAffected uint64, insertID uint64, rows []ISQLRow) ISQLResult
• type ISQLResultStream
  • func NewChannelSQLResultStream() ISQLResultStream
  • func NewSimpleSQLResultStream(res ISQLResult) ISQLResultStream
• type ISQLRow
  • func NewSQLRow(rawData []interface{}) ISQLRow
• type ISQLTable
  • func NewSQLTable(id int32, name string) ISQLTable
• type SQLColumn
  • func (sc *SQLColumn) GetAttrNum() int16
  • func (sc *SQLColumn) GetFormat() string
  • func (sc *SQLColumn) GetName() string
  • func (sc *SQLColumn) GetObjectID() uint32
  • func (sc *SQLColumn) GetTableId() int32
  • func (sc *SQLColumn) GetTypeModifier() int32
  • func (sc *SQLColumn) GetWidth() int16
• type SQLRow
  • func (sr *SQLRow) GetRowDataForPgWire() []interface{}
  • func (sr *SQLRow) GetRowDataNaive() []interface{}
• type SQLTable
  • func (st *SQLTable) GetId() int32
  • func (st *SQLTable) GetName() string
• type SimpleSQLResultStream
  • func (srs *SimpleSQLResultStream) Close() error
  • func (srs *SimpleSQLResultStream) Read() (ISQLResult, error)
  • func (srs *SimpleSQLResultStream) Write(r ISQLResult) error

Types

type ChannelSQLResultStream

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

func (*ChannelSQLResultStream) Close

func (srs *ChannelSQLResultStream) Close() error

func (*ChannelSQLResultStream) Read

func (srs *ChannelSQLResultStream) Read() (ISQLResult, error)

func (*ChannelSQLResultStream) Write

func (srs *ChannelSQLResultStream) Write(r ISQLResult) error

type ISQLColumn

type ISQLColumn interface {
	GetTableId() int32
	GetName() string
	GetAttrNum() int16
	GetObjectID() uint32
	GetWidth() int16
	GetTypeModifier() int32
	GetFormat() string
}

func NewSQLColumn

func NewSQLColumn(
	table ISQLTable,
	name string,
	attrNum int16,
	objectID uint32,
	width int16,
	typeModifier int32,
	format string,
) ISQLColumn

type ISQLResult

type ISQLResult interface {
	GetColumns() []ISQLColumn
	GetRowsAffected() uint64
	GetInsertId() uint64
	GetRows() []ISQLRow
	ToArr() []map[string]interface{}
}

func NewSQLResult

func NewSQLResult(
	columns []ISQLColumn,
	rowsAffected uint64,
	insertID uint64,
	rows []ISQLRow,
) ISQLResult

type ISQLResultStream

type ISQLResultStream interface {
	Read() (ISQLResult, error)
	Write(ISQLResult) error
	Close() error
}

func NewChannelSQLResultStream

func NewChannelSQLResultStream() ISQLResultStream

func NewSimpleSQLResultStream

func NewSimpleSQLResultStream(res ISQLResult) ISQLResultStream

type ISQLRow

type ISQLRow interface {
	GetRowDataNaive() []interface{}
	GetRowDataForPgWire() []interface{}
}

func NewSQLRow

func NewSQLRow(rawData []interface{}) ISQLRow

type ISQLTable

type ISQLTable interface {
	GetId() int32
	GetName() string
}

func NewSQLTable

func NewSQLTable(id int32, name string) ISQLTable

type SQLColumn

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

func (*SQLColumn) GetAttrNum

func (sc *SQLColumn) GetAttrNum() int16

func (*SQLColumn) GetFormat

func (sc *SQLColumn) GetFormat() string

func (*SQLColumn) GetName

func (sc *SQLColumn) GetName() string

func (*SQLColumn) GetObjectID

func (sc *SQLColumn) GetObjectID() uint32

func (*SQLColumn) GetTableId

func (sc *SQLColumn) GetTableId() int32

func (*SQLColumn) GetTypeModifier

func (sc *SQLColumn) GetTypeModifier() int32

func (*SQLColumn) GetWidth

func (sc *SQLColumn) GetWidth() int16

type SQLRow

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

func (*SQLRow) GetRowDataForPgWire

func (sr *SQLRow) GetRowDataForPgWire() []interface{}

func (*SQLRow) GetRowDataNaive

func (sr *SQLRow) GetRowDataNaive() []interface{}

type SQLTable

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

func (*SQLTable) GetId

func (st *SQLTable) GetId() int32

func (*SQLTable) GetName

func (st *SQLTable) GetName() string

type SimpleSQLResultStream

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

func (*SimpleSQLResultStream) Close

func (srs *SimpleSQLResultStream) Close() error

func (*SimpleSQLResultStream) Read

func (srs *SimpleSQLResultStream) Read() (ISQLResult, error)

func (*SimpleSQLResultStream) Write

func (srs *SimpleSQLResultStream) Write(r ISQLResult) error