Задача: написать метод, который будет при вызове возвращать true/false или массив из базы. Я в классе прописал вот такой метод, но он не работает:
public function queryExec($sql, $data=false, $execOnly=false) {
$stmt = $this->getCon()->prepare($sql);
if ($execOnly){
$result = $stmt->execute(); // Возвращает в массив
} else {
$data = array_filter($data);
if (!is_array($data) || count($data) < 1) {
//throw new Exception("you got error!", 1);
$stmt->execute();
} else {
$stmt->execute($data);
}
$result = $stmt->fetch();
}
return $result;
}
private function users_online(){
if (session_id() == '') session_start();
$session = session_id();
$curTime = time();
$timeout = $curTime - 60; // Время
$ip = $_SERVER['REMOTE_ADDR'];
$sql = "CREATE TABLE IF NOT EXISTS `users_online` (
`session` varchar(255) NOT NULL,
`time` varchar(255) NOT NULL,
`ip` varchar(255) NOT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8;";
$this->queryExec($sql, false, true);
$sql = "SELECT COUNT(time) FROM users_online WHERE session = ?";
$result = $this->queryExec($sql, [$session], false);
// Добавление или обновления - пользователя на сайте
if (count($result) > 0){
$sql = "UPDATE users_online SET time='?', ip='?' WHERE session = '?'";
} else {
$sql = "INSERT INTO users_online (time, ip, session) VALUES ('?', '?', '?')";
}
$sql = "UPDATE users_online SET time='?', ip='?' WHERE session = '?'";
$data['time'] = $curTime;
$data['ip'] = $ip;
$data['session'] = $session;
$result = $this->queryExec($sql, $data, false);
//var_dump(count($result));
if (!$result){
$this->errors[] = "SQL ошибка при проверке пользователей на сайте!";
return -1;
}
$sql = "DELETE FROM users_online WHERE time < ?";
$this->queryExec($sql, [$timeout], false);
// Смотрим сколько пользователей на сайте
$sql = "SELECT COUNT(*) FROM users_online";
$result = $this->queryExec($sql, false, true);
if (!$result)
return -1;
else {
var_dump($result);
return $r[0];
}
}
метод queryExec планируется использовать везде во всех классах, которые будут наследоваться от класса подключения к базе данных.
Помогите исправить ошибку. Выдает примерно вот это:
Fatal error: Uncaught exception 'PDOException' with message 'SQLSTATE[HY000]: General error' in /Users/userName/Sites/board_php/classes/connection.php:66 Stack trace: #0 /Users/userName/Sites/board_php/classes/connection.php(66): PDOStatement->fetch() #1 /Users/userName/Sites/board_php/classes/connection.php(108): Connection->queryExec('UPDATE users_on...', Array, false) #2 /Users/userName/Sites/board_php/classes/connection.php(38): Connection->users_online() #3 /Users/userName/Sites/board_php/login.php(37): Connection->Connection() #4 {main} thrown in /Users/userName/Sites/board_php/classes/connection.php on line 66
Самое интересное то, что до использования массивов в users_online() в queryExec() все срабатывает, а когда вводится массив $data выдает ошибку.
UPD!
Ошибка вылетает в другом месте с тем же PDO не че все не так
код вот такой:
for ($i=0; $i < rand(1,6); $i++) {
$authLoginData['randomHash'] = md5(md5(generateCode(rand(1,32).WEBSITESOLT)));
}
$sqls = "UPDATE `users` SET `user_hash`= ?,`user_last_visit`= ?, `user_ip`= ? WHERE user_id = ? ";
$Ndata['hash_'] = $authLoginData['randomHash'];
$Ndata['visit_'] = time();
$Ndata['ip_'] = $this->filteringData($_SERVER['REMOTE_ADDR']);
$Ndata['id_'] = intval($result['user_id']);
$resultat = $this->queryExec($sql, $Ndata)->fetch();
// Проверяем, если SQL код не исполнился выводим ошибку!
if (!$resultat) {
$this->errors[] = $this->lang['error_SQL_update_data'];
return false;
} else {
$this->errors['first'] = $this->lang['welcome_msg'];
В запросе выдает ошибку
Fatal error: Uncaught exception 'PDOException' with message 'SQLSTATE[HY093]: Invalid parameter number: number of bound variables does not match number of tokens' in /Users/userName/Sites/board_php/classes/connection.php:73 Stack trace: #0 /Users/userName/Sites/board_php/classes/connection.php(73): PDOStatement->execute(Array) #1 /Users/userName/Sites/board_php/classes/users.class.php(71): Connection->queryExec('SELECT `user_id...', Array) #2 /Users/userName/Sites/board_php/controllers/loginController.php(27): Users->loginAction() #3 /Users/userName/Sites/board_php/routers/loginRoute.php(11): LoginController->loginAction() #4 /Users/userName/Sites/board_php/login.php(31): require_once('/Users/userName/Si...') #5 {main} thrown in /Users/userName/Sites/board_php/classes/connection.php on line 73
WTF?????
$sql = "UPDATE users_online SET time='?', ip='?' WHERE session = '?'";