Add ability to select from vreplication_log in VReplicationExec

Signed-off-by: Rohit Nayak <[email protected]>
vitessio · Apr 27, 2021 · f57350c · f57350c
1 parent 427cac8
commit f57350c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/go/vt/vttablet/tabletmanager/vreplication/controller_plan.go b/go/vt/vttablet/tabletmanager/vreplication/controller_plan.go
@@ -222,7 +222,7 @@ func buildDeletePlan(del *sqlparser.Delete) (*controllerPlan, error) {
 
 func buildSelectPlan(sel *sqlparser.Select) (*controllerPlan, error) {
 	switch sqlparser.String(sel.From) {
-	case vreplicationTableName, reshardingJournalTableName, copyStateTableName:
+	case vreplicationTableName, reshardingJournalTableName, copyStateTableName, vreplicationLogTableName:
 		return &controllerPlan{
 			opcode: selectQuery,
 		}, nil

diff --git a/go/vt/vttablet/tabletmanager/vreplication/utils.go b/go/vt/vttablet/tabletmanager/vreplication/utils.go
@@ -26,7 +26,8 @@ import (
 )
 
 const (
-	createVReplicationLog = `CREATE TABLE IF NOT EXISTS _vt.vreplication_log (
+	vreplicationLogTableName = "_vt.vreplication_log"
+	createVReplicationLog    = `CREATE TABLE IF NOT EXISTS _vt.vreplication_log (
 		id BIGINT(20) AUTO_INCREMENT,
 		vrepl_id INT NOT NULL,
 		type VARBINARY(256) NOT NULL,