--- rpl/src/instructions_s8.c 2011/09/20 14:36:29 1.38 +++ rpl/src/instructions_s8.c 2012/04/13 14:13:00 1.46 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.3 - Copyright (C) 1989-2011 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.8 + Copyright (C) 1989-2012 Dr. BERTRAND Joël This file is part of RPL/2. @@ -787,25 +787,17 @@ instruction_sqlquery(struct_processus *s { # define d_LONGUEUR 1024 +# if defined(MYSQL_SUPPORT) || defined(POSTGRESQL_SUPPORT) logical1 connexion_permanente; - logical1 presence_resultat; +# endif struct_objet *s_copie_1; struct_objet *s_objet_1; struct_objet *s_copie_2; struct_objet *s_objet_2; - struct_objet *s_objet_resultat; - - struct_liste_chainee *l_element_courant; - struct_liste_chainee *l_element_courant_ligne; unsigned char *tampon; - unsigned int i; - unsigned int j; - unsigned int nombre_colonnes; - unsigned int nombre_lignes; - (*s_etat_processus).erreur_execution = d_ex; if ((*s_etat_processus).affichage_arguments == 'Y') @@ -880,7 +872,9 @@ instruction_sqlquery(struct_processus *s if ((*s_objet_1).type == LST) { +# if defined(MYSQL_SUPPORT) || defined(POSTGRESQL_SUPPORT) connexion_permanente = d_faux; +# endif s_copie_1 = s_objet_1; @@ -891,6 +885,16 @@ instruction_sqlquery(struct_processus *s return; } + if ((*s_etat_processus).erreur_execution == + d_ex_instruction_indisponible) + { + liberation(s_etat_processus, s_objet_1); + liberation(s_etat_processus, s_objet_2); + liberation(s_etat_processus, s_copie_1); + + return; + } + liberation(s_etat_processus, s_copie_1); } else @@ -910,7 +914,9 @@ instruction_sqlquery(struct_processus *s } } +# if defined(MYSQL_SUPPORT) || defined(POSTGRESQL_SUPPORT) connexion_permanente = d_vrai; +# endif } if (((*s_objet_1).type == SQL) && ((*s_objet_2).type == CHN)) @@ -952,8 +958,18 @@ instruction_sqlquery(struct_processus *s { # ifdef MYSQL_SUPPORT - MYSQL_RES *resultat_mysql; - MYSQL_ROW ligne; + unsigned int i; + unsigned int nombre_colonnes; + + logical1 presence_resultat; + + MYSQL_RES *resultat_mysql; + MYSQL_ROW ligne; + + struct_objet *s_objet_resultat; + + struct_liste_chainee *l_element_courant; + struct_liste_chainee *l_element_courant_ligne; if (mysql_real_query((*((struct_connecteur_sql *) (*s_objet_1) .objet)).descripteur.mysql, (unsigned char *) (*s_objet_2) @@ -1155,7 +1171,19 @@ instruction_sqlquery(struct_processus *s { # ifdef POSTGRESQL_SUPPORT - PGresult *resultat_postgresql; + unsigned int i; + unsigned int j; + unsigned int nombre_colonnes; + unsigned int nombre_lignes; + + logical1 presence_resultat; + + PGresult *resultat_postgresql; + + struct_objet *s_objet_resultat; + + struct_liste_chainee *l_element_courant; + struct_liste_chainee *l_element_courant_ligne; if (PQstatus((*((struct_connecteur_sql *) (*s_objet_1).objet)) .descripteur.postgresql) != CONNECTION_OK)