auth/base: PDO

[tt-rss.git] / include / functions.php

diff --git a/include/functions.php b/include/functions.php
index 07f4f0f641023488d5aca5ba2720485ba8444c07..e7d74df04e23727b33c30c9e5d86f351ad38edec 100644 (file)
--- a/include/functions.php
+++ b/include/functions.php
@@ -266,8 +266,8 @@
                                marked = false AND
                                feed_id = ? AND
                                $query_limit
-                               ttrss_entries.date_updated < NOW() - INTERVAL ?");
-                       $sth->execute([$feed_id, "$purge_interval days"]);
+                               ttrss_entries.date_updated < NOW() - INTERVAL ? days");
+                       $sth->execute([$feed_id, $purge_interval]);
 
                } else {
             $sth  = $pdo->prepare("DELETE FROM ttrss_user_entries
@@ -591,10 +591,10 @@
 
                if (get_schema_version() < 63) $profile_qpart = "";
 
-               ////db_query("BEGIN");
-
         $pdo = DB::pdo();
 
+        $pdo->beginTransaction();
+
                $sth = $pdo->query("SELECT pref_name,def_value FROM ttrss_prefs");
 
         $profile = $profile ? $profile : null;
@@ -633,7 +633,7 @@
                        }
                }
 
-               ////db_query("COMMIT");
+               $pdo->commit();
 
        }
 
@@ -1952,11 +1952,10 @@
 
                if (!$feed_cat) return false;
 
-               ////db_query("BEGIN");
-
                $feed_cat = mb_substr($feed_cat, 0, 250);
 
                $pdo = Db::pdo();
+               $pdo->beginTransaction();
 
                $sth = $pdo->prepare("SELECT id FROM ttrss_feed_categories
                                WHERE (:parent IS NULL AND parent_cat IS NULL OR parent_cat = :parent) 
@@ -1969,11 +1968,13 @@
                                        VALUES (?, ?, ?)");
                        $sth->execute([$_SESSION['uid'], $feed_cat, $parent_cat_id]);
 
-                       //db_query("COMMIT");
+                       $pdo->commit();
 
                        return true;
                }
 
+        $pdo->commit();
+
                return false;
        }