C'est une classe qui permet de se connecter à n'import quelle base
Pourvu que l'on est les drivers JDBC !!
Entre autre, elle permet de se connecter, d'executer des requetes (preparées ou pas !),
de construire des tableaux pour remplir les combos ...
Source / Exemple :
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");
}
}
}
Conclusion :
Bon là elle est configurer pour une base mysql.
Pour l'utliser avec une autre base :
-> changer la valeur de pilote avec le bon driver
-> changer la valeur de url avec la bonne url de votre base
Vous n'êtes pas encore membre ?
inscrivez-vous, c'est gratuit et ça prend moins d'une minute !
Les membres obtiennent plus de réponses que les utilisateurs anonymes.
Le fait d'être membre vous permet d'avoir un suivi détaillé de vos demandes et codes sources.
Le fait d'être membre vous permet d'avoir des options supplémentaires.