@@ -74,8 +74,10 @@ function enableCentreonBrokerInDB($id)
7474 return ;
7575 }
7676
77- $ query"UPDATE cfg_centreonbroker SET config_activate = '1' WHERE config_id = " . $ id
78- $ pearDBquery ($ query
77+ $ query"UPDATE cfg_centreonbroker SET config_activate = '1' WHERE config_id = :config_id " ;
78+ $ statement$ pearDBprepare ($ query
79+ $ statementbindValue (':config_id ' , (int ) $ idPDO ::PARAM_INT );
80+ $ statementexecute ();
7981}
8082
8183/**
@@ -91,8 +93,10 @@ function disablCentreonBrokerInDB($id)
9193 return ;
9294 }
9395
94- $ query"UPDATE cfg_centreonbroker SET config_activate = '0' WHERE config_id = " . $ id
95- $ pearDBquery ($ query
96+ $ query"UPDATE cfg_centreonbroker SET config_activate = '0' WHERE config_id = :config_id " ;
97+ $ statement$ pearDBprepare ($ query
98+ $ statementbindValue (':config_id ' , (int ) $ idPDO ::PARAM_INT );
99+ $ statementexecute ();
96100}
97101
98102/**
@@ -104,8 +108,10 @@ function deleteCentreonBrokerInDB($ids = array())
104108{
105109 global $ pearDB
106110
111+ $ statement$ pearDBprepare ("DELETE FROM cfg_centreonbroker WHERE config_id = :config_id " );
107112 foreach ($ idsas $ key$ value
108- $ pearDBquery ("DELETE FROM cfg_centreonbroker WHERE config_id = " . $ key
113+ $ statementbindValue (':config_id ' , (int ) $ keyPDO ::PARAM_INT );
114+ $ statementexecute ();
109115 }
110116}
111117
@@ -194,13 +200,7 @@ function multipleCentreonBrokerInDB($ids, $nbrDup)
194200 foreach ($ idsas $ id$ value
195201 $ cbObjnew CentreonConfigCentreonBroker ($ pearDB
196202
197- $ query"SELECT config_name, config_filename, config_activate, ns_nagios_server,
198- event_queue_max_size, cache_directory, daemon "
199- . "FROM cfg_centreonbroker "
200- . "WHERE config_id = " . $ id" " ;
201- $ dbResult$ pearDBquery ($ query
202- $ row$ dbResultfetch ();
203- $ dbResultcloseCursor ();
203+ $ rowgetCfgBrokerData ((int ) $ id
204204
205205 # Prepare values
206206 $ valuesarray ();
@@ -210,14 +210,11 @@ function multipleCentreonBrokerInDB($ids, $nbrDup)
210210 $ values'event_queue_max_size ' ] = $ row'event_queue_max_size ' ];
211211 $ values'cache_directory ' ] = $ row'cache_directory ' ];
212212 $ values'activate_watchdog ' ]['activate_watchdog ' ] = $ row'daemon ' ];
213- $ query"SELECT config_key, config_value, config_group, config_group_id "
214- . "FROM cfg_centreonbroker_info "
215- . "WHERE config_id = " . $ id" " ;
216- $ dbResult$ pearDBquery ($ query
217213 $ values'output ' ] = array ();
218214 $ values'input ' ] = array ();
219215 $ values'logger ' ] = array ();
220- while ($ rowOpt$ dbResultfetch ()) {
216+ $ brokerCfgInfoDatagetCfgBrokerInfoData ((int ) $ id
217+ foreach ($ brokerCfgInfoDataas $ rowOpt
221218 if ($ rowOpt'config_key ' ] == 'filters ' ) {
222219 continue ;
223220 } elseif ($ rowOpt'config_key ' ] == 'category ' ) {
@@ -228,7 +225,6 @@ function multipleCentreonBrokerInDB($ids, $nbrDup)
228225 $ rowOpt'config_value ' ];
229226 }
230227 }
231- $ dbResultcloseCursor ();
232228
233229 # Convert values radio button
234230 foreach ($ valuesas $ group$ groups
@@ -254,16 +250,18 @@ function multipleCentreonBrokerInDB($ids, $nbrDup)
254250
255251 # Copy the configuration
256252 $ j1 ;
253+ $ query"SELECT COUNT(*) as nb FROM cfg_centreonbroker WHERE config_name = :config_name " ;
254+ $ statement$ pearDBprepare ($ query
257255 for ($ i1 ; $ i$ nbrDup$ id$ i
258256 $ nameNOktrue ;
259257
260258 # Find the name
261259 while ($ nameNOk
262260 $ newname$ row'config_name ' ] . '_ ' . $ j
263261 $ newfilename$ j'_ ' . $ row'config_filename ' ];
264- $ query = " SELECT COUNT(*) as nb FROM cfg_centreonbroker WHERE config_name = ' " . $ newname . " ' "
265- $ res = $ pearDB -> query ( $ query
266- $ rowNb$ res fetch ();
262+ $ statement -> bindValue ( ' : config_name' , $ newname, \ PDO :: PARAM_STR ) ;
263+ $ statement -> execute ( );
264+ $ rowNb$ statement fetch (\ PDO :: FETCH_ASSOC );
267265 if ($ rowNb'nb ' ] == 0 ) {
268266 $ nameNOkfalse ;
269267 }
@@ -293,3 +291,54 @@ function isPositiveNumeric($size): bool
293291 }
294292 return $ isPositive
295293}
294+
295+ /**
296+ * Getting Centreon CFG broker data
297+ *
298+ * @param int $configId
299+ * @return array
300+ */
301+ function getCfgBrokerData (int $ configIdarray
302+ {
303+ global $ pearDB
304+
305+ $ query"SELECT config_name, config_filename, config_activate, ns_nagios_server,
306+ event_queue_max_size, cache_directory, daemon "
307+ . "FROM cfg_centreonbroker "
308+ . "WHERE config_id = :config_id " ;
309+ try {
310+ $ statement$ pearDBprepare ($ query
311+ $ statementbindValue (':config_id ' , $ configIdPDO ::PARAM_INT );
312+ $ statementexecute ();
313+ $ cfgBrokerData$ statementfetch (\PDO ::FETCH_ASSOC );
314+ } catch (PDOException $ exception
315+ throw new \Exception ("Cannot fetch Broker config data " );
316+ }
317+ $ statementcloseCursor ();
318+ return $ cfgBrokerData
319+ }
320+
321+ /**
322+ * Getting Centreon CFG broker Info data
323+ *
324+ * @param int $configId
325+ * @return array
326+ */
327+ function getCfgBrokerInfoData (int $ configIdarray
328+ {
329+ global $ pearDB
330+
331+ $ query"SELECT config_key, config_value, config_group, config_group_id "
332+ . "FROM cfg_centreonbroker_info "
333+ . "WHERE config_id = :config_id " ;
334+ try {
335+ $ statement$ pearDBprepare ($ query
336+ $ statementbindValue (':config_id ' , $ configIdPDO ::PARAM_INT );
337+ $ statementexecute ();
338+ $ cfgBrokerInfoData$ statementfetchAll (\PDO ::FETCH_ASSOC );
339+ } catch (\PDOException $ exception
340+ throw new \Exception ("Cannot fetch Broker info config data " );
341+ }
342+ $ statementcloseCursor ();
343+ return $ cfgBrokerInfoData
344+ }
0 commit comments