| | |
| | | +-----------------------------------------------------------------------+ |
| | | | Author: Thomas Bruederli <roundcube@gmail.com> | |
| | | +-----------------------------------------------------------------------+ |
| | | |
| | | $Id$ |
| | | |
| | | */ |
| | | |
| | | |
| | |
| | | /** |
| | | * Store database connection. |
| | | * |
| | | * @var rcube_mdb2 |
| | | * @var rcube_db |
| | | */ |
| | | private $db = null; |
| | | private $user_id = 0; |
| | |
| | | $sql_filter = $search ? " AND " . $this->db->ilike('name', '%'.$search.'%') : ''; |
| | | |
| | | $sql_result = $this->db->query( |
| | | "SELECT * FROM ".get_table_name($this->db_groups). |
| | | "SELECT * FROM ".$this->db->table_name($this->db_groups). |
| | | " WHERE del<>1". |
| | | " AND user_id=?". |
| | | $sql_filter. |
| | |
| | | function get_group($group_id) |
| | | { |
| | | $sql_result = $this->db->query( |
| | | "SELECT * FROM ".get_table_name($this->db_groups). |
| | | "SELECT * FROM ".$this->db->table_name($this->db_groups). |
| | | " WHERE del<>1". |
| | | " AND contactgroup_id=?". |
| | | " AND user_id=?", |
| | |
| | | $length = $subset != 0 ? abs($subset) : $this->page_size; |
| | | |
| | | if ($this->group_id) |
| | | $join = " LEFT JOIN ".get_table_name($this->db_groupmembers)." AS m". |
| | | $join = " LEFT JOIN ".$this->db->table_name($this->db_groupmembers)." AS m". |
| | | " ON (m.contact_id = c.".$this->primary_key.")"; |
| | | |
| | | $order_col = (in_array($this->sort_col, $this->table_cols) ? $this->sort_col : 'name'); |
| | |
| | | $order_cols[] = 'c.email'; |
| | | |
| | | $sql_result = $this->db->limitquery( |
| | | "SELECT * FROM ".get_table_name($this->db_name)." AS c" . |
| | | "SELECT * FROM ".$this->db->table_name($this->db_name)." AS c" . |
| | | $join . |
| | | " WHERE c.del<>1" . |
| | | " AND c.user_id=?" . |
| | |
| | | // fulltext search in all fields |
| | | else if ($col == '*') { |
| | | $words = array(); |
| | | foreach (explode($WS, self::normalize_string($value)) as $word) { |
| | | foreach (explode($WS, rcube_utils::normalize_string($value)) as $word) { |
| | | switch ($mode) { |
| | | case 1: // strict |
| | | $words[] = '(' . $this->db->ilike('words', $word . '%') |
| | |
| | | // vCard field |
| | | else { |
| | | if (in_array($col, $this->fulltext_cols)) { |
| | | foreach (explode(" ", self::normalize_string($val)) as $word) { |
| | | foreach (rcube_utils::normalize_string($val, true) as $word) { |
| | | switch ($mode) { |
| | | case 1: // strict |
| | | $words[] = '(' . $this->db->ilike('words', $word . $WS . '%') |
| | |
| | | private function _count() |
| | | { |
| | | if ($this->group_id) |
| | | $join = " LEFT JOIN ".get_table_name($this->db_groupmembers)." AS m". |
| | | $join = " LEFT JOIN ".$this->db->table_name($this->db_groupmembers)." AS m". |
| | | " ON (m.contact_id=c.".$this->primary_key.")"; |
| | | |
| | | // count contacts for this user |
| | | $sql_result = $this->db->query( |
| | | "SELECT COUNT(c.contact_id) AS rows". |
| | | " FROM ".get_table_name($this->db_name)." AS c". |
| | | " FROM ".$this->db->table_name($this->db_name)." AS c". |
| | | $join. |
| | | " WHERE c.del<>1". |
| | | " AND c.user_id=?". |
| | |
| | | return $assoc ? $first : $this->result; |
| | | |
| | | $this->db->query( |
| | | "SELECT * FROM ".get_table_name($this->db_name). |
| | | "SELECT * FROM ".$this->db->table_name($this->db_name). |
| | | " WHERE contact_id=?". |
| | | " AND user_id=?". |
| | | " AND del<>1", |
| | |
| | | return $results; |
| | | |
| | | $sql_result = $this->db->query( |
| | | "SELECT cgm.contactgroup_id, cg.name FROM " . get_table_name($this->db_groupmembers) . " AS cgm" . |
| | | " LEFT JOIN " . get_table_name($this->db_groups) . " AS cg ON (cgm.contactgroup_id = cg.contactgroup_id AND cg.del<>1)" . |
| | | "SELECT cgm.contactgroup_id, cg.name FROM " . $this->db->table_name($this->db_groupmembers) . " AS cgm" . |
| | | " LEFT JOIN " . $this->db->table_name($this->db_groups) . " AS cg ON (cgm.contactgroup_id = cg.contactgroup_id AND cg.del<>1)" . |
| | | " WHERE cgm.contact_id=?", |
| | | $id |
| | | ); |
| | |
| | | |
| | | if (!$existing->count && !empty($a_insert_cols)) { |
| | | $this->db->query( |
| | | "INSERT INTO ".get_table_name($this->db_name). |
| | | "INSERT INTO ".$this->db->table_name($this->db_name). |
| | | " (user_id, changed, del, ".join(', ', $a_insert_cols).")". |
| | | " VALUES (".intval($this->user_id).", ".$this->db->now().", 0, ".join(', ', $a_insert_values).")" |
| | | ); |
| | |
| | | |
| | | if (!empty($write_sql)) { |
| | | $this->db->query( |
| | | "UPDATE ".get_table_name($this->db_name). |
| | | "UPDATE ".$this->db->table_name($this->db_name). |
| | | " SET changed=".$this->db->now().", ".join(', ', $write_sql). |
| | | " WHERE contact_id=?". |
| | | " AND user_id=?". |
| | |
| | | if (isset($value)) |
| | | $vcard->set($field, $value, $section); |
| | | if ($fulltext && is_array($value)) |
| | | $words .= ' ' . self::normalize_string(join(" ", $value)); |
| | | $words .= ' ' . rcube_utils::normalize_string(join(" ", $value)); |
| | | else if ($fulltext && strlen($value) >= 3) |
| | | $words .= ' ' . self::normalize_string($value); |
| | | $words .= ' ' . rcube_utils::normalize_string($value); |
| | | } |
| | | } |
| | | $out['vcard'] = $vcard->export(false); |
| | |
| | | |
| | | // flag record as deleted (always) |
| | | $this->db->query( |
| | | "UPDATE ".get_table_name($this->db_name). |
| | | "UPDATE ".$this->db->table_name($this->db_name). |
| | | " SET del=1, changed=".$this->db->now(). |
| | | " WHERE user_id=?". |
| | | " AND contact_id IN ($ids)", |
| | |
| | | |
| | | // clear deleted flag |
| | | $this->db->query( |
| | | "UPDATE ".get_table_name($this->db_name). |
| | | "UPDATE ".$this->db->table_name($this->db_name). |
| | | " SET del=0, changed=".$this->db->now(). |
| | | " WHERE user_id=?". |
| | | " AND contact_id IN ($ids)", |
| | |
| | | { |
| | | $this->cache = null; |
| | | |
| | | $this->db->query("UPDATE ".get_table_name($this->db_name). |
| | | $this->db->query("UPDATE ".$this->db->table_name($this->db_name). |
| | | " SET del=1, changed=".$this->db->now(). |
| | | " WHERE user_id = ?", $this->user_id); |
| | | |
| | |
| | | $name = $this->unique_groupname($name); |
| | | |
| | | $this->db->query( |
| | | "INSERT INTO ".get_table_name($this->db_groups). |
| | | "INSERT INTO ".$this->db->table_name($this->db_groups). |
| | | " (user_id, changed, name)". |
| | | " VALUES (".intval($this->user_id).", ".$this->db->now().", ".$this->db->quote($name).")" |
| | | ); |
| | |
| | | { |
| | | // flag group record as deleted |
| | | $sql_result = $this->db->query( |
| | | "UPDATE ".get_table_name($this->db_groups). |
| | | "UPDATE ".$this->db->table_name($this->db_groups). |
| | | " SET del=1, changed=".$this->db->now(). |
| | | " WHERE contactgroup_id=?". |
| | | " AND user_id=?", |
| | |
| | | * @param string New name to set for this group |
| | | * @return boolean New name on success, false if no data was changed |
| | | */ |
| | | function rename_group($gid, $newname) |
| | | function rename_group($gid, $newname, &$new_gid) |
| | | { |
| | | // make sure we have a unique name |
| | | $name = $this->unique_groupname($newname); |
| | | |
| | | $sql_result = $this->db->query( |
| | | "UPDATE ".get_table_name($this->db_groups). |
| | | "UPDATE ".$this->db->table_name($this->db_groups). |
| | | " SET name=?, changed=".$this->db->now(). |
| | | " WHERE contactgroup_id=?". |
| | | " AND user_id=?", |
| | |
| | | |
| | | // get existing assignments ... |
| | | $sql_result = $this->db->query( |
| | | "SELECT contact_id FROM ".get_table_name($this->db_groupmembers). |
| | | "SELECT contact_id FROM ".$this->db->table_name($this->db_groupmembers). |
| | | " WHERE contactgroup_id=?". |
| | | " AND contact_id IN (".$this->db->array2list($ids, 'integer').")", |
| | | $group_id |
| | |
| | | |
| | | foreach ($ids as $contact_id) { |
| | | $this->db->query( |
| | | "INSERT INTO ".get_table_name($this->db_groupmembers). |
| | | "INSERT INTO ".$this->db->table_name($this->db_groupmembers). |
| | | " (contactgroup_id, contact_id, created)". |
| | | " VALUES (?, ?, ".$this->db->now().")", |
| | | $group_id, |
| | | $contact_id |
| | | ); |
| | | |
| | | if (!$this->db->db_error) |
| | | if ($error = $this->db->is_error()) |
| | | $this->set_error(self::ERROR_SAVING, $error); |
| | | else |
| | | $added++; |
| | | } |
| | | |
| | |
| | | $ids = $this->db->array2list($ids, 'integer'); |
| | | |
| | | $sql_result = $this->db->query( |
| | | "DELETE FROM ".get_table_name($this->db_groupmembers). |
| | | "DELETE FROM ".$this->db->table_name($this->db_groupmembers). |
| | | " WHERE contactgroup_id=?". |
| | | " AND contact_id IN ($ids)", |
| | | $group_id |
| | |
| | | |
| | | do { |
| | | $sql_result = $this->db->query( |
| | | "SELECT 1 FROM ".get_table_name($this->db_groups). |
| | | "SELECT 1 FROM ".$this->db->table_name($this->db_groups). |
| | | " WHERE del<>1". |
| | | " AND user_id=?". |
| | | " AND name=?", |
| | |
| | | $checkname); |
| | | |
| | | // append number to make name unique |
| | | if ($hit = $this->db->num_rows($sql_result)) |
| | | if ($hit = $this->db->fetch_array($sql_result)) { |
| | | $checkname = $name . ' ' . $num++; |
| | | } while ($hit > 0); |
| | | } |
| | | } while ($hit); |
| | | |
| | | return $checkname; |
| | | } |