Function TestEncodeDecodeRowWithChecksum

pkg/util/rowcodec/rowcodec_test.go:1197–1230

(t *testing.T)

}

func TestEncodeDecodeRowWithChecksum(t *testing.T) {
	enc := rowcodec.Encoder{}

	raw, err := enc.Encode(time.UTC, nil, nil, nil, nil)
	require.NoError(t, err)

	dec := rowcodec.NewDatumMapDecoder([]rowcodec.ColInfo{}, time.UTC)
	_, err = dec.DecodeToDatumMap(raw, nil)
	require.NoError(t, err)

	checksum, ok := dec.GetChecksum()
	require.False(t, ok)
	require.Zero(t, checksum)

	rawChecksum := rowcodec.RawChecksum{
		Handle: kv.IntHandle(1),
	}
	raw, err = enc.Encode(time.UTC, nil, nil, rawChecksum, nil)
	require.NoError(t, err)

	expected, ok := enc.GetChecksum()
	require.True(t, ok)
	require.NotZero(t, expected)

	_, err = dec.DecodeToDatumMap(raw, nil)
	require.NoError(t, err)

	checksum, ok = dec.GetChecksum()
	require.True(t, ok)
	require.Equal(t, expected, checksum)

	version := dec.ChecksumVersion()
	require.Equal(t, 2, version)
}

var (
	withUnsigned = func(ft *types.FieldType) *types.FieldType {