import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

import com.mysql.jdbc.ResultSet;
import com.mysql.jdbc.Statement;

/**
 * implémentation finie
 * @author mythrys
 *
 */
public class DataBaseImpl implements DataBase {
        private String serveur;
        private String user;
        private String mdp;
        private String base;
        private boolean ok;
        private Connection conn;
        private Statement st;
       
       
        public DataBaseImpl() {
                this.serveur = "";
                this.user = "";
                this.base = "";
                this.mdp = "";
                this.ok = false;
        }
       
        /**
         * ouvre une connection avec le serveur mysql
         * @throws DataBaseException
         *
         */
        public void open() throws DataBaseException {
                //1
                if(!ok)
                        throw new DataBaseException("paramètre non initialiser");
               
                //2
                String url = "jdbc:mysql://" + serveur + "/" + base + "?user=" + user + "&password=" + mdp;
                //3
                try {
                        Class.forName("com.mysql.jdbc.Driver").newInstance();
                        conn = DriverManager.getConnection(url);
                        st = (Statement) conn.createStatement();
                }       
                catch(SQLException e) {
                        throw new DataBaseException(e);
                }
                catch(InstantiationException e) {
                        e.printStackTrace(System.err);
                        throw new DataBaseException(e.getMessage());
                       
                }
                catch(IllegalAccessException e) {
                        e.printStackTrace(System.err);
                        throw new DataBaseException(e.getMessage());
                }
                catch(ClassNotFoundException e) {
                        e.printStackTrace(System.err);
                        throw new DataBaseException(e.getMessage());
                }
               
        }
       
        /**
         * ferme la connection à la base de donnée
         * @throws DataBaseException
         */
        public void close() throws DataBaseException {
               
                if(!ok)
                        throw new DataBaseException("paramètre non initialiser");
               
               
                try {
                        conn.close();
                }
                catch(SQLException e) {
                        throw new DataBaseException(e);
                }
        }
       
        /**
         * exécute une requete et renvoie les résulats, si il n'y a pas de résultat
         *  alors la fonction renvoie null
         * @param requete la requete a executé, non null et en conformité
         * avec la syntaxe sql, sinon la fonction return null
         * @return les résultats de la requete
         * @throws DataBaseException
         */
        public ResultSet query(String requete) throws DataBaseException {
               
                if(!ok)
                        throw new DataBaseException("paramètre non initialiser");
               
               
                if(requete == null)
                        return null;
               
                try {
                        return (ResultSet) st.executeQuery(requete);
                }
                catch(SQLException e) {
                        throw new DataBaseException(e);
                }
               
               
        }
       
        /**
         * définit les paramètres du serveur mysql
         * @param serveur le nom du serveur
         * @param user le nom de l'utilisateur de mysql
         * @param mdp le mot de passe de l'utilisateur
         * @param base le nom de la base de donnée ou seront stocké les tables mysql
         *
         */
        public void setParametre(String serveur, String user, String mdp, String base) {
                //1
                this.serveur = serveur;
                this.user = user;
                this.base = base;
                this.mdp = mdp;
                //2
                this.ok = true;
               
        }
}

import java.sql.SQLException;

/**
 * implémentation terminée
 * @author mythrys
 *
 */
public class DataBaseException extends Exception {
       
       
       
        private SQLException exc;
        private String message;
       
        public DataBaseException(SQLException e) {
                exc = e;
                message = "SQLException: " + exc.getMessage() + "\n" +
                                  "SQLState: " + exc.getSQLState() + "\n" +
                                  "VendorError: " + exc.getErrorCode();
        }
       
       
        public DataBaseException(String message) {
                this.message = message;
        }
       
       
        /**
         * renvoie le message complet des erreur sql
         * @return renvoie le message complet des erreur sql
         */
        public String getMess() {              
                return message;
        }
       
        /**
         * ecrit les erreurs
         *
         */
        public void PrintException() {
                System.err.println(message);
        }
}