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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
|
-------------------------------------------------------------------------------
-- Nom : Exec_Entrepot_ArchData.sql
-- Description : Script qui permet d'exporter les donnees d'un arrete. C'est le script
-- à modifier pour ajouter des tables ou changer l'arrêté à exporter.
--
-- Auteur : XXXXXX
-- Date : XXXXXX
-- Parametres : 1) Date de l'arrete à exporter. Si nul on prend l'arrete courant.
-- Il est obligatoire meme vide
--
-- Exemple : @Exec_Entrepot_ArchData.sql ""
-- @Exec_Entrepot_ArchData.sql "28/02/2007" -> arrete du 28/02/2007
-- @Exec_Entrepot_ArchData.sql "05/02/2007" -> arrete du 28/02/2007
--
-- Details : ce script genere des scripts batch temporaires qui seront
-- ensuite appelés. Si la partition est inexistante le fichier
-- est quand meme cree, mais vide
--
-- OUT : Sqlldr_Import_Entrepot_Data.cmd (pour le reimport des donnees)
-- Entrepot_Export.cmd
--
-- Code retour : 0 si OK, sinon 1
--
-- Autre : Necessite les variables suivantes :
-- %APR_TMP%
-- %APR_ARCH_E%
-- %APR_SQL%
-- %ORA_USER%
-- %ORA_PWD%
-- %ORACLE_SID%
--
--!!!!!!!!!!!!!!!!! ATTENTION : Si le parametre est absent le script attend
--!!!!!!!!!!!!!!!!! une saisi manuelle sur le prompt DOS.
-------------------------------------------------------------------------------
--En cas d'erreur on retourne 1
WHENEVER SQLERROR EXIT 1
SET serveroutput ON
SET term OFF
SET newpage 0
SET heading OFF
SET embedded ON
SET feedback OFF
SET pagesize 0
SET trimspool ON
SET LINESIZE 250
SET VERIFY OFF
spool C:\Prive\01_Boulot\Entrepot_Export.cmd
--
--Generation d'un script d'export des données
--
DECLARE
l_partition VARCHAR2(10);
l_param DATE;
l_date_arrete DATE;
l_count number(10);
l_Ispartition VARCHAR2(1);
--Curseur pour les tables partitionnées
CURSOR C1 IS SELECT * FROM ALL_TAB_PARTITIONS WHERE TABLE_OWNER='ALM_DEI' AND PARTITION_NAME LIKE '%'||l_partition ORDER BY table_name;
--Curseur pour les tables non partitionneés (CEDRE ET GEODE)
CURSOR C2 IS SELECT * FROM ALL_TABLES WHERE OWNER ='ALM_DEI' AND ((TABLE_NAME LIKE '%CEDRE%' AND TABLE_NAME NOT LIKE '%PERI%') OR TABLE_NAME LIKE '%GEODE%' OR TABLE_NAME LIKE '%DPHG%' OR TABLE_NAME LIKE 'REF%' ) AND TABLE_NAME NOT LIKE '%BAD%' AND PARTITIONED='NO' ORDER BY table_name;
l_temp_line_1 C1%ROWTYPE;
l_temp_line_2 C2%ROWTYPE;
l_test_erreur VARCHAR2(300) := 'IF "%ERRORLEVEL%" NEQ "0" (CALL :KO "Erreur lors de l execution du script %APR_TMP%\Entrepot_Export.cmd")';
BEGIN
DBMS_OUTPUT.enable(1000000);
--
-- On récupére le numéro de la partition de l'arrete passé en parametre ou par defaut celui de l'arrete en cours
--
l_param := '&1';
--On test la valeur du parametre
IF l_param IS NOT NULL THEN
SELECT PARTITION_NAME INTO l_partition FROM TEC_PARTITIONS WHERE MAX_VALUE=LAST_DAY(TRUNC(l_param))+1;
l_date_arrete := LAST_DAY(TRUNC(l_param));
ELSE
--si le parametre est vide on exporte l'arrete courant
SELECT MAX(PERIOD) INTO l_date_arrete FROM LOG_PERIOD WHERE M_STATUS='O' AND J_STATUS='O';
SELECT PARTITION_NAME INTO l_partition FROM TEC_PARTITIONS WHERE TRUNC(MAX_VALUE)=TRUNC(LAST_DAY(l_date_arrete)+1);
END IF;
OPEN c1;
LOOP FETCH C1 INTO l_temp_line_1;
EXIT WHEN C1%NOTFOUND;
l_Ispartition:='O';
--Comptage du nombre de lignes dans la table
DBMS_OUTPUT.PUT_LINE('Debut1');
EXECUTE immediate 'select count(*) from '||l_temp_line_1.table_name||' PARTITION('||l_temp_line_1.PARTITION_NAME||')' into l_count;
--Ecriture du nombre de ligne dans le rapport APR
DBMS_OUTPUT.PUT_LINE('echo TABLE '||RPAD(l_temp_line_1.table_name, 30,' ')||' PARTITIONNÉE : '||l_Ispartition||' NB_LIGNES : '||l_count||' >> %APR_MAIL% ' );
--Ecriture du nombre de ligne dans la table de rapport
--EXECUTE immediate 'INSERT INTO ALM_DEI.RAPPORT_APR (APRR_DATE_EXEC, APRR_DATE_AR, APRR_TABLE,APRR_PART, APRR_NBL) VALUES (to_date('''||TO_CHAR(SYSDATE ,'dd/mm/yyyy hh24:mi:ss') ||''',''dd/mm/yyyy hh24:mi:ss''),'''||l_date_arrete||''','''||l_temp_line_1.table_name||''','''||l_Ispartition||''','||l_count||')';
COMMIT;
DBMS_OUTPUT.PUT_LINE('Debut2');
DBMS_OUTPUT.PUT_LINE('sqlplus -s %ORA_USER%/%ORA_PWD%@%ORACLE_SID% @%APR_SQL%\Exp_Tab_Data.sql '||l_temp_line_1.table_name||' "PARTITION ('||l_temp_line_1.PARTITION_NAME||')" %APR_ARCH_E%\'||l_temp_line_1.table_name||'_exp.ctl '||l_temp_line_1.TABLE_OWNER );
--si il y a une erreur on quitte le batch
DBMS_OUTPUT.PUT_LINE(l_test_erreur);
--commande permettant de faire un trim sur les lignes pour diminuer la taille des fichiers
DBMS_OUTPUT.PUT_LINE('cscript %APR_VBS%\Dei_RTrim_file.vbs %APR_ARCH_E%\'||l_temp_line_1.table_name||'_exp.ctl %APR_TMP%');
--si il y a une erreur on quitte le batch
DBMS_OUTPUT.PUT_LINE(l_test_erreur);
END LOOP;
CLOSE c1;
OPEN C2;
LOOP FETCH C2 INTO l_temp_line_2;
EXIT WHEN C2%NOTFOUND;
l_Ispartition:='N';
--Comptage du nombre de lignes dans la table
EXECUTE immediate 'select count(*) from '||l_temp_line_2.table_name into l_count;
--Ecriture du nombre de ligne dans le rapport APR
DBMS_OUTPUT.PUT_LINE('echo TABLE '||RPAD(l_temp_line_2.table_name, 30,' ')||' PARTITIONNÉE : '||l_Ispartition||' NB_LIGNES : '||l_count||' >> %APR_MAIL% ' );
--Ecriture du nombre de ligne dans la table de rapport
--EXECUTE immediate 'INSERT INTO ALM_DEI.RAPPORT_APR (APRR_DATE_EXEC, APRR_DATE_AR, APRR_TABLE,APRR_PART, APRR_NBL) VALUES (to_date('''||TO_CHAR(SYSDATE ,'dd/mm/yyyy hh24:mi:ss') ||''',''dd/mm/yyyy hh24:mi:ss''),'''||l_date_arrete||''','''||l_temp_line_2.table_name||''','''||l_Ispartition||''','||l_count||')';
COMMIT;
DBMS_OUTPUT.PUT_LINE('sqlplus -s %ORA_USER%/%ORA_PWD%@%ORACLE_SID% @%APR_SQL%\Exp_Tab_Data.sql '||l_temp_line_2.table_name||' "" %APR_ARCH_E%\'||l_temp_line_2.table_name||'_exp.ctl '||l_temp_line_2.OWNER );
--si il y a une erreur on quitte le batch
DBMS_OUTPUT.PUT_LINE(l_test_erreur);
--commande permettant de faire un trim sur les lignes pour diminuer la taille des fichiers
DBMS_OUTPUT.PUT_LINE('cscript %APR_VBS%\Dei_RTrim_file.vbs %APR_ARCH_E%\'||l_temp_line_2.table_name||'_exp.ctl %APR_TMP%');
--si il y a une erreur on quitte le batch
DBMS_OUTPUT.PUT_LINE(l_test_erreur);
END LOOP;
CLOSE C2;
DBMS_OUTPUT.PUT_LINE('ECHO fin de traitement de %APR_TMP%\Entrepot_Export.sql >> %LOGFILE%');
DBMS_OUTPUT.PUT_LINE('GOTO :EOF');
DBMS_OUTPUT.PUT_LINE('ECHO. >> %LOGFILE%');
DBMS_OUTPUT.PUT_LINE(':KO');
DBMS_OUTPUT.PUT_LINE('ECHO %1 >> %LOGFILE%');
DBMS_OUTPUT.PUT_LINE('ECHO. >> %LOGFILE%');
DBMS_OUTPUT.PUT_LINE('ECHO. >> %LOGFILE%');
DBMS_OUTPUT.PUT_LINE('ECHO ------------------------------------------------------------------------------- >> %LOGFILE%');
DBMS_OUTPUT.PUT_LINE('ECHO ------------ Fin de traitement KO --------------------------------------------- >> %LOGFILE%');
DBMS_OUTPUT.PUT_LINE('ECHO ------------------------------------------------------------------------------- >> %LOGFILE%');
DBMS_OUTPUT.PUT_LINE('EXIT 1');
EXCEPTION
WHEN NO_DATA_FOUND THEN
DBMS_OUTPUT.PUT_LINE('REM Probleme sur la date de l arrete');
END;
/
spool OFF
spool %APR_ARCH_E%\Sqlldr_Import_Entrepot_Data.cmd
--
--Generation du batch d'import des données
--
PROMPT REM------------------------------------------------------------------------------*/
PROMPT REM-- Nom : Sqlldr_Import_Entrepot_Data.cmd.cmd */
PROMPT REM-- Description : Script qui permet d'importer les donnees d'un arrete */
PROMPT REM-- */
PROMPT REM-- Auteur : XXXXX */
PROMPT REM-- Date : XXXXX */
PROMPT REM-- */
PROMPT REM-- Details : ce script permet via sqlloader de charger les données */
PROMPT REM-- */
PROMPT REM-- OUT : un fichier de log par table */
PROMPT REM-- */
PROMPT REM-- Autre : Necessite les variables suivantes : */
PROMPT REM-- %DIR_TMP% */
PROMPT REM-- %DIR_LOG% */
PROMPT REM-- %ORAHOME% */
PROMPT REM-- %ORA_USER% */
PROMPT REM-- %ORA_PWD% */
PROMPT REM-- %ORACLE_SID% */
PROMPT REM------------------------------------------------------------------------------*/
PROMPT
PROMPT
PROMPT SET DIR_TMP=
PROMPT SET DIR_LOG=
PROMPT SET ORA_USER=
PROMPT SET ORA_PWD=
PROMPT SET ORACLE_SID=
PROMPT
PROMPT
SELECT 'sqlldr USERID=%ORA_USER%/%ORA_PWD%@%ORACLE_SID% CONTROL=%DIR_TMP%\'||table_name||'_exp.ctl LOG=%DIR_LOG%\'||table_name||'_exp.log' FROM ALL_TABLES WHERE OWNER='ALM_DEI' AND PARTITIONED='YES' ORDER BY table_name;
SELECT 'sqlldr USERID=%ORA_USER%/%ORA_PWD%@%ORACLE_SID% CONTROL=%DIR_TMP%\'||table_name||'_exp.ctl LOG=%DIR_LOG%\'||table_name||'_exp.log' FROM ALL_TABLES WHERE OWNER ='ALM_DEI' AND ((TABLE_NAME LIKE '%CEDRE%' AND TABLE_NAME NOT LIKE '%PERI%') OR TABLE_NAME LIKE '%GEODE%' OR TABLE_NAME LIKE '%DPHG%' ) AND TABLE_NAME NOT LIKE '%BAD%' AND PARTITIONED='NO' ORDER BY table_name;
spool OFF
EXIT |
SQL command not properly ended / Execute immediate
Répondre avec citation
Partager