VReplication TableStreamer: Only stream tables in tablestreamer (igno…

…re views) (#14646)

Signed-off-by: Rohit Nayak <[email protected]>

go/test/endtoend/vreplication/fk_config_test.go

@@ -20,6 +20,7 @@ var (
 	initialFKSchema = `
 create table parent(id int, name varchar(128), primary key(id)) engine=innodb;
 create table child(id int, parent_id int, name varchar(128), primary key(id), foreign key(parent_id) references parent(id) on delete cascade) engine=innodb;
+create view vparent as select * from parent;
 `
 	initialFKData = `
 insert into parent values(1, 'parent1'), (2, 'parent2');

go/vt/vttablet/tabletserver/vstreamer/tablestreamer.go

@@ -23,12 +23,12 @@ import (
 	"strings"
 	"sync/atomic"
 
-	"vitess.io/vitess/go/vt/vttablet"
-
 	"vitess.io/vitess/go/sqlescape"
 	"vitess.io/vitess/go/sqltypes"
 	"vitess.io/vitess/go/vt/dbconfigs"
 	"vitess.io/vitess/go/vt/log"
+	"vitess.io/vitess/go/vt/mysqlctl/tmutils"
+	"vitess.io/vitess/go/vt/vttablet"
 	"vitess.io/vitess/go/vt/vttablet/tabletserver/schema"
 
 	binlogdatapb "vitess.io/vitess/go/vt/proto/binlogdata"
@@ -117,12 +117,16 @@ func (ts *tableStreamer) Stream() error {
 		return err
 	}
 
-	rs, err := conn.ExecuteFetch("show tables", -1, true)
+	rs, err := conn.ExecuteFetch("show full tables", -1, true)
 	if err != nil {
 		return err
 	}
 	for _, row := range rs.Rows {
 		tableName := row[0].ToString()
+		tableType := row[1].ToString()
+		if tableType != tmutils.TableBaseTable {
+			continue
+		}
 		if schema2.IsInternalOperationTableName(tableName) {
 			log.Infof("Skipping internal table %s", tableName)
 			continue