test

media.class.php

@@ -237,25 +237,56 @@ class Media {
 	}
 	private function addMovie($DataArr){
 		$mysqli = new mysqli($this->config["DB_Server"],$this->config["DB_Username"],$this->config["DB_Passwort"],$this->config["DB_Database"]);
-		if($mysqli->error != ""){		return "Mysql-Fehler: ".$mysqli->error.PHP_EOL;}
+		if($mysqli->error != ""){		echo "Mysql-Fehler: ".$mysqli->error.PHP_EOL; return false;}
 		//$ret->num_rows
+		$Querys= array();
 		foreach ($DataArr as $key => $value) {
 			if(in_array($key, array("Genre", "Schauspieler")) ){//TODO hier weiter!!
 				//echo " ".$key." => '".implode("|", )."'".PHP_EOL;
 				var_dump($value);
+				if ($key == "Genre"){
+					$genreArr = explode(" / ", $value);
+					foreach ($genreArr as $value) {
+						
+						$Querys[] =  'INSERT INTO FilmGenre ('.$DataArr['imdbID'].','.getGenreID($mysqli, $value).')';
+						
+					}
+				}
+				else if ($key == "Schauspieler"){
+					$Schauspielers = explode(" / ", $value);
+					foreach ($genreArr as $value) {
+						$Schauspieler = explode(">", str_replace("nm", "", $value));
+						$Querys[] =  'INSERT INTO FilmSchauspieler ('.$DataArr['imdbID'].','.getSchauspielerID($mysqli, $Schauspieler[1],$Schauspieler[0]).')';
+						
+					}
+				}
 			}else{
 				echo " ".$key." => '".$value."'".PHP_EOL;
 			}
 		}
+		foreach ($Querys as $Query) {
+			echo $this->Console->getColoredString("Query", "light_gray", "green")." ".$Query;
+		}
 		
 		$mysqli->close();
 		return true;
 	}
 	private function getGenreID($mysqli, $GenreName){ //TODO hier weiter!!
+		$result = $mysqli->query("SELECT genreID FROM Genre WHERE engname = '".$GenreName."'");
+		if($result->num_rows>0){
+			$resultArr = $result->fetch_array();
+			return $resultArr["genreID"];
+		}
+		else{
+			$Query = "INSERT INTO Genre (engname) VALUES('".$GenreName."')";
+			echo $this->Console->getColoredString("Query", "light_gray", "green")." ".$Query;
+		}
 		
+		
+		//
 	}
-	private function getSchauspielerID($mysqli, $SchauspielerName){//TODO hier weiter!!
-	
+	private function getSchauspielerID($mysqli, $SchauspielerName, $SchauspielerID){//TODO hier weiter!!
+		return $SchauspielerID;
 	}
 	private function getRunTime($laufzeit){
 		$string = explode(" ", $laufzeit);