squelette Historic

Projet_POO/src/bdd/GestionnaireHistorique.java

@@ -3,6 +3,7 @@ package bdd;
 import java.net.InetAddress;
 import java.sql.Connection;
 import java.sql.PreparedStatement;
+import java.sql.Statement;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 
@@ -35,37 +36,40 @@ public class GestionnaireHistorique {
 	
 	public void recuperer(String id1, String id2) {
 
-		PreparedStatement st;
-		ResultSet rs;
-		System.out.println("iciiiiiiiiiiiiiiiiiiiiiiiiiiiiiiiii");
-		String query = 
-				  "IF object_id( ?, U) is null"
-				+ 	"CREATE TABLE ?(id1 VARCHAR(50) NOT NULL, id VARCHAR(50) NOT NULL, id INT NOT NULL AUTO_INCREMENT, expediteur VARCHAR(50), msg VARCHAR(max) )"
-				+ 	"SELECT * FROM ?"
-				+ "ELSE"
-				+ 	"SELECT * FROM ?";
-
+		Statement st;
+		int rs1;
+		ResultSet rs2;
+		
+		String query1 = 
+				  "CREATE TABLE IF NOT EXISTS " + (id1+id2)
+				+ "(id INT NOT NULL AUTO_INCREMENT,"
+				+ "expediteur VARCHAR(50),"
+				+ "msg VARCHAR(70),"
+				+ "PRIMARY KEY (id) );";
+		
+		String query2 = "SELECT * FROM " + (id1+id2) 
+				      + " ORDRE BY id;";
+		
 		try {
 			Connection con = Liaison.getConnection();
 
-			st = con.prepareStatement(query);
+			st = con.createStatement();
 
-			if(id1.compareTo(id2) >= 0) {
-				st.setString(1, id1+id2);
-			}
-			else {
-				st.setString(1, id2+id1);
-			}
-
-			rs = st.executeQuery();
-
-			while(rs.next()) {
-				System.out.println("BDD SUCCESS");
-				//System.out.println(rs);
-			}
+			rs1 = st.executeUpdate(query1);
+			rs2 = st.executeQuery(query2);
 			
 			
 			
+			while(rs2.next()) {
+				System.out.println("Historic SUCCESS");
+				System.out.println(rs2.getString(2)); //indice commence à 1
+			}
+			
+			// à mettre dans un finally
+			rs2.close();
+			st.close();
+			con.close();
+			
 		} catch (SQLException e) {
 			System.out.println("Erreur : Historic BDD");
 			e.printStackTrace();
@@ -74,4 +78,31 @@ public class GestionnaireHistorique {
 		
 	}
 
+	
+	
+	public void ajouter(String idCombine, String expediteur, String msg) {
+		Statement st;
+		int rs;
+		
+		String query = "INSERT INTO " + idCombine 
+				      + "(expediteur, msg) VALUES (" + expediteur + ", " + msg + ");";
+		
+		try {
+			Connection con = Liaison.getConnection();
+
+			st = con.createStatement();
+			rs = st.executeUpdate(query);
+			
+			
+			
+			// à mettre dans un finally
+			st.close();
+			con.close();
+			
+		} catch (SQLException e) {
+			System.out.println("Erreur : Historic BDD");
+			e.printStackTrace();
+		}
+		
+	}
 }

Projet_POO/src/defaut/Main.java

@@ -10,7 +10,7 @@ public class Main {
 	
 	public static void main(String[] args) {
 		
-		GestionnaireHistorique.instance().recuperer("", "user");
+		//GestionnaireHistorique.instance().recuperer("z", "user");
 		//on lance le server d'écoute de cmd
 		GestionnaireListeUtilisateur.instance().ecoute2(2002); //enlever le 2, debug //TODO   PORT = 2001 à 2009
 		

Projet_POO/src/ui/Login_RegisterUI.java

@@ -280,6 +280,10 @@ public class Login_RegisterUI extends JFrame implements Runnable{
 				passwordField.setText("");
 			}
 			
+			// à mettre dans un finally
+			rs.close();
+			st.close();
+			con.close();
 			
 		} catch (SQLException e) {
 			System.out.println("Erreur : BDD");