H Упрощение запросов PDO в черновиках Recovery Mode

Добрый день. Хочу рассказать свой метод работы с PDO. Работать с PDO довольно безопасно чем стандартными средствами но не очень удобно записывать/обновлять большие массивы данных.

Простой запрос PDO, это уже четыре строчки.

$sql = "SELECT * FROM `table` WHERE `id` = '1'";
$st = $DB->query($sql);
$st>setFetchMode(PDO::FETCH_OBJ);
$list = $st>fetch(PDO::FETCH_ASSOC);

А запись данных так вообще как одни том книги «Война и мир», и это еще короткий запрос.

$sql = "INSERT INTO `users` (`email`, `password`, `registration`, `userkod`) VALUES (:email, :password, :registration, :userkod)";
$st = $DB->prepare($sql);
$st->bindValue(":email", $email, PDO::PARAM_STR);
$st->bindValue(":password", $insert_passwrd, PDO::PARAM_STR);
$st->bindValue(":registration", $data, PDO::PARAM_STR);
$st->bindValue(":userkod", $userkod, PDO::PARAM_STR);
$st->execute();

Не буду таить греха но такие я “Копипастю”.

После долгих мучений решил упростить запрос путем написание класса c функцмями SELECT, INSERT, UPDATE

Создадим класс и вставим в него приведенные ниже функции

class DB {
}

SELECT

/*
*  $sql - это запрос к базе
*  $fetch - тип получения результата из базы
*/
function select($sql, $fetch=””){
	//в файле index мы подключемся к БД (можно реализовать несколькими путями, я же создал глобальную переменую)
        global $DB; 

        $st = $DB->query($sql);
        $st->setFetchMode(PDO::FETCH_OBJ);
        if($fetch == '' || $fetch == 'row'){
	    //Возвращает строку
            $fetch_fn = 'fetch';
        }elseif($fetch == 'all'  || $fetch == 'fetchAll'){
	    //Возвращает массив
            $fetch_fn = 'fetchAll';
        }else{
            //вернет ошибку с указанием на неправильный параметр
	    return 'error $fetch';
        }
        //выполняем запрос и возвращаем ответ, за одно решил возвращать и количество строк
        return array('return'=>$st->$fetch_fn(PDO::FETCH_ASSOC), 'count'=>$st->rowCount());
}

Эта функция возвращает результат запроса и количество строк
Теперь запрос выглядит так, намного легче. Правда пришлось отказаться от bindValue, хотя я думаю это не особо критично будет.
$sql = «SELECT * FROM `table` WHERE `id` = '1'»;
$return = DB::select($sql);

INSERT

/*
*  $sql - это запрос к базе
*  $fetch - массив данных где ключами являются колонки в записываемой таблице
*/
function insert($sql, array $data) {
       //в файле index мы подключаемся к БД (можно реализовать несколькими путями, я же создал глобальную переменную)
       global $DB;

       //Проверяем на присутствие всех данных
       if(empty($sql) || empty($data)){
           return false;
       }

       //Создаем два массива с ключами в разном формате
       foreach ($data as $key => $value) {
           $set1[] = "`$key`";
           $set2[] = ":$key";
       }
        
       //Переводим массивы в строку
       $set1_str = implode(', ', $set1);
       $set2_str = implode(', ', $set2);

       //Две строки сливаем в элемент запроса
       $set_str = '('.$set1_str.') VALUES ('.$set2_str.')';

       //заменяем псевдопеременную ?set в запросе на созданный элемент
       $sql = preg_replace("#\?set#is", $set_str, $sql);
       $st = $DB->prepare($sql);

       //Создаем bindValue по ключам и значениям
       foreach ($data as $key => $value) {
           $st->bindValue(":$key", $value);
       }
       //выполняем запрос и возвращаем ответ
       return array('return'=>$st->execute(), 'id'=>$DB->lastInsertId());
}

А в этом запросе bindValue реализованы и создаются путем перебора ключей и значений.

$coll["name"] = $_POST[name];
$coll["email"] = $_POST[email];
$coll["password"] = $_POST[password];
$coll["dateCreated"] = date("Y-m-d H:i:s");
    
$sql = "INSERT INTO `users` ?set";
$return = DB::insert($sql, $coll);

UPDATE

/*
*  $sql - это запрос к базе
*  $fetch - массив данных где ключами являются колонки в обновляемой таблице
*/
function update($sql, array $data) {
        //в файле index мы подключаемся к БД (можно реализовать несколькими путями, я же создал глобальную переменную)
        global $DB;

        //Проверяем на присутствие всех данных
        if(empty($sql) || empty($data)){
            return false;
        }
        //создаем массив с элементами ключей
        foreach ($data as $key => $value) {
            $set[] = "`$key`=:$key";
        }
        //переводим массив в строку
        $set_str = implode(', ', $set);

        //заменяем псевдопеременную ?set в запросе на созданный элемент
        $sql = preg_replace("#\?set#is", $set_str, $sql);
        $st = $DB->prepare($sql);

        //Создаем bindValue по ключам и значениям
        foreach ($data as $key => $value) {
            $st->bindValue(":$key", $value);
        }
        //выполняем запрос и возвращаем ответ
        return array('return'=>$st->execute());
}

При таком подходе мы можем перезаписывать большие формы (мне приходилось работать с анкетами состоящими из >50 полей и хранящимися в одной таблице и поверьте это не очень весело)

Пример:
$data[‘name’] = “Иван”;
$data[‘family’] = “Иванов”;
$sql = «UPDATE `users` SET ?set WHERE `id`='$id' LIMIT 1»;
$retDB = DB::update($sql, $data);

Вот в общем то и все. Надеюсь что хоть кому то пригодится эта статья

$sql = "INSERT INTO `users` (`email`, `password`, `registration`, `userkod`) VALUES (:email, :password, :registration, :userkod)";
$st = $DB->prepare($sql); $st->execute([":email"=>$email,":password"=>$insert_passwrd,":registration"=>$data,":userkod"=>$userkod]);

$sql = "INSERT INTO `users` (`email`, `password`, `registration`, `userkod`) VALUES (:email, :password, :registration, :userkod)";
 $DB->prepare($sql)->execute([":email"=>$email,":password"=>$insert_passwrd,":registration"=>$data":userkod"=>$userkod]);

$sql = "INSERT INTO `users` (`email`, `password`, `registration`, `userkod`) VALUES (:email, SHA1(:password), :registration, :userkod)";
 $DB->prepare($sql)->execute([":email"=>$email,":password"=>$insert_passwrd,":registration"=>$data,":userkod"=>$userkod]);

$sql = "SELECT * FROM `table` WHERE `id` = '1'";
$one = $DB->query($sql)->fetch(PDO::FETCH_ASSOC);

$sql = "INSERT INTO `users` (`email`, `password`, `registration`, `userkod`) VALUES (:email, :password, :registration, :userkod)";
 $DB->prepare($sql)->execute([":email"=>$email,":password"=>$insert_passwrd,":registration"=>$data,":userkod"=>$userkod]);

$sql = «UPDATE `users` SET ?set WHERE `id`='$id' LIMIT 1»; 

$sql = "INSERT INTO `users` (`email`, `password`, `registration`, `userkod`) VALUES (?, SHA1(?), ?, ?)";
 $DB->prepare($sql)->execute([$email,$insert_passwrd,$data,$userkod]);

$data[‘name’] = “Иван”;
$data[‘family’] = “Иванов”;
$retDB = DB::update('users', $data); 

$st->setFetchMode(PDO::FETCH_OBJ);

$st->$fetch_fn(PDO::FETCH_ASSOC)

$collections = $sql->reset()->select('collections', 'collections.*')
    ->joinOn('brands', 'brands.id = collections.id_brand AND brands.visible')
    ->where('collections.visible')
    ->group('collections.id')
    ->order('brands.fullname, collections.fullname')
    ->fetchAll();
/* ... */
$this->sql->reset()
  ->update( 'postRates' )
  ->set([
    'postRateValue' => $rate,
    'postRateDate'  => $this->date()
  ])
  ->where->eq([
    static::$ID   => $id,
    'id_profiles' => $idProfiles
  ])
  ->execute();

$delete = Delete::getInstance()->table('people')->where('name', '=', 'ivan')->create('OID', '<', '5')->orC('OID', '>', '10')->last('AND')->delete->get();
echo $delete->interpretation('mysql);