worked on dbcontroller part 2

fixed a few bugs but still a lot to do

src/application/DBController.java

@@ -1,7 +1,7 @@
 /**
  * DBController for Project HomeFlix
  * 
- * TODO fav and defav
+ * connection is in manual commit!
  */
 
 package application;
@@ -24,56 +24,43 @@ import java.io.IOException;
 
 public class DBController {
 
-	public DBController(MainWindowController m){
+	public DBController(MainWindowController m) {
-		mainWindowController=m;
+		mainWindowController = m;
 	}
 
 	private MainWindowController mainWindowController;
 	private String DB_PATH = System.getProperty("user.home") + "\\Documents\\HomeFlix" + "\\" + "Homeflix.db"; // der Pfad der Datenbank-Datei
 	Connection connection = null;
 
-	public void main() 
+	public void main() {
-    {
+		try {
-		
-		System.out.println("Hallo");
-		
-      try
-      {
 			// create a database connection
-        connection = DriverManager.getConnection("jdbc:sqlite:"+DB_PATH);
+			connection = DriverManager.getConnection("jdbc:sqlite:" + DB_PATH);
-//        Statement statement = connection.createStatement();
+			// Statement statement = connection.createStatement();
-//        statement.setQueryTimeout(30);  // set timeout to 30 sec. TODO don't know wath to do with this
+			// statement.setQueryTimeout(30); // set timeout to 30 sec. TODO don't know wath to do with this
-
-
 
+			connection.setAutoCommit(false);	//Autocommit to false -> manual commit is active!
 			fuelleDatenbank();
 //			ausgeben();
-       getFavStatus("House of Cards");
+//			getFavStatus("House of Cards");
-       favorisieren("House of Cards");
+//			favorisieren("House of Cards");
-       getFavStatus("House of Cards");
+//			getFavStatus("House of Cards");
-       defavorisieren("House of Cards");
+//			defavorisieren("House of Cards");
-       getFavStatus("House of Cards");
+//			getFavStatus("House of Cards");
 
-      }
+		} catch (SQLException e) {
-      catch(SQLException e)
+			// if the error message is "out of memory", it probably means no database file is found
-      {
-        // if the error message is "out of memory", 
-        // it probably means no database file is found
 			System.err.println(e.getMessage());
 		}
-      finally
+//		finally {
-      {
+//			try {
-        try
+//				if (connection != null)
-        {
+//					connection.close();
-          if(connection != null)
+//			} catch (SQLException e) {
-            connection.close();
+//				// connection close failed.
-        }
+//				System.err.println(e);
-        catch(SQLException e)
+//			}
-        {
+//		}
-          // connection close failed.
-          System.err.println(e);
-        }
-      }
 	}
 	
 	public void fuelleDatenbank() { 
@@ -92,7 +79,6 @@ public class DBController {
 			PreparedStatement psS = connection.prepareStatement("insert into film_streaming values (?, ?, ?, ?, ?, ?, ?)"); // SQL Befehl
 
 			String[] entries = new File(mainWindowController.getPath()).list();
-			System.out.println("Size: "+entries.length);
 
 			for(int i=0;i!=entries.length;i++) // Geht alle Dateien im Verzeichniss durch
 			{
@@ -104,9 +90,7 @@ public class DBController {
 			}
 			
 			
-			System.out.println("Erstelle Einträge streaming");
+			System.out.println("Erstelle Einträge streaming \n");
-
-			System.out.println(mainWindowController.getStreamingPath());
 			if(mainWindowController.getStreamingPath().equals("")||mainWindowController.getStreamingPath().equals(null)){
 				System.out.println("Kein Pfad angegeben");	//falls der Pfad null oder "" ist
 			}else{
@@ -131,16 +115,16 @@ public class DBController {
 				}
 			}
 			}
-			connection.setAutoCommit(false); 
+//			connection.setAutoCommit(false); 
 			ps.executeBatch();  // scheibt alle Einträge in die Datenbank
 			psS.executeBatch();			
-			connection.setAutoCommit(true);
+			connection.commit();
 			ps.close();
 			psS.close();
 			//connection.close(); 
-		} catch (SQLException e) { 
+		} catch (SQLException ea) { 
 			System.err.println("Konnte nicht ausgeführt werden"); 
-			e.printStackTrace(); 
+			ea.printStackTrace(); 
 		} 
 	}
 	
@@ -200,8 +184,11 @@ public class DBController {
 		try{
 			Statement stmt = connection.createStatement(); 
 			stmt.executeUpdate("UPDATE film_local SET rating=0 WHERE titel='"+name+"';");
-			connection.commit();	//TODO hier kommt es zu fehlern mit dem autocommit
+			connection.commit();
 		}catch(SQLException e){
+			System.out.println("Ups! an error occured!");
+			e.printStackTrace();
+		}
 		try {
 			Statement stmtS = connection.createStatement(); 
 			stmtS.executeUpdate("UPDATE film_streaming SET rating=0 WHERE titel='"+name+"';");
@@ -211,15 +198,17 @@ public class DBController {
 			e1.printStackTrace();
 		}
 	}
-	}
 //setzt die Favorisierung eines bestimmten Films
 	public void favorisieren(String name){
 		System.out.println("favorisieren ...");
 		try{
 			Statement stmt = connection.createStatement(); 
 			stmt.executeUpdate("UPDATE film_local SET rating=1 WHERE titel='"+name+"';");
-			connection.commit();	//TODO hier kommt es zu fehlern mit dem autocommit
+			connection.commit();
 		}catch(SQLException e){
+			System.out.println("Ups! an error occured!");
+			e.printStackTrace();
+		}
 		try {
 			Statement stmtS = connection.createStatement(); 
 			stmtS.executeUpdate("UPDATE film_streaming SET rating=1 WHERE titel='"+name+"';");
@@ -229,7 +218,6 @@ public class DBController {
 			e1.printStackTrace();
 		}
 	}
-	}
 	
 //entfernt die Endung
 	private String ohneEndung (String str) {

src/application/MainWindowController.java

@@ -425,7 +425,12 @@ public class MainWindowController {
 	
 	@FXML
 	private void debugBtnclicked(){
-		dbController.main();
+		dbController.main();	//TODO das muss vor einen anderen Befehl warum auch immer
+		dbController.getFavStatus("House of Cards");
+		dbController.favorisieren("House of Cards");
+		dbController.getFavStatus("House of Cards");
+//		dbController.defavorisieren("House of Cards");
+//		dbController.getFavStatus("House of Cards");
 		//for testing
 	}
 
@@ -514,7 +519,7 @@ public class MainWindowController {
 		
 		System.out.println("Mode: "+mode);
 		
-//		dbController.ausgeben();
+//		dbController.main();
 		
 		debugBtn.setDisable(false); 	//debugging btn for tests
 		debugBtn.setVisible(true);