*: add a PERFORMANCE_SCHEMA.slow_query table

domain/domain.go

@@ -378,10 +378,13 @@ func (do *Domain) topNSlowQueryLoop() {
 			do.slowQuery.Append(info)
 		case msg := <-do.slowQuery.msgCh:
 			req := msg.request
-			if req.Tp == ast.ShowSlowTop {
+			switch req.Tp {
+			case ast.ShowSlowTop:
 				msg.result = do.slowQuery.QueryTop(int(req.Count), req.Kind)
-			} else if req.Tp == ast.ShowSlowRecent {
+			case ast.ShowSlowRecent:
 				msg.result = do.slowQuery.QueryRecent(int(req.Count))
+			default:
+				msg.result = do.slowQuery.QueryAll()
 			}
 			msg.Done()
 		}

domain/topn_slow_query.go

@@ -178,6 +178,10 @@ const (
 	queryTypeRecent
 )
 
+func (q *topNSlowQueries) QueryAll() []*SlowQueryInfo {
+	return q.recent.data
+}
+
 func (q *topNSlowQueries) QueryRecent(count int) []*SlowQueryInfo {
 	return q.recent.Query(count)
 }

infoschema/infoschema.go

@@ -358,5 +358,13 @@ func initInfoSchemaDB() {
 
 // IsMemoryDB checks if the db is in memory.
 func IsMemoryDB(dbName string) bool {
-	return dbName == "information_schema" || dbName == "performance_schema"
+	if dbName == "information_schema" {
+		return true
+	}
+	for _, driver := range drivers {
+		if driver.DBInfo.Name.L == dbName {
+			return true
+		}
+	}
+	return false
 }

infoschema/perfschema/tables.go

@@ -27,7 +27,19 @@ type perfSchemaTable struct {
 	cols []*table.Column
 }
 
+var pluginTable = make(map[string]func(autoid.Allocator, *model.TableInfo) (table.Table, error))
+
+func RegisterTable(tableName, sql string,
+	tableFromMeta func(autoid.Allocator, *model.TableInfo) (table.Table, error)) {
+	perfSchemaTables = append(perfSchemaTables, sql)
+	pluginTable[tableName] = tableFromMeta
+}
+
 func tableFromMeta(alloc autoid.Allocator, meta *model.TableInfo) (table.Table, error) {
+	if f, ok := pluginTable[meta.Name.L]; ok {
+		ret, err := f(alloc, meta)
+		return ret, err
+	}
 	return createPerfSchemaTable(meta), nil
 }
 

infoschema/tiniub/tables.go

@@ -0,0 +1,135 @@
+// 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 tiniub
+
+import (
+	"github.com/pingcap/parser/ast"
+	"github.com/pingcap/parser/model"
+	"github.com/pingcap/parser/mysql"
+	"github.com/pingcap/tidb/domain"
+	"github.com/pingcap/tidb/infoschema"
+	"github.com/pingcap/tidb/infoschema/perfschema"
+	"github.com/pingcap/tidb/kv"
+	"github.com/pingcap/tidb/meta/autoid"
+	"github.com/pingcap/tidb/sessionctx"
+	"github.com/pingcap/tidb/table"
+	"github.com/pingcap/tidb/types"
+)
+
+// Init should be called before perfschema.Init()
+func Init() {
+	perfschema.RegisterTable("slow_query", tableSlowQuery, tableFromMeta)
+}
+
+type slowQueryTable struct {
+	infoschema.VirtualTable
+	meta *model.TableInfo
+	cols []*table.Column
+}
+
+const tableSlowQuery = "CREATE TABLE if not exists slow_query (" +
+	"`SQL` VARCHAR(4096)," +
+	"`START` TIMESTAMP (6)," +
+	"`DURATION` TIME (6)," +
+	"DETAILS VARCHAR(256)," +
+	"SUCC TINYINT," +
+	"CONN_ID BIGINT," +
+	"TRANSACTION_TS BIGINT," +
+	"USER VARCHAR(32) NOT NULL," +
+	"DB VARCHAR(64) NOT NULL," +
+	"TABLE_IDS VARCHAR(256)," +
+	"INDEX_IDS VARCHAR(256)," +
+	"INTERNAL TINYINT);"
+
+// tableFromMeta creates the slow query table.
+func tableFromMeta(alloc autoid.Allocator, meta *model.TableInfo) (table.Table, error) {
+	columns := make([]*table.Column, 0, len(meta.Columns))
+	for _, colInfo := range meta.Columns {
+		col := table.ToColumn(colInfo)
+		columns = append(columns, col)
+	}
+	t := &slowQueryTable{
+		meta: meta,
+		cols: columns,
+	}
+	return t, nil
+}
+
+// IterRecords rewrites the IterRecords method of slowQueryTable.
+func (s slowQueryTable) IterRecords(ctx sessionctx.Context, startKey kv.Key, cols []*table.Column, fn table.RecordIterFunc) error {
+	dom := domain.GetDomain(ctx)
+	result := dom.ShowSlowQuery(&ast.ShowSlow{Tp: 42})
+
+	for i, item := range result {
+		row := make([]types.Datum, 0, len(cols))
+		for _, col := range cols {
+			switch col.Name.L {
+			case "sql":
+				row = append(row, types.NewDatum(item.SQL))
+			case "start":
+				ts := types.NewTimeDatum(types.Time{types.FromGoTime(item.Start), mysql.TypeTimestamp, types.MaxFsp})
+				row = append(row, ts)
+			case "duration":
+				row = append(row, types.NewDurationDatum(types.Duration{item.Duration, types.MaxFsp}))
+			case "details":
+				row = append(row, types.NewDatum(item.Detail.String()))
+			case "succ":
+				row = append(row, types.NewDatum(item.Succ))
+			case "conn_id":
+				row = append(row, types.NewDatum(item.ConnID))
+			case "transaction_ts":
+				row = append(row, types.NewDatum(item.TxnTS))
+			case "user":
+				row = append(row, types.NewDatum(item.User))
+			case "db":
+				row = append(row, types.NewDatum(item.DB))
+			case "table_ids":
+				row = append(row, types.NewDatum(item.TableIDs))
+			case "index_ids":
+				row = append(row, types.NewDatum(item.IndexIDs))
+			case "internal":
+				row = append(row, types.NewDatum(item.Internal))
+			}
+		}
+
+		more, err := fn(int64(i), row, cols)
+		if err != nil {
+			return err
+		}
+		if !more {
+			break
+		}
+	}
+	return nil
+}
+
+// Cols implements table.Table Type interface.
+func (vt *slowQueryTable) Cols() []*table.Column {
+	return vt.cols
+}
+
+// WritableCols implements table.Table Type interface.
+func (vt *slowQueryTable) WritableCols() []*table.Column {
+	return vt.cols
+}
+
+// GetID implements table.Table GetID interface.
+func (vt *slowQueryTable) GetPhysicalID() int64 {
+	return vt.meta.ID
+}
+
+// Meta implements table.Table Type interface.
+func (vt *slowQueryTable) Meta() *model.TableInfo {
+	return vt.meta
+}

infoschema/tiniub/tables_test.go

@@ -0,0 +1,52 @@
+// Copyright 2018 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 tiniub_test
+
+import (
+	"testing"
+
+	. "github.com/pingcap/check"
+	"github.com/pingcap/tidb/infoschema/tiniub"
+	"github.com/pingcap/tidb/session"
+	"github.com/pingcap/tidb/store/mockstore"
+	"github.com/pingcap/tidb/util/testkit"
+	"github.com/pingcap/tidb/util/testleak"
+)
+
+func TestT(t *testing.T) {
+	CustomVerboseFlag = true
+	TestingT(t)
+}
+
+var _ = Suite(&testSuite{})
+
+type testSuite struct {
+}
+
+func (s *testSuite) TestTiNiuBTables(c *C) {
+	testleak.BeforeTest()
+	defer testleak.AfterTest(c)()
+	tiniub.Init()
+	store, err := mockstore.NewMockTikvStore()
+	c.Assert(err, IsNil)
+	defer store.Close()
+	do, err := session.BootstrapSession(store)
+	c.Assert(err, IsNil)
+	defer do.Close()
+
+	tk := testkit.NewTestKit(c, store)
+
+	tk.MustExec("use PERFORMANCE_SCHEMA")
+	tk.MustQuery("select * from slow_query").Check(testkit.Rows())
+}

statistics/bootstrap.go

@@ -23,6 +23,7 @@ import (
 	"github.com/pingcap/parser/terror"
 	"github.com/pingcap/tidb/infoschema"
 	"github.com/pingcap/tidb/sessionctx"
+	tt "github.com/pingcap/tidb/table"
 	"github.com/pingcap/tidb/types"
 	"github.com/pingcap/tidb/util/chunk"
 	"github.com/pingcap/tidb/util/sqlexec"
@@ -37,6 +38,10 @@ func (h *Handle) initStatsMeta4Chunk(is infoschema.InfoSchema, tables statsCache
 			log.Debugf("Unknown physical ID %d in stats meta table, maybe it has been dropped", physicalID)
 			continue
 		}
+		if table.Type() != tt.NormalTable {
+			continue
+		}
+
 		tableInfo := table.Meta()
 		newHistColl := HistColl{
 			PhysicalID:     physicalID,

statistics/update.go

@@ -29,6 +29,7 @@ import (
 	"github.com/pingcap/tidb/metrics"
 	"github.com/pingcap/tidb/sessionctx/variable"
 	"github.com/pingcap/tidb/store/tikv/oracle"
+	tt "github.com/pingcap/tidb/table"
 	"github.com/pingcap/tidb/util/chunk"
 	"github.com/pingcap/tidb/util/sqlexec"
 	log "github.com/sirupsen/logrus"
@@ -711,6 +712,9 @@ func (h *Handle) HandleAutoAnalyze(is infoschema.InfoSchema) error {
 	for _, db := range dbs {
 		tbls := is.SchemaTables(model.NewCIStr(db))
 		for _, tbl := range tbls {
+			if tbl.Type() != tt.NormalTable {
+				continue
+			}
 			tblInfo := tbl.Meta()
 			pi := tblInfo.GetPartitionInfo()
 			tblName := "`" + db + "`.`" + tblInfo.Name.O + "`"