Java

Se connecter à une base de données via JDBC

Connexion d’un programme Java à une base de données via JDB

Il est courant aujourd’hui d’avoir à développer des applications bases de données relationnelles. En java c’est l’API et les drivers JDBC qui fournissent les fonctionnalités permettant de se connecter et d’exécuter des requêtes SQL sur une base de données. L’intérêt de cette API est de fournir une méthodes d’accès standard quelque soit le SGBD utilisé.

Sommaire

1. Principe de connexion à une base de données

Pour qu’une application Java puisse accéder à une base de données, que se soit pour consulter ou modifier des données, vous devrez réaliser un certains nombre d’actions dans cet ordre :

Installer le driver de base de données sur le poste.
Dans l’application Java :
- charger le driver en mémoire
- établir une connexion à la base de données à l’aide d’un objet Connection
- à partir de la connexion récupérer un objet Statement qui permettra l’exécution de requêtes.

2. Installation du driver sur le poste

Vous devrez récupérer le pilote JDBC de la base de données que vous désirez utiliser. En principe, c’est le constructeur du SGBD qui fournie le driver. Un moyen simple est de le récupérer sur Internet à partir du site http://developers.sun.com/product/jdbc/drivers. Un driver JDBC se présente sous la forme d’une archive .jar et est donc multi-plateforme (si type 4).

Une fois l’archive récupérée, vous devrez l’installer dans un dossier de votre disque dur. Vous aurez le choix entre :

copier le fichier de la bibliothèque dans le répertoire /lib/ext se trouvant dans le dossier d’installation du runtime java utilisé,

copier le fichier bibliothèque dans un répertoire quelconque

Dans ce dernier cas vous devrez spécifier à votre programme comment retrouver le fichier bibliothèque pour utiliser le pilote :

soit en définissant ou mettre à jour la variable d’environnement CLASSPATH de votre système pour lui ajouter le chemin de la bibliothèque

soit en passant le chemin dans en argument -classpath dans la ligne de commande d’exécution du programme Java.

L’exemple suivant montre un extrait d’un fichier .bashrc d’un système LINUX avec les différentes variables d’environnements définies pour une base Derby.

export JAVA_HOME=/opt/sun/java/jdk1.6.0_16
export DERBY_HOME=$JAVA_HOME/db
export PATH=$JAVA_HOME/bin:$DERBY_HOME/bin:$PATH
export CLASSPATH=.:$DERBY_HOME/lib/derby.jar:$DERBY_HOME/lib/derbytools.jar

Remarque : Si vous utilisez un environnement de développement comme Eclipse il vous suffira de spécifier la librairie dans les propriétés de votre projet.

3.Chargement du pilote

Pour charger le pilote en mémoire, vous avez 2 possibilités. Soit votre programme charge manuellement le pilote soit il ajoute le pilote à la liste des propriétés systèmes sous le nom jdbc.driver.

a) Chargement manuel du pilote.

Le chargement s’effectue en utilisant la méthode forName() de la classe Class en passant une chaine contenant le nom de la classe.

Class.forName( nomDriver )

Le code suivant montre comment charger le pilote d’une base de données Derby pour le mode embarqué.

String nomDriver = "org.apache.derby.jdbc.EmbeddedDriver";
Class.forName( nomDriver );

Télécharger

Vous devrez consulter la documentation de chaque pilote pour connaître les chaines de caractères à utiliser. Le tableau suivant donne quelques exemples de chaines de définition de pilote.

Classe de pilote	Description
org.apache.derby.jdbc.EmbeddedDriver	Pilote Derby en mode embarqué
org.apache.derby.jdbc.ClientDriver	Pilote Derby en mode client/serveur.
com.mysql.jdbc.Driver	Pilote MySql
org.firebirdsql.jdbc.FBDriver	Pilote Firebird
sun.jdbc.odbc.JdbcOdbcDriver	Driver pnt JDBC/ODBC fourni par sun. Il est déconseillé d’utiliser ce type de driver en production.
com.ibm.db2.jdbc.app.DB2Driver	Pilote DB2 d’IBM

b)Chargement du pilote par ajout d’une propriété système.

Vous avez 2 manières d’ajouter le pilote.

Vous pouvez l’ajouter en utilisant l’option -D en argument de ligne de commande lors du lancement du programme. L’exemple suivant vous montre comment lancer une application utilisant un pilote Derby :

java -Djdbc.drivers=org.apache.derby.jdbc.EmbeddedDriver NonProgramme

L’autre méthode étant de l’ajouter par le programme. Exemple :

System.setProperty( "jdbc.drivers", "org.apache.derby.jdbc.EmbeddedDriver" );

Remarque : Si votre application doit se connecter à plusieurs bases de données de types différents, vous pourrez spécifier les différents pilotes à charger en les séparant par " :".

4. Connexion à la base de données

Une fois le pilote chargé en mémoire, nous devons nous connecter à la base de données. Pour cela nous devrons utiliser un objet de type Connection que nous pourrons récupérer en utilisant une des méthodes de la classe DriverManager suivante :

Connection getConnection( String url );

ou :

Connection getConnection( String url, String, login, String pass );

La première méthode permet de définir les paramètres de connexions dans une chaîne unique dont la syntaxe est la suivante :

"jdbc:sous-protocole:[//hote:][port]/nomBaseDeDonnées"

Cette chaine est construite comme une url , le sous-protocole correspondant au SGBD utilisé. Vous devrez consulter la documentation de chaque driver pour connaître l’url exacte en fonction du SGBD.

Cela donnera pour se connecter à une base de donnée Derby se trouvant sur une machine UNIX et nommé base_exemple :

String url = "jdbc:derby:/var/databases/base_exemple;create=false";
…
Connection conn = DriverManager.getConnection( url );

Télécharger

Le tableau suivant donne quelques exemples d’url de connexions :

url	Description
jdbc:firebirdsql ://160.133.103:3052/d :\d :\databases\exemples_base.fdb	Connexion à une base de données firebird avec spécification de l’adresse IP et n° de port. La base de données se trouvant sur un serveur Windows
jdbc:derby ://localhost:1527/exemple_base ;create=true	Connexion à une base derby.Un paramètre propre à cette base spécifie qu’une base sera créée si pas trouvée.
jdbc:mysql ://localhost/exemple_base	Connexion à une base MySql en localhost

5. Exemple de programme de connexion.

5.1 Présentation du programme

Comme exemple, nous allons réaliser un programme permettant de se connecter à une petite base de données (une seule table) puis, nous afficherons les erreurs en cas d’echec.

Remarque : Vous pourrez vous référer au document : SGBD Derby Java Db, paragraphe : Utilisation de Derby pour savoir comment créer la base de données et récupérer le script d’emple.

Dans cet exemple nous utiliserons la version de Derby installée avec le JDK 6 sachant que seul les chemins des répertoires seront à adapter si vous utilisez une autre version de Derby. Nous utiliserons également le driver pour le mode embarqué de la base pour éviter d’avoir à configurer un serveur de bases de données. Pour bien comprendre ce que nous faisons, un simple éditeur de texte sera utilisé pour saisir le premier programme.

Le tableau suivant donne les paramètres de connexions :

Type de la base de données	Base de données Derby en mode embarqué.
Classe du pilote	org.apache.derby.jdbc.EmbeddedDriver
URL	jdbc:derby :///home/christophe/databases/derby_dbs/mediatheque
Nom d’utilisateur :	non utilisé
Mot de passe :	non utilisé

Nous n’utiliserons pas de spécifions de login utilisateur ni mot de passe pour ces tests, derby désactivant par défaut l’authentification.

5.2 Écriture du programme et exécution

Créez un répertoire puis créez dans celui-ci un fichier TestConnexion.java. Puis saisissez le code suivant :

// Programme de test de connexion
// Ce programme va charger le driver pour une base derby embarquée
// puis se connecter à une base de données nommée "mediatheque".
//
// Auteur: Ch. Chambon
//
import java.sql.*;
public class TestConnexion
{
public static void main( String[] args )
{
System.out.println( "Connexion en cours..." );
Connection connection = getConnection();
try
{
if ( connection != null )
{
System.out.println( "Fin de connexion" );
connection.close();
}
}
catch ( SQLException e )
{
System.out.println( "ERREUR sur fermeture de la connexion" );
e.printStackTrace();
}
}
public static Connection getConnection()
{
Connection connection = null;
boolean ok = false;
//--- chargement en mémoire du pilote
try
{
Class.forName( PILOTE );
ok = true;
}
catch( ClassNotFoundException e )
{
System.out.println( "ERREUR chargement du pilote: pilote non trouvé" );
}
//--- connexion à la base
if ( ok )
{
try
{
connection = DriverManager.getConnection( URL_DATABASE );
}
catch (SQLException e )
{
System.out.println( "ERREUR de connexion à la base de données: " + URL_DATABASE );
}
}
//--- Renvoi la connexion
return connection;
}
private static final String PILOTE =
"org.apache.derby.jdbc.EmbeddedDriver";
private static final String URL_DATABASE =
"jdbc:derby:/home/christophe/databases/derby_dbs/mediatheque;create=false";
}

Télécharger

Le code chargeant le driver et réalisant la connexion à la base de données se trouve dans la méthode getConnection().

Sauvegardez, compilez et exécutez le programme.

java TestConnexion

Connexion en cours...

5.3. Programme bases de données en utilisant un IDE .

Dans le cadre d’un développement réel il est indispensable d’utiliser un IDE . Nous allons voir que cela nous facilite grandement les choses mêmes pour de petits programmes.

Ecriture de l’exemple du programme de connexion dans Eclipse.

Remarques : Ce paragraphe ne traitant pas de l’utilisation d’Eclipse, les manipulations qui suivent ne seront pas détaillées. Pour plus d’informations, reportez vous aux rubriques traitant de cet environnement.

Lancez Eclipse et créez un nouveau projet java. Comme nous allons utiliser le pilote de base de données contenu dans l’archive derby.jar, nous devons le spécifier dans le projet. Pour cela, affichez la fenêtre des propriétés du projet (racourcis clavier : alt+entrée), sélectionnez l’option JavaBuild Path et l’onglet Libraries. Cliquez sur le bouton Add External JARs... puis sélectionnez le fichier derby.jar.

Créer un package testjdbc par exemple, créez une classe TestConnexion en cochant la création automatique de la méthode main() puis, retapez le code de l’exemple précédent. Enregistrez et exécutez. Normalement, vous devriez voir s’afficher le texte suivant dans la vue Console :

Connexion en cours...

Fin de connexion

6. Exécuter des requêtes

Récupérer un objet Statement

Maintenant que nous sommes connecté à la base de données nous devons récupérer un objet Statement qui nous permettra d’exécuter toutes requêtes SQL sur la base de données. A partir d’un objet Connection vous pourrez utiliser la méthode suivante :

Statement createStatement()

Exemple :

Connection con = …
...
Statement st = conn.createStatement();

Télécharger

Lancer l’exécution de requêtes

Cette classe dispose de plusieurs méthodes permettant d’exécuter des requêtes SQL . Vous utiliserez plutôt l’une ou l’autre selon le type de requête. Voici la liste de ces différentes méthodes :

ResultSet executeQuery( String sql )

Exécute une requête de sélection (SELECT) et renvoi une liste d’enregistrements dans un objet ResultSet.

int executeUpdate( String sql )

Exécute une requête de mise à jour (INSERT, UPDATE ou DELETE) ou une commande SQL de type DLL comme par exemple CREATE TABLE. Cette méthode renvoi le nombre d’enregistrements modifiés lorsqu’il s’agit d’une requête de mise à jour sinon -1.

boolean execute( String sql )

Permet d’exécuter une requête SQL quelconque. Retourne la valeur true si l’exécution de la requête renvoi un ensemble résultat sinon false.

Si la méthode execute renvoi true, vous devrez pouvoir exploiter les résultats avec les 2 méthodes suivante :

int getUpdateCount()

qui renvoi le nombre d’enregistrements disponibles ou -1 si la méthode execute ne renvoie pas d’ensembles résultats et :

ResultSet getResultSet()

qui permet de récupérer l’ensemble résultat.

Récupérer les données de la requête

Un objet ResultSet contient l’ensemble de données résultant d’une requête sélection.

Cette classe dispose des méthodes suivante pour vous permettre d’exploiter les données retournées

boolean next()

Avance d’une ligne dans le ResultSet et renvoi true tant que vous n’êtes pas sur la dernière ligne. Vous devrez appeler une première fois cette méthode pour pouvoir récupérer la première ligne.

void close()

Ferme l’ensemble résultat.

Pour balayer l’ensemble des lignes vous pourrez créer une boucle de ce type :

while ( rs.next() )
{
// lecture d'une ligne
...
}
rs.close();

Télécharger

Pour récupérer les informations, vous disposez d’une série de méthodes get.. auxquelles vous passerez en paramètre soit le nom du champ soit son numéro d’ordre (commence par 1). Il existe une version de ces méthodes pour chaque type de données courantes d’une base de données permettant de retourner la valeur dans un type Java compatible.

Les noms de ces méthodes auront la forme suivante :

typeJava getTypeJava( int columnNumber )

typeJava getTypeJava( String columnName )

Le tableau suivant présente la correspondance entre quelques types SQL et Java avec le nom de la méthode get correspondantes

Type java	Méthode d’accès	Type SQL à récupérer
boolean	getBooelan(...)	BIT
byte	getByte(...)	TINYINT
short	getShort	SMALLINT
int	getInt	INTEGER
long	getLong	BIGINT
float	getFloat	REAL
double	getDouble	FLOAT, DOUBLE
BigDecimal	getBigDecimal	DECIMAL, NUMERIC
String	getString	CHAR, VARCHAR
java.sql.Date	getDate	DATE
Time	getTime	TIME
Timestamp	getTimestamp	TIMESTAMP
...

Exemple de programme affichant le résultat d’une requête

Le programme reprend l’exemple précédent mais saisie dans Eclipse et en ajoutant l’affichage du contenu de la table. La méthode de connexion a également été modifiée pour lire les paramètres à partir d’un fichier properties.

package testjdbc;
import java.io.FileInputStream;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
public class AfficheResultat
{
/**
* @param args
*/
public static void main(String[] args)
{
{
System.out.println( "Connexion en cours..." );
Connection connection = getConnection( "database.properties" );
System.out.println( "===============================================" );
afficheListeCompositeurs( connection );
System.out.println( "===============================================" );
try
{
if ( connection != null )
{
System.out.println( "Fin de connexion..." );
connection.close();
}
System.out.println( "Ok." );
}
catch ( SQLException e )
{
System.out.println( "ERREUR sur fermeture de la connexion" );
}
}
}
public static Connection getConnection( String fichierProperties )
{
Connection connection = null;
boolean ok = false;
//---------------------------------
//--- lecture du fichier properties
//---------------------------------
String driver = null;
String url = null;
Properties properties = new Properties();
try
{
FileInputStream f = new FileInputStream( fichierProperties );
properties.load( f );
driver = properties.getProperty( "driver" );
url = properties.getProperty( "url" );
ok = true;
}
catch ( IOException e )
{
System.out.println( "Erreur lecture fichier: " + fichierProperties );
}
if ( ok )
{
//-----------------------------------
//--- chargement en mémoire du pilote
//-----------------------------------
ok = false;
try
{
Class.forName( driver );
ok = true;
}
catch ( ClassNotFoundException e )
{
System.out.println( "ERREUR chargement du pilote: pilote non trouvé" );
}
}
if ( ok )
{
//----------------------------------
//--- connexion à la base de données
//----------------------------------
try
{
connection = DriverManager.getConnection( url );
}
catch ( SQLException e )
{
System.out.println( "ERREUR de connexion à la base de données: " + url );
}
}
return connection;
}
public static void afficheListeCompositeurs( Connection connection )
{
Statement statement = null;
try
{
statement = connection.createStatement();
ResultSet resultset = null;
resultset = statement.executeQuery( "SELECT * FROM T_COMPOSITEURS_CMP" );
while ( resultset.next() )
{
System.out.println( resultset.getString("CMP_NOM" ) + " , " +
resultset.getString( "CMP_PRENOM" ) );
}
}
catch ( SQLException e )
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

Télécharger

Le fichier database.properties a la structure suivante :

####################################
#
# 	Fichier de connexion a la base de donnees.
#
# 	Fichier: connection.properties
#		Auteur: Ch.Chambon
#		Version: 1.0
#
#####################################

#	nom de la classe du pilote JDBC
driver=org.apache.derby.jdbc.EmbeddedDriver

#	URL de connexion a la base de donnees
url=jdbc:derby:D:\\databases\\derby\\mediatheque;create=false
#url=jdbc:derby:/home/christophe/database/derby/mediatheque;create=false

#	utilisateur (non utilise pour cet exemple)
user=

#	mote de passe (non utilise pour cet exemple)
password=

Remarque : La ligne #url est en commentaire pour montrer la différence de syntaxe entre un système MS-Windows et Unix.

7. Requêtes préparées

Les requêtes préparés sont des requêtes pré compilées paramétrables. Il suffira de mettre le caractère « ? » dans la requêtes aux emplacements paramétrables. Pour cela, il faut récupérer un objet PreparedStatement avec la méthode suivante :

PreparedStatement ps = connection.prepareStatement( String commandeSql )

comme dans l’exemple suivant :

public void add(Compositeur compositeur) throws DaoException
{
PreparedStatement statement = null;
try
{
statement = connection.prepareStatement( SQL_ADD );
statement.setString( 2, compositeur.getNom() );
statement.setString( 3, compositeur.getPrenom() );
statement.setInt( 4, compositeur.getAnneeNaissance() );
statement.setInt( 5, compositeur.getAnneeDece() );
statement.executeUpdate();
statement.close();
connection.commit();
}
catch (SQLException e)
{
throw new DaoException( "Erreur SQL lors de l'insertion d'un enregistrement. " + e.getMessage() );
}
}
…
private final static String SQL_ADD =
"INSERT INTO T_COMPOSITEURS_COMP VALUES ( ?, ?, ?, ?, ? )";

Télécharger

Un objet PreparedStatement dispose de méthodes setXXX permettant d’initialiser les paramètres de la requête en passant d’abord son numéro. Le premier « ? » Correspondant au paramètre n°1.

8. Ensemble résultats défilant et vivants

Depuis la version 2 de JDBC, il est possible d’avoir des résultats de requêtes défilant. C’est à dire que vous pourrez non seulement avancer mais aussi reculer dans la source de données. Cela peut être utile si vous désirez relier votre ResultSet à un JTable dans le but de visualiser le résultat dans une interface graphique. Il pourra être également intéressant de pouvoir modifier une ligne du ResultSet et que cela entraine la mise à jour de la base de données ou au contraire, si les données de la base évoluent que le ResultSet reflète ces changements pour mettre à jour l’affichage. Pour préciser ses options nous utiliserons l’une des méthodes suivantes :

Statement st = connection.createStatement( type, concurrency );

ou pour une requête préparée :

PreparedStatement st = 

                connection.prepareStatement( requête, type, concurrency );

Grace aux 2 paramètres types et concurrency vous pourrez spécifier le comportement du ResultSet. Les tableaux suivant résument les différentes options possibles.
Les valeurs pour type :

Constante	Description
TYPE_FORWARD_ONLY	Pas de possibilité de défilement
TYPE_SCROLL_INSENSITIVE	On peut faire défiler l’ensemble de résultat mais ne se met pas à jour automatiqument en cas de changement dans la base.
TYPE_SCROLL_SENSITIVE	On peut faire défiler l’ensemble résultat et ce dernier est mis à jour en cas de changement dans la base.

Les valeurs pour concurrency :

Constante	Description
ONCUR_READ_ONLY	L’ensemble résultat ne peut être utilisé pour mettre à jour la base de données.
CONCUR_UPDATABLE	L’ensemble résultat peut être utilisé pour mettre à jour la base de données.

Par exemple, si vous désirez faire défiler un ensemble résultat en lecture seule vous pourriez utiliser le code suivant :

Statement st = connection.createStatement( ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_READ_ONLY );

Télécharger

Vous pouvez maintenant vous déplacer dans votre ensemble de données en utilisant les méthodes suivantes :

Pour aller à l’enregistrement suivant :

if ( resultset.next() ) …

Pour aller à l’enregistrement précédent :

if ( resultset.previous() ) …

Déplacement relatif vers l’avant ou l’arrière :

resultset.relative( n );

Déplacement absolut :

resultset.absolute( n );

Les précédentes méthodes renvoient true si après la tentative de déplacement elles se trouvent sur un enregistrement. Si ce n’est pas possible, le curseur se positionne avant le premier enregistrement ou après le dernier et renvoi false.

Il est également possible de récupérer le n° de ligne actuelle à avec la méthode suivante :

int n = resultset.getRow();

La première ligne a la valeur 1. Si la méthode renvoi 0 c’est que le curseur ne se trouve pas sur une ligne.

Un certains nombre de méthodes existent pour se déplacer directement sur le premier ou dernier enregistrement et pour tester si c’est le cas :

first(), last(), beforeFirst(), afterLast(), isFirst(), isLast()...

Pour utiliser un ensemble de données actualisables, vous devrez utiliser d’abord les méthodes suivantes pour mettre à jour les champs :

resultset.updateString( champ, valeur );

resultset.updateDouble( champ, valeur );

…

Vous trouverez une méthode updateXXX pour tous les types de dnnées. Comme pour les méthodes get et set, vous pouvez spécifier le champ par son nom ou son nuyméro.

Ensuite vous devrez valider (enregistrement dans la base) la mise à jour de la ligne en cours avec la méthode :

resultset.updateRow();

ou annuler cette mise à jour avec :

resultset.cancelRowUpdate();

Exemple de code de mise à jour :

Statement st = connection.createStatement( ResultSet.TYPE_SCROLL_INSENSITIVE, 

                                                  ResultSet.CONCUR_UPDATE );

…

ResultSet rs = st.executeQuery( requeteSql );

…

rs.updateString( "CMP_NOM", "BACH" );

rs.updateRow();

Pour passer en mode ajout d’un enregistrement vous devrez utiliser la méthode suivante :

resultset.moveToInsertRow();

Initialisez les champs avec des méthodes updateXxxx puis validez avec la méthode :

resultset.insertRow();

Vous pourrez repositionner le curseur sur la ligne courante avec :

resultset.moveToCurrentRow();

Pour supprimer la ligne courante de la base utilisez :

resultset.deleteRow();

Remarques et limites des requêtes lives

Les ensembles de résultats vivants demandent à ce que la connexion soit permanente. Vous ne devrez donc pas utiliser cette méthode pour une application Web. Il existe également une interface nommée RowSet qui permet d’avoir un ensemble de lignes défilantes sans pour autant être connecté à une source de données.

Il y a plusieurs niveaux de drivers qui vont supporter ou pas l’ensemble des possibilités du ResultSet selon que vous aurez des drivers de type JDBC1, JDBC2 ou JDBC3.

Indépendamment du niveau de driver, il est également possible que vous ne puissiez pas mettre à jour des données à partir un ensemble de résultats s’il s’agit d’une requête complexe ou comportant des jointures.

9. Conclusion

Cet article ne vous a présenté qu’une partie des possibilités de JDBC. D’autre part, on peut constater que cette approche n’est pas très objet, qu’il faut gérer beaucoup d’exceptions qui nous oblige à taper beaucoup de codes. Pour des projets d’importance, vous ne devrez pas utiliser directement l’API JDBC. Vous devrez utiliser une couche supplémentaire au dessus de JDBC, que l’on nomme mapping objet /relationnel qui vous permet au niveau de l’application, d’utiliser des objets pour manipuler des données sauvegardées dans une base de données relationnelle.

Développement

Article n° 10

Crée par: chris

Créé le: 8 mai 2010

Modifié le: 31 octobre 2019

Nombre de visites: 1190

Popularité: 12 %

Popularité absolue: 1

Les bases du langage Java

Mots clés de cet article

Java39
SQL12