569 lines
15 KiB
Go
569 lines
15 KiB
Go
// Copyright 2015 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 stringutil
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"slices"
|
|
"strings"
|
|
"unicode/utf8"
|
|
|
|
"github.com/pingcap/errors"
|
|
"github.com/pingcap/tidb/pkg/parser/mysql"
|
|
"github.com/pingcap/tidb/pkg/util/hack"
|
|
)
|
|
|
|
// ErrSyntax indicates that a value does not have the right syntax for the target type.
|
|
var ErrSyntax = errors.New("invalid syntax")
|
|
|
|
// UnquoteChar decodes the first character or byte in the escaped string
|
|
// or character literal represented by the string s.
|
|
// It returns four values:
|
|
//
|
|
// 1) value, the decoded Unicode code point or byte value;
|
|
// 2) multibyte, a boolean indicating whether the decoded character requires a multibyte UTF-8 representation;
|
|
// 3) tail, the remainder of the string after the character; and
|
|
// 4) an error that will be nil if the character is syntactically valid.
|
|
//
|
|
// The second argument, quote, specifies the type of literal being parsed
|
|
// and therefore which escaped quote character is permitted.
|
|
// If set to a single quote, it permits the sequence \' and disallows unescaped '.
|
|
// If set to a double quote, it permits \" and disallows unescaped ".
|
|
// If set to zero, it does not permit either escape and allows both quote characters to appear unescaped.
|
|
// Different with strconv.UnquoteChar, it permits unnecessary backslash.
|
|
func UnquoteChar(s string, quote byte) (value []byte, tail string, err error) {
|
|
// easy cases
|
|
switch c := s[0]; {
|
|
case c == quote:
|
|
err = errors.Trace(ErrSyntax)
|
|
return
|
|
case c >= utf8.RuneSelf:
|
|
r, size := utf8.DecodeRuneInString(s)
|
|
if r == utf8.RuneError {
|
|
value = append(value, c)
|
|
return value, s[1:], nil
|
|
}
|
|
value = append(value, string(r)...)
|
|
return value, s[size:], nil
|
|
case c != '\\':
|
|
value = append(value, c)
|
|
return value, s[1:], nil
|
|
}
|
|
// hard case: c is backslash
|
|
if len(s) <= 1 {
|
|
err = errors.Trace(ErrSyntax)
|
|
return
|
|
}
|
|
c := s[1]
|
|
s = s[2:]
|
|
switch c {
|
|
case 'b':
|
|
value = append(value, '\b')
|
|
case 'n':
|
|
value = append(value, '\n')
|
|
case 'r':
|
|
value = append(value, '\r')
|
|
case 't':
|
|
value = append(value, '\t')
|
|
case 'Z':
|
|
value = append(value, '\032')
|
|
case '0':
|
|
value = append(value, '\000')
|
|
case '_', '%':
|
|
value = append(value, '\\')
|
|
value = append(value, c)
|
|
case '\\':
|
|
value = append(value, '\\')
|
|
case '\'', '"':
|
|
value = append(value, c)
|
|
default:
|
|
value = append(value, c)
|
|
}
|
|
tail = s
|
|
return
|
|
}
|
|
|
|
// Unquote interprets s as a single-quoted, double-quoted,
|
|
// or backquoted Go string literal, returning the string value
|
|
// that s quotes. For example: test=`"\"\n"` (hex: 22 5c 22 5c 6e 22)
|
|
// should be converted to `"\n` (hex: 22 0a).
|
|
func Unquote(s string) (t string, err error) {
|
|
n := len(s)
|
|
if n < 2 {
|
|
return "", errors.Trace(ErrSyntax)
|
|
}
|
|
quote := s[0]
|
|
if quote != s[n-1] {
|
|
return "", errors.Trace(ErrSyntax)
|
|
}
|
|
s = s[1 : n-1]
|
|
if quote != '"' && quote != '\'' {
|
|
return "", errors.Trace(ErrSyntax)
|
|
}
|
|
// Avoid allocation. No need to convert if there is no '\'
|
|
if strings.IndexByte(s, '\\') == -1 && strings.IndexByte(s, quote) == -1 {
|
|
return s, nil
|
|
}
|
|
buf := make([]byte, 0, 3*len(s)/2) // Try to avoid more allocations.
|
|
for len(s) > 0 {
|
|
mb, ss, err := UnquoteChar(s, quote)
|
|
if err != nil {
|
|
return "", errors.Trace(err)
|
|
}
|
|
s = ss
|
|
buf = append(buf, mb...)
|
|
}
|
|
return string(buf), nil
|
|
}
|
|
|
|
const (
|
|
// PatMatch is the enumeration value for per-character match.
|
|
PatMatch = iota + 1
|
|
// PatOne is the enumeration value for '_' match.
|
|
PatOne
|
|
// PatAny is the enumeration value for '%' match.
|
|
PatAny
|
|
)
|
|
|
|
// CompilePatternBinary is used for binary strings.
|
|
func CompilePatternBinary(pattern string, escape byte) (patChars, patTypes []byte) {
|
|
return CompilePatternInnerBinary(pattern, escape)
|
|
}
|
|
|
|
// CompilePattern is an adapter for `CompilePatternInner`, `pattern` can be any unicode string.
|
|
func CompilePattern(pattern string, escape byte) (patWeights []rune, patTypes []byte) {
|
|
return CompilePatternInner(pattern, escape)
|
|
}
|
|
|
|
// CompilePatternInner handles escapes and wild cards convert pattern characters and
|
|
// pattern types.
|
|
// Note: if anything changes in this method, please double-check CompilePatternInnerBytes
|
|
func CompilePatternInner(pattern string, escape byte) (patWeights []rune, patTypes []byte) {
|
|
runes := []rune(pattern)
|
|
escapeRune := rune(escape)
|
|
lenRunes := len(runes)
|
|
patWeights = make([]rune, lenRunes)
|
|
patTypes = make([]byte, lenRunes)
|
|
patLen := 0
|
|
for i := 0; i < lenRunes; i++ {
|
|
var tp byte
|
|
var r = runes[i]
|
|
switch r {
|
|
case escapeRune:
|
|
tp = PatMatch
|
|
if i < lenRunes-1 {
|
|
i++
|
|
r = runes[i]
|
|
}
|
|
case '_':
|
|
// %_ => _%
|
|
if patLen > 0 && patTypes[patLen-1] == PatAny {
|
|
tp = PatAny
|
|
r = '%'
|
|
patWeights[patLen-1], patTypes[patLen-1] = '_', PatOne
|
|
} else {
|
|
tp = PatOne
|
|
}
|
|
case '%':
|
|
// %% => %
|
|
if patLen > 0 && patTypes[patLen-1] == PatAny {
|
|
continue
|
|
}
|
|
tp = PatAny
|
|
default:
|
|
tp = PatMatch
|
|
}
|
|
patWeights[patLen] = r
|
|
patTypes[patLen] = tp
|
|
patLen++
|
|
}
|
|
patWeights = patWeights[:patLen]
|
|
patTypes = patTypes[:patLen]
|
|
return
|
|
}
|
|
|
|
// CompilePatternInnerBinary handles escapes and wild cards convert pattern characters and
|
|
// pattern types in bytes.
|
|
// The main algorithm is the same as CompilePatternInner. However, it's not easy to use interface/lambda to hide the different details here.
|
|
// Note: if anything changes in this method, please double-check CompilePatternInner
|
|
func CompilePatternInnerBinary(pattern string, escape byte) (patWeights, patTypes []byte) {
|
|
bytes := []byte(pattern)
|
|
lenBytes := len(bytes)
|
|
patWeights = make([]byte, lenBytes)
|
|
patTypes = make([]byte, lenBytes)
|
|
patLen := 0
|
|
for i := 0; i < lenBytes; i++ {
|
|
var tp byte
|
|
var b = bytes[i]
|
|
switch b {
|
|
case escape:
|
|
tp = PatMatch
|
|
if i < lenBytes-1 {
|
|
i++
|
|
b = bytes[i]
|
|
}
|
|
case '_':
|
|
// %_ => _%
|
|
if patLen > 0 && patTypes[patLen-1] == PatAny {
|
|
tp = PatAny
|
|
b = '%'
|
|
patWeights[patLen-1], patTypes[patLen-1] = '_', PatOne
|
|
} else {
|
|
tp = PatOne
|
|
}
|
|
case '%':
|
|
// %% => %
|
|
if patLen > 0 && patTypes[patLen-1] == PatAny {
|
|
continue
|
|
}
|
|
tp = PatAny
|
|
default:
|
|
tp = PatMatch
|
|
}
|
|
patWeights[patLen] = b
|
|
patTypes[patLen] = tp
|
|
patLen++
|
|
}
|
|
patWeights = patWeights[:patLen]
|
|
patTypes = patTypes[:patLen]
|
|
return
|
|
}
|
|
|
|
func matchRune(a, b rune) bool {
|
|
return a == b
|
|
// We may reuse below code block when like function go back to case insensitive.
|
|
/*
|
|
if a == b {
|
|
return true
|
|
}
|
|
if a >= 'a' && a <= 'z' && a-caseDiff == b {
|
|
return true
|
|
}
|
|
return a >= 'A' && a <= 'Z' && a+caseDiff == b
|
|
*/
|
|
}
|
|
|
|
// CompileLike2Regexp convert a like `lhs` to a regular expression
|
|
func CompileLike2Regexp(str string) string {
|
|
patChars, patTypes := CompilePattern(str, '\\')
|
|
var result []rune
|
|
for i := range patChars {
|
|
switch patTypes[i] {
|
|
case PatMatch:
|
|
result = append(result, patChars[i])
|
|
case PatOne:
|
|
result = append(result, '.')
|
|
case PatAny:
|
|
result = append(result, '.', '*')
|
|
}
|
|
}
|
|
return string(result)
|
|
}
|
|
|
|
// DoMatchBinary is an adapter for `DoMatchInner`, `str` is binary strings or ascii string.
|
|
func DoMatchBinary(str string, patChars, patTypes []byte) bool {
|
|
bytes := []byte(str)
|
|
lenBytes := len(bytes)
|
|
lenPatWeights := len(patChars)
|
|
return doMatchInner(lenPatWeights, lenBytes, patTypes, func(a, b int) bool { return bytes[a] == patChars[b] })
|
|
}
|
|
|
|
// DoMatch is an adapter for `DoMatchCustomized`, `str` can be any unicode string.
|
|
func DoMatch(str string, patChars []rune, patTypes []byte) bool {
|
|
return DoMatchCustomized(str, patChars, patTypes, matchRune)
|
|
}
|
|
|
|
// DoMatchCustomized is an adapter for `DoMatchInner`, `str` can be any unicode string.
|
|
func DoMatchCustomized(str string, patWeights []rune, patTypes []byte, matcher func(a, b rune) bool) bool {
|
|
// TODO(bb7133): it is possible to get the rune one by one to avoid the cost of get them as a whole.
|
|
runes := []rune(str)
|
|
lenRunes := len(runes)
|
|
lenPatWeights := len(patWeights)
|
|
return doMatchInner(lenPatWeights, lenRunes, patTypes, func(a, b int) bool { return matcher(runes[a], patWeights[b]) })
|
|
}
|
|
|
|
// doMatchInner matches the string with patChars and patTypes.
|
|
// The algorithm has linear time complexity.
|
|
// https://research.swtch.com/glob
|
|
func doMatchInner(lenPatWeights int, lenChars int, patTypes []byte, matcher func(a, b int) bool) bool {
|
|
var cIdx, pIdx, nextCIdx, nextPIdx int
|
|
for pIdx < lenPatWeights || cIdx < lenChars {
|
|
if pIdx < lenPatWeights {
|
|
switch patTypes[pIdx] {
|
|
case PatMatch:
|
|
if cIdx < lenChars && matcher(cIdx, pIdx) {
|
|
pIdx++
|
|
cIdx++
|
|
continue
|
|
}
|
|
case PatOne:
|
|
if cIdx < lenChars {
|
|
pIdx++
|
|
cIdx++
|
|
continue
|
|
}
|
|
case PatAny:
|
|
// Try to match at sIdx.
|
|
// If that doesn't work out,
|
|
// restart at sIdx+1 next.
|
|
nextPIdx = pIdx
|
|
nextCIdx = cIdx + 1
|
|
pIdx++
|
|
continue
|
|
}
|
|
}
|
|
// Mismatch. Maybe restart.
|
|
if 0 < nextCIdx && nextCIdx <= lenChars {
|
|
pIdx = nextPIdx
|
|
cIdx = nextCIdx
|
|
continue
|
|
}
|
|
return false
|
|
}
|
|
// Matched all of pattern to all of name. Success.
|
|
return true
|
|
}
|
|
|
|
// IsExactMatch return true if no wildcard character
|
|
func IsExactMatch(patTypes []byte) bool {
|
|
for _, pt := range patTypes {
|
|
if pt != PatMatch {
|
|
return false
|
|
}
|
|
}
|
|
return true
|
|
}
|
|
|
|
// Copy deep copies a string.
|
|
func Copy(src string) string {
|
|
return string(hack.Slice(src))
|
|
}
|
|
|
|
// StringerFunc defines string func implement fmt.Stringer.
|
|
type StringerFunc func() string
|
|
|
|
// String implements fmt.Stringer
|
|
func (l StringerFunc) String() string {
|
|
return l()
|
|
}
|
|
|
|
// MemoizeStr returns memoized version of stringFunc. When the result of l is not
|
|
// "", it will be cached and returned directly next time.
|
|
//
|
|
// MemoizeStr is not concurrency safe.
|
|
func MemoizeStr(l func() string) fmt.Stringer {
|
|
var result string
|
|
return StringerFunc(func() string {
|
|
if result != "" {
|
|
return result
|
|
}
|
|
result = l()
|
|
return result
|
|
})
|
|
}
|
|
|
|
// StringerStr defines a alias to normal string.
|
|
// implement fmt.Stringer
|
|
type StringerStr string
|
|
|
|
// String implements fmt.Stringer
|
|
func (i StringerStr) String() string {
|
|
return string(i)
|
|
}
|
|
|
|
// Escape the identifier for pretty-printing.
|
|
// For instance, the identifier
|
|
/*
|
|
"foo `bar`" will become "`foo ``bar```".
|
|
*/
|
|
// The sqlMode controls whether to escape with backquotes (`) or double quotes
|
|
// (`"`) depending on whether mysql.ModeANSIQuotes is enabled.
|
|
func Escape(str string, sqlMode mysql.SQLMode) string {
|
|
var quote string
|
|
if sqlMode&mysql.ModeANSIQuotes != 0 {
|
|
quote = `"`
|
|
} else {
|
|
quote = "`"
|
|
}
|
|
return quote + strings.ReplaceAll(str, quote, quote+quote) + quote
|
|
}
|
|
|
|
// BuildStringFromLabels construct config labels into string by following format:
|
|
// "keyA=valueA,keyB=valueB"
|
|
func BuildStringFromLabels(labels map[string]string) string {
|
|
if len(labels) < 1 {
|
|
return ""
|
|
}
|
|
s := make([]string, 0, len(labels))
|
|
for k := range labels {
|
|
s = append(s, k)
|
|
}
|
|
slices.Sort(s)
|
|
var r bytes.Buffer
|
|
// visit labels by sorted key in order to make sure that result should be consistency
|
|
for _, key := range s {
|
|
fmt.Fprintf(&r, "%s=%s,", key, labels[key])
|
|
}
|
|
returned := r.String()
|
|
return returned[:len(returned)-1]
|
|
}
|
|
|
|
// GetTailSpaceCount returns the number of tailed spaces.
|
|
func GetTailSpaceCount(str string) int64 {
|
|
length := len(str)
|
|
for length > 0 && str[length-1] == ' ' {
|
|
length--
|
|
}
|
|
return int64(len(str) - length)
|
|
}
|
|
|
|
// Utf8Len calculates how many bytes the utf8 character takes.
|
|
// This b parameter should be the first byte of utf8 character
|
|
func Utf8Len(b byte) int {
|
|
flag := uint8(128)
|
|
if (flag & b) == 0 {
|
|
return 1
|
|
}
|
|
|
|
length := 0
|
|
|
|
for ; (flag & b) != 0; flag >>= 1 {
|
|
length++
|
|
}
|
|
|
|
return length
|
|
}
|
|
|
|
// TrimUtf8String needs the string input should always be valid which means
|
|
// that it should always return true in utf8.ValidString(str)
|
|
func TrimUtf8String(str *string, trimmedNum int64) int64 {
|
|
totalLenTrimmed := int64(0)
|
|
for ; trimmedNum > 0; trimmedNum-- {
|
|
length := Utf8Len((*str)[0]) // character length
|
|
*str = (*str)[length:]
|
|
totalLenTrimmed += int64(length)
|
|
}
|
|
return totalLenTrimmed
|
|
}
|
|
|
|
// ConvertPosInUtf8 converts a binary index to the position which shows the occurrence location in the utf8 string
|
|
// Take "你好" as example:
|
|
//
|
|
// binary index for "好" is 3, ConvertPosInUtf8("你好", 3) should return 2
|
|
func ConvertPosInUtf8(str *string, pos int64) int64 {
|
|
preStr := (*str)[:pos]
|
|
preStrNum := utf8.RuneCountInString(preStr)
|
|
return int64(preStrNum + 1)
|
|
}
|
|
|
|
func toLowerIfAlphaASCII(c byte) byte {
|
|
return c | 0x20
|
|
}
|
|
|
|
func toUpperIfAlphaASCII(c byte) byte {
|
|
return c ^ 0x20
|
|
}
|
|
|
|
// IsUpperASCII judges if this is capital alphabet
|
|
func IsUpperASCII(c byte) bool {
|
|
if c >= 'A' && c <= 'Z' {
|
|
return true
|
|
}
|
|
return false
|
|
}
|
|
|
|
// IsLowerASCII judges if this is lower alphabet
|
|
func IsLowerASCII(c byte) bool {
|
|
if c >= 'a' && c <= 'z' {
|
|
return true
|
|
}
|
|
return false
|
|
}
|
|
|
|
// LowerOneString lowers the ascii characters in a string
|
|
func LowerOneString(str []byte) {
|
|
strLen := len(str)
|
|
for i := range strLen {
|
|
if IsUpperASCII(str[i]) {
|
|
str[i] = toLowerIfAlphaASCII(str[i])
|
|
}
|
|
}
|
|
}
|
|
|
|
// IsNumericASCII judges if a byte is numeric
|
|
func IsNumericASCII(c byte) bool {
|
|
return (c >= '0' && c <= '9')
|
|
}
|
|
|
|
// LowerOneStringExcludeEscapeChar lowers strings and exclude an escape char
|
|
//
|
|
// When escape_char is a capital char, we shouldn't lower the escape char.
|
|
// For example, 'aaaa' ilike 'AAAA' escape 'A', we should convert 'AAAA' to 'AaAa'.
|
|
// If we do not exclude the escape char, 'AAAA' will be lowered to 'aaaa', and we
|
|
// can not get the correct result.
|
|
//
|
|
// When escape_char is a lower char, we need to convert it to the capital char
|
|
// Because: when lowering "ABC" with escape 'a', after lower, "ABC" -> "abc",
|
|
// then 'a' will be an escape char and it is not expected.
|
|
// Morever, when escape char is uppered we need to tell it to the caller.
|
|
func LowerOneStringExcludeEscapeChar(str []byte, escapeChar byte) byte {
|
|
actualEscapeChar := escapeChar
|
|
if IsLowerASCII(escapeChar) {
|
|
actualEscapeChar = toUpperIfAlphaASCII(escapeChar)
|
|
}
|
|
escaped := false
|
|
strLen := len(str)
|
|
|
|
for i := 0; i < strLen; i++ {
|
|
if IsUpperASCII(str[i]) {
|
|
// Do not lower the escape char, however when a char is equal to
|
|
// an escape char and it's after an escape char, we still lower it
|
|
// For example: "AA" (escape 'A'), -> "Aa"
|
|
if !(str[i] != escapeChar || escaped) {
|
|
escaped = true
|
|
continue
|
|
}
|
|
str[i] = toLowerIfAlphaASCII(str[i])
|
|
} else {
|
|
if str[i] == escapeChar && !escaped {
|
|
escaped = true
|
|
|
|
// It should be `str[i] = toUpperIfAlphaASCII(str[i])`,
|
|
// but 'actual_escape_char' is always equal to 'toUpperIfAlphaASCII(str[i])'
|
|
str[i] = actualEscapeChar
|
|
continue
|
|
}
|
|
i += Utf8Len(str[i]) - 1
|
|
}
|
|
escaped = false
|
|
}
|
|
|
|
return actualEscapeChar
|
|
}
|
|
|
|
// EscapeGlobQuestionMark escapes '?' for a glob path pattern.
|
|
func EscapeGlobQuestionMark(s string) string {
|
|
var buf strings.Builder
|
|
buf.Grow(len(s))
|
|
for _, c := range s {
|
|
if c == '?' {
|
|
buf.WriteByte('\\')
|
|
}
|
|
buf.WriteRune(c)
|
|
}
|
|
return buf.String()
|
|
}
|