luos/workflow/engine/classes/model/AppSolrQueue.php

<?php

//require_once 'classes/model/om/BaseAppSolrQueue.php';
//require_once 'classes/entities/AppSolrQueue.php';

/**
 * Skeleton subclass for representing a row from the 'APP_SOLR_QUEUE' table.
 *
 *
 *
 * You should add additional methods to this class to meet the
 * application requirements. This class will only be generated as
 * long as it does not already exist in the output directory.
 *
 * @package classes.model
 */
class AppSolrQueue extends BaseAppSolrQueue
{

    public function exists ($sAppUid)
    {
        try {
            $oRow = AppSolrQueuePeer::retrieveByPK( $sAppUid );
            if (! is_null( $oRow )) {
                return true;
            } else {
                return false;
            }
        } catch (Exception $oError) {
            return false;
        }
    }

    public function createUpdate ($sAppUid, $iUpdated)
    {
        $con = Propel::getConnection( AppSolrQueuePeer::DATABASE_NAME );
        try {
            if ($this->exists( $sAppUid )) {
                $con->begin();
                //update record
                //$oRow = AppSolrQueuePeer::retrieveByPK( $sAppUid );
                //$aFields = $oRow->toArray(BasePeer::TYPE_FIELDNAME);
                //$this->fromArray($aFields,BasePeer::TYPE_FIELDNAME);
                $this->setNew( false );
                //set field
                $this->setAppUid( $sAppUid );
                $this->setAppUpdated( $iUpdated );
                if ($this->validate()) {
                    $result = $this->save();
                } else {
                    $con->rollback();
                    throw (new Exception( "Failed Validation in class " . get_class( $this ) . "." ));
                }
                $con->commit();
                return $result;
            } else {
                //create record
                //set values
                $this->setAppUid( $sAppUid );
                $this->setAppUpdated( $iUpdated );
                if ($this->validate()) {
                    $result = $this->save();
                } else {
                    $e = new Exception( "Failed Validation in class " . get_class( $this ) . "." );
                    //$e->aValidationFailures=$this->getValidationFailures();
                    throw ($e);
                }
                $con->commit();
                return $result;
            }
        } catch (Exception $e) {
            $con->rollback();
            throw ($e);
        }
    }

    /**
     * Returns the list of updated applications
     * array of Entity_AppSolrQueue
     */
    public function getListUpdatedApplications ()
    {
        $updatedApplications = array ();
        try {
            $c = new Criteria();

            $c->addSelectColumn( AppSolrQueuePeer::APP_UID );
            $c->addSelectColumn( AppSolrQueuePeer::APP_UPDATED );

            //"WHERE
            $c->add( AppSolrQueuePeer::APP_UPDATED, 0, Criteria::NOT_EQUAL );

            $rs = AppSolrQueuePeer::doSelectRS( $c );
            $rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
            //echo $c->toString();
            $rs->next();
            $row = $rs->getRow();

            while (is_array( $row )) {
                $appSolrQueue = Entity_AppSolrQueue::createEmpty();
                $appSolrQueue->appUid = $row['APP_UID'];
                $appSolrQueue->appUpdated = $row['APP_UPDATED'];
                $updatedApplications[] = $appSolrQueue;
                $rs->next();
                $row = $rs->getRow();
            }
            return $updatedApplications;
        } catch (Exception $e) {
            $con->rollback();
            throw ($e);
        }
    }
}