A couple endtoend cluster tests enhancement (#17247)

Signed-off-by: Shlomi Noach <[email protected]>

go/test/endtoend/cluster/vtctldclient_process.go

@@ -41,6 +41,7 @@ type VtctldClientProcess struct {
 	TempDirectory            string
 	ZoneName                 string
 	VtctldClientMajorVersion int
+	Quiet                    bool
 }
 
 // ExecuteCommand executes any vtctldclient command
@@ -72,7 +73,9 @@ func (vtctldclient *VtctldClientProcess) ExecuteCommandWithOutput(args ...string
 			filterDoubleDashArgs(pArgs, vtctldclient.VtctldClientMajorVersion)...,
 		)
 		msg := binlogplayer.LimitString(strings.Join(tmpProcess.Args, " "), 256) // limit log line length
-		log.Infof("Executing vtctldclient with command: %v (attempt %d of %d)", msg, i+1, retries)
+		if !vtctldclient.Quiet {
+			log.Infof("Executing vtctldclient with command: %v (attempt %d of %d)", msg, i+1, retries)
+		}
 		resultByte, err = tmpProcess.CombinedOutput()
 		resultStr = string(resultByte)
 		if err == nil || !shouldRetry(resultStr) {

go/test/endtoend/cluster/vttablet_process.go

@@ -459,6 +459,16 @@ func (vttablet *VttabletProcess) QueryTablet(query string, keyspace string, useD
 	return executeQuery(conn, query)
 }
 
+// MultiQueryTablet lets you execute a query in this tablet and get the result
+func (vttablet *VttabletProcess) MultiQueryTablet(sql string, keyspace string, useDb bool) error {
+	conn, err := vttablet.TabletConn(keyspace, useDb)
+	if err != nil {
+		return err
+	}
+	defer conn.Close()
+	return executeMultiQuery(conn, sql)
+}
+
 // SemiSyncExtensionLoaded returns what type of semi-sync extension is loaded
 func (vttablet *VttabletProcess) SemiSyncExtensionLoaded() (mysql.SemiSyncType, error) {
 	conn, err := vttablet.TabletConn("", false)