gXbfB#) ۻbis_IIߪ ۻbis_IIߪ ۻbis_IIߪ ۻbis_II4&D.5;Aϳކ:}Wۻp%7ޔ_#5L@?ss\,fa\eChɛ+MMX,-\_[6Eq_uC^avh ->]+/Wg׿>|"d2D^1=]mwgFN5K]OElf5F \wgFN5K]OwgFN5K]OwgFN5K]O[_׮|S 6 iS&XVŰįwgFN5K]OwgFN5K]OwgFN5K]O7XxKѨ#TKl]-ފ@έlJwh(B_;R0ԉ"T L"z{P36ocFHsGej|{ZewgFN5K]OwgFN5K]O{[SԥRYcxsc!^C ۻbis_IIߪ ۻbis_IIߪ ۻbis_II߸Hh)+|J &O9VCdt{g6}D #F _PRMwgFN5K]OT y/5Oڪ ۻbis_IIߪ ۻbis_IIߪ ۻbis_II=o@h7p̢V:q۪ 9Z6ZlX_S)V0AE 9B!U! Σr#ʞTQ |gTO= Y-mi?r-" } EjB]N,JaOc]IAsN,Y)-A30V\[M靖URM&C5V _1-O--cL+ `hlﰕk38XPF}QtЁzfi\Wf"h;|\+3sK%ͥNsu!v k-#DqXz)>ܷ7y_ R1vhJ[@%FSH?D[d39GY90Y#K"6U]Q7dg@TQzɸ{dEHn4INx$rm':Bc+@#F]9YxtflE'HI y5ٔ(=0 "MeFEWz=Dav>^hLW9S2dުD縷{C!<.K# Q&hJG)8;KGi\Yp0וJ~=J}m5?gՇ*SFa}vՒtE1J_ G2ZdU{@&?|KRISt(tPԙ"w =?BoGګ"D-t T F,r̀bjKJS*B,˭Vɮ<8ޅ]鴠dkF1LVaч{YB 14x/nudюS tίLuU*=FCb^3w̾)N F C d*.C5M"|!2!{!աkݒZ =>L,8!@t~{1`;ݨ(WdmwQYro;~P1VS6ڶ}!f)UE{Ԕ'833}sz^5*YzJrt"xGȢʬj+.`Յ2Kx?d`nD€ ŋrpvŇm ڞ֨@귴m:~MN* أs,{^4>?Fe( dA|t .B C~+۞؝F5~yRMlz|ByMtﶩĀE ␍&=ZhOi8ԻEVA~υPR=v֢(dHbB6csxh1%=[Ϟ #LS4G 8e)b@.2dުD縷{C!zĨr-+%1i?dւzu]$0)}2C蒾 K! iNDr3p:˻e!mB(wf%rc[ݾ`W3AЧ ߁:UT"-E_:ʰCWQBMvߤ0+"Lޚ vOp$dgȥQ̼j ?E6eީs8~Մ &U=69Q6)MuH6nR+ݴjs+ ۸q&^?P'Dh^yy epf` c-V$aA_:n/|KY>cUX[Qk>$@j3nzCiz@ABSx'^ _4t֯@)~qDd+Osh3$+xHs63Eo-}YyS:{В9MU"M%5;x4٨]Cb+twj>ֹڔtK}v ia"N{~^܉RT#:Ìϻrn/6F[U#YIи Xx;EUZ[}&>FP03 h0T&k)ܼw]7o#YY5R6z0e>8_\GÕhkWIz=xBZ@s҄"4ՐV)?_G73ծ&m $result = 'now()'; if ($interval) { $result .= ' ' . ($interval > 0 ? '+' : '-') . " interval '" . ($interval > 0 ? intval($interval) : intval($interval) * -1) . " seconds'"; } return $result; } /** * Return SQL statement for case insensitive LIKE * * @param string $column Field name * @param string $value Search value * * @return string SQL statement to use in query */ public function ilike($column, $value) { return $this->quote_identifier($column) . ' ILIKE ' . $this->quote($value); } /** * Get database runtime variables * * @param string $varname Variable name * @param mixed $default Default value if variable is not set * * @return mixed Variable value or default */ public function get_variable($varname, $default = null) { // There's a known case when max_allowed_packet is queried // PostgreSQL doesn't have such limit, return immediately if ($varname == 'max_allowed_packet') { return rcube::get_instance()->config->get('db_' . $varname, $default); } $this->variables[$varname] = rcube::get_instance()->config->get('db_' . $varname); if (!isset($this->variables)) { $this->variables = []; $result = $this->query('SHOW ALL'); while ($row = $this->fetch_array($result)) { $this->variables[$row[0]] = $row[1]; } } return $this->variables[$varname] ?? $default; } /** * INSERT ... ON CONFLICT DO UPDATE. * When not supported by the engine we do UPDATE and INSERT. * * @param string $table Table name (should be already passed via table_name() with quoting) * @param array $keys Hash array (column => value) of the unique constraint * @param array $columns List of columns to update * @param array $values List of values to update (number of elements * should be the same as in $columns) * * @return PDOStatement|bool Query handle or False on error * @todo Multi-insert support */ public function insert_or_update($table, $keys, $columns, $values) { // Check if version >= 9.5, otherwise use fallback if ($this->get_variable('server_version_num') < 90500) { return parent::insert_or_update($table, $keys, $columns, $values); } $columns = array_map([$this, 'quote_identifier'], $columns); $target = implode(', ', array_map([$this, 'quote_identifier'], array_keys($keys))); $cols = $target . ', ' . implode(', ', $columns); $vals = implode(', ', array_map(function($i) { return $this->quote($i); }, $keys)); $vals .= ', ' . rtrim(str_repeat('?, ', count($columns)), ', '); $update = implode(', ', array_map(function($i) { return "$i = EXCLUDED.$i"; }, $columns)); return $this->query("INSERT INTO $table ($cols) VALUES ($vals)" . " ON CONFLICT ($target) DO UPDATE SET $update", $values); } /** * Returns list of tables in a database * * @return array List of all tables of the current database */ public function list_tables() { // get tables if not cached if ($this->tables === null) { if (($schema = $this->options['table_prefix']) && $schema[strlen($schema)-1] === '.') { $add = " AND TABLE_SCHEMA = " . $this->quote(substr($schema, 0, -1)); } else { $add = " AND TABLE_SCHEMA NOT IN ('pg_catalog', 'information_schema')"; } $q = $this->query("SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES" . " WHERE TABLE_TYPE = 'BASE TABLE'" . $add . " ORDER BY TABLE_NAME"); $this->tables = $q ? $q->fetchAll(PDO::FETCH_COLUMN, 0) : []; } return $this->tables; } /** * Returns list of columns in database table * * @param string $table Table name * * @return array List of table cols */ public function list_cols($table) { $args = [$table]; if (($schema = $this->options['table_prefix']) && $schema[strlen($schema)-1] === '.') { $add = " AND TABLE_SCHEMA = ?"; $args[] = substr($schema, 0, -1); } else { $add = " AND TABLE_SCHEMA NOT IN ('pg_catalog', 'information_schema')"; } $q = $this->query("SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS" . " WHERE TABLE_NAME = ?" . $add, $args); if ($q) { return $q->fetchAll(PDO::FETCH_COLUMN, 0); } return []; } /** * Returns PDO DSN string from DSN array * * @param array $dsn DSN parameters * * @return string DSN string */ protected function dsn_string($dsn) { $params = []; $result = 'pgsql:'; if (isset($dsn['hostspec'])) { $params[] = 'host=' . $dsn['hostspec']; } else if (isset($dsn['socket'])) { $params[] = 'host=' . $dsn['socket']; } if (isset($dsn['port'])) { $params[] = 'port=' . $dsn['port']; } if (isset($dsn['database'])) { $params[] = 'dbname=' . $dsn['database']; } foreach (self::$libpq_connect_params as $param) { if (isset($dsn[$param])) { $params[] = $param . '=' . $dsn[$param]; } } if (!empty($params)) { $result .= implode(';', $params); } return $result; } /** * Parse SQL file and fix table names according to table prefix */ protected function fix_table_names($sql) { if (!$this->options['table_prefix']) { return $sql; } $sql = parent::fix_table_names($sql); // replace sequence names, and other postgres-specific commands $sql = preg_replace_callback( '/((SEQUENCE |RENAME TO |nextval\()["\']*)([^"\' \r\n]+)/', [$this, 'fix_table_names_callback'], $sql ); return $sql; } }