connexion postgres et nb de processus

Version imprimable

Bonjour,
j'ai un souci avec le nombre de processus sur une connexion postgres.
j'ai une classe baseDonnees avec :
Code:

1 2 3 4 5 6 7 8 9 10 11 public static Connection connexionPostgres() { try{ Class.forName("org.postgresql.Driver"); String url = "jdbc:postgresql://x.x.x.x:5432/TOTO"; Connection cn = DriverManager.getConnection(url,"xxxxx","xxxxx"); return(cn); }catch(Exception e){ System.err.println("pas de connexion a la base postgres"); return null; }
j'ai une autre classe insertBase ou je fais mes traitements avec :
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 try{ BaseDonnees.cn.setAutoCommit(false); st1 = BaseDonnees.connexionPostgres().prepareStatement("insert into savsuivitr (cste,cetab,transp,numre,codecli,libcli,cdem,ind,cdecli,sit,just," + "datenv,heure,com,nbcol,poids,an,mois,jour,aliv,mliv,jliv,indx) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"); st1.setString(1, "CRP"); st1.setString(2, "E11"); st1.setString(3, transp); st1.setString(4, pci); st1.setString(5, clil); st1.setString(6, cli); st1.setString(7, ref); st1.setString(8, ind); st1.setString(9, refc); st1.setString(10, sit); st1.setString(11, just); st1.setString(12, dtm); st1.setString(13, h); st1.setString(14, txt); st1.setString(15, cp); st1.setString(16, pds); st1.setString(17, a); st1.setString(18, m); st1.setString(19, j); st1.setString(20, aenv); st1.setString(21, menv); st1.setString(22, jenv); st1.setInt(23, indx); st1.execute(); st1.close(); }catch (Exception e) { // TODO: handle exception creaFichier(ref, e.getMessage()); } st1.close(); BaseDonnees.connexionPostgres().close();
j'ai une classe traitementFichier ou je recupere les infos d'un fichier csv pour les envoyer vers insertBase. dans ce traitementFichier je fais aussi des appels a la connexion postgres pour traduire et verifier des infos.

Mon pb est que lorsque je lance le prog et que je verifie sur les serveur postgres au niveau du gestionnaire de taches j'ai un nombre de process postgres.exe qui ne cesse de croitre.

Quel est la bonne methode pour reduire ce nombre d'ouverture de processs?

Merci pour votre indulgence :oops:

15/10/2008, 17h08
CheryBen

Plutôt que de renvoyer une nouvelle connexion à chaque appel à la méthode connexionPostgres, stocke la connexion en attribut et tu en renvoi une nouvelle seulement si l'attribut est null.
15/10/2008, 17h16
fred33

re

Merci de ta reponse mais un petit exemple serait le bienvenu parceque je ne vois pas ce que tu veux dire ...:oops:

Simplement :
Code:

1 2 3 4 5 6 7 8 9 private static Connection _connection; public static Connection connexionPostgres() throws Exception { if(_connection == null) { Class.forName("org.postgresql.Driver"); String url = "jdbc:postgresql://x.x.x.x:5432/TOTO"; _connection = DriverManager.getConnection(url,"xxxxx","xxxxx"); } return _connection; }
Je te conseille de ne pas catcher les exceptions ici pour ne pas avoir à renvoyer null. Sinon dans ton code qui appellera cette méthode, tu risques d'avoir des NullPointerException. L'idéal serait même de détailler les exceptions plutôt que d'utiliser le type générique Exception.

15/10/2008, 17h31
fred33

re

Merci c'est ce que j'avais cru comprendre mais j'etais pas sur, par contre pour le catch j'en savais rien.
Je test

Merci encore

rere

Bon j'ai fait ca

Code:

1
2
3
4
5
6
7
8
9
10
11
 
public static Connection connexionPostgres() throws Exception {
		System.out.println("entree :"+cn);
		if(cn == null){
			Class.forName("org.postgresql.Driver");
			String url = "jdbc:postgresql://xxx.xxx.xx.xx:5432/TOTO";
			cn = DriverManager.getConnection(url,"xxxx","xxxx");
		}
			System.out.println("sortie :"+cn);
			return(cn);
	}

resultat du sysout :
entree :org.postgresql.jdbc3.Jdbc3Connection@97a560
sortie :org.postgresql.jdbc3.Jdbc3Connection@97a560

et voila comment j'appel dans mon autre classe la connexion

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
public String testDoublonD(String transp,String numre,String codecli,String sit,String just) {
		/**on test dans la base postgres si l'enregistrement 
                 * existe ou pas
                 */
			try{
				pst = BaseDonnees.connexionPostgres().createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 
				rst = pst.executeQuery("select * from savsuivitr where transp='"+transp+"' and numre='"+numre+"' and codecli='"+codecli+"' and sit='"+sit+"' and just='"+just+"'");
				if(rst.first()){
					resultd = "vrai";
				}else{
					resultd ="faux";
				}
			}catch (Exception e) {
				// TODO: handle exception
				System.out.println("erreur test doublon");
			}
			return(resultd);
	}

le retour resultd est null et l'appli s'arrete.

Merci:mrgreen:

15/10/2008, 18h10
CheryBen

Qu'est-ce qui est null exactement? tu as une trace? il faut au moins faire e.printStackTrace() dans un catch. Avec ton catch, on ne saura pas pourquoi l'exception arrive.
15/10/2008, 18h10
fred33

rerere

Bon c'est une erreur de ma part j'ai trouve bien cachee une ligne qui mettait ma connection a close, une fois supprimer cette ligne ca fonctionne. :oops:
15/10/2008, 18h13
CheryBen

J'allais oublier, tu devrais regarder :
Doit on fermer un ResultSet ?
Doit on fermer un Statement ?

Et n'oubli pas le bouton Résolu si tout va bien ;)