@@ -136,7 +136,7 @@ function drop_or_revoke_user($database_id, $user_id, $host_list){
136136 // set to all hosts if none given
137137 if (trim ($ host_list ) == '' ) $ host_list = '% ' ;
138138
139- $ db_user_databases = $ app ->db ->queryAllRecords ("SELECT * FROM web_database WHERE (database_user_id = " . $ user_id . " OR database_ro_user_id = " . $ user_id . " ) AND active = 'y' AND database_id != " . $ database_id );
139+ $ db_user_databases = $ app ->db ->queryAllRecords ("SELECT * FROM web_database WHERE (database_user_id = ? OR database_ro_user_id = ? ) AND active = 'y' AND database_id != ? " , $ user_id , $ user_id , $ database_id );
140140 $ db_user_host_list = array ();
141141 if (is_array ($ db_user_databases ) && !empty ($ db_user_databases )){
142142 foreach ($ db_user_databases as $ db_user_database ){
@@ -205,9 +205,8 @@ function db_insert($event_name, $data) {
205205 if ($ data ['new ' ]['active ' ] == 'y ' ) {
206206
207207 // get the users for this database
208- $ db_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ' " . intval ($ data ['new ' ]['database_user_id ' ]) . "' " );
209-
210- $ db_ro_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ' " . intval ($ data ['new ' ]['database_ro_user_id ' ]) . "' " );
208+ $ db_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ? " , $ data ['new ' ]['database_user_id ' ]);
209+ $ db_ro_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ? " , $ data ['new ' ]['database_ro_user_id ' ]);
211210
212211 $ host_list = '' ;
213212 if ($ data ['new ' ]['remote_access ' ] == 'y ' ) {
@@ -253,11 +252,11 @@ function db_update($event_name, $data) {
253252 }
254253
255254 // get the users for this database
256- $ db_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ' " . intval ( $ data ['new ' ]['database_user_id ' ]) . " ' " );
257- $ old_db_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ' " . intval ( $ data ['old ' ]['database_user_id ' ]) . " ' " );
255+ $ db_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ? " , $ data ['new ' ]['database_user_id ' ]);
256+ $ old_db_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ? " , $ data ['old ' ]['database_user_id ' ]);
258257
259- $ db_ro_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ' " . intval ( $ data ['new ' ]['database_ro_user_id ' ]) . " ' " );
260- $ old_db_ro_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ' " . intval ( $ data ['old ' ]['database_ro_user_id ' ]) . " ' " );
258+ $ db_ro_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ? " , $ data ['new ' ]['database_ro_user_id ' ]);
259+ $ old_db_ro_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ? " , $ data ['old ' ]['database_ro_user_id ' ]);
261260
262261 $ host_list = '' ;
263262 if ($ data ['new ' ]['remote_access ' ] == 'y ' ) {
@@ -484,13 +483,13 @@ function db_delete($event_name, $data) {
484483 $ old_host_list .= 'localhost ' ;
485484
486485 if ($ data ['old ' ]['database_user_id ' ]) {
487- $ old_db_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ' " . intval ( $ data ['old ' ]['database_user_id ' ]) . " ' " );
486+ $ old_db_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ? " , $ data ['old ' ]['database_user_id ' ]);
488487 $ drop_or_revoke_user = $ this ->drop_or_revoke_user ($ data ['old ' ]['database_id ' ], $ data ['old ' ]['database_user_id ' ], $ old_host_list );
489488 if ($ drop_or_revoke_user ['drop_hosts ' ] != '' ) $ this ->process_host_list ('DROP ' , $ data ['old ' ]['database_name ' ], $ old_db_user ['database_user ' ], $ old_db_user ['database_password ' ], $ drop_or_revoke_user ['drop_hosts ' ], $ link );
490489 if ($ drop_or_revoke_user ['revoke_hosts ' ] != '' ) $ this ->process_host_list ('REVOKE ' , $ data ['old ' ]['database_name ' ], $ old_db_user ['database_user ' ], $ old_db_user ['database_password ' ], $ drop_or_revoke_user ['revoke_hosts ' ], $ link );
491490 }
492491 if ($ data ['old ' ]['database_ro_user_id ' ]) {
493- $ old_db_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ' " . intval ( $ data ['old ' ]['database_ro_user_id ' ]) . " ' " );
492+ $ old_db_user = $ app ->db ->queryOneRecord ("SELECT `database_user`, `database_password` FROM `web_database_user` WHERE `database_user_id` = ? " , $ data ['old ' ]['database_ro_user_id ' ]);
494493 $ drop_or_revoke_user = $ this ->drop_or_revoke_user ($ data ['old ' ]['database_id ' ], $ data ['old ' ]['database_ro_user_id ' ], $ old_host_list );
495494 if ($ drop_or_revoke_user ['drop_hosts ' ] != '' ) $ this ->process_host_list ('DROP ' , $ data ['old ' ]['database_name ' ], $ old_db_user ['database_user ' ], $ old_db_user ['database_password ' ], $ drop_or_revoke_user ['drop_hosts ' ], $ link );
496495 if ($ drop_or_revoke_user ['revoke_hosts ' ] != '' ) $ this ->process_host_list ('REVOKE ' , $ data ['old ' ]['database_name ' ], $ old_db_user ['database_user ' ], $ old_db_user ['database_password ' ], $ drop_or_revoke_user ['revoke_hosts ' ], $ link );
@@ -539,7 +538,8 @@ function db_user_update($event_name, $data) {
539538
540539 $ host_list = array ('localhost ' );
541540 // get all databases this user was active for
542- $ db_list = $ app ->db ->queryAllRecords ("SELECT `remote_access`, `remote_ips` FROM `web_database` WHERE `database_user_id` = ' " . intval ($ data ['old ' ]['database_user_id ' ]) . "' " );
541+ $ user_id = intval ($ data ['old ' ]['database_user_id ' ]);
542+ $ db_list = $ app ->db ->queryAllRecords ("SELECT `remote_access`, `remote_ips` FROM `web_database` WHERE `database_user_id` = ? OR database_ro_user_id = ? " , $ user_id , $ user_id );;
543543 if (count ($ db_list ) < 1 ) return ; // nothing to do on this server for this db user
544544
545545 foreach ($ db_list as $ database ) {
0 commit comments