Intercepter les erreurs SQL en RPG ile
ven 15 novembre 2019SQL c’est bien MAIS !
En RPG ile, quand une requête SQL se passe mal, le SQLCODE est négatif tout le monde le sait. Cependant dans le cas du code SQL embarqué dans du RPG ile, si le code SQL est inférieur à zéro, le RPG ne peux pas l’intercepter avec un monitor par exemple.
La solution est d’écrire une procédure qui va provoquer une erreur interprétable par les opérations d’interception (Monitor, *PSSR, Exception/error system…).
C
x
148
148
1
**FREE2
ctl-opt nomain;3
ctl-opt datedit(*ymd) decedit('0,');4
ctl-opt option(*nodebugio:*srcstmt:*nounref) CCSIDCVT(*LIST);5
6
ctl-opt bnddir('QC2LE');7
8
// API d'information des JOBs 9
Dcl-pr rtvJobInf EXTPGM('QUSRJOBI');10
Receiver char(100) OPTIONS(*VARSIZE); // Receiver variable11
RcvLen int(10:0) CONST; // Length of receiver12
FmtName char(8) CONST; // Format name13
ObjName char(20) CONST; // Object and library14
ObjType char(10) CONST; // Object type15
// Optional 116
ErrorCode char(32767) OPTIONS(*VARSIZE:*NOPASS); // Error Code17
end-pr; 18
19
// Job information20
dcl-ds jobi0100 LikeDS(JOBI0100_t);21
22
//----------------------------------------------------------------23
// QMHSNDPM - send program messages24
//----------------------------------------------------------------25
dcl-pr QMHSNDPM extpgm('QMHSNDPM');26
*n char(7) const; // MessageId27
*n char(20) const; // MessageFile28
*n char(512) const options(*varsize); // MessageData29
*n bindec(9) const; // MessageDataL30
*n char(10) const; // MessageType31
*n char(128) const options(*varsize); // CallStkEntry32
*n bindec(9) const; // CallStkCount33
*n char(4) const; // MessageKey34
*n char(120) options(*varsize); // ErrApi35
end-pr;36
37
// send program message38
dcl-ds sndpgmmsg;39
msgid char(7) inz('CPF9898');40
msgfile char(20) inz('QCPFMSG QSYS ');41
msgdataL bindec(9) inz(512);42
msgtype char(10) inz('*COMP ');43
msgmsgq char(11) inz('* ');44
msgstack bindec(9) inz(1);45
msgkey char(4);46
end-ds;47
48
dcl-s msgdata char(512);49
50
//----------------------------------------------------------------51
// sql communication area52
//----------------------------------------------------------------53
dcl-ds SQLCA;54
SQLCAID char(8);55
SQLCABC bindec(9);56
SQLCODE bindec(9);57
SQLERRML bindec(4);58
SQLERRMC char(70);59
SQLERRP char(8);60
SQLERRD char(24);61
SQLER1 bindec(9) overlay(sqlerrd:1);62
SQLER2 bindec(9) overlay(sqlerrd:5);63
SQLER3 bindec(9) overlay(sqlerrd:9);64
SQLER4 bindec(9) overlay(sqlerrd:13);65
SQLER5 bindec(9) overlay(sqlerrd:17);66
SQLER6 char(4) overlay(sqlerrd:21);67
SQLWARN char(11);68
SQLSTATE char(5);69
P_SQLCA char(136) pos(1);70
end-ds;71
72
dcl-pr Sleep int(10) extproc('sleep');73
*n uns(10) value; // Seconds74
end-pr;75
76
dcl-s rc int(10);77
78
//----------------------------------------------------------------79
dcl-proc SQLErreur export;80
dcl-pi SQLErreur;81
pSqlca char(136) const;82
pStop ind options( *nopass );83
end-pi;84
dcl-s wStop ind inz(*on);85
86
Jobi0100.Job = '*';87
Jobi0100.IntJobID = *Blanks;88
Jobi0100.Status = 'JOBI0100';89
90
if %Parms =2;91
wStop = pStop;92
endif;93
P_SQLCA = pSqlca;94
select;95
// Erreur détectée96
when SQLCODE < 0;97
msgtype = '*DIAG';98
// cpf message...99
If SQLER1 > 0;100
msgid = %editw(%dec(SQLER1:7:0):'0 ');101
%subst(msgid:1:3) = 'CPF';102
else;103
// cpd message...104
If SQLER2 > 0;105
msgid = %editw(%dec(SQLER2:7:0):'0 ');106
%subst(msgid:1:3) = 'CPD';107
else;108
msgid = %editw(%dec(SQLCODE*-1:7:0):'0 ');109
%subst(msgid:1:3) = 'SQL';110
%subst(msgfile:1:10) = 'QSQLMSG';111
EndIf;112
EndIf;113
// Avertissement114
when SQLCODE > 0;115
msgid = %editw(%dec(SQLCODE:7:0):'0 ');116
%subst(msgid:1:3) = 'SQL';117
%subst(msgfile:1:10) = 'QSQLMSG';118
// Exécution SQL OK119
other;120
msgid = 'SQL' + SQLER6;121
%subst(msgfile:1:10) = 'QSQLMSG';122
endsl;123
124
// message text125
If SQLERrml > 0;126
msgdata = SQLERrmc;127
msgdataL = SQLERrml;128
EndIf;129
// Retrouve les attributs du Job en cours130
rtvJobInf (jobi0100:Jobi0100.BytesRet:Jobi0100.Status:131
Jobi0100.Job:Jobi0100.IntJobID:Errapi);132
// Job inter-actif ?133
If Jobi0100.Type = 'I';134
msgtype = '*STATUS';135
msgmsgq = '*EXT';136
msgstack = 0;137
QMHSNDPM (msgid:msgfile:msgdata:msgdataL:msgtype:138
msgmsgq:msgstack:msgkey:ErrApi);139
rc = sleep(1);140
msgtype = '*DIAG';141
msgmsgq = '*';142
Endif;143
// Message d'échappement144
If SQLCODE < 0 and wStop;145
QMHSNDPM (msgid:msgfile:msgdata:msgdataL:146
'*ESCAPE':'*CTLBDY':1:msgkey:ErrApi);147
EndIf;148
end-proc;Voici ci-dessous les explications sur la procédure utilisée :
- Lignes 9 à 17, nous déclarons le prototype de réception de l’API QUSRJOBI.
- Ligne 20 nous déclarons la DS du format JOBI100 de l’API QUSRJOBI
- Lignes 25 à 35, nous déclarons le prototype de l’API QMHSNDPM qui nous servira en envoyé des messages programme
- Lignes 38 à 46 la DS sndpgmmsg va recueillir les informations relatives à l’erreur SQL interceptée. Elle est initialisé avec le code message CPF9898, puis selon le code SQL reçu, elle sera mise à jour avec des informations supplémentaires.
- Ligne 48 est déclarée la variable msgdata qui reçoit les valeurs qui prennent la place des parties variables du message (SQLERRMC).
- Lignes 54 à 71, SQLCA est déclaré car ce source est déclaré en type RPGILE.
- Lignes 73 à 75 prototype de la procédure sleep qui a pour fonction de faire un délai, comme la commande CL DLYJOB.
- Ligne 80 à 84 déclaration de l’interface procédure, le 1er paramètre contient le SQLCA de la requête que l’on souhaite et qui sera contrôlée pour extraire une erreur éventuelle. Le 2me paremètre indique s’il faut ou non envoyé un message d’échappement en cas de SQLcode négatif, par défaut « oui ».
- Lignes 95 à 123, contrôles des différents niveaux de SQLERR pour déterminer quels type de message (CPF, CPD, SQL) il s’agit. Les numéro de message sont extrait des variables SQLERRx.
- Lignes 125 à 129, on extrait le texte du message.
- Lignes 131 à 143, on affiche un message en cas de travail interactif.
- Lignes 145 à 148, si le SQLcode est négatif et que l’on souhaite une interception de message par le système, on envoi un message d’échappement.
