foo.go

func restoreDump(conn mysqlConnection) {
	log.Print("Restoring dump")
	// Collect the output from the command(s)
	var output bytes.Buffer
	var stderr bytes.Buffer

	bzcat := exec.Command("/bin/bzcat", "/tmp/location")
	bzcat.Stderr = &stderr

	cmdString := mysqlCommand(conn, []string{"cms"})
	mysql := exec.Command(cmdString[0], cmdString[1:]...)

	var err error
	mysql.Stdin, err = bzcat.StdoutPipe()
	if err != nil {
		log.Fatal(err)
	}

	mysql.Stdout, mysql.Stderr = &output, &stderr

	log.Print("Starting bzcat")
	err = bzcat.Start()
	if err != nil {
		log.Fatal(output.String(), stderr.String(), err)
	}

	log.Print("Starting mysql")
	err = mysql.Start()
	if err != nil {
		log.Fatal(output.String(), stderr.String(), err)
	}

	log.Print("Waiting for bzcat")
	err = bzcat.Wait()
	if err != nil {
		log.Fatal(output.String(), stderr.String(), err)
	}

	log.Print("Waiting for mysql")
	err = mysql.Wait()
	if err != nil {
		log.Fatal(output.String(), stderr.String(), err)
	}
}