File Source for UpdateLocalDataRule.php

<?php
/**
* <b>Class Description</b>: Class representing the rules for refreshing linked data.
* (see {@link package.php} for documentation
* of the DDMS package.).
*@see package.php
* @since : 29/04/2009
* @author Jan van der Breggen
* @package DDMS
* @subpackage DDMSClient
***/
define('COUNTRY', 'country');
define('ACTIVE_RETREATS', 'active_retreats');
class UpdateLocalDataRule extends ORM implements RuleObject
{
private $defaultUpdateEvent;
private $externallyLinkedOrm;
function __construct($orm)
{
$this->database = 'rigregversiontwo';
//just for test purposes
$this->defaultUpdateEvent = COUNTRY;
$this->externallyLinkedOrm = $orm;
}
public function applyRule()
{
$numargs = func_num_args();
if (func_num_args() > 0)
{
$updateEvent = func_get_arg(0);
} else
{
$updateEvent = $this->defaultUpdateEvent;
}
switch ($this->externallyLinkedOrm->getTableName()) {
case "students":
return $this->studentTable($updateEvent);
break;
case "country":
return;
break;
case "sanghas":
//return $this->sanghaTable();
}
}
function sanghaTable()
{
return $this->externallyLinkedOrm->getKeySetForUpdate('ID', '>', '0');
}
function studentTable ($updateEvent)
{
if ($updateEvent ==COUNTRY)
{
return $this->externallyLinkedOrm->getKeySetForUpdate('country', '=', 'NP');//'country', '=', 'DE'
} elseif ($updateEvent == ACTIVE_RETREATS)
{
$this->query("SELECT distinct(studentID) FROM retreatreg r, retreat rt where r.retreatUID = rt.ID and rt.status = 1 limit 100");
return $this->externallyLinkedOrm->convertLocalKeyValuesToRemoteKeyValues($this->rows_array());
}
}
private function reduce($data)
{
$values = array();
foreach ($data as $value)
{
array_push($values, implode(',', $value));
}
return implode(",", $values);
}
public function setORM($orm)
{
$this->externallyLinkedOrm = $orm;
}
}
?>

Source for file UpdateLocalDataRule.php