Method Compare

server/types/type.go:199–404

Compare implements the types.ExtendedType interface.

(ctx context.Context, v1 interface{}, v2 interface{})

// Compare implements the types.ExtendedType interface.
func (t *DoltgresType) Compare(ctx context.Context, v1 interface{}, v2 interface{}) (int, error) {
	// TODO: for some large types, we could do this much faster by doing it chunk-by-chunk, rather than eagerly loading
	//  the full value into memory
	var err error
	v1, err = sql.UnwrapAny(ctx, v1)
	if err != nil {
		return 0, err
	}
	v2, err = sql.UnwrapAny(ctx, v2)
	if err != nil {
		return 0, err
	}

	if v1 == nil && v2 == nil {
		return 0, nil
	} else if v1 != nil && v2 == nil {
		return 1, nil
	} else if v1 == nil && v2 != nil {
		return -1, nil
	}

	if t.TypType == TypeType_Enum {
		// TODO: temporary solution to getting the enum type (which has label info) into the 'enum_cmp' function
		// ctx is not guaranteed to be a *sql.Context when called from index comparator goroutines.
		sqlCtx, ok := ctx.(*sql.Context)
		if !ok {
			sqlCtx = sql.NewEmptyContext()
		}
		qf := globalFunctionRegistry.GetFunction(sqlCtx, t.CompareFunc)
		resTypes := qf.ResolvedTypes()
		newFunc := qf.WithResolvedTypes([]*DoltgresType{t, t, resTypes[len(resTypes)-1]})
		i, err := newFunc.(QuickFunction).CallVariadic(nil, v1, v2)
		if err != nil {
			return 0, err
		}
		return int(i.(int32)), nil
	} else if t == Oidvector {
		// ctx is not guaranteed to be a *sql.Context when called from index comparator goroutines.
		sqlCtx, ok := ctx.(*sql.Context)
		if !ok {
			sqlCtx = sql.NewEmptyContext()
		}
		i, err := globalFunctionRegistry.GetFunction(sqlCtx, t.CompareFunc).CallVariadic(nil, v1, v2)
		if err != nil {
			return 0, err
		}
		return int(i.(int32)), nil
	}

	switch ab := v1.(type) {
	case bool:
		bb := v2.(bool)
		if ab == bb {
			return 0, nil
		} else if !ab {
			return -1, nil
		} else {
			return 1, nil