PDO выборка из базы и подсчет результатов?

Question

[kr_ilya]

Недавно начал изучать pdo. Необходимо сделать выборку из бд и определить имеется ли поле с указанными данными. Запрос:

$f_sql = 'SELECT COUNT(*) FROM db_users_a WHERE user = ?';
						$f_arr = array($login);
						$frow = $db->FetchRow($f_sql, $f_arr);
						if ($frow == 0) {
//если юзера с таким логином нет, то регаем

Функция:

public function FetchRow($f_sql, $f_arr){
	(36)	$f_row = $this->pdo->prepare($f_sql);
	(37)	$f_row->execute($f_arr);
	(38) 	$res = $this->pdo->query($f_row);	 	
	(39)  return ($res->fetchColumn() > 1) ? $res :  $res[0];
	}

Ошибка:

Warning:  PDO::query() expects parameter 1 to be string, object given in E:\OSPanel\domains\test.ru\classes\_new.db.php on line 38

Fatal error:  Uncaught Error: Call to a member function fetchColumn() on boolean in E:\OSPanel\domains\test.ru\classes\_new.db.php:39
Stack trace:
#0 E:\OSPanel\domains\test.ru\api\ajax.php(30): db->FetchRow('SELECT COUNT(*)...', Array)
#1 {main}
  thrown in E:\OSPanel\domains\test.ru\classes\_new.db.php on line 39

Спасибо!

Answer 1

[Юнус Газиев]

Главная ошибка начинающих, это паника во время ошибки.
Вчитывайтесь в лог ошибки, он вам помогает.

PDO::query() expects parameter 1 to be string, object given
db->FetchRow('SELECT COUNT(*)...', Array)

$f_arr = array($login); в $login что прилетает, какого типа? (var_dump($login))

Вот хорошая статья для изучения Как работать с PDO? Полное руководство.

Comments

[kr_ilya]

string(9) "testlogin"

[FanatPHP]

Да читал он эту статью, судя по коду. Только она ему не помогает абсолютно. Потому что его метод программирования - написать наугад несколько операторов в случайном порядке, а потом идти на Тостер спрашивать, что с ними не так.

[FanatPHP]

И, строго говоря, читать надо не только текст ошибки, но и строку на которую она указывает. поскльку дело не в $login, а в $f_row (и общей бессмысленности кода)

[kr_ilya]

FanatPHP, ну, гений, блесни умом. Что тебе не нравиться полностью в коде или что бы ты поменял:

<?php
error_reporting(E_ALL);
ini_set('display_errors', 1);
@session_start();
if(isset($_SESSION["user_id"])){ Header("Location: /account"); return; }
function __autoload($name){ include($_SERVER['DOCUMENT_ROOT']."/classes/_new.".$name.".php");}
$func = new func();
$config = new config;
$db = new db($config);
$login = htmlentities($_POST["login"], ENT_QUOTES); //фильтрация логина
$pass = htmlentities($_POST["password"], ENT_QUOTES); //фильтрация пароля
$password = $func->IsPassword($pass); //валиация пароля (длина)
$hash1 = $func->md5Password($password); //хэш пароля
$r_pass = htmlentities($_POST["reppass"], ENT_QUOTES); //фильтрация повтора пароля
$hash2 = $func->md5Password($r_pass); //хэш повтора пароля
$email = htmlentities($_POST["email"], ENT_QUOTES); //фильтрация email
$login2 = $func->IsLogin($login); //валидация логина
$time = time();
$referer_id = (isset($_COOKIE["i"]) AND intval($_COOKIE["i"]) > 0 AND intval($_COOKIE["i"]) < 1000000) ? intval($_COOKIE["i"]) : 1;
$referer= "";
if($referer_id != 1){
	$f_sql = "SELECT user FROM db_users_a WHERE id = ? LIMIT ?";
	$f_arr = array($referer_id, 1);
	$ref = $db->FetchColumn($f_sql, $f_arr);
	if (!$ref){
		$referer_id = 1; $referer = "Admin";
	}else{$referer = $ref;}
}else{ $referer_id = 1; $referer = "Admin"; }
$ip2 = ip2long($func->UserIP); //ip юзера
if (isset($login) && isset($pass) && isset($email) && isset($r_pass)) {
	if (!empty($login && $pass && $email && $r_pass)) {
		if (filter_var($email, FILTER_VALIDATE_EMAIL) !== false) { //валидация email
			if ($login2 !== false) {
				if ($password !== false) {
					if ($hash1 === $hash2) {
						$f_sql = 'SELECT COUNT(*) FROM db_users_a WHERE email = ?';
						$f_arr = array($email);
						$frow = $db->FetchColumn($f_sql, $f_arr);
						if (!$frow) { //если email не зарегистрирован, продолжаем
							$f_sql = 'SELECT COUNT(*) FROM db_users_a WHERE user = ?';
							$f_arr = array($login);
							$frow = $db->FetchColumn($f_sql, $f_arr);
							if (!$frow) { //если логин не занят, продолжаем
								$sql='INSERT INTO db_users_a (user, email, pass, referer, referer_id, date_reg, date_login, ip) 
								VALUES (?, ?, ?, ?, ?, ?, ?, ?)';
								$arr = array($login, $email, $hash1, $referer, $referer_id, $time, $time, $ip2);
								$db->prep($sql, $arr); //добавляем в бд #1
								$f_sql = "SELECT id FROM db_users_a WHERE email = ?";
								$f_arr = array($email);
								$id = $db->FetchColumn($f_sql, $f_arr); //получаем id
								$sql='INSERT INTO db_users_b (id, user) VALUES (?, ?)';
								$arr = array($id, $login);
								$db->prep($sql, $arr);//добавляем в бд #2
								$_SESSION["user_id"] = $id; //авторизируем
								$_SESSION["user"] = $login;
								$_SESSION["referer_id"] = $referer_id;
								$result["error"] = false;
								$result["title"] = 'Успех';
								$result["message"] = 'Вы успешно зарегистрировались';
								$result["type"] = 'success';
							}else{ $result["title"] = 'Ошибка'; $result["error"] = true; $result["message"] = 'Логин занят'; $result["type"] = 'error'; }
						}else{ $result["title"] = 'Ошибка'; $result["error"] = true; $result["message"] = 'Email уже зарегистрирован'; $result["type"] = 'error'; }	
					}else{ $result["title"] = 'Ошибка'; $result["error"] = true; $result["message"] = 'Пароли не совпадают'; $result["type"] = 'error'; }
				}else{ $result["title"] = 'Ошибка'; $result["error"] = true; $result["message"] = 'Некорректный пароль'; $result["type"] = 'error'; }
			}else{ $result["title"] = 'Ошибка'; $result["error"] = true; $result["message"] = 'Некорректный логин'; $result["type"] = 'error'; }
		}else{ $result["title"] = 'Ошибка'; $result["error"] = true; $result["message"] = 'Некорректный Email'; $result["type"] = 'error'; }
	}else{ $result["title"] = 'Ошибка'; $result["error"] = true; $result["message"] = 'Заполнены не все поля!'; $result["type"] = 'error'; }
}else{ $result["title"] = 'Ошибка'; $result["error"] = true; $result["message"] = 'Заполнены не все поля!'; $result["type"] = 'error'; }
echo json_encode($result);
?>

PS: знаю, что есть php функция шифрования пароля, сейчас собирался менять.
Недописанный класс:

<?PHP
error_reporting(E_ALL);
ini_set('display_errors', 1);
class db{
	private $config;
	private $pdo;
  public function __construct(Config $config)
  {
  	$this->config = $config;
  	$this->connect();
  }

  private function connect()
  {
  	$host = $this->config->host;
  	$dbname = $this->config->base;
 	$charset = $this->config->charset;
 	$user = $this->config->user;
 	$pass = $this->config->pass;
  	$dsn = "mysql:host=$host;dbname=$dbname;charset=$charset";
  	$opt = [
        PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
        PDO::ATTR_EMULATE_PREPARES   => false,
    ];
	 $this->pdo = $pdo = new PDO($dsn, $user, $pass, $opt);
  	return $this;
  }

  public function prep($sql, $arr)
  {
  	$stmt = $this->pdo->prepare($sql);
  	return $stmt->execute($arr);
  }

  public function FetchColumn($f_sql, $f_arr)
  {
		$f_row = $this->pdo->prepare($f_sql);
		$f_row->execute($f_arr);	 	
	 	return $res = $f_row->fetchColumn();
	}

  public  function Fetch($fsql, $farr)
  {
    $fet = $this->pdo->prepare($fsql);
    $fet->execute($farr);    
    return $fres = $fet->fetch();
  }
}

?>

[Юнус Газиев]

Energy2, codestyle точно надо менять.

[FanatPHP]

Я действительно, если пользоваться твоей терминологией, "гений": ты учишься делать первые шаги в программировании по моим статьям, многие из которых написаны еще тогда, когда ты пешком под стол ходил.

И я обычно с удовольствием помогаю новичкам, разбирая ошибки в их коде.

Но. Тебе следует научиться тому, как правильно общаться с людьми. Обращение вида "ну, гений, блесни умом" уместно в разговоре с приятелем в подворотне. Пытаясь же таким образом получить безвозмездную помощь от незнакомого человека, ты в лучшем случае получишь в ответ недоуменное пожатие плечами.

[kr_ilya]

FanatPHP, прошу прощения, я слегка вышел из себя. :)
(нет, серьёзно, я обычно культурно общаюсь, но тут, видимо что-то пошло не так... Я благодарен и уважаю тебя и таких людей, как ты, за то что не проходите мимо в трудной ситуации. Спасибо)

Answer 2

[kr_ilya]

Разобрался, рабочий вариант:

public function FetchRow($f_sql, $f_arr){
		$f_row = $this->pdo->prepare($f_sql);
		$f_row->execute($f_arr);	 	
	 	return $res = $f_row->fetchColumn();
	}

Comments

[FanatPHP]

Этот вариант функции FetchRow такой же бессмысленный, как и предыдущий. Функция с таким названием должна возвращать row, то есть строку, а не единственное значение. Я уважаю твое упорство в написании класса для работы с бд обладая нулевыми знаниями как в классах,так и в бд, но вот упорство в игнорировании ответов, которые тебе пишут - это не то чем тебе стоит гордиться.

[kr_ilya]

FanatPHP, я разве игнорирую? Название поменять не долго. Это название осталось от прошлого кода. Тобиш я скрипт потихиньку перевожу на pdo. Спасибо за критику) + ТОЛЬКО в вышеописанном контексте эта функция возвращает единственное значение.