Skip to content

S
soar

Xiaomi / soar
大约 2 年 前同步成功

通知 467
Star 8513
Fork 1329
S
soar
提交 68128b73 编写于 作者: martianzhang's avatar martianzhang
浏览文件
操作

update vendor

上级 fb13892e
显示空白变更内容
内联 并排
Showing with 11225 addition and 10418 deletion
vendor/github.com/pingcap/parser/Makefile
浏览文件 @ 68128b73
...@@ -33,7 +33,7 @@ bin/goyacc: goyacc/main.go ...@@ -33,7 +33,7 @@ bin/goyacc: goyacc/main.go
fmt: fmt:
@echo "gofmt (simplify)" @echo "gofmt (simplify)"
@ gofmt -s -l -w . 2>&1 | awk '{print} END{if(NR>0) {exit 1}}' @gofmt -s -l -w . 2>&1 | awk '{print} END{if(NR>0) {exit 1}}'
clean: clean:
go clean -i ./... go clean -i ./...
......
vendor/github.com/pingcap/parser/ast/ddl.go
浏览文件 @ 68128b73
...@@ -548,6 +548,16 @@ func (n *ColumnOption) Accept(v Visitor) (Node, bool) { ...@@ -548,6 +548,16 @@ func (n *ColumnOption) Accept(v Visitor) (Node, bool) {
return v.Leave(n) return v.Leave(n)
} }
// IndexVisibility is the option for index visibility.
type IndexVisibility int
// IndexVisibility options.
const (
IndexVisibilityDefault IndexVisibility = iota
IndexVisibilityVisible
IndexVisibilityInvisible
)
// IndexOption is the index options. // IndexOption is the index options.
// KEY_BLOCK_SIZE [=] value // KEY_BLOCK_SIZE [=] value
// | index_type // | index_type
...@@ -560,6 +570,8 @@ type IndexOption struct { ...@@ -560,6 +570,8 @@ type IndexOption struct {
KeyBlockSize uint64 KeyBlockSize uint64
Tp model.IndexType Tp model.IndexType
Comment string Comment string
ParserName model.CIStr
Visibility IndexVisibility
} }
// Restore implements Node interface. // Restore implements Node interface.
...@@ -580,12 +592,34 @@ func (n *IndexOption) Restore(ctx *RestoreCtx) error { ...@@ -580,12 +592,34 @@ func (n *IndexOption) Restore(ctx *RestoreCtx) error {
hasPrevOption = true hasPrevOption = true
} }
if len(n.ParserName.O) > 0 {
if hasPrevOption {
ctx.WritePlain(" ")
}
ctx.WriteKeyWord("WITH PARSER ")
ctx.WriteName(n.ParserName.O)
hasPrevOption = true
}
if n.Comment != "" { if n.Comment != "" {
if hasPrevOption { if hasPrevOption {
ctx.WritePlain(" ") ctx.WritePlain(" ")
} }
ctx.WriteKeyWord("COMMENT ") ctx.WriteKeyWord("COMMENT ")
ctx.WriteString(n.Comment) ctx.WriteString(n.Comment)
hasPrevOption = true
}
if n.Visibility != IndexVisibilityDefault {
if hasPrevOption {
ctx.WritePlain(" ")
}
switch n.Visibility {
case IndexVisibilityVisible:
ctx.WriteKeyWord("VISIBLE")
case IndexVisibilityInvisible:
ctx.WriteKeyWord("INVISIBLE")
}
} }
return nil return nil
} }
...@@ -1312,7 +1346,7 @@ func (n *CreateIndexStmt) Restore(ctx *RestoreCtx) error { ...@@ -1312,7 +1346,7 @@ func (n *CreateIndexStmt) Restore(ctx *RestoreCtx) error {
} }
ctx.WritePlain(")") ctx.WritePlain(")")
if n.IndexOption.Tp != model.IndexTypeInvalid || n.IndexOption.KeyBlockSize > 0 || n.IndexOption.Comment != "" { if n.IndexOption.Tp != model.IndexTypeInvalid || n.IndexOption.KeyBlockSize > 0 || n.IndexOption.Comment != "" || len(n.IndexOption.ParserName.O) > 0 || n.IndexOption.Visibility != IndexVisibilityDefault {
ctx.WritePlain(" ") ctx.WritePlain(" ")
if err := n.IndexOption.Restore(ctx); err != nil { if err := n.IndexOption.Restore(ctx); err != nil {
return errors.Annotate(err, "An error occurred while restore CreateIndexStmt.IndexOption") return errors.Annotate(err, "An error occurred while restore CreateIndexStmt.IndexOption")
...@@ -1557,6 +1591,8 @@ const ( ...@@ -1557,6 +1591,8 @@ const (
TableOptionSecondaryEngineNull TableOptionSecondaryEngineNull
TableOptionInsertMethod TableOptionInsertMethod
TableOptionTableCheckSum TableOptionTableCheckSum
TableOptionUnion
TableOptionEncryption
) )
// RowFormat types // RowFormat types
...@@ -1595,6 +1631,7 @@ type TableOption struct { ...@@ -1595,6 +1631,7 @@ type TableOption struct {
Default bool Default bool
StrValue string StrValue string
UintValue uint64 UintValue uint64
TableNames []*TableName
} }
func (n *TableOption) Restore(ctx *RestoreCtx) error { func (n *TableOption) Restore(ctx *RestoreCtx) error {
...@@ -1762,6 +1799,20 @@ func (n *TableOption) Restore(ctx *RestoreCtx) error { ...@@ -1762,6 +1799,20 @@ func (n *TableOption) Restore(ctx *RestoreCtx) error {
ctx.WriteKeyWord("TABLE_CHECKSUM ") ctx.WriteKeyWord("TABLE_CHECKSUM ")
ctx.WritePlain("= ") ctx.WritePlain("= ")
ctx.WritePlainf("%d", n.UintValue) ctx.WritePlainf("%d", n.UintValue)
case TableOptionUnion:
ctx.WriteKeyWord("UNION ")
ctx.WritePlain("= (")
for i, tableName := range n.TableNames {
if i != 0 {
ctx.WritePlain(",")
}
tableName.Restore(ctx)
}
ctx.WritePlain(")")
case TableOptionEncryption:
ctx.WriteKeyWord("ENCRYPTION ")
ctx.WritePlain("= ")
ctx.WriteString(n.StrValue)
default: default:
return errors.Errorf("invalid TableOption: %d", n.Tp) return errors.Errorf("invalid TableOption: %d", n.Tp)
} }
...@@ -1865,8 +1916,11 @@ const ( ...@@ -1865,8 +1916,11 @@ const (
AlterTableDiscardPartitionTablespace AlterTableDiscardPartitionTablespace
AlterTableAlterCheck AlterTableAlterCheck
AlterTableDropCheck AlterTableDropCheck
AlterTableImportTablespace
AlterTableDiscardTablespace
AlterTableIndexInvisible
// TODO: Add more actions // TODO: Add more actions
AlterTableOrderByColumns
) )
// LockType is the type for AlterTableSpec. // LockType is the type for AlterTableSpec.
...@@ -1943,6 +1997,7 @@ type AlterTableSpec struct { ...@@ -1943,6 +1997,7 @@ type AlterTableSpec struct {
Name string Name string
Constraint *Constraint Constraint *Constraint
Options []*TableOption Options []*TableOption
OrderByList []*AlterOrderItem
NewTable *TableName NewTable *TableName
NewColumns []*ColumnDef NewColumns []*ColumnDef
OldColumnName *ColumnName OldColumnName *ColumnName
...@@ -1958,6 +2013,25 @@ type AlterTableSpec struct { ...@@ -1958,6 +2013,25 @@ type AlterTableSpec struct {
PartDefinitions []*PartitionDefinition PartDefinitions []*PartitionDefinition
WithValidation bool WithValidation bool
Num uint64 Num uint64
Visibility IndexVisibility
}
// AlterOrderItem represents an item in order by at alter table stmt.
type AlterOrderItem struct {
node
Column *ColumnName
Desc bool
}
// Restore implements Node interface.
func (n *AlterOrderItem) Restore(ctx *RestoreCtx) error {
if err := n.Column.Restore(ctx); err != nil {
return errors.Annotate(err, "An error occurred while restore AlterOrderItem.Column")
}
if n.Desc {
ctx.WriteKeyWord(" DESC")
}
return nil
} }
// Restore implements Node interface. // Restore implements Node interface.
...@@ -2109,6 +2183,16 @@ func (n *AlterTableSpec) Restore(ctx *RestoreCtx) error { ...@@ -2109,6 +2183,16 @@ func (n *AlterTableSpec) Restore(ctx *RestoreCtx) error {
ctx.WriteKeyWord("LOCK ") ctx.WriteKeyWord("LOCK ")
ctx.WritePlain("= ") ctx.WritePlain("= ")
ctx.WriteKeyWord(n.LockType.String()) ctx.WriteKeyWord(n.LockType.String())
case AlterTableOrderByColumns:
ctx.WriteKeyWord("ORDER BY ")
for i, alterOrderItem := range n.OrderByList {
if i != 0 {
ctx.WritePlain(",")
}
if err := alterOrderItem.Restore(ctx); err != nil {
return errors.Annotatef(err, "An error occurred while restore AlterTableSpec.OrderByList[%d]", i)
}
}
case AlterTableAlgorithm: case AlterTableAlgorithm:
ctx.WriteKeyWord("ALGORITHM ") ctx.WriteKeyWord("ALGORITHM ")
ctx.WritePlain("= ") ctx.WritePlain("= ")
...@@ -2322,6 +2406,19 @@ func (n *AlterTableSpec) Restore(ctx *RestoreCtx) error { ...@@ -2322,6 +2406,19 @@ func (n *AlterTableSpec) Restore(ctx *RestoreCtx) error {
case AlterTableDropCheck: case AlterTableDropCheck:
ctx.WriteKeyWord("DROP CHECK ") ctx.WriteKeyWord("DROP CHECK ")
ctx.WriteName(n.Constraint.Name) ctx.WriteName(n.Constraint.Name)
case AlterTableImportTablespace:
ctx.WriteKeyWord("IMPORT TABLESPACE")
case AlterTableDiscardTablespace:
ctx.WriteKeyWord("DISCARD TABLESPACE")
case AlterTableIndexInvisible:
ctx.WriteKeyWord("ALTER INDEX ")
ctx.WriteName(n.Name)
switch n.Visibility {
case IndexVisibilityVisible:
ctx.WriteKeyWord(" VISIBLE")
case IndexVisibilityInvisible:
ctx.WriteKeyWord(" INVISIBLE")
}
default: default:
// TODO: not support // TODO: not support
ctx.WritePlainf(" /* AlterTableType(%d) is not supported */ ", n.Tp) ctx.WritePlainf(" /* AlterTableType(%d) is not supported */ ", n.Tp)
...@@ -2390,7 +2487,7 @@ func (n *AlterTableStmt) Restore(ctx *RestoreCtx) error { ...@@ -2390,7 +2487,7 @@ func (n *AlterTableStmt) Restore(ctx *RestoreCtx) error {
return errors.Annotate(err, "An error occurred while restore AlterTableStmt.Table") return errors.Annotate(err, "An error occurred while restore AlterTableStmt.Table")
} }
for i, spec := range n.Specs { for i, spec := range n.Specs {
if i == 0 || spec.Tp == AlterTablePartition || spec.Tp == AlterTableRemovePartitioning { if i == 0 || spec.Tp == AlterTablePartition || spec.Tp == AlterTableRemovePartitioning || spec.Tp == AlterTableImportTablespace || spec.Tp == AlterTableDiscardTablespace {
ctx.WritePlain(" ") ctx.WritePlain(" ")
} else { } else {
ctx.WritePlain(", ") ctx.WritePlain(", ")
......
vendor/github.com/pingcap/parser/ast/dml.go
浏览文件 @ 68128b73
...@@ -764,6 +764,8 @@ type SelectStmt struct { ...@@ -764,6 +764,8 @@ type SelectStmt struct {
IsAfterUnionDistinct bool IsAfterUnionDistinct bool
// IsInBraces indicates whether it's a stmt in brace. // IsInBraces indicates whether it's a stmt in brace.
IsInBraces bool IsInBraces bool
// QueryBlockOffset indicates the order of this SelectStmt if counted from left to right in the sql text.
QueryBlockOffset int
} }
// Restore implements Node interface. // Restore implements Node interface.
...@@ -906,6 +908,14 @@ func (n *SelectStmt) Accept(v Visitor) (Node, bool) { ...@@ -906,6 +908,14 @@ func (n *SelectStmt) Accept(v Visitor) (Node, bool) {
n.TableHints = newHints n.TableHints = newHints
} }
if n.Fields != nil {
node, ok := n.Fields.Accept(v)
if !ok {
return n, false
}
n.Fields = node.(*FieldList)
}
if n.From != nil { if n.From != nil {
node, ok := n.From.Accept(v) node, ok := n.From.Accept(v)
if !ok { if !ok {
...@@ -922,14 +932,6 @@ func (n *SelectStmt) Accept(v Visitor) (Node, bool) { ...@@ -922,14 +932,6 @@ func (n *SelectStmt) Accept(v Visitor) (Node, bool) {
n.Where = node.(ExprNode) n.Where = node.(ExprNode)
} }
if n.Fields != nil {
node, ok := n.Fields.Accept(v)
if !ok {
return n, false
}
n.Fields = node.(*FieldList)
}
if n.GroupBy != nil { if n.GroupBy != nil {
node, ok := n.GroupBy.Accept(v) node, ok := n.GroupBy.Accept(v)
if !ok { if !ok {
......
vendor/github.com/pingcap/parser/ast/misc.go
浏览文件 @ 68128b73
...@@ -150,7 +150,7 @@ func (n *TraceStmt) Accept(v Visitor) (Node, bool) { ...@@ -150,7 +150,7 @@ func (n *TraceStmt) Accept(v Visitor) (Node, bool) {
if !ok { if !ok {
return n, false return n, false
} }
n.Stmt = node.(DMLNode) n.Stmt = node.(StmtNode)
return v.Leave(n) return v.Leave(n)
} }
...@@ -2030,10 +2030,11 @@ type TableOptimizerHint struct { ...@@ -2030,10 +2030,11 @@ type TableOptimizerHint struct {
QBName model.CIStr QBName model.CIStr
Tables []HintTable Tables []HintTable
Indexes []model.CIStr Indexes []model.CIStr
StoreType model.CIStr
// Statement Execution Time Optimizer Hints // Statement Execution Time Optimizer Hints
// See https://dev.mysql.com/doc/refman/5.7/en/optimizer-hints.html#optimizer-hints-execution-time // See https://dev.mysql.com/doc/refman/5.7/en/optimizer-hints.html#optimizer-hints-execution-time
MaxExecutionTime uint64 MaxExecutionTime uint64
MemoryQuota uint64 MemoryQuota int64
QueryType model.CIStr QueryType model.CIStr
HintFlag bool HintFlag bool
} }
...@@ -2064,7 +2065,7 @@ func (n *TableOptimizerHint) Restore(ctx *RestoreCtx) error { ...@@ -2064,7 +2065,7 @@ func (n *TableOptimizerHint) Restore(ctx *RestoreCtx) error {
} }
// Hints without args except query block. // Hints without args except query block.
switch n.HintName.L { switch n.HintName.L {
case "hash_agg", "stream_agg", "read_consistent_replica", "no_index_merge", "qb_name": case "hash_agg", "stream_agg", "agg_to_cop", "read_consistent_replica", "no_index_merge", "qb_name":
ctx.WritePlain(")") ctx.WritePlain(")")
return nil return nil
} }
...@@ -2100,7 +2101,20 @@ func (n *TableOptimizerHint) Restore(ctx *RestoreCtx) error { ...@@ -2100,7 +2101,20 @@ func (n *TableOptimizerHint) Restore(ctx *RestoreCtx) error {
case "query_type": case "query_type":
ctx.WriteKeyWord(n.QueryType.String()) ctx.WriteKeyWord(n.QueryType.String())
case "memory_quota": case "memory_quota":
ctx.WritePlainf("%d M", n.MemoryQuota) ctx.WritePlainf("%d MB", n.MemoryQuota/1024/1024)
case "read_from_storage":
ctx.WriteKeyWord(n.StoreType.String())
for i, table := range n.Tables {
if i == 0 {
ctx.WritePlain("[")
}
table.Restore(ctx)
if i == len(n.Tables)-1 {
ctx.WritePlain("]")
} else {
ctx.WritePlain(", ")
}
}
} }
ctx.WritePlain(")") ctx.WritePlain(")")
return nil return nil
......
vendor/github.com/pingcap/parser/misc.go
浏览文件 @ 68128b73
...@@ -89,6 +89,8 @@ func init() { ...@@ -89,6 +89,8 @@ func init() {
initTokenByte('<', int('<')) initTokenByte('<', int('<'))
initTokenByte('(', int('(')) initTokenByte('(', int('('))
initTokenByte(')', int(')')) initTokenByte(')', int(')'))
initTokenByte('[', int('['))
initTokenByte(']', int(']'))
initTokenByte(';', int(';')) initTokenByte(';', int(';'))
initTokenByte(',', int(',')) initTokenByte(',', int(','))
initTokenByte('&', int('&')) initTokenByte('&', int('&'))
...@@ -138,6 +140,7 @@ var tokenMap = map[string]int{ ...@@ -138,6 +140,7 @@ var tokenMap = map[string]int{
"ADDDATE": addDate, "ADDDATE": addDate,
"ADMIN": admin, "ADMIN": admin,
"AFTER": after, "AFTER": after,
"AGG_TO_COP": hintAggToCop,
"ALL": all, "ALL": all,
"ALGORITHM": algorithm, "ALGORITHM": algorithm,
"ALTER": alter, "ALTER": alter,
...@@ -333,6 +336,7 @@ var tokenMap = map[string]int{ ...@@ -333,6 +336,7 @@ var tokenMap = map[string]int{
"INTERVAL": interval, "INTERVAL": interval,
"INTERNAL": internal, "INTERNAL": internal,
"INTO": into, "INTO": into,
"INVISIBLE": invisible,
"INVOKER": invoker, "INVOKER": invoker,
"IS": is, "IS": is,
"ISSUER": issuer, "ISSUER": issuer,
...@@ -424,6 +428,7 @@ var tokenMap = map[string]int{ ...@@ -424,6 +428,7 @@ var tokenMap = map[string]int{
"OUTER": outer, "OUTER": outer,
"PACK_KEYS": packKeys, "PACK_KEYS": packKeys,
"PAGE": pageSym, "PAGE": pageSym,
"PARSER": parser,
"PARTIAL": partial, "PARTIAL": partial,
"PARTITION": partition, "PARTITION": partition,
"PARTITIONING": partitioning, "PARTITIONING": partitioning,
...@@ -456,6 +461,7 @@ var tokenMap = map[string]int{ ...@@ -456,6 +461,7 @@ var tokenMap = map[string]int{
"REBUILD": rebuild, "REBUILD": rebuild,
"READ": read, "READ": read,
"READ_CONSISTENT_REPLICA": hintReadConsistentReplica, "READ_CONSISTENT_REPLICA": hintReadConsistentReplica,
"READ_FROM_STORAGE": hintReadFromStorage,
"REAL": realType, "REAL": realType,
"RECENT": recent, "RECENT": recent,
"REDUNDANT": redundant, "REDUNDANT": redundant,
...@@ -575,6 +581,8 @@ var tokenMap = map[string]int{ ...@@ -575,6 +581,8 @@ var tokenMap = map[string]int{
"TIDB_HJ": hintHJ, "TIDB_HJ": hintHJ,
"TIDB_INLJ": hintINLJ, "TIDB_INLJ": hintINLJ,
"TIDB_SMJ": hintSMJ, "TIDB_SMJ": hintSMJ,
"TIKV": hintTiKV,
"TIFLASH": hintTiFlash,
"TIME": timeType, "TIME": timeType,
"TIMESTAMP": timestampType, "TIMESTAMP": timestampType,
"TIMESTAMPADD": timestampAdd, "TIMESTAMPADD": timestampAdd,
...@@ -625,6 +633,7 @@ var tokenMap = map[string]int{ ...@@ -625,6 +633,7 @@ var tokenMap = map[string]int{
"VALUES": values, "VALUES": values,
"VARBINARY": varbinaryType, "VARBINARY": varbinaryType,
"VARCHAR": varcharType, "VARCHAR": varcharType,
"VARCHARACTER": varcharacter,
"VARIABLES": variables, "VARIABLES": variables,
"VARIANCE": varPop, "VARIANCE": varPop,
"VARYING": varying, "VARYING": varying,
...@@ -632,6 +641,7 @@ var tokenMap = map[string]int{ ...@@ -632,6 +641,7 @@ var tokenMap = map[string]int{
"VAR_SAMP": varSamp, "VAR_SAMP": varSamp,
"VIEW": view, "VIEW": view,
"VIRTUAL": virtual, "VIRTUAL": virtual,
"VISIBLE": visible,
"WARNINGS": warnings, "WARNINGS": warnings,
"ERRORS": identSQLErrors, "ERRORS": identSQLErrors,
"WEEK": week, "WEEK": week,
......
vendor/github.com/pingcap/parser/mysql/errcode.go
浏览文件 @ 68128b73
...@@ -898,6 +898,7 @@ const ( ...@@ -898,6 +898,7 @@ const (
ErrJSONUsedAsKey = 3152 ErrJSONUsedAsKey = 3152
ErrInvalidJSONPathArrayCell = 3165 ErrInvalidJSONPathArrayCell = 3165
ErrBadUser = 3162 ErrBadUser = 3162
ErrInvalidEncryptionOption = 3184
ErrRoleNotGranted = 3530 ErrRoleNotGranted = 3530
ErrWindowNoSuchWindow = 3579 ErrWindowNoSuchWindow = 3579
ErrWindowCircularityInWindowGraph = 3580 ErrWindowCircularityInWindowGraph = 3580
......
vendor/github.com/pingcap/parser/mysql/errname.go
浏览文件 @ 68128b73
...@@ -893,6 +893,7 @@ var MySQLErrName = map[uint16]string{ ...@@ -893,6 +893,7 @@ var MySQLErrName = map[uint16]string{
ErrInvalidJSONContainsPathType: "The second argument can only be either 'one' or 'all'.", ErrInvalidJSONContainsPathType: "The second argument can only be either 'one' or 'all'.",
ErrJSONUsedAsKey: "JSON column '%-.192s' cannot be used in key specification.", ErrJSONUsedAsKey: "JSON column '%-.192s' cannot be used in key specification.",
ErrInvalidJSONPathArrayCell: "A path expression is not a path to a cell in an array.", ErrInvalidJSONPathArrayCell: "A path expression is not a path to a cell in an array.",
ErrInvalidEncryptionOption: "Invalid encryption option.",
ErrWindowNoSuchWindow: "Window name '%s' is not defined.", ErrWindowNoSuchWindow: "Window name '%s' is not defined.",
ErrWindowCircularityInWindowGraph: "There is a circularity in the window dependency graph.", ErrWindowCircularityInWindowGraph: "There is a circularity in the window dependency graph.",
ErrWindowNoChildPartitioning: "A window which depends on another cannot define partitioning.", ErrWindowNoChildPartitioning: "A window which depends on another cannot define partitioning.",
......
vendor/github.com/pingcap/parser/parser.go
浏览文件 @ 68128b73
因为 它太大了无法显示 source diff 。你可以改为 查看blob。
vendor/github.com/pingcap/parser/parser.y
浏览文件 @ 68128b73
...@@ -200,6 +200,7 @@ import ( ...@@ -200,6 +200,7 @@ import (
over "OVER" over "OVER"
packKeys "PACK_KEYS" packKeys "PACK_KEYS"
partition "PARTITION" partition "PARTITION"
parser "PARSER"
percentRank "PERCENT_RANK" percentRank "PERCENT_RANK"
precisionType "PRECISION" precisionType "PRECISION"
primary "PRIMARY" primary "PRIMARY"
...@@ -261,6 +262,7 @@ import ( ...@@ -261,6 +262,7 @@ import (
values "VALUES" values "VALUES"
long "LONG" long "LONG"
varcharType "VARCHAR" varcharType "VARCHAR"
varcharacter "VARCHARACTER"
varbinaryType "VARBINARY" varbinaryType "VARBINARY"
varying "VARYING" varying "VARYING"
virtual "VIRTUAL" virtual "VIRTUAL"
...@@ -361,6 +363,7 @@ import ( ...@@ -361,6 +363,7 @@ import (
issuer "ISSUER" issuer "ISSUER"
incremental "INCREMENTAL" incremental "INCREMENTAL"
indexes "INDEXES" indexes "INDEXES"
invisible "INVISIBLE"
invoker "INVOKER" invoker "INVOKER"
io "IO" io "IO"
ipc "IPC" ipc "IPC"
...@@ -497,6 +500,7 @@ import ( ...@@ -497,6 +500,7 @@ import (
value "VALUE" value "VALUE"
variables "VARIABLES" variables "VARIABLES"
view "VIEW" view "VIEW"
visible "VISIBLE"
binding "BINDING" binding "BINDING"
bindings "BINDINGS" bindings "BINDINGS"
warnings "WARNINGS" warnings "WARNINGS"
...@@ -578,6 +582,7 @@ import ( ...@@ -578,6 +582,7 @@ import (
statsBuckets "STATS_BUCKETS" statsBuckets "STATS_BUCKETS"
statsHealthy "STATS_HEALTHY" statsHealthy "STATS_HEALTHY"
tidb "TIDB" tidb "TIDB"
hintAggToCop "AGG_TO_COP"
hintHJ "HASH_JOIN" hintHJ "HASH_JOIN"
hintSMJ "SM_JOIN" hintSMJ "SM_JOIN"
hintINLJ "INL_JOIN" hintINLJ "INL_JOIN"
...@@ -589,11 +594,14 @@ import ( ...@@ -589,11 +594,14 @@ import (
hintEnablePlanCache "ENABLE_PLAN_CACHE" hintEnablePlanCache "ENABLE_PLAN_CACHE"
hintUsePlanCache "USE_PLAN_CACHE" hintUsePlanCache "USE_PLAN_CACHE"
hintReadConsistentReplica "READ_CONSISTENT_REPLICA" hintReadConsistentReplica "READ_CONSISTENT_REPLICA"
hintReadFromStorage "READ_FROM_STORAGE"
hintQBName "QB_NAME" hintQBName "QB_NAME"
hintQueryType "QUERY_TYPE" hintQueryType "QUERY_TYPE"
hintMemoryQuota "MEMORY_QUOTA" hintMemoryQuota "MEMORY_QUOTA"
hintOLAP "OLAP" hintOLAP "OLAP"
hintOLTP "OLTP" hintOLTP "OLTP"
hintTiKV "TIKV"
hintTiFlash "TIFLASH"
topn "TOPN" topn "TOPN"
split "SPLIT" split "SPLIT"
width "WIDTH" width "WIDTH"
...@@ -833,6 +841,7 @@ import ( ...@@ -833,6 +841,7 @@ import (
IndexHintListOpt "index hint list opt" IndexHintListOpt "index hint list opt"
IndexHintScope "index hint scope" IndexHintScope "index hint scope"
IndexHintType "index hint type" IndexHintType "index hint type"
IndexInvisible "index visible/invisible"
IndexKeyTypeOpt "index key type" IndexKeyTypeOpt "index key type"
IndexLockAndAlgorithmOpt "index lock and algorithm" IndexLockAndAlgorithmOpt "index lock and algorithm"
IndexName "index name" IndexName "index name"
...@@ -869,6 +878,8 @@ import ( ...@@ -869,6 +878,8 @@ import (
ByItem "BY item" ByItem "BY item"
OrderByOptional "Optional ORDER BY clause optional" OrderByOptional "Optional ORDER BY clause optional"
ByList "BY list" ByList "BY list"
AlterOrderItem "Alter Order item"
AlterOrderList "Alter Order list"
QuickOptional "QUICK or empty" QuickOptional "QUICK or empty"
QueryBlockOpt "Query block identifier optional" QueryBlockOpt "Query block identifier optional"
PartitionDefinition "Partition definition" PartitionDefinition "Partition definition"
...@@ -1058,11 +1069,15 @@ import ( ...@@ -1058,11 +1069,15 @@ import (
NUM "A number" NUM "A number"
NumList "Some numbers" NumList "Some numbers"
LengthNum "Field length num(uint64)" LengthNum "Field length num(uint64)"
StorageOptimizerHintOpt "Storage level optimizer hint"
TableOptimizerHintOpt "Table level optimizer hint" TableOptimizerHintOpt "Table level optimizer hint"
TableOptimizerHints "Table level optimizer hints" TableOptimizerHints "Table level optimizer hints"
TableOptimizerHintList "Table level optimizer hint list" OptimizerHintList "optimizer hint list"
HintTable "Table in optimizer hint" HintTable "Table in optimizer hint"
HintTableList "Table list in optimizer hint" HintTableList "Table list in optimizer hint"
HintStorageType "storage type in optimizer hint"
HintStorageTypeAndTable "storage type and tables in optimizer hint"
HintStorageTypeAndTableList "storage type and tables list in optimizer hint"
HintTrueOrFalse "True or false in optimizer hint" HintTrueOrFalse "True or false in optimizer hint"
HintQueryType "Query type in optimizer hint" HintQueryType "Query type in optimizer hint"
HintMemoryQuota "Memory quota in optimizer hint" HintMemoryQuota "Memory quota in optimizer hint"
...@@ -1087,8 +1102,8 @@ import ( ...@@ -1087,8 +1102,8 @@ import (
ValueSym "Value or Values" ValueSym "Value or Values"
Char "{CHAR|CHARACTER}" Char "{CHAR|CHARACTER}"
NChar "{NCHAR|NATIONAL CHARACTER|NATIONAL CHAR}" NChar "{NCHAR|NATIONAL CHARACTER|NATIONAL CHAR}"
Varchar "{VARCHAR|CHARACTER VARYING|CHAR VARYING}" Varchar "{VARCHAR|VARCHARACTER|CHARACTER VARYING|CHAR VARYING}"
NVarchar "{NATIONAL VARCHAR|NVARCHAR|NCHAR VARCHAR|NATIONAL CHARACTER VARYING|NATIONAL CHAR VARYING|NCHAR VARYING}" NVarchar "{NATIONAL VARCHAR|NATIONAL VARCHARACTER|NVARCHAR|NCHAR VARCHAR|NATIONAL CHARACTER VARYING|NATIONAL CHAR VARYING|NCHAR VARYING}"
DeallocateSym "Deallocate or drop" DeallocateSym "Deallocate or drop"
OuterOpt "optional OUTER clause" OuterOpt "optional OUTER clause"
CrossOpt "Cross join option" CrossOpt "Cross join option"
...@@ -1143,6 +1158,8 @@ import ( ...@@ -1143,6 +1158,8 @@ import (
%precedence local %precedence local
%precedence lowerThanRemove %precedence lowerThanRemove
%precedence remove %precedence remove
%precedence lowerThenOrder
%precedence order
%left join straightJoin inner cross left right full natural %left join straightJoin inner cross left right full natural
/* A dummy token to force the priority of TableRef production in a join. */ /* A dummy token to force the priority of TableRef production in a join. */
...@@ -1441,6 +1458,24 @@ AlterTableSpec: ...@@ -1441,6 +1458,24 @@ AlterTableSpec:
yylex.AppendError(yylex.Errorf("The DISCARD PARTITION TABLESPACE clause is parsed but ignored by all storage engines.")) yylex.AppendError(yylex.Errorf("The DISCARD PARTITION TABLESPACE clause is parsed but ignored by all storage engines."))
parser.lastErrorAsWarn() parser.lastErrorAsWarn()
} }
| "IMPORT" "TABLESPACE"
{
ret := &ast.AlterTableSpec{
Tp: ast.AlterTableImportTablespace,
}
$$ = ret
yylex.AppendError(yylex.Errorf("The IMPORT TABLESPACE clause is parsed but ignored by all storage engines."))
parser.lastErrorAsWarn()
}
| "DISCARD" "TABLESPACE"
{
ret := &ast.AlterTableSpec{
Tp: ast.AlterTableDiscardTablespace,
}
$$ = ret
yylex.AppendError(yylex.Errorf("The DISCARD TABLESPACE clause is parsed but ignored by all storage engines."))
parser.lastErrorAsWarn()
}
| "REBUILD" "PARTITION" NoWriteToBinLogAliasOpt AllOrPartitionNameList | "REBUILD" "PARTITION" NoWriteToBinLogAliasOpt AllOrPartitionNameList
{ {
ret := &ast.AlterTableSpec{ ret := &ast.AlterTableSpec{
...@@ -1479,6 +1514,13 @@ AlterTableSpec: ...@@ -1479,6 +1514,13 @@ AlterTableSpec:
Name: $5.(string), Name: $5.(string),
} }
} }
| "ORDER" "BY" AlterOrderList %prec lowerThenOrder
{
$$ = &ast.AlterTableSpec{
Tp: ast.AlterTableOrderByColumns,
OrderByList: $3.([]*ast.AlterOrderItem),
}
}
| "DISABLE" "KEYS" | "DISABLE" "KEYS"
{ {
$$ = &ast.AlterTableSpec{ $$ = &ast.AlterTableSpec{
...@@ -1668,6 +1710,14 @@ AlterTableSpec: ...@@ -1668,6 +1710,14 @@ AlterTableSpec:
yylex.AppendError(yylex.Errorf("The DROP CHECK clause is parsed but not implemented yet.")) yylex.AppendError(yylex.Errorf("The DROP CHECK clause is parsed but not implemented yet."))
parser.lastErrorAsWarn() parser.lastErrorAsWarn()
} }
| "ALTER" "INDEX" Identifier IndexInvisible
{
$$ = &ast.AlterTableSpec{
Tp: ast.AlterTableIndexInvisible,
Name: $3,
Visibility: $4.(ast.IndexVisibility),
}
}
ReorganizePartitionRuleOpt: ReorganizePartitionRuleOpt:
/* empty */ %prec lowerThanRemove /* empty */ %prec lowerThanRemove
...@@ -1741,27 +1791,25 @@ AlgorithmClause: ...@@ -1741,27 +1791,25 @@ AlgorithmClause:
} }
LockClause: LockClause:
"LOCK" EqOpt "NONE" "LOCK" EqOpt "DEFAULT"
{
$$ = ast.LockTypeNone
}
| "LOCK" EqOpt "DEFAULT"
{ {
$$ = ast.LockTypeDefault $$ = ast.LockTypeDefault
} }
| "LOCK" EqOpt "SHARED" | "LOCK" EqOpt Identifier
{ {
id := strings.ToUpper($3)
if id == "NONE" {
$$ = ast.LockTypeNone
} else if id == "SHARED" {
$$ = ast.LockTypeShared $$ = ast.LockTypeShared
} } else if id == "EXCLUSIVE" {
| "LOCK" EqOpt "EXCLUSIVE"
{
$$ = ast.LockTypeExclusive $$ = ast.LockTypeExclusive
} } else {
| "LOCK" EqOpt identifier
{
yylex.AppendError(ErrUnknownAlterLock.GenWithStackByArgs($3)) yylex.AppendError(ErrUnknownAlterLock.GenWithStackByArgs($3))
return 1 return 1
} }
}
KeyOrIndex: "KEY" | "INDEX" KeyOrIndex: "KEY" | "INDEX"
...@@ -2655,7 +2703,9 @@ NumLiteral: ...@@ -2655,7 +2703,9 @@ NumLiteral:
* index_option: * index_option:
* KEY_BLOCK_SIZE [=] value * KEY_BLOCK_SIZE [=] value
* | index_type * | index_type
* | WITH PARSER parser_name
* | COMMENT 'string' * | COMMENT 'string'
* | {VISIBLE | INVISIBLE}
* *
* index_type: * index_type:
* USING {BTREE | HASH} * USING {BTREE | HASH}
...@@ -4136,6 +4186,10 @@ IndexOptionList: ...@@ -4136,6 +4186,10 @@ IndexOptionList:
opt1.Tp = opt2.Tp opt1.Tp = opt2.Tp
} else if opt2.KeyBlockSize > 0 { } else if opt2.KeyBlockSize > 0 {
opt1.KeyBlockSize = opt2.KeyBlockSize opt1.KeyBlockSize = opt2.KeyBlockSize
} else if len(opt2.ParserName.O) > 0 {
opt1.ParserName = opt2.ParserName
} else if opt2.Visibility != ast.IndexVisibilityDefault {
opt1.Visibility = opt2.Visibility
} }
$$ = opt1 $$ = opt1
} }
...@@ -4155,12 +4209,26 @@ IndexOption: ...@@ -4155,12 +4209,26 @@ IndexOption:
Tp: $1.(model.IndexType), Tp: $1.(model.IndexType),
} }
} }
| "WITH" "PARSER" Identifier
{
$$ = &ast.IndexOption {
ParserName: model.NewCIStr($3),
}
yylex.AppendError(yylex.Errorf("The WITH PARASER clause is parsed but ignored by all storage engines."))
parser.lastErrorAsWarn()
}
| "COMMENT" stringLit | "COMMENT" stringLit
{ {
$$ = &ast.IndexOption { $$ = &ast.IndexOption {
Comment: $2, Comment: $2,
} }
} }
| IndexInvisible
{
$$ = &ast.IndexOption {
Visibility: $1.(ast.IndexVisibility),
}
}
IndexType: IndexType:
"USING" "BTREE" "USING" "BTREE"
...@@ -4185,6 +4253,16 @@ IndexTypeOpt: ...@@ -4185,6 +4253,16 @@ IndexTypeOpt:
$$ = $1 $$ = $1
} }
IndexInvisible:
"VISIBLE"
{
$$ = ast.IndexVisibilityVisible
}
| "INVISIBLE"
{
$$ = ast.IndexVisibilityInvisible
}
/**********************************Identifier********************************************/ /**********************************Identifier********************************************/
Identifier: Identifier:
identifier | UnReservedKeyword | NotKeywordToken | TiDBKeyword identifier | UnReservedKeyword | NotKeywordToken | TiDBKeyword
...@@ -4206,12 +4284,12 @@ UnReservedKeyword: ...@@ -4206,12 +4284,12 @@ UnReservedKeyword:
| "RECOVER" | "CIPHER" | "SUBJECT" | "ISSUER" | "X509" | "NEVER" | "EXPIRE" | "ACCOUNT" | "INCREMENTAL" | "CPU" | "MEMORY" | "BLOCK" | "IO" | "CONTEXT" | "SWITCHES" | "PAGE" | "FAULTS" | "IPC" | "SWAPS" | "SOURCE" | "RECOVER" | "CIPHER" | "SUBJECT" | "ISSUER" | "X509" | "NEVER" | "EXPIRE" | "ACCOUNT" | "INCREMENTAL" | "CPU" | "MEMORY" | "BLOCK" | "IO" | "CONTEXT" | "SWITCHES" | "PAGE" | "FAULTS" | "IPC" | "SWAPS" | "SOURCE"
| "TRADITIONAL" | "SQL_BUFFER_RESULT" | "DIRECTORY" | "HISTORY" | "LIST" | "NODEGROUP" | "SYSTEM_TIME" | "PARTIAL" | "SIMPLE" | "REMOVE" | "PARTITIONING" | "STORAGE" | "DISK" | "STATS_SAMPLE_PAGES" | "SECONDARY_ENGINE" | "SECONDARY_LOAD" | "SECONDARY_UNLOAD" | "VALIDATION" | "TRADITIONAL" | "SQL_BUFFER_RESULT" | "DIRECTORY" | "HISTORY" | "LIST" | "NODEGROUP" | "SYSTEM_TIME" | "PARTIAL" | "SIMPLE" | "REMOVE" | "PARTITIONING" | "STORAGE" | "DISK" | "STATS_SAMPLE_PAGES" | "SECONDARY_ENGINE" | "SECONDARY_LOAD" | "SECONDARY_UNLOAD" | "VALIDATION"
| "WITHOUT" | "RTREE" | "EXCHANGE" | "COLUMN_FORMAT" | "REPAIR" | "IMPORT" | "DISCARD" | "TABLE_CHECKSUM" | "WITHOUT" | "RTREE" | "EXCHANGE" | "COLUMN_FORMAT" | "REPAIR" | "IMPORT" | "DISCARD" | "TABLE_CHECKSUM"
| "SQL_TSI_DAY" | "SQL_TSI_HOUR" | "SQL_TSI_MINUTE" | "SQL_TSI_MONTH" | "SQL_TSI_QUARTER" | "SQL_TSI_SECOND" | "SQL_TSI_WEEK" | "SQL_TSI_YEAR" | "SQL_TSI_DAY" | "SQL_TSI_HOUR" | "SQL_TSI_MINUTE" | "SQL_TSI_MONTH" | "SQL_TSI_QUARTER" | "SQL_TSI_SECOND" | "SQL_TSI_WEEK" | "SQL_TSI_YEAR" | "INVISIBLE" | "VISIBLE"
TiDBKeyword: TiDBKeyword:
"ADMIN" | "BUCKETS" | "CANCEL" | "CMSKETCH" | "DDL" | "DEPTH" | "DRAINER" | "JOBS" | "JOB" | "NODE_ID" | "NODE_STATE" | "PUMP" | "SAMPLES" | "STATS" | "STATS_META" | "STATS_HISTOGRAMS" | "STATS_BUCKETS" | "STATS_HEALTHY" | "TIDB" "ADMIN" | "AGG_TO_COP" |"BUCKETS" | "CANCEL" | "CMSKETCH" | "DDL" | "DEPTH" | "DRAINER" | "JOBS" | "JOB" | "NODE_ID" | "NODE_STATE" | "PUMP" | "SAMPLES" | "STATS" | "STATS_META" | "STATS_HISTOGRAMS" | "STATS_BUCKETS" | "STATS_HEALTHY" | "TIDB"
| "HASH_JOIN" | "SM_JOIN" | "INL_JOIN" | "HASH_AGG" | "STREAM_AGG" | "USE_INDEX_MERGE" | "NO_INDEX_MERGE" | "USE_TOJA" | "ENABLE_PLAN_CACHE" | "USE_PLAN_CACHE" | "HASH_JOIN" | "SM_JOIN" | "INL_JOIN" | "HASH_AGG" | "STREAM_AGG" | "USE_INDEX_MERGE" | "NO_INDEX_MERGE" | "USE_TOJA" | "ENABLE_PLAN_CACHE" | "USE_PLAN_CACHE"
| "READ_CONSISTENT_REPLICA" | "QB_NAME" | "QUERY_TYPE" | "MEMORY_QUOTA" | "OLAP" | "OLTP" |"TOPN" | "SPLIT" | "OPTIMISTIC" | "PESSIMISTIC" | "WIDTH" | "REGIONS" | "READ_CONSISTENT_REPLICA" | "READ_FROM_STORAGE" | "QB_NAME" | "QUERY_TYPE" | "MEMORY_QUOTA" | "OLAP" | "OLTP" | "TOPN" | "TIKV" | "TIFLASH" | "SPLIT" | "OPTIMISTIC" | "PESSIMISTIC" | "WIDTH" | "REGIONS"
NotKeywordToken: NotKeywordToken:
"ADDDATE" | "BIT_AND" | "BIT_OR" | "BIT_XOR" | "CAST" | "COPY" | "COUNT" | "CURTIME" | "DATE_ADD" | "DATE_SUB" | "EXTRACT" | "GET_FORMAT" | "GROUP_CONCAT" "ADDDATE" | "BIT_AND" | "BIT_OR" | "BIT_XOR" | "CAST" | "COPY" | "COUNT" | "CURTIME" | "DATE_ADD" | "DATE_SUB" | "EXTRACT" | "GET_FORMAT" | "GROUP_CONCAT"
...@@ -4473,6 +4551,21 @@ StringLiteral: ...@@ -4473,6 +4551,21 @@ StringLiteral:
$$ = expr $$ = expr
} }
AlterOrderList:
AlterOrderItem
{
$$ = []*ast.AlterOrderItem{$1.(*ast.AlterOrderItem)}
}
| AlterOrderList ',' AlterOrderItem
{
$$ = append($1.([]*ast.AlterOrderItem), $3.(*ast.AlterOrderItem))
}
AlterOrderItem:
ColumnName Order
{
$$ = &ast.AlterOrderItem{Column: $1.(*ast.ColumnName), Desc: $2.(bool)}
}
OrderBy: OrderBy:
"ORDER" "BY" ByList "ORDER" "BY" ByList
...@@ -6470,7 +6563,7 @@ TableOptimizerHints: ...@@ -6470,7 +6563,7 @@ TableOptimizerHints:
{ {
$$ = nil $$ = nil
} }
| hintBegin TableOptimizerHintList hintEnd | hintBegin OptimizerHintList hintEnd
{ {
$$ = $2 $$ = $2
} }
...@@ -6481,19 +6574,31 @@ TableOptimizerHints: ...@@ -6481,19 +6574,31 @@ TableOptimizerHints:
$$ = nil $$ = nil
} }
TableOptimizerHintList: OptimizerHintList:
TableOptimizerHintOpt TableOptimizerHintOpt
{ {
$$ = []*ast.TableOptimizerHint{$1.(*ast.TableOptimizerHint)} $$ = []*ast.TableOptimizerHint{$1.(*ast.TableOptimizerHint)}
} }
| TableOptimizerHintList TableOptimizerHintOpt | StorageOptimizerHintOpt
{
$$ = $1.([]*ast.TableOptimizerHint)
}
| OptimizerHintList TableOptimizerHintOpt
{ {
$$ = append($1.([]*ast.TableOptimizerHint), $2.(*ast.TableOptimizerHint)) $$ = append($1.([]*ast.TableOptimizerHint), $2.(*ast.TableOptimizerHint))
} }
| TableOptimizerHintList ',' TableOptimizerHintOpt | OptimizerHintList ',' TableOptimizerHintOpt
{ {
$$ = append($1.([]*ast.TableOptimizerHint), $3.(*ast.TableOptimizerHint)) $$ = append($1.([]*ast.TableOptimizerHint), $3.(*ast.TableOptimizerHint))
} }
| OptimizerHintList StorageOptimizerHintOpt
{
$$ = append($1.([]*ast.TableOptimizerHint), $2.([]*ast.TableOptimizerHint)...)
}
| OptimizerHintList ',' StorageOptimizerHintOpt
{
$$ = append($1.([]*ast.TableOptimizerHint), $3.([]*ast.TableOptimizerHint)...)
}
TableOptimizerHintOpt: TableOptimizerHintOpt:
index '(' QueryBlockOpt HintTable IndexNameList ')' index '(' QueryBlockOpt HintTable IndexNameList ')'
...@@ -6549,7 +6654,7 @@ TableOptimizerHintOpt: ...@@ -6549,7 +6654,7 @@ TableOptimizerHintOpt:
} }
| hintMemoryQuota '(' QueryBlockOpt HintMemoryQuota ')' | hintMemoryQuota '(' QueryBlockOpt HintMemoryQuota ')'
{ {
$$ = &ast.TableOptimizerHint{HintName: model.NewCIStr($1), QBName: $3.(model.CIStr), MemoryQuota: $4.(uint64)} $$ = &ast.TableOptimizerHint{HintName: model.NewCIStr($1), QBName: $3.(model.CIStr), MemoryQuota: $4.(int64)}
} }
| hintHASHAGG '(' QueryBlockOpt ')' | hintHASHAGG '(' QueryBlockOpt ')'
{ {
...@@ -6559,6 +6664,10 @@ TableOptimizerHintOpt: ...@@ -6559,6 +6664,10 @@ TableOptimizerHintOpt:
{ {
$$ = &ast.TableOptimizerHint{HintName: model.NewCIStr($1), QBName: $3.(model.CIStr)} $$ = &ast.TableOptimizerHint{HintName: model.NewCIStr($1), QBName: $3.(model.CIStr)}
} }
| hintAggToCop '(' QueryBlockOpt ')'
{
$$ = &ast.TableOptimizerHint{HintName: model.NewCIStr($1), QBName: $3.(model.CIStr)}
}
| hintNoIndexMerge '(' QueryBlockOpt ')' | hintNoIndexMerge '(' QueryBlockOpt ')'
{ {
$$ = &ast.TableOptimizerHint{HintName: model.NewCIStr($1), QBName: $3.(model.CIStr)} $$ = &ast.TableOptimizerHint{HintName: model.NewCIStr($1), QBName: $3.(model.CIStr)}
...@@ -6572,6 +6681,35 @@ TableOptimizerHintOpt: ...@@ -6572,6 +6681,35 @@ TableOptimizerHintOpt:
$$ = &ast.TableOptimizerHint{HintName: model.NewCIStr($1), QBName: model.NewCIStr($3)} $$ = &ast.TableOptimizerHint{HintName: model.NewCIStr($1), QBName: model.NewCIStr($3)}
} }
StorageOptimizerHintOpt:
hintReadFromStorage '(' QueryBlockOpt HintStorageTypeAndTableList ')'
{
$$ = $4.([]*ast.TableOptimizerHint)
for _, hint := range $$.([]*ast.TableOptimizerHint) {
hint.HintName = model.NewCIStr($1)
hint.QBName = $3.(model.CIStr)
}
}
HintStorageTypeAndTableList:
HintStorageTypeAndTable
{
$$ = []*ast.TableOptimizerHint{$1.(*ast.TableOptimizerHint)}
}
| HintStorageTypeAndTableList ',' HintStorageTypeAndTable
{
$$ = append($1.([]*ast.TableOptimizerHint), $3.(*ast.TableOptimizerHint))
}
HintStorageTypeAndTable:
HintStorageType '[' HintTableList ']'
{
$$ = &ast.TableOptimizerHint{
StoreType: model.NewCIStr($1.(string)),
Tables: $3.([]ast.HintTable),
}
}
QueryBlockOpt: QueryBlockOpt:
{ {
$$ = model.NewCIStr("") $$ = model.NewCIStr("")
...@@ -6607,6 +6745,16 @@ HintTrueOrFalse: ...@@ -6607,6 +6745,16 @@ HintTrueOrFalse:
$$ = false $$ = false
} }
HintStorageType:
hintTiKV
{
$$ = $1
}
| hintTiFlash
{
$$ = $1
}
HintQueryType: HintQueryType:
hintOLAP hintOLAP
{ {
...@@ -6620,15 +6768,14 @@ HintQueryType: ...@@ -6620,15 +6768,14 @@ HintQueryType:
HintMemoryQuota: HintMemoryQuota:
NUM Identifier NUM Identifier
{ {
// May change into MB/MiB or GB/GiB
switch model.NewCIStr($2).L { switch model.NewCIStr($2).L {
case "m": case "mb":
$$ = getUint64FromNUM($1) $$ = $1.(int64) * 1024 * 1024
case "g": case "gb":
$$ = getUint64FromNUM($1) * 1024 $$ = $1.(int64) * 1024 * 1024 * 1024
default: default:
// Trigger warning in TiDB Planner // Executor handle memory quota < 0 as no memory limit, here use it to trigger warning in TiDB.
$$ = uint64(0) $$ = int64(-1)
} }
} }
...@@ -8085,6 +8232,10 @@ TraceableStmt: ...@@ -8085,6 +8232,10 @@ TraceableStmt:
| ReplaceIntoStmt | ReplaceIntoStmt
| UnionStmt | UnionStmt
| LoadDataStmt | LoadDataStmt
| BeginTransactionStmt
| CommitStmt
| RollbackStmt
| SetStmt
ExplainableStmt: ExplainableStmt:
SelectStmt SelectStmt
...@@ -8317,6 +8468,23 @@ TableOption: ...@@ -8317,6 +8468,23 @@ TableOption:
yylex.AppendError(yylex.Errorf("The SECONDARY_ENGINE clause is parsed but ignored by all storage engines.")) yylex.AppendError(yylex.Errorf("The SECONDARY_ENGINE clause is parsed but ignored by all storage engines."))
parser.lastErrorAsWarn() parser.lastErrorAsWarn()
} }
| "UNION" EqOpt '(' TableNameListOpt ')'
{
// Parse it but will ignore it
$$ = &ast.TableOption{
Tp: ast.TableOptionUnion,
TableNames: $4.([]*ast.TableName),
}
yylex.AppendError(yylex.Errorf("The UNION option is parsed but ignored by all storage engines."))
parser.lastErrorAsWarn()
}
| "ENCRYPTION" EqOpt stringLit
{
// Parse it but will ignore it
$$ = &ast.TableOption{Tp: ast.TableOptionEncryption, StrValue: $3}
yylex.AppendError(yylex.Errorf("The ENCRYPTION clause is parsed but ignored by all storage engines."))
parser.lastErrorAsWarn()
}
StatsPersistentVal: StatsPersistentVal:
"DEFAULT" "DEFAULT"
...@@ -8725,6 +8893,24 @@ StringType: ...@@ -8725,6 +8893,24 @@ StringType:
x.Collate = charset.CollationBin x.Collate = charset.CollationBin
$$ = x $$ = x
} }
| "LONG" Varchar OptBinary
{
x := types.NewFieldType(mysql.TypeMediumBlob)
x.Charset = $3.(*ast.OptBinary).Charset
if $3.(*ast.OptBinary).IsBinary {
x.Flag |= mysql.BinaryFlag
}
$$ = x
}
| "LONG" OptBinary
{
x := types.NewFieldType(mysql.TypeMediumBlob)
x.Charset = $2.(*ast.OptBinary).Charset
if $2.(*ast.OptBinary).IsBinary {
x.Flag |= mysql.BinaryFlag
}
$$ = x
}
Char: Char:
"CHARACTER" "CHARACTER"
...@@ -8739,11 +8925,14 @@ Varchar: ...@@ -8739,11 +8925,14 @@ Varchar:
"CHARACTER" "VARYING" "CHARACTER" "VARYING"
| "CHAR" "VARYING" | "CHAR" "VARYING"
| "VARCHAR" | "VARCHAR"
| "VARCHARACTER"
NVarchar: NVarchar:
"NATIONAL" "VARCHAR" "NATIONAL" "VARCHAR"
| "NATIONAL" "VARCHARACTER"
| "NVARCHAR" | "NVARCHAR"
| "NCHAR" "VARCHAR" | "NCHAR" "VARCHAR"
| "NCHAR" "VARCHARACTER"
| "NATIONAL" "CHARACTER" "VARYING" | "NATIONAL" "CHARACTER" "VARYING"
| "NATIONAL" "CHAR" "VARYING" | "NATIONAL" "CHAR" "VARYING"
| "NCHAR" "VARYING" | "NCHAR" "VARYING"
...@@ -8771,6 +8960,11 @@ BlobType: ...@@ -8771,6 +8960,11 @@ BlobType:
x := types.NewFieldType(mysql.TypeLongBlob) x := types.NewFieldType(mysql.TypeLongBlob)
$$ = x $$ = x
} }
| "LONG" "VARBINARY"
{
x := types.NewFieldType(mysql.TypeMediumBlob)
$$ = x
}
TextType: TextType:
"TINYTEXT" "TINYTEXT"
...@@ -8795,16 +8989,6 @@ TextType: ...@@ -8795,16 +8989,6 @@ TextType:
x := types.NewFieldType(mysql.TypeLongBlob) x := types.NewFieldType(mysql.TypeLongBlob)
$$ = x $$ = x
} }
| "LONG"
{
x := types.NewFieldType(mysql.TypeMediumBlob)
$$ = x
}
| "LONG" "VARCHAR"
{
x := types.NewFieldType(mysql.TypeMediumBlob)
$$ = x
}
DateAndTimeType: DateAndTimeType:
......
vendor/github.com/pingcap/tidb/sessionctx/stmtctx/stmtctx.go
浏览文件 @ 68128b73
...@@ -76,13 +76,6 @@ type StatementContext struct { ...@@ -76,13 +76,6 @@ type StatementContext struct {
// prefix in a strict way, only extract 0-9 and (+ or - in first bit). // prefix in a strict way, only extract 0-9 and (+ or - in first bit).
CastStrToIntStrict bool CastStrToIntStrict bool
// StartTime is the query start time.
StartTime time.Time
// DurationParse is the duration of pasing SQL string to AST.
DurationParse time.Duration
// DurationCompile is the duration of compiling AST to execution plan.
DurationCompile time.Duration
// mu struct holds variables that change during execution. // mu struct holds variables that change during execution.
mu struct { mu struct {
sync.Mutex sync.Mutex
...@@ -131,7 +124,7 @@ type StatementContext struct { ...@@ -131,7 +124,7 @@ type StatementContext struct {
MemTracker *memory.Tracker MemTracker *memory.Tracker
RuntimeStatsColl *execdetails.RuntimeStatsColl RuntimeStatsColl *execdetails.RuntimeStatsColl
TableIDs []int64 TableIDs []int64
IndexIDs []int64 IndexNames []string
nowTs time.Time // use this variable for now/current_timestamp calculation/cache for one stmt nowTs time.Time // use this variable for now/current_timestamp calculation/cache for one stmt
stmtTimeCached bool stmtTimeCached bool
StmtType string StmtType string
...@@ -419,10 +412,7 @@ func (sc *StatementContext) ResetForRetry() { ...@@ -419,10 +412,7 @@ func (sc *StatementContext) ResetForRetry() {
sc.mu.allExecDetails = make([]*execdetails.ExecDetails, 0, 4) sc.mu.allExecDetails = make([]*execdetails.ExecDetails, 0, 4)
sc.mu.Unlock() sc.mu.Unlock()
sc.TableIDs = sc.TableIDs[:0] sc.TableIDs = sc.TableIDs[:0]
sc.IndexIDs = sc.IndexIDs[:0] sc.IndexNames = sc.IndexNames[:0]
sc.StartTime = time.Now()
sc.DurationCompile = time.Duration(0)
sc.DurationParse = time.Duration(0)
} }
// MergeExecDetails merges a single region execution details into self, used to print // MergeExecDetails merges a single region execution details into self, used to print
......
vendor/github.com/pingcap/tidb/types/field_name.go 0 → 100644
浏览文件 @ 68128b73
// Copyright 2019 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,
// See the License for the specific language governing permissions and
// limitations under the License.
package types
import (
"strings"
"github.com/pingcap/parser/model"
)
// FieldName records the names used for mysql protocol.
type FieldName struct {
OrigTblName model.CIStr
OrigColName model.CIStr
DBName model.CIStr
TblName model.CIStr
ColName model.CIStr
}
// String implements Stringer interface.
func (name *FieldName) String() string {
builder := strings.Builder{}
if name.TblName.L != "" {
builder.WriteString(name.TblName.L + ".")
}
if name.DBName.L != "" {
builder.WriteString(name.DBName.L + ".")
}
builder.WriteString(name.ColName.L)
return builder.String()
}
vendor/github.com/pingcap/tidb/types/field_type.go
浏览文件 @ 68128b73
...@@ -183,6 +183,12 @@ func DefaultTypeForValue(value interface{}, tp *FieldType) { ...@@ -183,6 +183,12 @@ func DefaultTypeForValue(value interface{}, tp *FieldType) {
tp.Flen = len(x) tp.Flen = len(x)
tp.Decimal = UnspecifiedLength tp.Decimal = UnspecifiedLength
tp.Charset, tp.Collate = charset.GetDefaultCharsetAndCollate() tp.Charset, tp.Collate = charset.GetDefaultCharsetAndCollate()
case float32:
tp.Tp = mysql.TypeFloat
s := strconv.FormatFloat(float64(x), 'f', -1, 32)
tp.Flen = len(s)
tp.Decimal = UnspecifiedLength
SetBinChsClnFlag(tp)
case float64: case float64:
tp.Tp = mysql.TypeDouble tp.Tp = mysql.TypeDouble
s := strconv.FormatFloat(x, 'f', -1, 64) s := strconv.FormatFloat(x, 'f', -1, 64)
...@@ -201,7 +207,7 @@ func DefaultTypeForValue(value interface{}, tp *FieldType) { ...@@ -201,7 +207,7 @@ func DefaultTypeForValue(value interface{}, tp *FieldType) {
SetBinChsClnFlag(tp) SetBinChsClnFlag(tp)
case HexLiteral: case HexLiteral:
tp.Tp = mysql.TypeVarString tp.Tp = mysql.TypeVarString
tp.Flen = len(x) tp.Flen = len(x) * 3
tp.Decimal = 0 tp.Decimal = 0
tp.Flag |= mysql.UnsignedFlag tp.Flag |= mysql.UnsignedFlag
SetBinChsClnFlag(tp) SetBinChsClnFlag(tp)
......
vendor/github.com/pingcap/tidb/types/mydecimal.go
浏览文件 @ 68128b73
...@@ -250,6 +250,21 @@ func (d *MyDecimal) GetDigitsFrac() int8 { ...@@ -250,6 +250,21 @@ func (d *MyDecimal) GetDigitsFrac() int8 {
return d.digitsFrac return d.digitsFrac
} }
// Copy copies a new *MyDecimal from itself.
func (d *MyDecimal) Copy() *MyDecimal {
if d == nil {
return nil
}
dst := &MyDecimal{
digitsInt: d.digitsInt,
digitsFrac: d.digitsFrac,
resultFrac: d.resultFrac,
negative: d.negative,
}
copy(dst.wordBuf[:], d.wordBuf[:])
return dst
}
// String returns the decimal string representation rounded to resultFrac. // String returns the decimal string representation rounded to resultFrac.
func (d *MyDecimal) String() string { func (d *MyDecimal) String() string {
tmp := *d tmp := *d
......
vendor/github.com/pingcap/tidb/types/time.go
浏览文件 @ 68128b73
...@@ -16,6 +16,7 @@ package types ...@@ -16,6 +16,7 @@ package types
import ( import (
"bytes" "bytes"
"fmt" "fmt"
"io"
"math" "math"
"regexp" "regexp"
"strconv" "strconv"
...@@ -1169,6 +1170,9 @@ func ParseDuration(sc *stmtctx.StatementContext, str string, fsp int8) (Duration ...@@ -1169,6 +1170,9 @@ func ParseDuration(sc *stmtctx.StatementContext, str string, fsp int8) (Duration
return ZeroDuration, ErrTruncatedWrongVal.GenWithStackByArgs("time", origStr) return ZeroDuration, ErrTruncatedWrongVal.GenWithStackByArgs("time", origStr)
} }
if terror.ErrorEqual(err, io.EOF) {
err = ErrTruncatedWrongVal.GenWithStackByArgs("time", origStr)
}
if err != nil { if err != nil {
return ZeroDuration, errors.Trace(err) return ZeroDuration, errors.Trace(err)
} }
......
vendor/github.com/pingcap/tidb/util/execdetails/execdetails.go
浏览文件 @ 68128b73
...@@ -49,7 +49,11 @@ type CommitDetails struct { ...@@ -49,7 +49,11 @@ type CommitDetails struct {
PrewriteTime time.Duration PrewriteTime time.Duration
CommitTime time.Duration CommitTime time.Duration
LocalLatchTime time.Duration LocalLatchTime time.Duration
TotalBackoffTime time.Duration CommitBackoffTime int64
Mu struct {
sync.Mutex
BackoffTypes []fmt.Stringer
}
ResolveLockTime int64 ResolveLockTime int64
WriteKeys int WriteKeys int
WriteSize int WriteSize int
...@@ -104,9 +108,15 @@ func (d ExecDetails) String() string { ...@@ -104,9 +108,15 @@ func (d ExecDetails) String() string {
if commitDetails.GetCommitTsTime > 0 { if commitDetails.GetCommitTsTime > 0 {
parts = append(parts, fmt.Sprintf("Get_commit_ts_time: %v", commitDetails.GetCommitTsTime.Seconds())) parts = append(parts, fmt.Sprintf("Get_commit_ts_time: %v", commitDetails.GetCommitTsTime.Seconds()))
} }
if commitDetails.TotalBackoffTime > 0 { commitBackoffTime := atomic.LoadInt64(&commitDetails.CommitBackoffTime)
parts = append(parts, fmt.Sprintf("Total_backoff_time: %v", commitDetails.TotalBackoffTime.Seconds())) if commitBackoffTime > 0 {
parts = append(parts, fmt.Sprintf("Commit_backoff_time: %v", time.Duration(commitBackoffTime).Seconds()))
} }
commitDetails.Mu.Lock()
if len(commitDetails.Mu.BackoffTypes) > 0 {
parts = append(parts, fmt.Sprintf("Backoff_types: %v", commitDetails.Mu.BackoffTypes))
}
commitDetails.Mu.Unlock()
resolveLockTime := atomic.LoadInt64(&commitDetails.ResolveLockTime) resolveLockTime := atomic.LoadInt64(&commitDetails.ResolveLockTime)
if resolveLockTime > 0 { if resolveLockTime > 0 {
parts = append(parts, fmt.Sprintf("Resolve_lock_time: %v", time.Duration(resolveLockTime).Seconds())) parts = append(parts, fmt.Sprintf("Resolve_lock_time: %v", time.Duration(resolveLockTime).Seconds()))
...@@ -163,9 +173,15 @@ func (d ExecDetails) ToZapFields() (fields []zap.Field) { ...@@ -163,9 +173,15 @@ func (d ExecDetails) ToZapFields() (fields []zap.Field) {
if commitDetails.GetCommitTsTime > 0 { if commitDetails.GetCommitTsTime > 0 {
fields = append(fields, zap.String("get_commit_ts_time", fmt.Sprintf("%v", strconv.FormatFloat(commitDetails.GetCommitTsTime.Seconds(), 'f', -1, 64)+"s"))) fields = append(fields, zap.String("get_commit_ts_time", fmt.Sprintf("%v", strconv.FormatFloat(commitDetails.GetCommitTsTime.Seconds(), 'f', -1, 64)+"s")))
} }
if commitDetails.TotalBackoffTime > 0 { commitBackoffTime := atomic.LoadInt64(&commitDetails.CommitBackoffTime)
fields = append(fields, zap.String("total_backoff_time", fmt.Sprintf("%v", strconv.FormatFloat(commitDetails.TotalBackoffTime.Seconds(), 'f', -1, 64)+"s"))) if commitBackoffTime > 0 {
fields = append(fields, zap.String("commit_backoff_time", fmt.Sprintf("%v", strconv.FormatFloat(time.Duration(commitBackoffTime).Seconds(), 'f', -1, 64)+"s")))
}
commitDetails.Mu.Lock()
if len(commitDetails.Mu.BackoffTypes) > 0 {
fields = append(fields, zap.String("backoff_types", fmt.Sprintf("%v", commitDetails.Mu.BackoffTypes)))
} }
commitDetails.Mu.Unlock()
resolveLockTime := atomic.LoadInt64(&commitDetails.ResolveLockTime) resolveLockTime := atomic.LoadInt64(&commitDetails.ResolveLockTime)
if resolveLockTime > 0 { if resolveLockTime > 0 {
fields = append(fields, zap.String("resolve_lock_time", fmt.Sprintf("%v", strconv.FormatFloat(time.Duration(resolveLockTime).Seconds(), 'f', -1, 64)+"s"))) fields = append(fields, zap.String("resolve_lock_time", fmt.Sprintf("%v", strconv.FormatFloat(time.Duration(resolveLockTime).Seconds(), 'f', -1, 64)+"s")))
......
vendor/github.com/pingcap/tidb/util/hack/hack.go
浏览文件 @ 68128b73
...@@ -32,7 +32,7 @@ func String(b []byte) MutableString { ...@@ -32,7 +32,7 @@ func String(b []byte) MutableString {
// Use at your own risk. // Use at your own risk.
func Slice(s string) (b []byte) { func Slice(s string) (b []byte) {
pbytes := (*reflect.SliceHeader)(unsafe.Pointer(&b)) pbytes := (*reflect.SliceHeader)(unsafe.Pointer(&b))
pstring := (*reflect.StringHeader)(unsafe.Pointer(&s)) pstring := *(*reflect.StringHeader)(unsafe.Pointer(&s))
pbytes.Data = pstring.Data pbytes.Data = pstring.Data
pbytes.Len = pstring.Len pbytes.Len = pstring.Len
pbytes.Cap = pstring.Len pbytes.Cap = pstring.Len
......
vendor/vendor.json
浏览文件 @ 68128b73
...@@ -129,118 +129,118 @@ ...@@ -129,118 +129,118 @@
"revisionTime": "2019-03-07T07:54:52Z" "revisionTime": "2019-03-07T07:54:52Z"
}, },
{ {
"checksumSHA1": "RK5vW/hPsPk0JDi1atCWaUR8iFo=", "checksumSHA1": "wopyI0JhbHosTiSv1vL/d6xyjDs=",
"path": "github.com/pingcap/parser", "path": "github.com/pingcap/parser",
"revision": "41d48df058643bdb2e24c64b1685c4e9ff6608f8", "revision": "736e807a964125f7730192af0016e4fcf05c7b70",
"revisionTime": "2019-08-22T02:41:27Z" "revisionTime": "2019-08-29T07:33:47Z"
}, },
{ {
"checksumSHA1": "WYPpAYqE/lpu4PBR9TCn6UigcTg=", "checksumSHA1": "rNycpMFm1SPArRiqljKlCdtbKlE=",
"path": "github.com/pingcap/parser/ast", "path": "github.com/pingcap/parser/ast",
"revision": "41d48df058643bdb2e24c64b1685c4e9ff6608f8", "revision": "736e807a964125f7730192af0016e4fcf05c7b70",
"revisionTime": "2019-08-22T02:41:27Z" "revisionTime": "2019-08-29T07:33:47Z"
}, },
{ {
"checksumSHA1": "xiv40YqnvHcbIhaEzJqjh5K7ehM=", "checksumSHA1": "xiv40YqnvHcbIhaEzJqjh5K7ehM=",
"path": "github.com/pingcap/parser/auth", "path": "github.com/pingcap/parser/auth",
"revision": "41d48df058643bdb2e24c64b1685c4e9ff6608f8", "revision": "736e807a964125f7730192af0016e4fcf05c7b70",
"revisionTime": "2019-08-22T02:41:27Z" "revisionTime": "2019-08-29T07:33:47Z"
}, },
{ {
"checksumSHA1": "EvDXpplklIXmKqLclzWzaN/uHKQ=", "checksumSHA1": "EvDXpplklIXmKqLclzWzaN/uHKQ=",
"path": "github.com/pingcap/parser/charset", "path": "github.com/pingcap/parser/charset",
"revision": "41d48df058643bdb2e24c64b1685c4e9ff6608f8", "revision": "736e807a964125f7730192af0016e4fcf05c7b70",
"revisionTime": "2019-08-22T02:41:27Z" "revisionTime": "2019-08-29T07:33:47Z"
}, },
{ {
"checksumSHA1": "Aao6Mul/qqogOwPwM2arBKZkYZs=", "checksumSHA1": "Aao6Mul/qqogOwPwM2arBKZkYZs=",
"path": "github.com/pingcap/parser/format", "path": "github.com/pingcap/parser/format",
"revision": "41d48df058643bdb2e24c64b1685c4e9ff6608f8", "revision": "736e807a964125f7730192af0016e4fcf05c7b70",
"revisionTime": "2019-08-22T02:41:27Z" "revisionTime": "2019-08-29T07:33:47Z"
}, },
{ {
"checksumSHA1": "GAJ7IUg0t8DCKJbJQxJLkklEj2E=", "checksumSHA1": "GAJ7IUg0t8DCKJbJQxJLkklEj2E=",
"path": "github.com/pingcap/parser/model", "path": "github.com/pingcap/parser/model",
"revision": "41d48df058643bdb2e24c64b1685c4e9ff6608f8", "revision": "736e807a964125f7730192af0016e4fcf05c7b70",
"revisionTime": "2019-08-22T02:41:27Z" "revisionTime": "2019-08-29T07:33:47Z"
}, },
{ {
"checksumSHA1": "WMkc5bRIYYfQdu9lBlVGyKTGIyg=", "checksumSHA1": "9aEsfUW5bJTXPD7x2obSyd+6gw4=",
"path": "github.com/pingcap/parser/mysql", "path": "github.com/pingcap/parser/mysql",
"revision": "41d48df058643bdb2e24c64b1685c4e9ff6608f8", "revision": "736e807a964125f7730192af0016e4fcf05c7b70",
"revisionTime": "2019-08-22T02:41:27Z" "revisionTime": "2019-08-29T07:33:47Z"
}, },
{ {
"checksumSHA1": "olapD16WCMBU9vrA5PtlERGFfXw=", "checksumSHA1": "olapD16WCMBU9vrA5PtlERGFfXw=",
"path": "github.com/pingcap/parser/opcode", "path": "github.com/pingcap/parser/opcode",
"revision": "41d48df058643bdb2e24c64b1685c4e9ff6608f8", "revision": "736e807a964125f7730192af0016e4fcf05c7b70",
"revisionTime": "2019-08-22T02:41:27Z" "revisionTime": "2019-08-29T07:33:47Z"
}, },
{ {
"checksumSHA1": "L6rzy3sJU1RPf7AkJN+0zcwW/YY=", "checksumSHA1": "L6rzy3sJU1RPf7AkJN+0zcwW/YY=",
"path": "github.com/pingcap/parser/terror", "path": "github.com/pingcap/parser/terror",
"revision": "41d48df058643bdb2e24c64b1685c4e9ff6608f8", "revision": "736e807a964125f7730192af0016e4fcf05c7b70",
"revisionTime": "2019-08-22T02:41:27Z" "revisionTime": "2019-08-29T07:33:47Z"
}, },
{ {
"checksumSHA1": "u1Lmm4Fa3su4ElZMN4w0hPzFZl4=", "checksumSHA1": "u1Lmm4Fa3su4ElZMN4w0hPzFZl4=",
"path": "github.com/pingcap/parser/types", "path": "github.com/pingcap/parser/types",
"revision": "41d48df058643bdb2e24c64b1685c4e9ff6608f8", "revision": "736e807a964125f7730192af0016e4fcf05c7b70",
"revisionTime": "2019-08-22T02:41:27Z" "revisionTime": "2019-08-29T07:33:47Z"
}, },
{ {
"checksumSHA1": "cbEwgTkDlGpIIIqmNAuWrxsUwKw=", "checksumSHA1": "ryt2yutvbgdMuS5uvtaiJqqvZXQ=",
"path": "github.com/pingcap/tidb/sessionctx/stmtctx", "path": "github.com/pingcap/tidb/sessionctx/stmtctx",
"revision": "6f76bbe1f75e01dc40f2d0478d484aa9df2b284c", "revision": "bdbaeb419dd5ff1b3a0b16f907a0cd7c421c83b0",
"revisionTime": "2019-08-22T02:51:25Z" "revisionTime": "2019-08-29T06:45:52Z"
}, },
{ {
"checksumSHA1": "erB64jt/DCEoRs+KrywwHGJG2/k=", "checksumSHA1": "tKaN6jgHhSXad0RSNpSe0q9fiMo=",
"path": "github.com/pingcap/tidb/types", "path": "github.com/pingcap/tidb/types",
"revision": "6f76bbe1f75e01dc40f2d0478d484aa9df2b284c", "revision": "bdbaeb419dd5ff1b3a0b16f907a0cd7c421c83b0",
"revisionTime": "2019-08-22T02:51:25Z" "revisionTime": "2019-08-29T06:45:52Z"
}, },
{ {
"checksumSHA1": "gKBD02jzm/d7gn2kX7pXLi+M2ZY=", "checksumSHA1": "gKBD02jzm/d7gn2kX7pXLi+M2ZY=",
"path": "github.com/pingcap/tidb/types/json", "path": "github.com/pingcap/tidb/types/json",
"revision": "6f76bbe1f75e01dc40f2d0478d484aa9df2b284c", "revision": "bdbaeb419dd5ff1b3a0b16f907a0cd7c421c83b0",
"revisionTime": "2019-08-22T02:51:25Z" "revisionTime": "2019-08-29T06:45:52Z"
}, },
{ {
"checksumSHA1": "45zWX5Q6D6aTEWtc4p/lbD9WD4o=", "checksumSHA1": "45zWX5Q6D6aTEWtc4p/lbD9WD4o=",
"path": "github.com/pingcap/tidb/types/parser_driver", "path": "github.com/pingcap/tidb/types/parser_driver",
"revision": "6f76bbe1f75e01dc40f2d0478d484aa9df2b284c", "revision": "bdbaeb419dd5ff1b3a0b16f907a0cd7c421c83b0",
"revisionTime": "2019-08-22T02:51:25Z" "revisionTime": "2019-08-29T06:45:52Z"
}, },
{ {
"checksumSHA1": "q5aOzPGCVZNkrru6v6+uImWm1eA=", "checksumSHA1": "uH6u5fhPvRiiOUCG8bJfphXm4jo=",
"path": "github.com/pingcap/tidb/util/execdetails", "path": "github.com/pingcap/tidb/util/execdetails",
"revision": "6f76bbe1f75e01dc40f2d0478d484aa9df2b284c", "revision": "bdbaeb419dd5ff1b3a0b16f907a0cd7c421c83b0",
"revisionTime": "2019-08-22T02:51:25Z" "revisionTime": "2019-08-29T06:45:52Z"
}, },
{ {
"checksumSHA1": "EFDXphVEI9ohnPky64fc+0lkRkw=", "checksumSHA1": "zw1limoYLowZjRm8wgicyjC72+U=",
"path": "github.com/pingcap/tidb/util/hack", "path": "github.com/pingcap/tidb/util/hack",
"revision": "6f76bbe1f75e01dc40f2d0478d484aa9df2b284c", "revision": "bdbaeb419dd5ff1b3a0b16f907a0cd7c421c83b0",
"revisionTime": "2019-08-22T02:51:25Z" "revisionTime": "2019-08-29T06:45:52Z"
}, },
{ {
"checksumSHA1": "fDbwnQlRCKnr5y6MY799BEd4WlQ=", "checksumSHA1": "fDbwnQlRCKnr5y6MY799BEd4WlQ=",
"path": "github.com/pingcap/tidb/util/logutil", "path": "github.com/pingcap/tidb/util/logutil",
"revision": "6f76bbe1f75e01dc40f2d0478d484aa9df2b284c", "revision": "bdbaeb419dd5ff1b3a0b16f907a0cd7c421c83b0",
"revisionTime": "2019-08-22T02:51:25Z" "revisionTime": "2019-08-29T06:45:52Z"
}, },
{ {
"checksumSHA1": "OveQu0ABBJmMEwmmthqSRQC2Ef0=", "checksumSHA1": "OveQu0ABBJmMEwmmthqSRQC2Ef0=",
"path": "github.com/pingcap/tidb/util/math", "path": "github.com/pingcap/tidb/util/math",
"revision": "6f76bbe1f75e01dc40f2d0478d484aa9df2b284c", "revision": "bdbaeb419dd5ff1b3a0b16f907a0cd7c421c83b0",
"revisionTime": "2019-08-22T02:51:25Z" "revisionTime": "2019-08-29T06:45:52Z"
}, },
{ {
"checksumSHA1": "loL2JgZDLapEOgfM/XUJI5f0HVs=", "checksumSHA1": "loL2JgZDLapEOgfM/XUJI5f0HVs=",
"path": "github.com/pingcap/tidb/util/memory", "path": "github.com/pingcap/tidb/util/memory",
"revision": "6f76bbe1f75e01dc40f2d0478d484aa9df2b284c", "revision": "bdbaeb419dd5ff1b3a0b16f907a0cd7c421c83b0",
"revisionTime": "2019-08-22T02:51:25Z" "revisionTime": "2019-08-29T06:45:52Z"
}, },
{ {
"checksumSHA1": "QPIBwDNUFF5Whrnd41S3mkKa4gQ=", "checksumSHA1": "QPIBwDNUFF5Whrnd41S3mkKa4gQ=",
...@@ -497,68 +497,68 @@ ...@@ -497,68 +497,68 @@
{ {
"checksumSHA1": "aKn1oKcY74N8TRLm3Ayt7Q4bbI4=", "checksumSHA1": "aKn1oKcY74N8TRLm3Ayt7Q4bbI4=",
"path": "vitess.io/vitess/go/bytes2", "path": "vitess.io/vitess/go/bytes2",
"revision": "b5207f0d590a8b596a9b465ee378be182459300f", "revision": "ad6099c8cb9fce72a4b2d22ea55f4f693e846b3e",
"revisionTime": "2019-08-21T22:46:46Z" "revisionTime": "2019-08-28T05:53:53Z"
}, },
{ {
"checksumSHA1": "bhE6CGQgZTIgLPp9lnvlKW/47xc=", "checksumSHA1": "bhE6CGQgZTIgLPp9lnvlKW/47xc=",
"path": "vitess.io/vitess/go/hack", "path": "vitess.io/vitess/go/hack",
"revision": "b5207f0d590a8b596a9b465ee378be182459300f", "revision": "ad6099c8cb9fce72a4b2d22ea55f4f693e846b3e",
"revisionTime": "2019-08-21T22:46:46Z" "revisionTime": "2019-08-28T05:53:53Z"
}, },
{ {
"checksumSHA1": "8zh04M7R0JjzpE+w6/gxHdgZrJg=", "checksumSHA1": "y2C3mKrC39Tffb/614ZYa/qEVGU=",
"path": "vitess.io/vitess/go/sqltypes", "path": "vitess.io/vitess/go/sqltypes",
"revision": "b5207f0d590a8b596a9b465ee378be182459300f", "revision": "ad6099c8cb9fce72a4b2d22ea55f4f693e846b3e",
"revisionTime": "2019-08-21T22:46:46Z" "revisionTime": "2019-08-28T05:53:53Z"
}, },
{ {
"checksumSHA1": "vAIRxI6MHsq3x1hLQwIyw5AvqtI=", "checksumSHA1": "vAIRxI6MHsq3x1hLQwIyw5AvqtI=",
"path": "vitess.io/vitess/go/vt/log", "path": "vitess.io/vitess/go/vt/log",
"revision": "b5207f0d590a8b596a9b465ee378be182459300f", "revision": "ad6099c8cb9fce72a4b2d22ea55f4f693e846b3e",
"revisionTime": "2019-08-21T22:46:46Z" "revisionTime": "2019-08-28T05:53:53Z"
}, },
{ {
"checksumSHA1": "//MHnGEq9xApvIMdwQaRrQf5ZWo=", "checksumSHA1": "//MHnGEq9xApvIMdwQaRrQf5ZWo=",
"path": "vitess.io/vitess/go/vt/proto/binlogdata", "path": "vitess.io/vitess/go/vt/proto/binlogdata",
"revision": "b5207f0d590a8b596a9b465ee378be182459300f", "revision": "ad6099c8cb9fce72a4b2d22ea55f4f693e846b3e",
"revisionTime": "2019-08-21T22:46:46Z" "revisionTime": "2019-08-28T05:53:53Z"
}, },
{ {
"checksumSHA1": "87Zndvk3Y+M+QxMx3uFa0iSbvWY=", "checksumSHA1": "u8uuZWMqaXgQ1MduggrgIHU50FI=",
"path": "vitess.io/vitess/go/vt/proto/query", "path": "vitess.io/vitess/go/vt/proto/query",
"revision": "b5207f0d590a8b596a9b465ee378be182459300f", "revision": "ad6099c8cb9fce72a4b2d22ea55f4f693e846b3e",
"revisionTime": "2019-08-21T22:46:46Z" "revisionTime": "2019-08-28T05:53:53Z"
}, },
{ {
"checksumSHA1": "xpcb9NfXMEeHhEPStbJntIfa5GQ=", "checksumSHA1": "rJ1Iqz/lvaKikIUx4oEFfYJtoBQ=",
"path": "vitess.io/vitess/go/vt/proto/topodata", "path": "vitess.io/vitess/go/vt/proto/topodata",
"revision": "b5207f0d590a8b596a9b465ee378be182459300f", "revision": "ad6099c8cb9fce72a4b2d22ea55f4f693e846b3e",
"revisionTime": "2019-08-21T22:46:46Z" "revisionTime": "2019-08-28T05:53:53Z"
}, },
{ {
"checksumSHA1": "Bv8lucvoH9AnJSYiWX8MIrJl4zY=", "checksumSHA1": "Bv8lucvoH9AnJSYiWX8MIrJl4zY=",
"path": "vitess.io/vitess/go/vt/proto/vtgate", "path": "vitess.io/vitess/go/vt/proto/vtgate",
"revision": "b5207f0d590a8b596a9b465ee378be182459300f", "revision": "ad6099c8cb9fce72a4b2d22ea55f4f693e846b3e",
"revisionTime": "2019-08-21T22:46:46Z" "revisionTime": "2019-08-28T05:53:53Z"
}, },
{ {
"checksumSHA1": "qz32abYdmm9NfKTc++K0l1EvXXM=", "checksumSHA1": "HeUJu5njPq9iznpAOcrLpLD7f9w=",
"path": "vitess.io/vitess/go/vt/proto/vtrpc", "path": "vitess.io/vitess/go/vt/proto/vtrpc",
"revision": "b5207f0d590a8b596a9b465ee378be182459300f", "revision": "ad6099c8cb9fce72a4b2d22ea55f4f693e846b3e",
"revisionTime": "2019-08-21T22:46:46Z" "revisionTime": "2019-08-28T05:53:53Z"
}, },
{ {
"checksumSHA1": "0SPe/oMz50OW+yC+DGV4UJpjZ3Y=", "checksumSHA1": "uhDAaoN8RkmdkmkbYkaX5dLPquc=",
"path": "vitess.io/vitess/go/vt/sqlparser", "path": "vitess.io/vitess/go/vt/sqlparser",
"revision": "b5207f0d590a8b596a9b465ee378be182459300f", "revision": "ad6099c8cb9fce72a4b2d22ea55f4f693e846b3e",
"revisionTime": "2019-08-21T22:46:46Z" "revisionTime": "2019-08-28T05:53:53Z"
}, },
{ {
"checksumSHA1": "z9+F/lA1Xrl5S16LKssUH8VL6hs=", "checksumSHA1": "z9+F/lA1Xrl5S16LKssUH8VL6hs=",
"path": "vitess.io/vitess/go/vt/vterrors", "path": "vitess.io/vitess/go/vt/vterrors",
"revision": "b5207f0d590a8b596a9b465ee378be182459300f", "revision": "ad6099c8cb9fce72a4b2d22ea55f4f693e846b3e",
"revisionTime": "2019-08-21T22:46:46Z" "revisionTime": "2019-08-28T05:53:53Z"
} }
], ],
"rootPath": "github.com/XiaoMi/soar" "rootPath": "github.com/XiaoMi/soar"
......
vendor/vitess.io/vitess/go/sqltypes/arithmetic.go
浏览文件 @ 68128b73
...@@ -19,6 +19,8 @@ package sqltypes ...@@ -19,6 +19,8 @@ package sqltypes
import ( import (
"bytes" "bytes"
"fmt" "fmt"
"math"
"strconv" "strconv"
querypb "vitess.io/vitess/go/vt/proto/query" querypb "vitess.io/vitess/go/vt/proto/query"
...@@ -40,6 +42,25 @@ type numeric struct { ...@@ -40,6 +42,25 @@ type numeric struct {
var zeroBytes = []byte("0") var zeroBytes = []byte("0")
// Add adds two values together
// if v1 or v2 is null, then it returns null
func Add(v1, v2 Value) (Value, error) {
if v1.IsNull() || v2.IsNull() {
return NULL, nil
}
lv1, err := newNumeric(v1)
lv2, err := newNumeric(v2)
lresult, err := addNumericWithError(lv1, lv2)
if err != nil {
return NULL, err
}
return castFromNumeric(lresult, lresult.typ), nil
}
// NullsafeAdd adds two Values in a null-safe manner. A null value // NullsafeAdd adds two Values in a null-safe manner. A null value
// is treated as 0. If both values are null, then a null is returned. // is treated as 0. If both values are null, then a null is returned.
// If both values are not null, a numeric value is built // If both values are not null, a numeric value is built
...@@ -51,7 +72,7 @@ var zeroBytes = []byte("0") ...@@ -51,7 +72,7 @@ var zeroBytes = []byte("0")
// addition, if one of the input types was Decimal, then // addition, if one of the input types was Decimal, then
// a Decimal is built. Otherwise, the final type of the // a Decimal is built. Otherwise, the final type of the
// result is preserved. // result is preserved.
func NullsafeAdd(v1, v2 Value, resultType querypb.Type) (Value, error) { func NullsafeAdd(v1, v2 Value, resultType querypb.Type) Value {
if v1.IsNull() { if v1.IsNull() {
v1 = MakeTrusted(resultType, zeroBytes) v1 = MakeTrusted(resultType, zeroBytes)
} }
...@@ -61,16 +82,14 @@ func NullsafeAdd(v1, v2 Value, resultType querypb.Type) (Value, error) { ...@@ -61,16 +82,14 @@ func NullsafeAdd(v1, v2 Value, resultType querypb.Type) (Value, error) {
lv1, err := newNumeric(v1) lv1, err := newNumeric(v1)
if err != nil { if err != nil {
return NULL, err return NULL
} }
lv2, err := newNumeric(v2) lv2, err := newNumeric(v2)
if err != nil { if err != nil {
return NULL, err return NULL
}
lresult, err := addNumeric(lv1, lv2)
if err != nil {
return NULL, err
} }
lresult := addNumeric(lv1, lv2)
return castFromNumeric(lresult, resultType) return castFromNumeric(lresult, resultType)
} }
...@@ -224,10 +243,7 @@ func ToInt64(v Value) (int64, error) { ...@@ -224,10 +243,7 @@ func ToInt64(v Value) (int64, error) {
// ToFloat64 converts Value to float64. // ToFloat64 converts Value to float64.
func ToFloat64(v Value) (float64, error) { func ToFloat64(v Value) (float64, error) {
num, err := newNumeric(v) num, _ := newNumeric(v)
if err != nil {
return 0, err
}
switch num.typ { switch num.typ {
case Int64: case Int64:
return float64(num.ival), nil return float64(num.ival), nil
...@@ -292,7 +308,7 @@ func newNumeric(v Value) (numeric, error) { ...@@ -292,7 +308,7 @@ func newNumeric(v Value) (numeric, error) {
if fval, err := strconv.ParseFloat(str, 64); err == nil { if fval, err := strconv.ParseFloat(str, 64); err == nil {
return numeric{fval: fval, typ: Float64}, nil return numeric{fval: fval, typ: Float64}, nil
} }
return numeric{}, vterrors.Errorf(vtrpcpb.Code_INVALID_ARGUMENT, "could not parse value: '%s'", str) return numeric{ival: 0, typ: Int64}, nil
} }
// newIntegralNumeric parses a value and produces an Int64 or Uint64. // newIntegralNumeric parses a value and produces an Int64 or Uint64.
...@@ -323,22 +339,41 @@ func newIntegralNumeric(v Value) (numeric, error) { ...@@ -323,22 +339,41 @@ func newIntegralNumeric(v Value) (numeric, error) {
return numeric{}, vterrors.Errorf(vtrpcpb.Code_INVALID_ARGUMENT, "could not parse value: '%s'", str) return numeric{}, vterrors.Errorf(vtrpcpb.Code_INVALID_ARGUMENT, "could not parse value: '%s'", str)
} }
func addNumeric(v1, v2 numeric) (numeric, error) { func addNumeric(v1, v2 numeric) numeric {
v1, v2 = prioritize(v1, v2) v1, v2 = prioritize(v1, v2)
switch v1.typ { switch v1.typ {
case Int64: case Int64:
return intPlusInt(v1.ival, v2.ival), nil return intPlusInt(v1.ival, v2.ival)
case Uint64: case Uint64:
switch v2.typ { switch v2.typ {
case Int64: case Int64:
return uintPlusInt(v1.uval, v2.ival) return uintPlusInt(v1.uval, v2.ival)
case Uint64: case Uint64:
return uintPlusUint(v1.uval, v2.uval), nil return uintPlusUint(v1.uval, v2.uval)
}
case Float64:
return floatPlusAny(v1.fval, v2)
}
panic("unreachable")
}
func addNumericWithError(v1, v2 numeric) (numeric, error) {
v1, v2 = prioritize(v1, v2)
switch v1.typ {
case Int64:
return intPlusIntWithError(v1.ival, v2.ival)
case Uint64:
switch v2.typ {
case Int64:
return uintPlusIntWithError(v1.uval, v2.ival)
case Uint64:
return uintPlusUintWithError(v1.uval, v2.uval)
} }
case Float64: case Float64:
return floatPlusAny(v1.fval, v2), nil return floatPlusAny(v1.fval, v2), nil
} }
panic("unreachable") panic("unreachable")
} }
// prioritize reorders the input parameters // prioritize reorders the input parameters
...@@ -353,6 +388,7 @@ func prioritize(v1, v2 numeric) (altv1, altv2 numeric) { ...@@ -353,6 +388,7 @@ func prioritize(v1, v2 numeric) (altv1, altv2 numeric) {
if v2.typ == Float64 { if v2.typ == Float64 {
return v2, v1 return v2, v1
} }
} }
return v1, v2 return v1, v2
} }
...@@ -371,21 +407,47 @@ overflow: ...@@ -371,21 +407,47 @@ overflow:
return numeric{typ: Float64, fval: float64(v1) + float64(v2)} return numeric{typ: Float64, fval: float64(v1) + float64(v2)}
} }
func uintPlusInt(v1 uint64, v2 int64) (numeric, error) { func intPlusIntWithError(v1, v2 int64) (numeric, error) {
if v2 < 0 { result := v1 + v2
return numeric{}, vterrors.Errorf(vtrpcpb.Code_INVALID_ARGUMENT, "cannot add a negative number to an unsigned integer: %d, %d", v1, v2) if (result > v1) != (v2 > 0) {
return numeric{}, vterrors.Errorf(vtrpcpb.Code_INVALID_ARGUMENT, "BIGINT value is out of range in %v + %v", v1, v2)
} }
return uintPlusUint(v1, uint64(v2)), nil return numeric{typ: Int64, ival: result}, nil
}
func uintPlusInt(v1 uint64, v2 int64) numeric {
return uintPlusUint(v1, uint64(v2))
}
func uintPlusIntWithError(v1 uint64, v2 int64) (numeric, error) {
if v2 >= math.MaxInt64 && v1 > 0 {
return numeric{}, vterrors.Errorf(vtrpcpb.Code_INVALID_ARGUMENT, "BIGINT value is out of range in %v + %v", v1, v2)
}
//convert to int -> uint is because for numeric operators (such as + or -)
//where one of the operands is an unsigned integer, the result is unsigned by default.
return uintPlusUintWithError(v1, uint64(v2))
} }
func uintPlusUint(v1, v2 uint64) numeric { func uintPlusUint(v1, v2 uint64) numeric {
result := v1 + v2 result := v1 + v2
if result < v2 { if result < v2 {
return numeric{typ: Float64, fval: float64(v1) + float64(v2)} return numeric{typ: Float64, fval: float64(v1) + float64(v2)}
} }
return numeric{typ: Uint64, uval: result} return numeric{typ: Uint64, uval: result}
} }
func uintPlusUintWithError(v1, v2 uint64) (numeric, error) {
result := v1 + v2
if result < v2 {
return numeric{}, vterrors.Errorf(vtrpcpb.Code_INVALID_ARGUMENT, "BIGINT UNSIGNED value is out of range in %v + %v", v1, v2)
}
return numeric{typ: Uint64, uval: result}, nil
}
func floatPlusAny(v1 float64, v2 numeric) numeric { func floatPlusAny(v1 float64, v2 numeric) numeric {
switch v2.typ { switch v2.typ {
case Int64: case Int64:
...@@ -396,37 +458,43 @@ func floatPlusAny(v1 float64, v2 numeric) numeric { ...@@ -396,37 +458,43 @@ func floatPlusAny(v1 float64, v2 numeric) numeric {
return numeric{typ: Float64, fval: v1 + v2.fval} return numeric{typ: Float64, fval: v1 + v2.fval}
} }
func castFromNumeric(v numeric, resultType querypb.Type) (Value, error) { func castFromNumeric(v numeric, resultType querypb.Type) Value {
switch { switch {
case IsSigned(resultType): case IsSigned(resultType):
switch v.typ { switch v.typ {
case Int64: case Int64:
return MakeTrusted(resultType, strconv.AppendInt(nil, v.ival, 10)), nil return MakeTrusted(resultType, strconv.AppendInt(nil, v.ival, 10))
case Uint64, Float64: case Uint64:
return NULL, vterrors.Errorf(vtrpcpb.Code_INVALID_ARGUMENT, "unexpected type conversion: %v to %v", v.typ, resultType) return MakeTrusted(resultType, strconv.AppendInt(nil, int64(v.uval), 10))
case Float64:
return MakeTrusted(resultType, strconv.AppendInt(nil, int64(v.fval), 10))
} }
case IsUnsigned(resultType): case IsUnsigned(resultType):
switch v.typ { switch v.typ {
case Uint64: case Uint64:
return MakeTrusted(resultType, strconv.AppendUint(nil, v.uval, 10)), nil return MakeTrusted(resultType, strconv.AppendUint(nil, v.uval, 10))
case Int64, Float64: case Int64:
return NULL, vterrors.Errorf(vtrpcpb.Code_INVALID_ARGUMENT, "unexpected type conversion: %v to %v", v.typ, resultType) return MakeTrusted(resultType, strconv.AppendUint(nil, uint64(v.ival), 10))
case Float64:
return MakeTrusted(resultType, strconv.AppendUint(nil, uint64(v.fval), 10))
} }
case IsFloat(resultType) || resultType == Decimal: case IsFloat(resultType) || resultType == Decimal:
switch v.typ { switch v.typ {
case Int64: case Int64:
return MakeTrusted(resultType, strconv.AppendInt(nil, v.ival, 10)), nil return MakeTrusted(resultType, strconv.AppendInt(nil, v.ival, 10))
case Uint64: case Uint64:
return MakeTrusted(resultType, strconv.AppendUint(nil, v.uval, 10)), nil return MakeTrusted(resultType, strconv.AppendUint(nil, v.uval, 10))
case Float64: case Float64:
format := byte('g') format := byte('g')
if resultType == Decimal { if resultType == Decimal {
format = 'f' format = 'f'
} }
return MakeTrusted(resultType, strconv.AppendFloat(nil, v.fval, format, -1, 64)), nil return MakeTrusted(resultType, strconv.AppendFloat(nil, v.fval, format, -1, 64))
} }
} }
return NULL, vterrors.Errorf(vtrpcpb.Code_INVALID_ARGUMENT, "unexpected type conversion to non-numeric: %v", resultType) return NULL
} }
func compareNumeric(v1, v2 numeric) int { func compareNumeric(v1, v2 numeric) int {
......
vendor/vitess.io/vitess/go/sqltypes/value.go
浏览文件 @ 68128b73
...@@ -89,9 +89,11 @@ func NewValue(typ querypb.Type, val []byte) (v Value, err error) { ...@@ -89,9 +89,11 @@ func NewValue(typ querypb.Type, val []byte) (v Value, err error) {
// comments. Other packages can also use the function to create // comments. Other packages can also use the function to create
// VarBinary or VarChar values. // VarBinary or VarChar values.
func MakeTrusted(typ querypb.Type, val []byte) Value { func MakeTrusted(typ querypb.Type, val []byte) Value {
if typ == Null { if typ == Null {
return NULL return NULL
} }
return Value{typ: typ, val: val} return Value{typ: typ, val: val}
} }
......
vendor/vitess.io/vitess/go/vt/proto/query/query.pb.go
浏览文件 @ 68128b73
...@@ -964,7 +964,7 @@ type Field struct { ...@@ -964,7 +964,7 @@ type Field struct {
ColumnLength uint32 `protobuf:"varint,7,opt,name=column_length,json=columnLength,proto3" json:"column_length,omitempty"` ColumnLength uint32 `protobuf:"varint,7,opt,name=column_length,json=columnLength,proto3" json:"column_length,omitempty"`
// charset is actually a uint16. Only the lower 16 bits are used. // charset is actually a uint16. Only the lower 16 bits are used.
Charset uint32 `protobuf:"varint,8,opt,name=charset,proto3" json:"charset,omitempty"` Charset uint32 `protobuf:"varint,8,opt,name=charset,proto3" json:"charset,omitempty"`
// decimals is actualy a uint8. Only the lower 8 bits are used. // decimals is actually a uint8. Only the lower 8 bits are used.
Decimals uint32 `protobuf:"varint,9,opt,name=decimals,proto3" json:"decimals,omitempty"` Decimals uint32 `protobuf:"varint,9,opt,name=decimals,proto3" json:"decimals,omitempty"`
// flags is actually a uint16. Only the lower 16 bits are used. // flags is actually a uint16. Only the lower 16 bits are used.
Flags uint32 `protobuf:"varint,10,opt,name=flags,proto3" json:"flags,omitempty"` Flags uint32 `protobuf:"varint,10,opt,name=flags,proto3" json:"flags,omitempty"`
......
vendor/vitess.io/vitess/go/vt/proto/topodata/topodata.pb.go
浏览文件 @ 68128b73
...@@ -505,7 +505,7 @@ func (m *Shard_ServedType) GetCells() []string { ...@@ -505,7 +505,7 @@ func (m *Shard_ServedType) GetCells() []string {
} }
// SourceShard represents a data source for filtered replication // SourceShard represents a data source for filtered replication
// accross shards. When this is used in a destination shard, the master // across shards. When this is used in a destination shard, the master
// of that shard will run filtered replication. // of that shard will run filtered replication.
type Shard_SourceShard struct { type Shard_SourceShard struct {
// Uid is the unique ID for this SourceShard object. // Uid is the unique ID for this SourceShard object.
......
vendor/vitess.io/vitess/go/vt/proto/vtrpc/vtrpc.pb.go
浏览文件 @ 68128b73
...@@ -174,7 +174,7 @@ func (Code) EnumDescriptor() ([]byte, []int) { ...@@ -174,7 +174,7 @@ func (Code) EnumDescriptor() ([]byte, []int) {
// LegacyErrorCode is the enum values for Errors. This type is deprecated. // LegacyErrorCode is the enum values for Errors. This type is deprecated.
// Use Code instead. Background: In the initial design, we thought // Use Code instead. Background: In the initial design, we thought
// that we may end up with a different list of canonical error codes // that we may end up with a different list of canonical error codes
// than the ones defined by grpc. In hindisght, we realize that // than the ones defined by grpc. In hindsight, we realize that
// the grpc error codes are fairly generic and mostly sufficient. // the grpc error codes are fairly generic and mostly sufficient.
// In order to avoid confusion, this type will be deprecated in // In order to avoid confusion, this type will be deprecated in
// favor of the new Code that matches exactly what grpc defines. // favor of the new Code that matches exactly what grpc defines.
......
vendor/vitess.io/vitess/go/vt/sqlparser/analyzer.go
浏览文件 @ 68128b73
...@@ -285,6 +285,9 @@ func ExtractSetValues(sql string) (keyValues map[SetKey]interface{}, scope strin ...@@ -285,6 +285,9 @@ func ExtractSetValues(sql string) (keyValues map[SetKey]interface{}, scope strin
case strings.HasPrefix(key, "@@session."): case strings.HasPrefix(key, "@@session."):
scope = SessionStr scope = SessionStr
key = strings.TrimPrefix(key, "@@session.") key = strings.TrimPrefix(key, "@@session.")
case strings.HasPrefix(key, "@@vitess_metadata."):
scope = VitessMetadataStr
key = strings.TrimPrefix(key, "@@vitess_metadata.")
case strings.HasPrefix(key, "@@"): case strings.HasPrefix(key, "@@"):
key = strings.TrimPrefix(key, "@@") key = strings.TrimPrefix(key, "@@")
} }
......
vendor/vitess.io/vitess/go/vt/sqlparser/ast.go
浏览文件 @ 68128b73
...@@ -664,6 +664,7 @@ type Set struct { ...@@ -664,6 +664,7 @@ type Set struct {
const ( const (
SessionStr = "session" SessionStr = "session"
GlobalStr = "global" GlobalStr = "global"
VitessMetadataStr = "vitess_metadata"
ImplicitStr = "" ImplicitStr = ""
) )
......
vendor/vitess.io/vitess/go/vt/sqlparser/like_filter.go 0 → 100644
浏览文件 @ 68128b73
package sqlparser
import (
"fmt"
"regexp"
"strings"
)
var (
re = regexp.MustCompile(`([^\\]?|[\\]{2})[%_]`)
)
func replacer(s string) string {
if strings.HasPrefix(s, `\\`) {
return s[2:]
}
result := strings.Replace(s, "%" ,".*", -1)
result = strings.Replace(result, "_", ".", -1)
return result
}
// LikeToRegexp converts a like sql expression to regular expression
func LikeToRegexp(likeExpr string) *regexp.Regexp {
if likeExpr == "" {
return regexp.MustCompile("^.*$") // Can never fail
}
keyPattern := regexp.QuoteMeta(likeExpr)
keyPattern = re.ReplaceAllStringFunc(keyPattern, replacer)
keyPattern = fmt.Sprintf("^%s$", keyPattern)
return regexp.MustCompile(keyPattern) // Can never fail
}
vendor/vitess.io/vitess/go/vt/sqlparser/sql.go
浏览文件 @ 68128b73
因为 它太大了无法显示 source diff 。你可以改为 查看blob。
vendor/vitess.io/vitess/go/vt/sqlparser/sql.y
浏览文件 @ 68128b73
...@@ -182,7 +182,7 @@ func skipToEnd(yylex interface{}) { ...@@ -182,7 +182,7 @@ func skipToEnd(yylex interface{}) {
%token <bytes> NULLX AUTO_INCREMENT APPROXNUM SIGNED UNSIGNED ZEROFILL %token <bytes> NULLX AUTO_INCREMENT APPROXNUM SIGNED UNSIGNED ZEROFILL
// Supported SHOW tokens // Supported SHOW tokens
%token <bytes> COLLATION DATABASES TABLES VSCHEMA FULL PROCESSLIST COLUMNS FIELDS ENGINES PLUGINS %token <bytes> COLLATION DATABASES TABLES VITESS_METADATA VSCHEMA FULL PROCESSLIST COLUMNS FIELDS ENGINES PLUGINS
// SET tokens // SET tokens
%token <bytes> NAMES CHARSET GLOBAL SESSION ISOLATION LEVEL READ WRITE ONLY REPEATABLE COMMITTED UNCOMMITTED SERIALIZABLE %token <bytes> NAMES CHARSET GLOBAL SESSION ISOLATION LEVEL READ WRITE ONLY REPEATABLE COMMITTED UNCOMMITTED SERIALIZABLE
...@@ -262,7 +262,7 @@ func skipToEnd(yylex interface{}) { ...@@ -262,7 +262,7 @@ func skipToEnd(yylex interface{}) {
%type <bytes> for_from %type <bytes> for_from
%type <str> ignore_opt default_opt %type <str> ignore_opt default_opt
%type <str> full_opt from_database_opt tables_or_processlist columns_or_fields %type <str> full_opt from_database_opt tables_or_processlist columns_or_fields
%type <showFilter> like_or_where_opt %type <showFilter> like_or_where_opt like_opt
%type <byt> exists_opt %type <byt> exists_opt
%type <empty> not_exists_opt non_add_drop_or_rename_operation to_opt index_opt constraint_opt %type <empty> not_exists_opt non_add_drop_or_rename_operation to_opt index_opt constraint_opt
%type <bytes> reserved_keyword non_reserved_keyword %type <bytes> reserved_keyword non_reserved_keyword
...@@ -1572,6 +1572,11 @@ show_statement: ...@@ -1572,6 +1572,11 @@ show_statement:
showCollationFilterOpt := $4 showCollationFilterOpt := $4
$$ = &Show{Type: string($2), ShowCollationFilterOpt: &showCollationFilterOpt} $$ = &Show{Type: string($2), ShowCollationFilterOpt: &showCollationFilterOpt}
} }
| SHOW VITESS_METADATA VARIABLES like_opt
{
showTablesOpt := &ShowTablesOpt{Filter: $4}
$$ = &Show{Scope: string($2), Type: string($3), ShowTablesOpt: showTablesOpt}
}
| SHOW VSCHEMA TABLES | SHOW VSCHEMA TABLES
{ {
$$ = &Show{Type: string($2) + " " + string($3)} $$ = &Show{Type: string($2) + " " + string($3)}
...@@ -1661,6 +1666,16 @@ like_or_where_opt: ...@@ -1661,6 +1666,16 @@ like_or_where_opt:
$$ = &ShowFilter{Filter:$2} $$ = &ShowFilter{Filter:$2}
} }
like_opt:
/* empty */
{
$$ = nil
}
| LIKE STRING
{
$$ = &ShowFilter{Like:string($2)}
}
show_session_or_global: show_session_or_global:
/* empty */ /* empty */
{ {
...@@ -3393,6 +3408,7 @@ non_reserved_keyword: ...@@ -3393,6 +3408,7 @@ non_reserved_keyword:
| VIEW | VIEW
| VINDEX | VINDEX
| VINDEXES | VINDEXES
| VITESS_METADATA
| VSCHEMA | VSCHEMA
| WARNINGS | WARNINGS
| WITH | WITH
......
vendor/vitess.io/vitess/go/vt/sqlparser/token.go
浏览文件 @ 68128b73
...@@ -391,6 +391,7 @@ var keywords = map[string]int{ ...@@ -391,6 +391,7 @@ var keywords = map[string]int{
"vindex": VINDEX, "vindex": VINDEX,
"vindexes": VINDEXES, "vindexes": VINDEXES,
"view": VIEW, "view": VIEW,
"vitess_metadata": VITESS_METADATA,
"vschema": VSCHEMA, "vschema": VSCHEMA,
"warnings": WARNINGS, "warnings": WARNINGS,
"when": WHEN, "when": WHEN,
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或