package exem;


// librairie pour utiliser les classes pour la base de données
import java.sql.*;

public class Exemple
{
        public static void main(String argv[])
        {
                BaseDeDonnee basededonnee = new BaseDeDonnee();
        }
}

class BaseDeDonnee
{
        Connection connection = null;

        public BaseDeDonnee()
        {
                connexion();
                affichage();
        }

        // Connexion à la base de donnees
        public void connexion ()
        {
                try
        {
                        // Chargement des drivers SQL
                        Class.forName ("org.gjt.mm.mysql.Driver").newInstance();
                }
                catch (ClassNotFoundException a)
                {
                        System.out.println ("Driver non trouve");
                }
                catch (Exception b)
                {     
                        System.out.println ("Problème sur chargement de driver JDBC");     
                }

                try
        {              
                        // Etablissement de la connexion avec la base
                        connection = DriverManager.getConnection ("jdbc:mysql://localhost/Table/", "root", "");
                }
                catch (SQLException c)
                {       
                        System.out.println ("Connexion refuse ou base inconnu");
                }
                catch (Exception d)
                {
                        System.out.println ("Problème sur connexion");   
                }
        }
        public void affichage()
        {
                ResultSet rs   = null;

                try
                {
                        // Exécution des requêtes
                        Statement stmt = connection.createStatement();
                        String requete = null;

                        requete = "SELECT Nom, Prenom, Adresse From personne";

                        rs = stmt.executeQuery(requete);

                        System.out.println("");

                        while (rs.next())
                        {
                                // Affichage les resultats de la requete SQL
                                System.out.println("Nom : "+rs.getString(1));
                                System.out.println("Prenom : "+rs.getString(2));
                                System.out.println("Adresse : "+rs.getString(3));
                                System.out.println("");
                        }
                }
                catch (Exception d)
                {
                        System.out.println ("Problème la requete");          
                }
        }
        public void fin_connexion()
        {
                try
                {
                        // Fermeture de la connexion
                        connection.close();
                }
                catch (Exception d)
                {
                        System.out.println ("Problème sur la fermeture de connexion"); 
                }
        }
}

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 {
        private String serveur;
        private String user;
        private String mdp;
        private String base;
        private boolean ok;
        private Connection conn;
        private Statement st;
       
        //1: remplit de vide le tout
        //2: on indique que les paramètres ne sont pas initialiser
        public DataBaseImpl() {
                this.serveur = "";
                this.user = "";
                this.base = "";
                this.mdp = "";
                this.ok = false;
        }
       
        //1: vérifie que les paramètres sont initialiser
        //2: définit l'url en fonction des paramètres
        //3 on ouvre la connection et on renvoie les exceptions si il y en a
        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());
                }
               
        }
       
        //1: vérifie que les paramètres sont initialiser
        //2: ferme la connection ou renvoie une exception
        public void close() throws DataBaseException {
                //1
                if(!ok)
                        throw new DataBaseException("paramètre non initialiser");
               
                //2
                try {
                        conn.close();
                }
                catch(SQLException e) {
                        throw new DataBaseException(e);
                }
        }
       
        //1: vérifie que les paramètres sont initialiser
        //2: vérifie que la requete n'est pas nulle
        //3: on exécute la requete et on renvoie une exception si il y a eu un problème
        public ResultSet query(String requete) throws DataBaseException {
                //1
                if(!ok)
                        throw new DataBaseException("paramètre non initialiser");
               
                //2
                if(requete == null)
                        return null;
                //3
                try {
                        return (ResultSet) st.executeQuery(requete);
                }
                catch(SQLException e) {
                        throw new DataBaseException(e);
                }
               
               
        }
       
        //1: définir les paramètres
        //2: signaler que les paramètres sont initialiser
        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;
               
        }
       
        /**
         * exécute une requete sql qui ne demande pas de retour de résultat
         * @param requete la requete à exécuter non null et en conformité avec la syntaxe sql
         * @throws SQLException
         */
        public void execute(String requete) throws DataBaseException {
                //test des variable
                if(requete == null)
                        return;
                try {
                        st.execute(requete);
                }
                catch(SQLException e) {
                        throw new DataBaseException(e);
                }
        }
}