Function TestDecodeIndexKey

pkg/tablecodec/tablecodec_test.go:477–509

(t *testing.T)

}

func TestDecodeIndexKey(t *testing.T) {
	tableID := int64(4)
	indexID := int64(5)
	values := []types.Datum{
		types.NewIntDatum(1),
		types.NewBytesDatum([]byte("abc")),
		types.NewFloat64Datum(123.45),
		// MysqlTime is not supported.
		// types.NewTimeDatum(types.Time{
		// 	Time: types.FromGoTime(time.Now()),
		// 	Fsp:  6,
		// 	Type: mysql.TypeTimestamp,
		// }),
	}
	valueStrs := make([]string, 0, len(values))
	for _, v := range values {
		str, err := v.ToString()
		if err != nil {
			str = fmt.Sprintf("%d-%v", v.Kind(), v.GetValue())
		}
		valueStrs = append(valueStrs, str)
	}
	sc := stmtctx.NewStmtCtxWithTimeZone(time.UTC)
	encodedValue, err := codec.EncodeKey(sc.TimeZone(), nil, values...)
	require.NoError(t, err)
	indexKey := EncodeIndexSeekKey(tableID, indexID, encodedValue)

	decodeTableID, decodeIndexID, decodeValues, err := DecodeIndexKey(indexKey)
	require.NoError(t, err)
	require.Equal(t, tableID, decodeTableID)
	require.Equal(t, indexID, decodeIndexID)
	require.Equal(t, valueStrs, decodeValues)
}

func TestCutPrefix(t *testing.T) {
	key := EncodeTableIndexPrefix(42, 666)