sync.inc.php

Go to the documentation of this file.

<?
require_once("form.inc.php");

class FormSync extends Form
{
    private $table; 
    private $id; 
    private $dbConn; 
    
    public function __construct($layout = null)
    {
        parent::__construct($layout);

        if(isset($GLOBALS['dbconn']))
        {
            self::assertIsDbObject($GLOBALS['dbconn']);
            $this->dbConn = &$GLOBALS['dbconn'];
        }
        
        $this->id = 0;
    }
    
    public function __set($name, $value)
    {
        switch($name)
        {
            case 'table':
            case 'id':
                $this->$name = $value;
                return true;
                break;

            case 'dbConn':
                self::assertIsDbObject($value);
                $this->dbConn = $value;
                break;

            default:
                return parent::__set($name, $value);
        }
    }
    
    public function handleSubmit($redir = null)
    {
        if($this->isSubmitted())
        {
            $this->validate();
            if(!$this->hasError())
            {
                $this->sync();
                
                if($redir)
                    header("Location: $redir");
            }
        }
    }

    
    public function handleSubmitWithCallback($callback, $redir = null)
    {
        if($this->isSubmitted())
        {
            $this->validate();

            if(!$this->hasError())
            {
                if(!is_callable($callback))
                    throw new InvalidCallbackException();

                $ret = call_user_func($callback, $this->getData(), &$this); 

                if($ret && $redir)
                    header("Location: $redir");
                
                return $ret;
            }
        }

        return false;
    }
    
    public static function assertIsDbObject(&$obj)
    {
        $type = get_class($obj);
        if(!preg_match('/^DB_.+$/', $type))
            throw new InvalidValueException();

        return true;
    }

    public function sync(&$dbConn = null)
    {
        # Table name is required, otherwise generated SQL is invalid.
        if(!$this->table)
            throw new TableNotSetException();

        if($dbConn === null)
            $dbConn = $this->dbConn;

        self::assertIsDbObject($dbConn);
        $this->id = (int)$_REQUEST['id'];

        $fieldSql = array();
        foreach($this->fields as $field)
        {
            $fieldSql[] = $field->getSqlImpl();
        }

        # Implode the array, using array_diff against a null array to remove all empty elements
        $fieldSql = implode(',', array_diff($fieldSql, array('')));
        $sql = <<<EOSQL
        INSERT INTO $this->table
        SET
            id = $this->id,
            $fieldSql   
        ON DUPLICATE KEY UPDATE
            $fieldSql   
EOSQL;
        
        $res =& $dbConn->query($sql);

        if(PEAR::isError($res))
            throw new Exception($res->getMessage());
    }

    
    protected function drawHiddenFields()
    {
        parent::drawHiddenFields();
        
        echo "<input type=\"hidden\" name=\"id\" value=\"$this->id\"/>";
    }
}
?>

---