| | |
| | | private $user_id = 0; |
| | | private $filter = null; |
| | | private $result = null; |
| | | private $name; |
| | | private $cache; |
| | | private $table_cols = array('name', 'email', 'firstname', 'surname'); |
| | | private $fulltext_cols = array('name', 'firstname', 'surname', 'middlename', 'nickname', |
| | |
| | | public $primary_key = 'contact_id'; |
| | | public $readonly = false; |
| | | public $groups = true; |
| | | public $undelete = true; |
| | | public $list_page = 1; |
| | | public $page_size = 10; |
| | | public $group_id = 0; |
| | |
| | | |
| | | |
| | | /** |
| | | * Returns addressbook name |
| | | */ |
| | | function get_name() |
| | | { |
| | | return $this->name; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Save a search string for future listings |
| | | * |
| | | * @param string SQL params to use in listing method |
| | | * @param string SQL params to use in listing method |
| | | */ |
| | | function set_search_set($filter) |
| | | { |
| | |
| | | } |
| | | } |
| | | |
| | | foreach ($required as $col) { |
| | | foreach (array_intersect($required, $this->table_cols) as $col) { |
| | | $and_where[] = $this->db->quoteIdentifier($col).' <> '.$this->db->quote(''); |
| | | } |
| | | |
| | |
| | | if (!empty($post_search)) { |
| | | $ids = array(0); |
| | | // build key name regexp |
| | | $regexp = '/^(' . implode(array_keys($post_search), '|') . ')(:.*?)$/'; |
| | | $regexp = '/^(' . implode(array_keys($post_search), '|') . ')(?:.*)$/'; |
| | | // use initial WHERE clause, to limit records number if possible |
| | | if (!empty($where)) |
| | | $this->set_search_set($where); |
| | |
| | | |
| | | return $updated; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | private function convert_db_data($sql_arr) |
| | | { |
| | | $record = array(); |
| | | $record['ID'] = $sql_arr[$this->primary_key]; |
| | | |
| | | |
| | | if ($sql_arr['vcard']) { |
| | | unset($sql_arr['email']); |
| | | $vcard = new rcube_vcard($sql_arr['vcard']); |
| | |
| | | $record += $sql_arr; |
| | | $record['email'] = preg_split('/,\s*/', $record['email']); |
| | | } |
| | | |
| | | |
| | | return $record; |
| | | } |
| | | |
| | |
| | | /** |
| | | * Mark one or more contact records as deleted |
| | | * |
| | | * @param array Record identifiers |
| | | * @param array Record identifiers |
| | | * @param boolean Remove record(s) irreversible (unsupported) |
| | | */ |
| | | function delete($ids) |
| | | function delete($ids, $force=true) |
| | | { |
| | | if (!is_array($ids)) |
| | | $ids = explode(',', $ids); |
| | | |
| | | $ids = $this->db->array2list($ids, 'integer'); |
| | | |
| | | // flag record as deleted |
| | | // flag record as deleted (always) |
| | | $this->db->query( |
| | | "UPDATE ".get_table_name($this->db_name). |
| | | " SET del=1, changed=".$this->db->now(). |
| | | " WHERE user_id=?". |
| | | " AND contact_id IN ($ids)", |
| | | $this->user_id |
| | | ); |
| | | |
| | | $this->cache = null; |
| | | |
| | | return $this->db->affected_rows(); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Undelete one or more contact records |
| | | * |
| | | * @param array Record identifiers |
| | | */ |
| | | function undelete($ids) |
| | | { |
| | | if (!is_array($ids)) |
| | | $ids = explode(',', $ids); |
| | | |
| | | $ids = $this->db->array2list($ids, 'integer'); |
| | | |
| | | // clear deleted flag |
| | | $this->db->query( |
| | | "UPDATE ".get_table_name($this->db_name). |
| | | " SET del=0, changed=".$this->db->now(). |
| | | " WHERE user_id=?". |
| | | " AND contact_id IN ($ids)", |
| | | $this->user_id |
| | |
| | | */ |
| | | function delete_all() |
| | | { |
| | | $this->db->query("DELETE FROM ".get_table_name($this->db_name)." WHERE user_id = ?", $this->user_id); |
| | | $this->cache = null; |
| | | |
| | | $this->db->query("UPDATE ".get_table_name($this->db_name). |
| | | " SET del=1, changed=".$this->db->now(). |
| | | " WHERE user_id = ?", $this->user_id); |
| | | |
| | | return $this->db->affected_rows(); |
| | | } |
| | | |