test: now that we are running multiple keyspaces, specify it in the o…

…nlineddl queries to see the status

Signed-off-by: Manan Gupta <manan@planetscale.com>

go/test/endtoend/onlineddl/vtgate_util.go

@@ -257,7 +257,8 @@ func CheckForceMigrationCutOver(t *testing.T, vtParams *mysql.ConnParams, shards
 
 // CheckMigrationStatus verifies that the migration indicated by given UUID has the given expected status
 func CheckMigrationStatus(t *testing.T, vtParams *mysql.ConnParams, shards []cluster.Shard, uuid string, expectStatuses ...schema.OnlineDDLStatus) bool {
- query, err := sqlparser.ParseAndBind("show vitess_migrations like %a",
+ ksName := shards[0].PrimaryTablet().VttabletProcess.Keyspace
+ query, err := sqlparser.ParseAndBind(fmt.Sprintf("show vitess_migrations from %s like %%a", ksName),
  sqltypes.StringBindVariable(uuid),
  )
  require.NoError(t, err)

go/test/endtoend/transaction/twopc/stress/stress_test.go

@@ -338,7 +338,7 @@ func waitForMigrationStatus(t *testing.T, vtParams *mysql.ConnParams, shards []c
  for _, shard := range shards {
  shardNames[shard.Name] = true
  }
- query := fmt.Sprintf("show vitess_migrations like '%s'", uuid)
+ query := fmt.Sprintf("show vitess_migrations from %s like '%s'", keyspaceName, uuid)
 
  statusesMap := map[string]bool{}
  for _, status := range expectStatuses {