327 lines
9.8 KiB
Go
327 lines
9.8 KiB
Go
// Copyright 2023 PingCAP, Inc.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package external
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
|
|
"github.com/pingcap/tidb/br/pkg/storage"
|
|
"github.com/pingcap/tidb/pkg/kv"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestSeekPropsOffsets(t *testing.T) {
|
|
ctx := context.Background()
|
|
store := storage.NewMemStorage()
|
|
|
|
rc1 := &rangePropertiesCollector{
|
|
props: []*rangeProperty{
|
|
{
|
|
firstKey: []byte("key1"),
|
|
offset: 10,
|
|
},
|
|
{
|
|
firstKey: []byte("key3"),
|
|
offset: 30,
|
|
},
|
|
{
|
|
firstKey: []byte("key5"),
|
|
offset: 50,
|
|
},
|
|
},
|
|
}
|
|
file1 := "/test1"
|
|
w1, err := store.Create(ctx, file1, nil)
|
|
require.NoError(t, err)
|
|
_, err = w1.Write(ctx, rc1.encode())
|
|
require.NoError(t, err)
|
|
err = w1.Close(ctx)
|
|
require.NoError(t, err)
|
|
|
|
rc2 := &rangePropertiesCollector{
|
|
props: []*rangeProperty{
|
|
{
|
|
firstKey: []byte("key2"),
|
|
offset: 20,
|
|
},
|
|
{
|
|
firstKey: []byte("key4"),
|
|
offset: 40,
|
|
},
|
|
},
|
|
}
|
|
file2 := "/test2"
|
|
w2, err := store.Create(ctx, file2, nil)
|
|
require.NoError(t, err)
|
|
_, err = w2.Write(ctx, rc2.encode())
|
|
require.NoError(t, err)
|
|
err = w2.Close(ctx)
|
|
require.NoError(t, err)
|
|
|
|
got, err := seekPropsOffsets(ctx, []kv.Key{[]byte("key2.5")}, []string{file1, file2}, store)
|
|
require.NoError(t, err)
|
|
require.Equal(t, [][]uint64{{10, 20}}, got)
|
|
|
|
got, err = seekPropsOffsets(ctx, []kv.Key{[]byte("key2.5"), []byte("key2.6")}, []string{file1, file2}, store)
|
|
require.NoError(t, err)
|
|
require.Equal(t, [][]uint64{{10, 20}, {10, 20}}, got)
|
|
|
|
got, err = seekPropsOffsets(ctx, []kv.Key{[]byte("key3")}, []string{file1, file2}, store)
|
|
require.NoError(t, err)
|
|
require.Equal(t, [][]uint64{{30, 20}}, got)
|
|
|
|
got, err = seekPropsOffsets(ctx, []kv.Key{[]byte("key2.5"), []byte("key3")}, []string{file1, file2}, store)
|
|
require.NoError(t, err)
|
|
require.Equal(t, [][]uint64{{10, 20}, {30, 20}}, got)
|
|
|
|
got, err = seekPropsOffsets(ctx, []kv.Key{[]byte("key0")}, []string{file1, file2}, store)
|
|
require.NoError(t, err)
|
|
require.Equal(t, [][]uint64{{0, 0}}, got)
|
|
|
|
got, err = seekPropsOffsets(ctx, []kv.Key{[]byte("key1")}, []string{file1, file2}, store)
|
|
require.NoError(t, err)
|
|
require.Equal(t, [][]uint64{{10, 0}}, got)
|
|
|
|
got, err = seekPropsOffsets(ctx, []kv.Key{[]byte("key0"), []byte("key1")}, []string{file1, file2}, store)
|
|
require.NoError(t, err)
|
|
require.Equal(t, [][]uint64{{0, 0}, {10, 0}}, got)
|
|
|
|
got, err = seekPropsOffsets(ctx, []kv.Key{[]byte("key999")}, []string{file1, file2}, store)
|
|
require.NoError(t, err)
|
|
require.Equal(t, [][]uint64{{50, 40}}, got)
|
|
|
|
got, err = seekPropsOffsets(ctx, []kv.Key{[]byte("key999"), []byte("key999")}, []string{file1, file2}, store)
|
|
require.NoError(t, err)
|
|
require.Equal(t, [][]uint64{{50, 40}, {50, 40}}, got)
|
|
|
|
file3 := "/test3"
|
|
w3, err := store.Create(ctx, file3, nil)
|
|
require.NoError(t, err)
|
|
err = w3.Close(ctx)
|
|
require.NoError(t, err)
|
|
|
|
file4 := "/test4"
|
|
w4, err := store.Create(ctx, file4, nil)
|
|
require.NoError(t, err)
|
|
_, err = w4.Write(ctx, rc1.encode())
|
|
require.NoError(t, err)
|
|
err = w4.Close(ctx)
|
|
require.NoError(t, err)
|
|
got, err = seekPropsOffsets(ctx, []kv.Key{[]byte("key3")}, []string{file1, file2, file3, file4}, store)
|
|
require.NoError(t, err)
|
|
require.Equal(t, [][]uint64{{30, 20, 0, 30}}, got)
|
|
|
|
got, err = seekPropsOffsets(ctx, []kv.Key{[]byte("key3"), []byte("key999")}, []string{file1, file2, file3, file4}, store)
|
|
require.NoError(t, err)
|
|
require.Equal(t, [][]uint64{{30, 20, 0, 30}, {50, 40, 0, 50}}, got)
|
|
}
|
|
|
|
func TestGetAllFileNames(t *testing.T) {
|
|
ctx := context.Background()
|
|
store := storage.NewMemStorage()
|
|
w := NewWriterBuilder().
|
|
SetMemorySizeLimit(10*(lengthBytes*2+2)).
|
|
SetBlockSize(10*(lengthBytes*2+2)).
|
|
SetPropSizeDistance(5).
|
|
SetPropKeysDistance(3).
|
|
Build(store, "/subtask", "0")
|
|
|
|
keys := make([][]byte, 0, 30)
|
|
values := make([][]byte, 0, 30)
|
|
for i := 0; i < 30; i++ {
|
|
keys = append(keys, []byte{byte(i)})
|
|
values = append(values, []byte{byte(i)})
|
|
}
|
|
|
|
for i, key := range keys {
|
|
err := w.WriteRow(ctx, key, values[i], nil)
|
|
require.NoError(t, err)
|
|
}
|
|
err := w.Close(ctx)
|
|
require.NoError(t, err)
|
|
|
|
w2 := NewWriterBuilder().
|
|
SetMemorySizeLimit(10*(lengthBytes*2+2)).
|
|
SetBlockSize(10*(lengthBytes*2+2)).
|
|
SetPropSizeDistance(5).
|
|
SetPropKeysDistance(3).
|
|
Build(store, "/subtask", "3")
|
|
for i, key := range keys {
|
|
err := w2.WriteRow(ctx, key, values[i], nil)
|
|
require.NoError(t, err)
|
|
}
|
|
require.NoError(t, err)
|
|
err = w2.Close(ctx)
|
|
require.NoError(t, err)
|
|
|
|
w3 := NewWriterBuilder().
|
|
SetMemorySizeLimit(10*(lengthBytes*2+2)).
|
|
SetBlockSize(10*(lengthBytes*2+2)).
|
|
SetPropSizeDistance(5).
|
|
SetPropKeysDistance(3).
|
|
Build(store, "/subtask", "12")
|
|
for i, key := range keys {
|
|
err := w3.WriteRow(ctx, key, values[i], nil)
|
|
require.NoError(t, err)
|
|
}
|
|
err = w3.Close(ctx)
|
|
require.NoError(t, err)
|
|
|
|
dataFiles, statFiles, err := GetAllFileNames(ctx, store, "/subtask")
|
|
require.NoError(t, err)
|
|
require.Equal(t, []string{
|
|
"/subtask/0_stat/0", "/subtask/0_stat/1", "/subtask/0_stat/2",
|
|
"/subtask/12_stat/0", "/subtask/12_stat/1", "/subtask/12_stat/2",
|
|
"/subtask/3_stat/0", "/subtask/3_stat/1", "/subtask/3_stat/2",
|
|
}, statFiles)
|
|
require.Equal(t, []string{
|
|
"/subtask/0/0", "/subtask/0/1", "/subtask/0/2",
|
|
"/subtask/12/0", "/subtask/12/1", "/subtask/12/2",
|
|
"/subtask/3/0", "/subtask/3/1", "/subtask/3/2",
|
|
}, dataFiles)
|
|
}
|
|
|
|
func TestCleanUpFiles(t *testing.T) {
|
|
ctx := context.Background()
|
|
store := storage.NewMemStorage()
|
|
w := NewWriterBuilder().
|
|
SetMemorySizeLimit(10*(lengthBytes*2+2)).
|
|
SetBlockSize(10*(lengthBytes*2+2)).
|
|
SetPropSizeDistance(5).
|
|
SetPropKeysDistance(3).
|
|
Build(store, "/subtask", "0")
|
|
keys := make([][]byte, 0, 30)
|
|
values := make([][]byte, 0, 30)
|
|
for i := 0; i < 30; i++ {
|
|
keys = append(keys, []byte{byte(i)})
|
|
values = append(values, []byte{byte(i)})
|
|
}
|
|
for i, key := range keys {
|
|
err := w.WriteRow(ctx, key, values[i], nil)
|
|
require.NoError(t, err)
|
|
}
|
|
err := w.Close(ctx)
|
|
require.NoError(t, err)
|
|
|
|
dataFiles, statFiles, err := GetAllFileNames(ctx, store, "/subtask")
|
|
require.NoError(t, err)
|
|
require.Equal(t, []string{
|
|
"/subtask/0_stat/0", "/subtask/0_stat/1", "/subtask/0_stat/2",
|
|
}, statFiles)
|
|
require.Equal(t, []string{
|
|
"/subtask/0/0", "/subtask/0/1", "/subtask/0/2",
|
|
}, dataFiles)
|
|
|
|
require.NoError(t, CleanUpFiles(ctx, store, "/subtask"))
|
|
|
|
dataFiles, statFiles, err = GetAllFileNames(ctx, store, "/subtask")
|
|
require.NoError(t, err)
|
|
require.Equal(t, []string(nil), statFiles)
|
|
require.Equal(t, []string(nil), dataFiles)
|
|
}
|
|
|
|
func TestGetMaxOverlapping(t *testing.T) {
|
|
// [1, 3), [2, 4)
|
|
points := []Endpoint{
|
|
{Key: []byte{1}, Tp: InclusiveStart, Weight: 1},
|
|
{Key: []byte{3}, Tp: ExclusiveEnd, Weight: 1},
|
|
{Key: []byte{2}, Tp: InclusiveStart, Weight: 1},
|
|
{Key: []byte{4}, Tp: ExclusiveEnd, Weight: 1},
|
|
}
|
|
require.EqualValues(t, 2, GetMaxOverlapping(points))
|
|
// [1, 3), [2, 4), [3, 5)
|
|
points = []Endpoint{
|
|
{Key: []byte{1}, Tp: InclusiveStart, Weight: 1},
|
|
{Key: []byte{3}, Tp: ExclusiveEnd, Weight: 1},
|
|
{Key: []byte{2}, Tp: InclusiveStart, Weight: 1},
|
|
{Key: []byte{4}, Tp: ExclusiveEnd, Weight: 1},
|
|
{Key: []byte{3}, Tp: InclusiveStart, Weight: 1},
|
|
{Key: []byte{5}, Tp: ExclusiveEnd, Weight: 1},
|
|
}
|
|
require.EqualValues(t, 2, GetMaxOverlapping(points))
|
|
// [1, 3], [2, 4], [3, 5]
|
|
points = []Endpoint{
|
|
{Key: []byte{1}, Tp: InclusiveStart, Weight: 1},
|
|
{Key: []byte{3}, Tp: InclusiveEnd, Weight: 1},
|
|
{Key: []byte{2}, Tp: InclusiveStart, Weight: 1},
|
|
{Key: []byte{4}, Tp: InclusiveEnd, Weight: 1},
|
|
{Key: []byte{3}, Tp: InclusiveStart, Weight: 1},
|
|
{Key: []byte{5}, Tp: InclusiveEnd, Weight: 1},
|
|
}
|
|
require.EqualValues(t, 3, GetMaxOverlapping(points))
|
|
}
|
|
|
|
func TestSortedKVMeta(t *testing.T) {
|
|
summary := []*WriterSummary{
|
|
{
|
|
Min: []byte("a"),
|
|
Max: []byte("b"),
|
|
TotalSize: 123,
|
|
MultipleFilesStats: []MultipleFilesStat{
|
|
{
|
|
Filenames: [][2]string{
|
|
{"f1", "stat1"},
|
|
{"f2", "stat2"},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
Min: []byte("x"),
|
|
Max: []byte("y"),
|
|
TotalSize: 177,
|
|
MultipleFilesStats: []MultipleFilesStat{
|
|
{
|
|
Filenames: [][2]string{
|
|
{"f3", "stat3"},
|
|
{"f4", "stat4"},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
}
|
|
meta0 := NewSortedKVMeta(summary[0])
|
|
require.Equal(t, []byte("a"), meta0.StartKey)
|
|
require.Equal(t, []byte{'b', 0}, meta0.EndKey)
|
|
require.Equal(t, uint64(123), meta0.TotalKVSize)
|
|
require.Equal(t, summary[0].MultipleFilesStats, meta0.MultipleFilesStats)
|
|
meta1 := NewSortedKVMeta(summary[1])
|
|
require.Equal(t, []byte("x"), meta1.StartKey)
|
|
require.Equal(t, []byte{'y', 0}, meta1.EndKey)
|
|
require.Equal(t, uint64(177), meta1.TotalKVSize)
|
|
require.Equal(t, summary[1].MultipleFilesStats, meta1.MultipleFilesStats)
|
|
|
|
meta0.MergeSummary(summary[1])
|
|
require.Equal(t, []byte("a"), meta0.StartKey)
|
|
require.Equal(t, []byte{'y', 0}, meta0.EndKey)
|
|
require.Equal(t, uint64(300), meta0.TotalKVSize)
|
|
mergedStats := append([]MultipleFilesStat{}, summary[0].MultipleFilesStats...)
|
|
mergedStats = append(mergedStats, summary[1].MultipleFilesStats...)
|
|
require.Equal(t, mergedStats, meta0.MultipleFilesStats)
|
|
|
|
meta00 := NewSortedKVMeta(summary[0])
|
|
meta00.Merge(meta1)
|
|
require.Equal(t, meta0, meta00)
|
|
}
|
|
|
|
func TestKeyMinMax(t *testing.T) {
|
|
require.Equal(t, []byte("a"), BytesMin([]byte("a"), []byte("b")))
|
|
require.Equal(t, []byte("a"), BytesMin([]byte("b"), []byte("a")))
|
|
|
|
require.Equal(t, []byte("b"), BytesMax([]byte("a"), []byte("b")))
|
|
require.Equal(t, []byte("b"), BytesMax([]byte("b"), []byte("a")))
|
|
}
|