lib/DB.php

   1 <?php
   2
   3 namespace Nominatim;
   4
   5 require_once(CONST_BasePath.'/lib/DatabaseError.php');
   6
   7 /**
   8  * Uses PDO to access the database specified in the CONST_Database_DSN
   9  * setting.
  10  */
  11 class DB
  12 {
  13     protected $connection;
  14
  15     public function __construct($sDSN = CONST_Database_DSN)
  16     {
  17         $this->sDSN = $sDSN;
  18     }
  19
  20     public function connect($bNew = false, $bPersistent = true)
  21     {
  22         if (isset($this->connection) && !$bNew) {
  23             return true;
  24         }
  25         $aConnOptions = array(
  26                          \PDO::ATTR_ERRMODE            => \PDO::ERRMODE_EXCEPTION,
  27                          \PDO::ATTR_DEFAULT_FETCH_MODE => \PDO::FETCH_ASSOC,
  28                          \PDO::ATTR_PERSISTENT         => $bPersistent
  29         );
  30
  31         // https://secure.php.net/manual/en/ref.pdo-pgsql.connection.php
  32         try {
  33             $conn = new \PDO($this->sDSN, null, null, $aConnOptions);
  34         } catch (\PDOException $e) {
  35             $sMsg = 'Failed to establish database connection:' . $e->getMessage();
  36             throw new \Nominatim\DatabaseError($sMsg, 500, null, $e->getMessage());
  37         }
  38
  39         $conn->exec("SET DateStyle TO 'sql,european'");
  40         $conn->exec("SET client_encoding TO 'utf-8'");
  41         $iMaxExecution = ini_get('max_execution_time');
  42         if ($iMaxExecution > 0) $conn->setAttribute(\PDO::ATTR_TIMEOUT, $iMaxExecution); // seconds
  43
  44         $this->connection = $conn;
  45         return true;
  46     }
  47
  48     // returns the number of rows that were modified or deleted by the SQL
  49     // statement. If no rows were affected returns 0.
  50     public function exec($sSQL, $aInputVars = null, $sErrMessage = 'Database query failed')
  51     {
  52         $val = null;
  53         try {
  54             if (isset($aInputVars)) {
  55                 $stmt = $this->connection->prepare($sSQL);
  56                 $stmt->execute($aInputVars);
  57             } else {
  58                 $val = $this->connection->exec($sSQL);
  59             }
  60         } catch (\PDOException $e) {
  61             throw new \Nominatim\DatabaseError($sErrMessage, 500, null, $e, $sSQL);
  62         }
  63         return $val;
  64     }
  65
  66     /**
  67      * Executes query. Returns first row as array.
  68      * Returns false if no result found.
  69      *
  70      * @param string  $sSQL
  71      *
  72      * @return array[]
  73      */
  74     public function getRow($sSQL, $aInputVars = null, $sErrMessage = 'Database query failed')
  75     {
  76         try {
  77             $stmt = $this->getQueryStatement($sSQL, $aInputVars, $sErrMessage);
  78             $row = $stmt->fetch();
  79         } catch (\PDOException $e) {
  80             throw new \Nominatim\DatabaseError($sErrMessage, 500, null, $e, $sSQL);
  81         }
  82         return $row;
  83     }
  84
  85     /**
  86      * Executes query. Returns first value of first result.
  87      * Returns false if no results found.
  88      *
  89      * @param string  $sSQL
  90      *
  91      * @return array[]
  92      */
  93     public function getOne($sSQL, $aInputVars = null, $sErrMessage = 'Database query failed')
  94     {
  95         try {
  96             $stmt = $this->getQueryStatement($sSQL, $aInputVars, $sErrMessage);
  97             $row = $stmt->fetch(\PDO::FETCH_NUM);
  98             if ($row === false) return false;
  99         } catch (\PDOException $e) {
 100             throw new \Nominatim\DatabaseError($sErrMessage, 500, null, $e, $sSQL);
 101         }
 102         return $row[0];
 103     }
 104
 105     /**
 106      * Executes query. Returns array of results (arrays).
 107      * Returns empty array if no results found.
 108      *
 109      * @param string  $sSQL
 110      *
 111      * @return array[]
 112      */
 113     public function getAll($sSQL, $aInputVars = null, $sErrMessage = 'Database query failed')
 114     {
 115         try {
 116             $stmt = $this->getQueryStatement($sSQL, $aInputVars, $sErrMessage);
 117             $rows = $stmt->fetchAll();
 118         } catch (\PDOException $e) {
 119             throw new \Nominatim\DatabaseError($sErrMessage, 500, null, $e, $sSQL);
 120         }
 121         return $rows;
 122     }
 123
 124     /**
 125      * Executes query. Returns array of the first value of each result.
 126      * Returns empty array if no results found.
 127      *
 128      * @param string  $sSQL
 129      *
 130      * @return array[]
 131      */
 132     public function getCol($sSQL, $aInputVars = null, $sErrMessage = 'Database query failed')
 133     {
 134         $aVals = array();
 135         try {
 136             $stmt = $this->getQueryStatement($sSQL, $aInputVars, $sErrMessage);
 137
 138             while (($val = $stmt->fetchColumn(0)) !== false) { // returns first column or false
 139                 $aVals[] = $val;
 140             }
 141         } catch (\PDOException $e) {
 142             throw new \Nominatim\DatabaseError($sErrMessage, 500, null, $e, $sSQL);
 143         }
 144         return $aVals;
 145     }
 146
 147     /**
 148      * Executes query. Returns associate array mapping first value to second value of each result.
 149      * Returns empty array if no results found.
 150      *
 151      * @param string  $sSQL
 152      *
 153      * @return array[]
 154      */
 155     public function getAssoc($sSQL, $aInputVars = null, $sErrMessage = 'Database query failed')
 156     {
 157         try {
 158             $stmt = $this->getQueryStatement($sSQL, $aInputVars, $sErrMessage);
 159
 160             $aList = array();
 161             while ($aRow = $stmt->fetch(\PDO::FETCH_NUM)) {
 162                 $aList[$aRow[0]] = $aRow[1];
 163             }
 164         } catch (\PDOException $e) {
 165             throw new \Nominatim\DatabaseError($sErrMessage, 500, null, $e, $sSQL);
 166         }
 167         return $aList;
 168     }
 169
 170     /**
 171      * Executes query. Returns a PDO statement to iterate over.
 172      *
 173      * @param string  $sSQL
 174      *
 175      * @return PDOStatement
 176      */
 177     public function getQueryStatement($sSQL, $aInputVars = null, $sErrMessage = 'Database query failed')
 178     {
 179         try {
 180             if (isset($aInputVars)) {
 181                 $stmt = $this->connection->prepare($sSQL);
 182                 $stmt->execute($aInputVars);
 183             } else {
 184                 $stmt = $this->connection->query($sSQL);
 185             }
 186         } catch (\PDOException $e) {
 187             throw new \Nominatim\DatabaseError($sErrMessage, 500, null, $e, $sSQL);
 188         }
 189         return $stmt;
 190     }
 191
 192     /**
 193      * St. John's Way => 'St. John\'s Way'
 194      *
 195      * @param string  $sVal  Text to be quoted.
 196      *
 197      * @return string
 198      */
 199     public function getDBQuoted($sVal)
 200     {
 201         return $this->connection->quote($sVal);
 202     }
 203
 204     /**
 205      * Like getDBQuoted, but takes an array.
 206      *
 207      * @param array  $aVals  List of text to be quoted.
 208      *
 209      * @return array[]
 210      */
 211     public function getDBQuotedList($aVals)
 212     {
 213         return array_map(function ($sVal) {
 214             return $this->getDBQuoted($sVal);
 215         }, $aVals);
 216     }
 217
 218     /**
 219      * [1,2,'b'] => 'ARRAY[1,2,'b']''
 220      *
 221      * @param array  $aVals  List of text to be quoted.
 222      *
 223      * @return string
 224      */
 225     public function getArraySQL($a)
 226     {
 227         return 'ARRAY['.join(',', $a).']';
 228     }
 229
 230     /**
 231      * Check if a table exists in the database. Returns true if it does.
 232      *
 233      * @param string  $sTableName
 234      *
 235      * @return boolean
 236      */
 237     public function tableExists($sTableName)
 238     {
 239         $sSQL = 'SELECT count(*) FROM pg_tables WHERE tablename = :tablename';
 240         return ($this->getOne($sSQL, array(':tablename' => $sTableName)) == 1);
 241     }
 242
 243     /**
 244     * Check if an index exists in the database. Optional filtered by tablename
 245     *
 246     * @param string  $sTableName
 247     *
 248     * @return boolean
 249     */
 250     public function indexExists($sIndexName, $sTableName = null)
 251     {
 252         return in_array($sIndexName, $this->getListOfIndices($sTableName));
 253     }
 254
 255     /**
 256     * Returns a list of index names in the database, optional filtered by tablename
 257     *
 258     * @param string  $sTableName
 259     *
 260     * @return array
 261     */
 262     public function getListOfIndices($sTableName = null)
 263     {
 264         //  table_name            | index_name                      | column_name
 265         // -----------------------+---------------------------------+--------------
 266         //  country_name          | idx_country_name_country_code   | country_code
 267         //  country_osm_grid      | idx_country_osm_grid_geometry   | geometry
 268         //  import_polygon_delete | idx_import_polygon_delete_osmid | osm_id
 269         //  import_polygon_delete | idx_import_polygon_delete_osmid | osm_type
 270         //  import_polygon_error  | idx_import_polygon_error_osmid  | osm_id
 271         //  import_polygon_error  | idx_import_polygon_error_osmid  | osm_type
 272         $sSql = <<< END
 273 SELECT
 274     t.relname as table_name,
 275     i.relname as index_name,
 276     a.attname as column_name
 277 FROM
 278     pg_class t,
 279     pg_class i,
 280     pg_index ix,
 281     pg_attribute a
 282 WHERE
 283     t.oid = ix.indrelid
 284     and i.oid = ix.indexrelid
 285     and a.attrelid = t.oid
 286     and a.attnum = ANY(ix.indkey)
 287     and t.relkind = 'r'
 288     and i.relname NOT LIKE 'pg_%'
 289     FILTERS
 290  ORDER BY
 291     t.relname,
 292     i.relname,
 293     a.attname
 294 END;
 295
 296         $aRows = null;
 297         if ($sTableName) {
 298             $sSql = str_replace('FILTERS', 'and t.relname = :tablename', $sSql);
 299             $aRows = $this->getAll($sSql, array(':tablename' => $sTableName));
 300         } else {
 301             $sSql = str_replace('FILTERS', '', $sSql);
 302             $aRows = $this->getAll($sSql);
 303         }
 304
 305         $aIndexNames = array_unique(array_map(function ($aRow) {
 306             return $aRow['index_name'];
 307         }, $aRows));
 308         sort($aIndexNames);
 309
 310         return $aIndexNames;
 311     }
 312
 313     /**
 314      * Since the DSN includes the database name, checks if the connection works.
 315      *
 316      * @return boolean
 317      */
 318     public function databaseExists()
 319     {
 320         $bExists = true;
 321         try {
 322             $this->connect(true);
 323         } catch (\Nominatim\DatabaseError $e) {
 324             $bExists = false;
 325         }
 326         return $bExists;
 327     }
 328
 329     /**
 330      * e.g. 9.6, 10, 11.2
 331      *
 332      * @return float
 333      */
 334     public function getPostgresVersion()
 335     {
 336         $sVersionString = $this->getOne('SHOW server_version_num');
 337         preg_match('#([0-9]?[0-9])([0-9][0-9])[0-9][0-9]#', $sVersionString, $aMatches);
 338         return (float) ($aMatches[1].'.'.$aMatches[2]);
 339     }
 340
 341     /**
 342      * e.g. 2, 2.2
 343      *
 344      * @return float
 345      */
 346     public function getPostgisVersion()
 347     {
 348         $sVersionString = $this->getOne('select postgis_lib_version()');
 349         preg_match('#^([0-9]+)[.]([0-9]+)[.]#', $sVersionString, $aMatches);
 350         return (float) ($aMatches[1].'.'.$aMatches[2]);
 351     }
 352
 353     public static function parseDSN($sDSN)
 354     {
 355         // https://secure.php.net/manual/en/ref.pdo-pgsql.connection.php
 356         $aInfo = array();
 357         if (preg_match('/^pgsql:(.+)$/', $sDSN, $aMatches)) {
 358             foreach (explode(';', $aMatches[1]) as $sKeyVal) {
 359                 list($sKey, $sVal) = explode('=', $sKeyVal, 2);
 360                 if ($sKey == 'host') $sKey = 'hostspec';
 361                 if ($sKey == 'dbname') $sKey = 'database';
 362                 if ($sKey == 'user') $sKey = 'username';
 363                 $aInfo[$sKey] = $sVal;
 364             }
 365         }
 366         return $aInfo;
 367     }
 368 }