Versions in this module Expand all Collapse all v1 v1.0.2 Nov 27, 2021 Changes in this version + const Binary + const Bit + const Blob + const Char + const Date + const Datetime + const Decimal + const DecimalLongLongDigits + const DoubleDigits + const Enum + const Expression + const Float32 + const Float64 + const FloatDigits + const Geometry + const Int16 + const Int24 + const Int32 + const Int64 + const Int8 + const Null + const Set + const Text + const Time + const Timestamp + const Tuple + const TypeJSON + const Uint16 + const Uint24 + const Uint32 + const Uint64 + const Uint8 + const VarBinary + const VarChar + const Year + var DontEscape = byte(255) + var NULL = Value + var NullBindVariable = &querypb.BindVariable + var SQLDecodeMap [256]byte + var SQLEncodeMap [256]byte + func BuildBindVariable(v interface{}) (*querypb.BindVariable, error) + func BuildBindVariables(in map[string]interface{}) (map[string]*querypb.BindVariable, error) + func BytesBindVariable(v []byte) *querypb.BindVariable + func CastToBool(v Value) bool + func CompareFloat64(x, y float64) int + func CompareInt64(x, y int64) int + func CompareUint64(x, y uint64) int + func CopyBindVariables(bindVariables map[string]*querypb.BindVariable) map[string]*querypb.BindVariable + func Float32BindVariable(v float32) *querypb.BindVariable + func Float64BindVariable(v float64) *querypb.BindVariable + func Int32BindVariable(v int32) *querypb.BindVariable + func Int64BindVariable(v int64) *querypb.BindVariable + func IsBinary(t querypb.Type) bool + func IsFloat(t querypb.Type) bool + func IsIntegral(t querypb.Type) bool + func IsQuoted(t querypb.Type) bool + func IsSigned(t querypb.Type) bool + func IsTemporal(t querypb.Type) bool + func IsText(t querypb.Type) bool + func IsUnsigned(t querypb.Type) bool + func MySQLToType(mysqlType, flags int64) (typ querypb.Type, err error) + func NullsafeCompare(v1, v2 Value) int + func ParseMySQLValues(buf *common.Buffer, typ querypb.Type) (interface{}, error) + func StringBindVariable(v string) *querypb.BindVariable + func TypeToMySQL(typ querypb.Type) (mysqlType, flags int64) + func Uint64BindVariable(v uint64) *querypb.BindVariable + func ValidateBindVariable(bv *querypb.BindVariable) error + func ValidateBindVariables(bv map[string]*querypb.BindVariable) error + func ValueBindVariable(v Value) *querypb.BindVariable + func ValueToProto(v Value) *querypb.Value + type AggEvaluateContext struct + func NewAggEvalCtxs(aggrs []*Aggregation, x []Value) []*AggEvaluateContext + type AggrType string + const AggrTypeAvg + const AggrTypeCount + const AggrTypeGroupBy + const AggrTypeMax + const AggrTypeMin + const AggrTypeNull + const AggrTypeSum + type Aggregation struct + func NewAggregation(index int, aggrTyp AggrType, distinct, isPushDown bool) *Aggregation + func (aggr *Aggregation) FixField(field *querypb.Field) + func (aggr *Aggregation) GetResult(evalCtx *AggEvaluateContext) Value + func (aggr *Aggregation) InitEvalCtx(x []Value) *AggEvaluateContext + func (aggr *Aggregation) Update(x []Value, evalCtx *AggEvaluateContext) + type BinWriter interface + Write func([]byte) (int, error) + WriteByte func(byte) error + type PlanValue struct + Key string + ListKey string + Value Value + Values []PlanValue + type Result struct + Extras *querypb.ResultExtras + Fields []*querypb.Field + InsertID uint64 + Rows [][]Value + RowsAffected uint64 + State ResultState + Warnings uint16 + func (result *Result) AppendResult(src *Result) + func (result *Result) Copy() *Result + func (result *Result) Limit(offset, limit int) + func (result *Result) RemoveColumns(idxs ...int) + func (result *Result) Repair(fields []*querypb.Field) + func (result *Result) StripFieldNames() *Result + type ResultState int + const RStateFields + const RStateFinished + const RStateNone + const RStateRows + type ResultStream interface + Recv func() (*Result, error) + type Row []Value + func (r Row) Copy() []Value + type Value struct + func BindVariableToValue(bv *querypb.BindVariable) (Value, error) + func BuildConverted(typ querypb.Type, goval interface{}) (v Value, err error) + func BuildIntegral(val string) (n Value, err error) + func BuildValue(goval interface{}) (v Value, err error) + func Cast(v Value, typ querypb.Type) (Value, error) + func GetResults(aggrs []*Aggregation, evalCtxs []*AggEvaluateContext, x []Value) ([]Value, []int) + func MakeString(val []byte) Value + func MakeTrusted(typ querypb.Type, val []byte) Value + func Max(v1, v2 Value) Value + func Min(v1, v2 Value) Value + func NewFloat32(v float32) Value + func NewFloat64(v float64) Value + func NewInt32(v int32) Value + func NewInt64(v int64) Value + func NewIntegral(val string) (n Value, err error) + func NewUint64(v uint64) Value + func NewValue(typ querypb.Type, val []byte) (v Value, err error) + func NewVarBinary(v string) Value + func NewVarChar(v string) Value + func NullsafeAdd(v1, v2 Value, resultType querypb.Type, prec int) (Value, error) + func NullsafeDiv(v1, v2 Value, resultType querypb.Type, prec int) (Value, error) + func NullsafeSum(sum, v Value, resultType querypb.Type, prec int) (Value, error) + func ProtoToValue(v *querypb.Value) Value + func ValueFromBytes(typ querypb.Type, val []byte) (v Value, err error) + func (v Value) EncodeASCII(b BinWriter) + func (v Value) EncodeSQL(b BinWriter) + func (v Value) IsBinary() bool + func (v Value) IsFloat() bool + func (v Value) IsIntegral() bool + func (v Value) IsNull() bool + func (v Value) IsQuoted() bool + func (v Value) IsSigned() bool + func (v Value) IsTemporal() bool + func (v Value) IsText() bool + func (v Value) IsUnsigned() bool + func (v Value) Len() int + func (v Value) ParseFloat64() (val float64, err error) + func (v Value) ParseInt64() (val int64, err error) + func (v Value) ParseUint64() (val uint64, err error) + func (v Value) Raw() []byte + func (v Value) String() string + func (v Value) ToMySQL() ([]byte, error) + func (v Value) ToNative() interface{} + func (v Value) ToString() string + func (v Value) Type() querypb.Type + type Values []Value + func (vs Values) Len() int