]> git.wh0rd.org - tt-rss.git/blobdiff - classes/dbupdater.php
remove $link
[tt-rss.git] / classes / dbupdater.php
index a9a7132735f268c3e94138ab626c97bd5d322331..ffcac7cf7cc3e7a686480b8476df60d5535bbf43 100644 (file)
@@ -1,18 +1,18 @@
 <?php
 class DbUpdater {
 
-       private $link;
+       private $dbh;
        private $db_type;
        private $need_version;
 
-       function __construct($link, $db_type, $need_version) {
-               $this->link = $link;
+       function __construct($dbh, $db_type, $need_version) {
+               $this->dbh = $dbh;
                $this->db_type = $db_type;
                $this->need_version = (int) $need_version;
        }
 
        function getSchemaVersion() {
-               $result = db_query($this->link, "SELECT schema_version FROM ttrss_version");
+               $result = db_query( "SELECT schema_version FROM ttrss_version");
                return (int) db_fetch_result($result, 0, "schema_version");
        }
 
@@ -37,21 +37,21 @@ class DbUpdater {
 
                        if (is_array($lines)) {
 
-                               db_query($this->link, "BEGIN");
+                               db_query( "BEGIN");
 
                                foreach ($lines as $line) {
                                        if (strpos($line, "--") !== 0 && $line) {
-                                               db_query($this->link, $line);
+                                               db_query( $line);
                                        }
                                }
 
                                $db_version = $this->getSchemaVersion();
 
                                if ($db_version == $version) {
-                                       db_query($this->link, "COMMIT");
+                                       db_query( "COMMIT");
                                        return true;
                                } else {
-                                       db_query($this->link, "ROLLBACK");
+                                       db_query( "ROLLBACK");
                                        return false;
                                }
                        } else {