Finalisation du backup sql et telechargement

main.go

@@ -5,6 +5,8 @@ import (
 	"fmt"
 	"log"
 	"os"
+	"strings"
+
 	"time"
 
 	"canguidev.fr/pvnet/function"
@@ -14,43 +16,44 @@ import (
 	"github.com/pkg/sftp"
 )
 
-func main(){
+func main() {
 	//var path string="/Users/cangui/.ssh/julien_pvnet"
 	///Users/cangui/Documents/Dev peso/Golang dev/test.xlsx
 	err := godotenv.Load()
 	if err != nil {
-	  log.Fatal("Error loading .env file")
+		log.Fatal("Error loading .env file")
 	}
 
-    var pathSsh string = os.Getenv("PATH_SSH")
+	var pathSsh string = os.Getenv("PATH_SSH")
 	var pathConfigSsh = os.Getenv("PATH_SSH_CONF")
-	var pathExcel string= os.Getenv("PATH_FOLDER")
+	var pathExcel string = os.Getenv("PATH_FOLDER")
 	var mysqlUser string
 	var mysqlPswd string
 	var pathSaveSql string
+	var nameBase string
 
 	// Chargement de la liste des hosts du fichier config ssh
-	d:=simplyssh.GetHost(pathConfigSsh)
+	d := simplyssh.GetHost(pathConfigSsh)
 	var s []string
-		for _, host := range d {
+	for _, host := range d {
-			fmt.Println(host)
+		fmt.Println(host)
-			s=append(s,string(host.Id)+" "+host.Host)
+		s = append(s, string(host.Id)+" "+host.Host)
-		}
+	}
 	// selectionne du host
 	choice, index, err := gochoice.Pick(
 		"What do you want to do?\nPick:",
 		s,
 	)
-	selectHost:=choice
+	selectHost := choice
 	if err != nil {
-		fmt.Println("You didn't select anything!",err)
+		fmt.Println("You didn't select anything!", err)
 	} else {
 		for _, host := range d {
 			// for sur les hosts et break sur le host selectionner
-			if(host.Id == uint(index)){
+			if host.Id == uint(index) {
 				fmt.Println("debut de connection")
 				// connection en ssh avec la clée et les informations du fichier config
-				client:=simplyssh.Connect(pathSsh,host.HostName,host.Port,host.User)	
+				client := simplyssh.Connect(pathSsh, host.HostName, host.Port, host.User)
 				command := "mkdir backup"
 				defer client.Close()
 
@@ -66,101 +69,88 @@ func main(){
 				//exceution de la commande
 				if err := session.Run(command); err != nil {
 					fmt.Println("Dossier existe dejà")
-						// Fermez donc cette session
+					// Fermez donc cette session
-						session.Close()
+					session.Close()
 
-						// Créez une nouvelle session pour exécuter le backup
+					// Créez une nouvelle session pour exécuter le backup
-						sessionBackup, err := client.NewSession()
-						if err != nil {
-							log.Fatal("Failed to create session for backup: ", err)
-						}
-						defer sessionBackup.Close()
 
-						choice, index, err := gochoice.Pick(
+					_, index, err := gochoice.Pick(
-							"What do you want to do?\nPick:",
+						"What do you want to do?\nPick:",
-							[]string{
+						[]string{
-								"Backup sql and download",
+							"Backup sql and download",
-								"Backup site",
+							"Backup site",
-								"Check serveur apache",
+							"Check serveur apache",
-							},
+						},
-						)
+					)
-						if err != nil {
+					if err != nil {
-							fmt.Println("You didn't select anything!")
+						fmt.Println("You didn't select anything!")
-							return
+						return
-						}
+					}
-					
+					if index == 0 {
-						fmt.Println("Enter path download key: ") 
+						excel := function.ReadExcel(pathExcel)
-						fmt.Printf("You have selected: '%s', which is the index %d\n", choice, index)
+						// Parcourir les résultats d'Excel
-					
+						for _, value := range excel {
-						if (index == 0) {
+							sessionBackup, err := client.NewSession()
-						
+							if err != nil {
-							//var pathSaveSite string
+								log.Fatal("Failed to create session for backup: ", err)
-							orderedKeys := []string{"host","mysql_login", "mysql_pasw", "path_save_sql", "path_save_site"}
+							}
-
+							defer sessionBackup.Close()
-							excel:=function.ReadExcel(pathExcel)
+							fmt.Println("--------------------------")
-								key:="host"
+							for key, val := range value {
-								// Parcourir les résultats d'Excel
+								if strings.Compare(val, selectHost) == 1 {
-								for _, value := range excel {
+									switch key {
-									// Lire les clés dans l'ordre spécifié
+									case "path_save_sql":
-									for _, k := range orderedKeys {
+										pathSaveSql = val
-										if v, exists := value[k]; exists && k == key {
+									case "path_save_site":
-											fmt.Println("Key:", k, "Value:", v)
+										// pathSaveSite = v
-										if(k==selectHost){
+									case "mysql_login":
-											switch k {
+										mysqlUser = val
-											case "path_save_sql":
+									case "mysql_pasw":
-												pathSaveSql = v
+										mysqlPswd = val
-											case "path_save_site":
+									case "name_base":
-												// pathSaveSite = v
+										nameBase = val
-											case "mysql_login":
-												mysqlUser = v
-											case "mysql_pasw":
-												mysqlPswd = v
-											}
-										}
-											// Switch pour affecter les variables
-											
-										}
 									}
 								}
-							
+							}
+							fmt.Println("--------------------------")
 							fmt.Println("MySQL User:", mysqlUser)
 							fmt.Println("MySQL Password:", mysqlPswd)
 							fmt.Println("Path Save SQL:", pathSaveSql)
-							log.Fatal("stop julien")
+							fmt.Println("Name Base:", nameBase)
-
+							fmt.Println("--------------------------")
+							//log.Fatal("stop julien")
 							currentTime := time.Now()
 							formattedTime := currentTime.Format("20060102_150405")
 
-							filename := "backup/test_" + formattedTime + ".sql"
+							filename := "backup/" + nameBase + "_" + formattedTime + ".sql"
-							commandBackup := "mysqldump -u "+mysqlUser+" -p'"+mysqlPswd+"' test > " + filename
+							commandBackup := "mysqldump -u " + mysqlUser + " -p'" + mysqlPswd + "' " + nameBase + " > " + filename
 
 							// Maintenant on utilise la sessionBackup pour exécuter la commande du backup
 							if err := sessionBackup.Run(commandBackup); err != nil {
 								log.Fatal("Failed to run commandBackup: " + err.Error())
 							}
 							fmt.Println("backup ok")
-					
+							if client == nil {
+								log.Fatal("Client SSH non initialisé")
+							}
 							sftpClient, err := sftp.NewClient(client)
 							if err != nil {
 								log.Fatal("Erreur connection: ", err)
 							}
 							defer sftpClient.Close()
-					
-							var pathDownload string 
-							fmt.Scanln(&pathDownload) 
-							fmt.Println(filename)
 							currentTime2 := time.Now()
-							formattedTime2:= currentTime2.Format("20060102_150405")
+							formattedTime2 := currentTime2.Format("20060102_150405")
-					
+							filename2 := nameBase+"_" + formattedTime2 + ".sql"
-							filename2 := "test_" + formattedTime2 + ".sql"
 							err = simplyssh.DownloadFile(sftpClient, filename, pathSaveSql+filename2)
 							if err != nil {
 								log.Fatal("Erreur lors du téléchargement: ", err)
 							}
 							fmt.Println("Téléchargement terminé")
+
 						}
 
-					//log.Fatal("Failed to run: " + err.Error())
+					}
+
 				}
 				fmt.Println(b.String())