MANAGER JDBC : TOUT CE QU'IL FAUT POUR SE CONNECTER AUX BASES

import java.sql.*;
import javax.swing.*;

/* Classe DbManager
 * -> Controleur pour les opérations sur la base de donnée 
 * @author Duss
**/

public class DbManager 
{
	private Connection 		conn;
    	private Statement			stmt;
    	private PreparedStatement 	pStmt;
	private ResultSet 		rs;	
	private String 			pilote = "org.gjt.mm.mysql.Driver";
    	private String 			url = "jdbc:mysql://localhost/");
	
	// Méthode de connection à la base
	// Arguments : le nom de la base, le log, le pass
	public void connect(String dbName, String log, String pass)
	{    
        try
        { 
            url += dbName;
		Class.forName(pilote);
            conn = DriverManager.getConnection(url,log,pass);
            stmt = conn.createStatement();
        }
        catch ( SQLException E)
        {
            JOptionPane.showMessageDialog(null,"Erreur de connexion à la base. Veuillez contacter votre administrateur système","Connexion",JOptionPane.WARNING_MESSAGE);
        	System.out.println("1");
        }
        catch ( ClassNotFoundException E)
        {
            E.printStackTrace();
        }
	}
	
	// Méthode qui renvoit un ResultSet pour une requête
	// @args -> la requete
	public ResultSet getQuery(String query)
	{
		try 
		{
			rs = stmt.executeQuery(query);
		} 
		catch (SQLException E) 
		{
			JOptionPane.showMessageDialog(null,"Erreur de connexion à la base. Veuillez contacter votre administrateur système","Connexion",JOptionPane.WARNING_MESSAGE);
			System.out.println("2");
			System.out.println("SQLException: " + E.getMessage());
            System.out.println("SQLState:         " + E.getSQLState());
            System.out.println("VendorError:    " + E.getErrorCode());
		}
		return rs;
	}
	
	// Méthode qui renvoit un ResultSet pour un objet PreparedStatement
	// @args -> le PrepardeStatement
	public ResultSet getQuery(PreparedStatement p)
	{
		pStmt = p;
		try 
		{
			rs = pStmt.executeQuery();
		} 
		catch (SQLException E) 
		{
			JOptionPane.showMessageDialog(null,"Erreur de connexion à la base. Veuillez contacter votre administrateur système","Connexion",JOptionPane.WARNING_MESSAGE);
			System.out.println("3");
		}
		return rs;
	}
	
	// Méthode qui renvoit un objet PreparedStatement pour une requête
	// @args -> la requête
	public PreparedStatement getPrepare(String query)
	{
		try 
		{
			pStmt = conn.prepareStatement(query);
		}
		catch (SQLException e) 
		{
			JOptionPane.showMessageDialog(null,"Erreur de connexion à la base. Veuillez contacter votre administrateur système","Connexion",JOptionPane.WARNING_MESSAGE);
			System.out.println("4");
		}
		return pStmt;
	}
	
	// Méthode qui renvoit le nombre d'enregistrements affectés
	// par une requete de type INSERT, DELETE, UPDATE
	// @args -> la requete
	public int update(String query)
	{
		int r = 0;
		try 
		{
			r = stmt.executeUpdate(query);
		} 
		catch (SQLException e) 
		{
			JOptionPane.showMessageDialog(null,"Erreur de connexion à la base. Veuillez contacter votre administrateur système","Connexion",JOptionPane.WARNING_MESSAGE);
			System.out.println("5");
		}
		return r;
	}
	
	// Méthode qui renvoit le nombre d'enregistrements affectés
	// par un objet PreparedStatement
	// @args -> le PreparedStatement
	public int update(PreparedStatement p)
	{
		int r = 0;
		try 
		{
			pStmt = p;
			r = pStmt.executeUpdate();
		} 
		catch (SQLException E) 
		{
			JOptionPane.showMessageDialog(null,"Erreur de connexion à la base. Veuillez contacter votre administrateur système","Connexion",JOptionPane.WARNING_MESSAGE);
			System.out.println("6");
		}
		return r;
	}
	
	// Méthode qui renvoit le nombre d'enregistrements 
	// d'un ResultSet
	// @args -> le ResultSet
	public int recordCount(ResultSet res)
	{
		int i = 0;
		try
		{
			while (res.next())
				i++;
		}
		catch (SQLException E)
		{
			JOptionPane.showMessageDialog(null,"Erreur de connexion à la base. Veuillez contacter votre administrateur système","Connexion",JOptionPane.WARNING_MESSAGE);
			System.out.println("7");
		}
		return i;	
	}
	
	// Méthode qui renvoit un String[] 
	// à partir d'un ResultSet
	// Pratique pour remplir une Combo
	// @args -> le ResultSet
	public String[] makeList(ResultSet res)
	{
		int 		rowCount 	= 	this.recordCount(res);
		String[] 	list		= 	new String[rowCount+1];
		int 		i			= 	0;

		try
		{
			for (i = 0 ; i < rowCount ; i++)
			{
				res.absolute(i+1);
				list[i+1] = res.getString(1);
			}
		}
		catch (SQLException E)
		{
			JOptionPane.showMessageDialog(null,"Erreur de connexion à la base. Veuillez contacter votre administrateur système","Connexion",JOptionPane.WARNING_MESSAGE);
			System.out.println("8");
		}	
		
		return list;
	}
	
	// Méthode qui renvoit un Object[][] 
	// à partir d'un ResultSet pour l'élaboration d'un DataGrid
	// @args -> le ResultSet
	public Object[][] makeData(ResultSet res)
	{
		ResultSetMetaData 	infos 		= null;
		Object[][] 			data		= null;			
		int 				colCount	= 0;
		
		try
		{	
			infos 		= 	res.getMetaData();
			colCount	=	infos.getColumnCount();
		}
		catch (SQLException E)
		{
			JOptionPane.showMessageDialog(null,"Erreur de connexion à la base. Veuillez contacter votre administrateur système","Connexion",JOptionPane.WARNING_MESSAGE);
			System.out.println("9");
		}
		int rowCount			= 	this.recordCount(res);
		int i,j				= 	0;
		data		 			= 	new Object[rowCount][colCount];
		
		try
		{
			
			// Remplissage de data
			for (i = 0 ; i < rowCount ; i++)
			{
				res.absolute(i+1);
				for (j	= 0 ; j < colCount ; j++)
				{
					int type = infos.getColumnType(j+1);
					switch (type)
					{
						case Types.CHAR 		:
						case Types.VARCHAR 	:
						case Types.LONGVARCHAR	: data[i][j] = res.getString(j+1); break;
						
						case Types.TINYINT		:	{
													if ( infos.getPrecision(j+1) == 1)
														data[i][j] = new Integer(res.getInt(j+1));
													else if (res.getInt(j+1) == 0)
															data[i][j] = new Boolean(false);
														  else
															data[i][j] = new Boolean(true);
													break;
													}
						case Types.SMALLINT	:
						case Types.INTEGER		: data[i][j] = new Integer(res.getInt(j+1)); break;
						
						case Types.DATE		: data[i][j] = res.getDate(j+1); break;

						default :
							break;
					}  
				}
			}
		}
		catch (SQLException E)
		{
			JOptionPane.showMessageDialog(null,"Erreur de connexion à la base. Veuillez contacter votre administrateur système","Connexion",JOptionPane.WARNING_MESSAGE);
			System.out.println("10");
		}
		
		return data;	
	} 
	
	// Méthode qui renvoit le nom des colonnes d'un ResultSet
	// @args -> le ResultSet
	public String[] getColNames(ResultSet res)
	{
		ResultSetMetaData 	infos 		= null;	
		String[] 			colName		= null;
		int 				colCount	= 0;
		
		try
		{	
			infos 		= 	res.getMetaData();
			colCount	=	infos.getColumnCount();
		}
		catch (SQLException E)
		{
			JOptionPane.showMessageDialog(null,"Erreur de connexion à la base. Veuillez contacter votre administrateur système","Connexion",JOptionPane.WARNING_MESSAGE);
			System.out.println("11");
		}
		int j					= 	0;
		colName					= 	new String[colCount];
				
		try
		{
			
			//Remplissage de colName
			for (j	= 0 ; j < colCount ; j++)
				colName[j] = infos.getColumnName(j+1);
				
		}
		catch (SQLException E)
		{
			JOptionPane.showMessageDialog(null,"Erreur de connexion à la base. Veuillez contacter votre administrateur système","Connexion",JOptionPane.WARNING_MESSAGE);
			System.out.println("12");
		}
		
		
		return colName;	
	}
	
	
	public void disconnect()
	{
		try
		{
			rs.close();
	        stmt.close();
    	    conn.close();
		}
        catch ( SQLException E)
        {
            JOptionPane.showMessageDialog(null,"Erreur de connexion à la base. Veuillez contacter votre administrateur système","Connexion",JOptionPane.WARNING_MESSAGE);
        	System.out.println("14");
        }
	}
	
	
}