JDBC Oracle Connection

Version imprimable

07/04/2009, 14h56
foxrol

JDBC Oracle Connection

Bonjour
Excuser moi de vous déranger mais j'aimerais savoir quelque chose.

En effet je voudrais me connecter à un base de données Oracle sous JDBC et sous eclipse.

1-Une classe qui récupère dans un fichier de configuration les mots de passe, login , instance et URL de connection. ------> Pas de problème

2-Une seconde classe qui utilise les informations précédentes pour se connecter à la base en question.--------> pas de problème

3-(La plus compliquée) Pour éviter de réécrire les informations de connecter tous le temps, j'aimerais créer une troisième classe qui fera appel à la seconde classe pour effectuer des requêtes d'insertion et autres dans la base, mais j'arrive pas.

merci de m'aider à avancer
07/04/2009, 15h01
Jidefix

Ben ce serait pas mal de nous dire où tu en est déjà (par exemple le code de ta 3e classe), et ce qui ne marche pas...
Si tu arrives à envoyer des requêtes à ta base et à traiter le retour tu as fait le plus gros, le reste ce n'est que de l'organisation...

C'est typiquement le principe d'un DAO.
Je ne vois pas trop où est ton problème mais voici un petit exemple

La classe utilitaire pour la connection

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
 
package com.test;
 
import java.sql.Connection;
import java.sql.DriverManager;
 
public class DataBaseUtils
{
    public static Connection getConnection()
    {
        Connection connection = null;
        try
        {
            Class.forName("com.mysql.jdbc.Driver");
            connection = DriverManager.getConnection("jdbc:mysql://localhost/test", "root", "ob");
            connection.setAutoCommit(false);
        }
        catch (Exception e)
        {
        }
        return connection;
    }
}

La classe DAO

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
 
package com.test;
 
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
 
public class PersonDAO
{
    private static PersonDAO personDAO;
 
    private PersonDAO()    {}
 
    public static PersonDAO getInstance()
    {
        if (personDAO == null)
        {
            personDAO = new PersonDAO();
        }
        return personDAO;
    }
 
    public Integer addPerson(String firstName, String lastName, String address, String zip, String city) throws Exception
    {
        Connection connection = null;
        Integer uid = 0;
        try
        {
            connection = DataBaseUtils.getConnection();
 
            PreparedStatement pstmt = connection.prepareStatement("insert into T_PERSON(FIRST_NAME, LAST_NAME, ADDRESS, ZIP, CITY) values(?, ?, ?, ?, ?)");
            pstmt.setString(1, firstName);
            pstmt.setString(2, lastName);
            pstmt.setString(3, address);
            pstmt.setString(4, zip);
            pstmt.setString(5, city);
            pstmt.executeUpdate();
 
            connection.commit(); // <- si autocommit = false
 
            ResultSet rs = pstmt.getGeneratedKeys();
            if(rs.next()) uid = rs.getInt(1);
        }
        catch (Exception e)
        {
            // logger
            throw e;
        }
        finally
        {
            if (connection != null) connection.close();
        }
        return uid;
    }
 
    public void removePerson(Integer uid) throws Exception
    {
        Connection connection = null;
        try
        {
            connection = DataBaseUtils.getConnection();
 
            PreparedStatement pstmt = connection.prepareStatement("delete from T_PERSON where UID = ?");
            pstmt.setInt(1, uid);
            pstmt.executeUpdate();
 
            connection.commit(); // <- si autocommit = false
        }
        catch (Exception e)
        {
            // logger
            throw e;
        }
        finally
        {
            if (connection != null) connection.close();
        }
    }
}

et le programme de test

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
package com.test;
 
public class Main
{
    /**
     * @param args
     */
    public static void main(String[] args)
    {
        try
        {
            String firstName = "FIRST NAME";
            String lastName = "LAST NAME";
            String address = "ADDRESS";
            String zip = "ZIP";
            String city = "VILLE";
            Integer uid = PersonDAO.getInstance().addPerson(firstName, lastName, address, zip, city);
            System.out.println("Personne créée, uid=" + uid);
        }
        catch (Exception e)
        {
            System.out.println("Erreur lors de la création de la personne");
        }
    }
}

Citation:

Envoyé par OButterlin

C'est typiquement le principe d'un DAO.
Je ne vois pas trop où est ton problème mais voici un petit exemple

La classe utilitaire pour la connection

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
 
package com.test;
 
import java.sql.Connection;
import java.sql.DriverManager;
 
public class DataBaseUtils
{
    public static Connection getConnection()
    {
        Connection connection = null;
        try
        {
            Class.forName("com.mysql.jdbc.Driver");
            connection = DriverManager.getConnection("jdbc:mysql://localhost/test", "root", "ob");
            connection.setAutoCommit(false);
        }
        catch (Exception e)
        {
        }
        return connection;
    }
}

La classe DAO

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
 
package com.test;
 
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
 
public class PersonDAO
{
    private static PersonDAO personDAO;
 
    private PersonDAO()    {}
 
    public static PersonDAO getInstance()
    {
        if (personDAO == null)
        {
            personDAO = new PersonDAO();
        }
        return personDAO;
    }
 
    public Integer addPerson(String firstName, String lastName, String address, String zip, String city) throws Exception
    {
        Connection connection = null;
        Integer uid = 0;
        try
        {
            connection = DataBaseUtils.getConnection();
 
            PreparedStatement pstmt = connection.prepareStatement("insert into T_PERSON(FIRST_NAME, LAST_NAME, ADDRESS, ZIP, CITY) values(?, ?, ?, ?, ?)");
            pstmt.setString(1, firstName);
            pstmt.setString(2, lastName);
            pstmt.setString(3, address);
            pstmt.setString(4, zip);
            pstmt.setString(5, city);
            pstmt.executeUpdate();
 
            connection.commit(); // <- si autocommit = false
 
            ResultSet rs = pstmt.getGeneratedKeys();
            if(rs.next()) uid = rs.getInt(1);
        }
        catch (Exception e)
        {
            // logger
            throw e;
        }
        finally
        {
            if (connection != null) connection.close();
        }
        return uid;
    }
 
    public void removePerson(Integer uid) throws Exception
    {
        Connection connection = null;
        try
        {
            connection = DataBaseUtils.getConnection();
 
            PreparedStatement pstmt = connection.prepareStatement("delete from T_PERSON where UID = ?");
            pstmt.setInt(1, uid);
            pstmt.executeUpdate();
 
            connection.commit(); // <- si autocommit = false
        }
        catch (Exception e)
        {
            // logger
            throw e;
        }
        finally
        {
            if (connection != null) connection.close();
        }
    }
}

et le programme de test

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
package com.test;
 
public class Main
{
    /**
     * @param args
     */
    public static void main(String[] args)
    {
        try
        {
            String firstName = "FIRST NAME";
            String lastName = "LAST NAME";
            String address = "ADDRESS";
            String zip = "ZIP";
            String city = "VILLE";
            Integer uid = PersonDAO.getInstance().addPerson(firstName, lastName, address, zip, city);
            System.out.println("Personne créée, uid=" + uid);
        }
        catch (Exception e)
        {
            System.out.println("Erreur lors de la création de la personne");
        }
    }
}

Bonsoir
j'ai essayer ton code pour voir si tout fonctionnait, les données sont effectivement enregistrées dans la table mais pas moyen d'avoir la valeur de uid.
Après avoir insérer les données dans la table le message Erreur lors de la création de la personne est affiché.

Apres avoir cheche sur la toile je voudrias te demander si t'as pas oublier un
Statement.RETURN_GENERATED_KEYS dans PreparedStatement pstmt?
merci pour ton aide

Non, mais j'ai testé ce code sur une base MySQL.
Je pense que le problème vient de la définition de la table T_PERSON, en particulier le champ UID qui est auto-increment.
Le code de création est le suivant
Code:

1 2 3 4 5 6 7 8 9 10 CREATE TABLE `test`.`t_person` ( `UID` int(10) unsigned NOT NULL auto_increment, `FIRST_NAME` varchar(60) default NULL, `LAST_NAME` varchar(60) default NULL, `ADDRESS` varchar(128) default NULL, `ZIP` varchar(45) default NULL, `CITY` varchar(60) default NULL, PRIMARY KEY (`UID`) )
Pour faire l'équivalent avec Oracle (d'après ce que j'ai lu), il faut passer par une SEQUENCE et créer un trigger sur la table... :traine:

Pétard, ça ne s'arrête pas là :aie: !!!
Il va falloir modifier le code comme ceci, bonjour la portabilité :roll:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
    public Integer addPerson(String firstName, String lastName, String address, String zip, String city) throws Exception
    {
        Connection connection = null;
        Integer uid = 0;
        try
        {
            connection = DataBaseUtils.getConnection();
            
            PreparedStatement pstmt = connection.prepareStatement("insert into T_PERSON(FIRST_NAME, LAST_NAME, ADDRESS, ZIP, CITY) values(?, ?, ?, ?, ?)", new String[]{"ID"});
            pstmt.setString(1, firstName);
            pstmt.setString(2, lastName);
            pstmt.setString(3, address);
            pstmt.setString(4, zip);
            pstmt.setString(5, city);
            pstmt.executeUpdate();
            
            connection.commit(); // <- si autocommit = false
            
            ResultSet rs = pstmt.getGeneratedKeys();
            if(rs.next()) uid = rs.getInt(1);
        }
        catch (Exception e)
        {
            // logger
            throw e;
        }
        finally
        {
            if (connection != null) connection.close();
        }
        return uid;
    }

09/04/2009, 11h01
foxrol

Solution
Voila j'ai trouvé la solution:

Si vous ecrivez:
1. PreparedStatement pstmt = connection.prepareStatement("insert into T_PERSON(FIRST_NAME, LAST_NAME, ADDRESS, ZIP, CITY) values(?, ?, ?, ?, ?)",new String[]{"U_ID"});--> vous obtenez la crétion d'une personne avec un uid=0.
2. PreparedStatement pstmt = connection.prepareStatement("insert into T_PERSON(FIRST_NAME, LAST_NAME, ADDRESS, ZIP, CITY) values(?, ?, ?, ?, ?)");--> vous obtenez la crétion d'une personne sans uid et le message Ereur de la creation.... est affiché
3. On commence par créée une séquence SEQ01, puis un trigger (si possible)
  
  PreparedStatement pstmt = connection.prepareStatement("insert into T_PERSON(U_ID,FIRST_NAME, LAST_NAME, ADDRESS, ZIP, CITY) values(SEQ01.nextval,?, ?, ?, ?, ?)",new String[]{"U_ID"});---> vous obtenez la solution.
09/04/2009, 11h02
foxrol

Merci OButterlin

Merci OButterlin
11/04/2009, 03h33
touftouf57

Wooaa, merci pour la réponse.

J'ai eut du mal à la trouver, depuis hier soir j'arpente le net à ce sujet.
J'ai essayé toutes le versions possibles. Et j'étais à 1000 lieux de ça.

Donc encore un grand merci.:bravo: