tikv
/
client-go
mirror of https://github.com/tikv/client-go.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix RowKVClient scan method can't rightly break loop (#43) 

* fix RowKVClient scan method can't rightly break loop

Signed-off-by: Yushen Lin <ldnvnbl@gmail.com>

* fix rawkv Scan and ReverseScan

Signed-off-by: Yushen Lin <ldnvnbl@gmail.com>
This commit is contained in:
LinYushen 2020-01-10 18:13:06 +08:00 committed by Shafreeck Sea
parent ddd42ffad4
commit a3ebdb020c
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@ -1,2 +1,3 @@
vendor vendor
go.sum go.sum
.idea

4
rawkv/rawkv.go
View File

@ -263,7 +263,7 @@ func (c *Client) Scan(ctx context.Context, startKey, endKey []byte, limit int) (
return nil, nil, errors.WithStack(ErrMaxScanLimitExceeded) return nil, nil, errors.WithStack(ErrMaxScanLimitExceeded)
} }
for len(keys) < limit { for len(keys) < limit && (len(endKey) == 0 || bytes.Compare(startKey, endKey) < 0) {
req := &rpc.Request{ req := &rpc.Request{
Type: rpc.CmdRawScan, Type: rpc.CmdRawScan,
RawScan: &kvrpcpb.RawScanRequest{ RawScan: &kvrpcpb.RawScanRequest{
@ -307,7 +307,7 @@ func (c *Client) ReverseScan(ctx context.Context, startKey, endKey []byte, limit
return nil, nil, errors.WithStack(ErrMaxScanLimitExceeded) return nil, nil, errors.WithStack(ErrMaxScanLimitExceeded)
} }
for len(keys) < limit { for len(keys) < limit && bytes.Compare(startKey, endKey) > 0 {
req := &rpc.Request{ req := &rpc.Request{
Type: rpc.CmdRawScan, Type: rpc.CmdRawScan,
RawScan: &kvrpcpb.RawScanRequest{ RawScan: &kvrpcpb.RawScanRequest{