extern/egroupware_official
1
0
Fork 0
mirror of https://github.com/EGroupware/egroupware.git synced 2025-01-05 05:29:13 +01:00
Code Issues Packages Projects Releases Wiki Activity

"using global db object"

Browse Source
This commit is contained in:
Ralf Becker 2008-03-21 17:15:02 +00:00
parent de74e8b6ce
commit 3108861db0
1 changed files with 165 additions and 191 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

140
phpgwapi/inc/class.contenthistory.inc.php
View File

@ -1,37 +1,34 @@
<?php <?php
/***************************************************************************\ /**
* eGroupWare - content history class * * eGW API - content history class
* http://www.egroupware.org * *
* Written by : Lars Kneschke [lkneschke@linux-at-work.de] * * @link http://www.egroupware.org
* ------------------------------------------------- * * @author Lars Kneschke [lkneschke@linux-at-work.de]
* This program is free software; you can redistribute it and/or modify it * * @copyright Lars Kneschke 2005
* under the terms of the GNU General Public License as published by the * * @license http://opensource.org/licenses/gpl-license.php GPL - GNU General Public License
* Free Software Foundation; either version 2 of the License. * * @package api
\***************************************************************************/ * @version $Id$
/* $Id$ */ */
/** /**
* class to maintain history of content * class to maintain history of content
* *
* This class contains all logic of the egw content history. * This class contains all logic of the egw content history.
* @package phpgwapi
* @author Lars Kneschke
* @version 1.35
* @copyright Lars Kneschke 2005
* @license http://opensource.org/licenses/gpl-license.php GPL
*/ */
class contenthistory class contenthistory
{ {
/** /**
* @var db-object $this->db * Name of the content-history table
*/ */
var $db; const TABLE = 'egw_api_content_history';
/**
* @var egw_db
*/
private $db;
function contenthistory() function __construct()
{ {
$this->db = clone($GLOBALS['egw']->db); $this->db = $GLOBALS['egw']->db;
$this->db->set_app('phpgwapi');
$this->table = 'egw_api_content_history';
} }
/** /**
@ -40,24 +37,17 @@
* mark a mapping from externel to internal id as expired, when * mark a mapping from externel to internal id as expired, when
* a egw entry gets deleted * a egw entry gets deleted
* *
* @param $_appName string the appname example: infolog_notes * @param string $_appName the appname example: infolog_notes
* @param $_id int the internal egwapp content id * @param int $_id the internal egwapp content id
* @return bool * @return bool
*/ */
function expireMapping($_appName, $_id) function expireMapping($_appName, $_id)
{ {
$where = array ( return !!$this->db->update('egw_contentmap',array (
'map_guid' => $GLOBALS['egw']->common->generate_uid($_appName, $_id),
);
$newData = array (
'map_expired' => 1, 'map_expired' => 1,
); ),array (
'map_guid' => $GLOBALS['egw']->common->generate_uid($_appName, $_id),
if(!$this->db->update('egw_contentmap',$newData,$where,__LINE__,__FILE__)) ),__LINE__,__FILE__);
return FALSE;
else
return TRUE;
} }
/** /**
@ -65,39 +55,34 @@
* *
* find which content changed since $_ts for application $_appName * find which content changed since $_ts for application $_appName
* *
* @param $_appName string the appname example: infolog_notes * @param string$_appName the appname example: infolog_notes
* @param $_action string can be modify, add or delete * @param string $_action can be modify, add or delete
* @param $_ts string timestamp where to start searching from * @param string $_ts timestamp where to start searching from
* @return array containing the global UID's * @return array containing the global UID's
*/ */
function getHistory($_appName, $_action, $_ts) function getHistory($_appName, $_action, $_ts)
{ {
$query = "select sync_guid from egw_api_content_history where sync_appname = '".$this->db->db_addslashes($_appName)."' and "; $where = array('sync_appname' => $_appName);
switch($_action) switch($_action)
{ {
case 'modify': case 'modify':
$query .= "sync_modified > '".$this->db->to_timestamp($_ts)."' and sync_deleted is null"; $where[] = "sync_modified > '".$this->db->to_timestamp($_ts)."' AND sync_deleted IS NULL";
break; break;
case 'delete': case 'delete':
$query .= "sync_deleted > '".$this->db->to_timestamp($_ts)."'"; $where[] = "sync_deleted > '".$this->db->to_timestamp($_ts)."'";
break; break;
case 'add': case 'add':
$query .= "sync_added > '".$this->db->to_timestamp($_ts)."' and sync_deleted is null and sync_modified is null"; $where[] = "sync_added > '".$this->db->to_timestamp($_ts)."' AND sync_deleted IS NULL AND sync_modified IS NULL";
break; break;
default: default:
// no valid $_action set // no valid $_action set
return array(); return array();
break;
} }
#Horde::logMessage("SymcML: egwcontactssync $query", __FILE__, __LINE__, PEAR_LOG_DEBUG);
$this->db->query($query, __LINE__, __FILE__);
$guidList = array(); $guidList = array();
foreach($this->db->select(self::TABLE,'sync_guid',$where,__LINE__,__FILE__) as $row)
while($this->db->next_record())
{ {
$guidList[] = $this->db->f('sync_guid'); $guidList[] = $row['sync_guid'];
} }
return $guidList; return $guidList;
@ -111,50 +96,47 @@
* @return string the last timestamp * @return string the last timestamp
*/ */
function getTSforAction($_guid, $_action) function getTSforAction($_guid, $_action)
{
$where = array (
'sync_guid' => $_guid,
);
$this->db->select($this->table,array('sync_added','sync_modified','sync_deleted'),$where,__LINE__,__FILE__);
if($this->db->next_record())
{ {
switch($_action) switch($_action)
{ {
case 'add': case 'add':
return $this->db->from_timestamp($this->db->f('sync_added')); $col = 'sync_added';
break; break;
case 'delete': case 'delete':
return $this->db->from_timestamp($this->db->f('sync_deleted')); $col = 'sync_deleted';
break; break;
case 'modify': case 'modify':
return $this->db->from_timestamp($this->db->f('sync_modified')); $col = 'sync_modified';
break; break;
default: default:
return false; return false;
} }
} $where = array (
'sync_guid' => $_guid,
);
return false; if (($ts = $this->db->select(self::TABLE,$col,$where,__LINE__,__FILE__)->fetchSingle()))
{
$ts = $this->db->from_timestamp($ts);
}
return $ts;
} }
/** /**
* update a timestamp for action * update a timestamp for action
* *
* @param $_appName string the appname example: infolog_notes * @param string $_appName the appname example: infolog_notes
* @param $_id int the app internal content id * @param int $_id the app internal content id
* @param $_action string can be modify, add or delete * @param string $_action can be modify, add or delete
* @param $_ts string timestamp where to start searching from * @param string $_ts timestamp where to start searching from
* @return boolean returns allways true * @return boolean returns allways true
*/ */
function updateTimeStamp($_appName, $_id, $_action, $_ts) function updateTimeStamp($_appName, $_id, $_action, $_ts)
{ {
$_ts = $this->db->to_timestamp($_ts);
$newData = array ( $newData = array (
'sync_appname' => $_appName, 'sync_appname' => $_appName,
'sync_contentid' => $_id, 'sync_contentid' => $_id,
'sync_added' => $_ts, 'sync_added' => $this->db->to_timestamp($_ts),
'sync_guid' => $GLOBALS['egw']->common->generate_uid($_appName, $_id), 'sync_guid' => $GLOBALS['egw']->common->generate_uid($_appName, $_id),
'sync_changedby' => $GLOBALS['egw_info']['user']['account_id'], 'sync_changedby' => $GLOBALS['egw_info']['user']['account_id'],
); );
@ -162,7 +144,7 @@
switch($_action) switch($_action)
{ {
case 'add': case 'add':
$this->db->insert($this->table,$newData,array(),__LINE__,__FILE__); $this->db->insert(self::TABLE,$newData,array(),__LINE__,__FILE__);
break; break;
case 'modify': case 'modify':
@ -173,27 +155,19 @@
'sync_contentid' => $_id, 'sync_contentid' => $_id,
); );
$this->db->select($this->table,'sync_contentid',$where,__LINE__,__FILE__); if (!$this->db->select(self::TABLE,'sync_contentid',$where,__LINE__,__FILE__)->fetchSingle())
if(!$this->db->next_record())
{ {
$this->db->insert($this->table,$newData,array(),__LINE__,__FILE__); $this->db->insert(self::TABLE,$newData,array(),__LINE__,__FILE__);
} }
#$this->db->select($this->table,'sync_added',$where,__LINE__,__FILE__);
#$this->db->next_record();
#$syncAdded = $this->db->f('sync_added');
// now update the time stamp // now update the time stamp
$newData = array ( $newData = array (
'sync_changedby' => $GLOBALS['egw_info']['user']['account_id'], 'sync_changedby' => $GLOBALS['egw_info']['user']['account_id'],
$_action == 'modify' ? 'sync_modified' : 'sync_deleted' => $_ts , $_action == 'modify' ? 'sync_modified' : 'sync_deleted' => $_ts ,
# 'sync_added' => $syncAdded,
); );
$this->db->update($this->table, $newData, $where,__LINE__,__FILE__); $this->db->update(self::TABLE, $newData, $where,__LINE__,__FILE__);
break; break;
} }
return true; return true;
} }
} }
?>