|
181 | 181 | if (!$_POST["val"]) { |
182 | 182 | Admin::get()->addError(lang('Ctrl+click on a value to modify it.')); |
183 | 183 | } else { |
184 | | - $result = true; |
| 184 | + $success = true; |
185 | 185 | $affected = 0; |
186 | 186 | foreach ($_POST["val"] as $unique_idf => $row) { |
187 | 187 | $set = []; |
188 | 188 | foreach ($row as $key => $val) { |
189 | 189 | $key = bracket_escape($key, true); |
190 | 190 | $set[idf_escape($key)] = (preg_match('~char|text~', $fields[$key]["type"]) || $val != "" ? Admin::get()->processFieldInput($fields[$key], $val) : "NULL"); |
191 | 191 | } |
192 | | - $result = Driver::get()->update( |
| 192 | + $success = (bool)Driver::get()->update( |
193 | 193 | $TABLE, |
194 | 194 | $set, |
195 | 195 | " WHERE " . ($where ? implode(" AND ", $where) . " AND " : "") . where_check($unique_idf, $fields), |
196 | 196 | ($is_group || $primary ? 0 : 1), |
197 | 197 | " " |
198 | 198 | ); |
199 | | - if (!$result) { |
| 199 | + if (!$success) { |
200 | 200 | break; |
201 | 201 | } |
202 | 202 | $affected += Connection::get()->getAffectedRows(); |
203 | 203 | } |
204 | | - queries_redirect(remove_from_uri(), lang('%d item(s) have been affected.', $affected), $result); |
| 204 | + queries_redirect(remove_from_uri(), lang('%d item(s) have been affected.', $affected), $success); |
205 | 205 | } |
206 | 206 |
|
207 | 207 | } elseif (!is_string($file = get_file("csv_file", true))) { |
|
231 | 231 | $rows[] = $set; |
232 | 232 | } |
233 | 233 | } |
234 | | - $result = (!$rows || Driver::get()->insertUpdate($TABLE, $rows, $primary)); |
235 | | - if ($result) { |
| 234 | + $success = !$rows || Driver::get()->insertUpdate($TABLE, $rows, $primary); |
| 235 | + if ($success) { |
236 | 236 | Driver::get()->commit(); |
237 | 237 | } |
238 | | - queries_redirect(remove_from_uri("page"), lang('%d row(s) have been imported.', $affected), $result); |
| 238 | + queries_redirect(remove_from_uri("page"), lang('%d row(s) have been imported.', $affected), $success); |
239 | 239 | Driver::get()->rollback(); // after queries_redirect() to not overwrite error |
240 | 240 | } |
241 | 241 | } |
|
0 commit comments