Gestion d'une Requête SQL grâce à JCBD

Gestion d'une Requête SQL grâce à JCBD - Java - Programmation

Marsh Posté le 24-01-2012 à 21:08:55    

Bonsoir à tous,
 
Pour ce premier post, je me permets de vous demander votre aide afin de réaliser une fonction dont je galère a réaliser depuis plus d'une semaine.
Je vous explique le contexte : Je dois réaliser un jeu de questions / réponses. Pour cela j'ai crée une base de données. J'ai donc créer une classe BaseDeDonnées qui a pour but de gérer les échanges entre mon application et ma base de données. La fonction en question doit permettre de mettre dans un vecteur de tableaux de strings (Vector<String[]> ) toutes les questions de la base ainsi que ses 4 réponses possibles, son thème et la bonne réponse. En effet le schéma (attributs) de la table Questions est le suivant : Intitulé Question, Thème, Bonne Réponse, Réponse 1, Réponse 2, Réponse 3 & Réponse 4.
 
Or je suis bloqué et je ne sais plus du tout comment m'y prendre. Je vous remercie par avance de votre aide :-)
 

Code :
  1. import java.sql.*;
  2. import java.util.Vector;
  6. public class BaseDeDonnees {
  8.     // import des variables pour la base de donnees postgres
  9.  private Connection connection_base = null;
  10.  private static ResultSet table_questions = null;
  11.  private Statement        sql;       // Our statement to run queries with
  12.  private DatabaseMetaData dbmd;
  14.   public BaseDeDonnees() throws SQLException {
  16.   // chargement du pilote
  17.      try {
  18.       Class.forName("org.postgresql.Driver" );
  19.      } catch (ClassNotFoundException e) {
  20.         arret("Impossible de charger le pilote jdbc:odbc" );
  21.      }
  22.    
  23.      //connection a la base de données
  24.      affiche("Connexion à  la base de données en cours..." );
  25.      try {
  26.         String DBurl = "jdbc:postgresql://postgres-info/bdbaret";
  27.         connection_base = DriverManager.getConnection(DBurl, "userbaret", "pbaret" );
  28.      } catch (Exception e) {
  29.         arret("Connection à  la base de données impossible" );
  30.      }
  31.    
  32.      dbmd = connection_base.getMetaData();
  33.      sql = connection_base.createStatement();
  34.    
  35.    //creation et execution de la requete
  36.      affiche("Création et execution de la requête" );
  37.      String requete = "SELECT * FROM Question";
  38.      try {
  39.      table_questions = sql.executeQuery(requete);
  40.      } catch (SQLException e) {
  41.      arret("Anomalie lors de l'execution de la requête" );
  42.      }
  43.    
  44. }
  46.   private static void affiche(String message) {
  47.       System.out.println(message);
  48.    }
  49.    private static void arret(String message) {
  50.       System.err.println(message);
  51.       System.exit(99);
  52.    }
  54.    public Vector<String[]> getListeQuestions() throws SQLException {
  55.     ResultSetMetaData rsmd = table_questions.getMetaData();
  56.        int nbCols = rsmd.getColumnCount();
  57.        Vector<String[]> Vecteur = new Vector<String[]>();
  58.        String Tableau [] = new String[6];
  59.        while(table_questions.next()) {
  60.         for (int i = 1; i <= nbCols; i++) {
  61.          Tableau[i-1] = table_questions.getString(i).toString();
  62.         }
  63.         Vecteur.add(Tableau);
  64.        }
  65.        return Vecteur;
  66.    }
  68. }


Message édité par Sylvain38220 le 24-01-2012 à 21:14:12
Reply

Marsh Posté le 24-01-2012 à 21:08:55   

Reply

Marsh Posté le 26-01-2012 à 23:24:57    

Salut Sylvain38220,
 
Tu ne décris pas très bien ton problème mais en regardant ton code on peut essayer de deviner pourquoi tu n'arrives pas à l'expliquer. Le principal problème de ta classe est que tu absorbes les exceptions qui pourtant pourraient te donner pas mal d'informations sur la cause du dysfonctionnement. Au lieu de faire :

Code :
  1. try {
  2.    String DBurl = "jdbc:postgresql://postgres-info/bdbaret";
  3.    connection_base = DriverManager.getConnection(DBurl, "userbaret", "******" );
  4. } catch (Exception e) {
  5.    arret("Connection à  la base de données impossible" );
  6. }


Je te suggères plutôt de faire :

Code :
  1. String DBurl = "jdbc:postgresql://postgres-info/bdbaret";
  2. try {
  3.    connection_base = DriverManager.getConnection(DBurl, "userbaret", "******" );
  4. } catch (SQLException e) {
  5.    System.err.println("Connexion à la base de données impossible" );
  6.    throw e;
  7. }


Si DriverManager lance une exception SQLException elle doit contenir au moins un message d'erreur qui pourrait te permettre de diagnostiquer le souci. Tu peux très bien afficher le message d'erreur de ton choix sur la sortie d'erreur mais il faut absolument re-throw l'exception afin que l'appelant en sache davantage.
 
Je vois pas mal d'autres problèmes dans ton code. Par exemple :

  • le membre table_questions est static : il n'a aucune raison de l'être et c'est même plutôt dangereux si on instance deux fois ta classe
  • le membre dbmd est instancié dans le constructeur mais tu ne l'utilises jamais : tu peux supprimer cette déclaration
  • la méthode statique affiche() est un renommage de System.out.println() (elle ne fait que ça) : le plus simple est de supprimer cette méthode et de remplacer chacun de ses appels par System.out.println(). En terme de refactoring on appelle cela l'inlining
  • ne jamais appeler System.exit() : on ne termine jamais un processus violemment comme ça (surtout vu ce que tu fais des connexions ouvertes vers ta base - j'en reparle plus bas).
  • une fois que tu as récupéré les données de chacune des lignes de ta requête tu ne nettoies rien : tu restes connecté à la base de données et ton ResultSet reste navigable. Si ta classe est instanciée très souvent, elle va finir par épuiser le stock de thread de connexions que ta base a alloué et finalement le programme Java va être bloqué. Pour clôturer proprement les ressources JDBC, il faut utiliser le mot clé finally de Java. Regarde ma proposition de solution plus bas pour voir comment ça peut fonctionner.
  • le mot de passe d'accès à ta base de données en clair dans le forum ce n'est pas très prudent : je te suggère de le supprimer dans ton post.


Si on se détache un peu de ton code : pour que les gens aient envie de t'aider, il faut que tu leur donnes plus d'informations sur l'erreur que tu rencontres. Le schéma de ta base de données aurait été un plus pour débugger. Par exemple voici le schéma que j'ai utilisé pour faire fonctionner ta classe :

Code :
  1. create table Question (Intitulé_Question varchar, Thème varchar, Bonne_Réponse integer, Réponse_1 varchar, Réponse_2 varchar, Réponse_3 varchar, Réponse_4 varchar);
  2. insert into Question values ('Quel président sera élu en 2012 ?', 'Politique', 4, 'Nicolas Sarkozy', 'François Hollande', 'Marine Le Pen', 'Obiwan Kenobi');


 
Proposition de solution :

Code :
  1. import java.sql.Connection;
  2. import java.sql.DriverManager;
  3. import java.sql.ResultSet;
  4. import java.sql.ResultSetMetaData;
  5. import java.sql.SQLException;
  6. import java.sql.Statement;
  7. import java.util.Vector;
  9. public class BaseDeDonneesOk {
  11.     private final Connection connexion_base;
  12.     private final Statement sql;
  13.     private final ResultSet table_questions;
  15.     public BaseDeDonneesOk() throws Exception {
  17.         // chargement du pilote
  18.         try {
  19.             Class.forName("org.postgresql.Driver" );
  20.         } catch (ClassNotFoundException e) {
  21.             System.err.println("Impossible de charger le pilote jdbc:odbc" );
  22.             throw e;
  23.         }
  25.         // connexion à la base de données
  26.         System.out.println("Connexion à la base de données en cours..." );
  27.         try {
  28.             connexion_base = DriverManager.getConnection("jdbc:postgresql://postgres-info/bdbaret", "userbaret", "******" );
  29.         } catch (SQLException e) {
  30.             System.err.println("Connexion à la base de données impossible" );
  31.             close();
  32.             throw e;
  33.         }
  35.         // création et exécution de la requete
  36.         System.out.println("Création et execution de la requête" );
  37.         String requete = "SELECT * FROM Question";
  38.         try {
  39.             sql = connexion_base.createStatement();
  40.             table_questions = sql.executeQuery(requete);
  41.         } catch (SQLException e) {
  42.             System.err.println("Anomalie lors de l'execution de la requête" );
  43.             close();
  44.             throw e;
  45.         }
  47.     }
  49.     public Vector<String[]> getListeQuestions() throws SQLException {
  50.         try {
  51.             ResultSetMetaData rsmd = table_questions.getMetaData();
  52.             int nbCols = rsmd.getColumnCount();
  53.             Vector<String[]> Vecteur = new Vector<String[]>();
  54.             String Tableau[] = new String[nbCols];
  55.             while (table_questions.next()) {
  56.                 for (int i = 0; i < nbCols; i++) {
  57.                     Tableau[i] = table_questions.getString(i + 1).toString();
  58.                 }
  59.                 Vecteur.add(Tableau);
  60.             }
  61.             return Vecteur;
  62.         } finally {
  63.             close();
  64.         }
  65.     }
  66.    
  67.     private void close() {
  68.         if (table_questions != null) {
  69.             try {
  70.                 table_questions.close();
  71.             } catch (SQLException e) {
  72.                 System.err.println(e.getMessage());
  73.             }
  74.         }
  75.         if (sql != null) {
  76.             try {
  77.                 sql.close();
  78.             } catch (SQLException e) {
  79.                 System.err.println(e.getMessage());
  80.             }
  81.         }
  82.         if (connexion_base != null) {
  83.             try {
  84.                 connexion_base.close();
  85.             } catch (SQLException e) {
  86.                 System.err.println(e.getMessage());
  87.             }
  88.         }
  89.     }
  91.     public static void main(final String[] args) throws Exception {
  92.         final BaseDeDonneesOk bd = new BaseDeDonneesOk();
  93.         for (final String[] donneesQuestion : bd.getListeQuestions()) {
  94.             final StringBuilder question = new StringBuilder();
  95.             question.append(donneesQuestion[1]).append(" : " ).append(donneesQuestion[0]).append('\n');
  96.             for (int i = 1; i <= 4; i++) {
  97.                 question.append(Integer.toString(i).equals(donneesQuestion[2])?'*':' ');
  98.                 question.append(' ').append(i).append(" - " ).append(donneesQuestion[i + 2]).append('\n');
  99.             }
  100.             question.append('\n');
  101.             System.out.println(question);
  102.         }
  103.         bd.close();
  104.     }
  106. }

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed