Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
type ISQLResult ¶
type ISQLResult interface { GetColumns() []ISQLColumn GetRowsAffected() uint64 GetInsertId() uint64 GetRows() []ISQLRow }
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{} }
type ISQLTable ¶
func NewSQLTable ¶
type SQLColumn ¶
type SQLColumn struct {
// contains filtered or unexported fields
}
func (*SQLColumn) GetAttrNum ¶
func (*SQLColumn) GetObjectID ¶
func (*SQLColumn) GetTableId ¶
func (*SQLColumn) GetTypeModifier ¶
type SQLResult ¶
type SQLResult struct {
// contains filtered or unexported fields
}
func NewSQLResult ¶
func NewSQLResult( columns []ISQLColumn, rowsAffected uint64, insertID uint64, rows []ISQLRow, ) *SQLResult
func (*SQLResult) GetColumns ¶
func (sr *SQLResult) GetColumns() []ISQLColumn
func (*SQLResult) GetInsertId ¶
func (*SQLResult) GetRowsAffected ¶
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 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
Click to show internal directories.
Click to hide internal directories.