fernando/luos
1
0
Fork 0
Code Releases Activity

CODE STYLE class.ArrayPeer.php

Browse Source
This commit is contained in:
Fernando Ontiveros
2012-10-09 12:32:00 -04:00
parent 5b60cca280
commit 97ad5a6c53
1 changed files with 765 additions and 719 deletions
Download Patch File Download Diff File Expand all files Collapse all files

412
workflow/engine/classes/class.ArrayPeer.php
View File

@@ -1,6 +1,7 @@
<?php
/**
* class.ArrayPeer.php
*
* @package workflow.engine.classes
*
* ProcessMaker Open Source Edition
@@ -34,70 +35,113 @@ include_once 'classes/model/Application.php';
*
* @package workflow.engine.classes
*/
abstract class ArrayBasePeer {
abstract class ArrayBasePeer
{
/** The default database name for this class */
/**
* The default database name for this class
*/
const DATABASE_NAME = 'dbarray';
/** The table name for this class */
/**
* The table name for this class
*/
//const TABLE_NAME = 'APPLICATION';
/** A class that can be returned by this peer. */
/**
* A class that can be returned by this peer.
*/
const CLASS_DEFAULT = 'classes.model.Application';
/** The total number of columns. */
/**
* The total number of columns.
*/
const NUM_COLUMNS = 15;
/** The number of lazy-loaded columns. */
/**
* The number of lazy-loaded columns.
*/
const NUM_LAZY_LOAD_COLUMNS = 0;
/** The column name for the APP_UID field */
/**
* The column name for the APP_UID field
*/
const APP_UID = 'APPLICATION.APP_UID';
/** The column name for the APP_NUMBER field */
/**
* The column name for the APP_NUMBER field
*/
const APP_NUMBER = 'APPLICATION.APP_NUMBER';
/** The column name for the APP_PARENT field */
/**
* The column name for the APP_PARENT field
*/
const APP_PARENT = 'APPLICATION.APP_PARENT';
/** The column name for the APP_STATUS field */
/**
* The column name for the APP_STATUS field
*/
const APP_STATUS = 'APPLICATION.APP_STATUS';
/** The column name for the PRO_UID field */
/**
* The column name for the PRO_UID field
*/
const PRO_UID = 'APPLICATION.PRO_UID';
/** The column name for the APP_PROC_STATUS field */
/**
* The column name for the APP_PROC_STATUS field
*/
const APP_PROC_STATUS = 'APPLICATION.APP_PROC_STATUS';
/** The column name for the APP_PROC_CODE field */
/**
* The column name for the APP_PROC_CODE field
*/
const APP_PROC_CODE = 'APPLICATION.APP_PROC_CODE';
/** The column name for the APP_PARALLEL field */
/**
* The column name for the APP_PARALLEL field
*/
const APP_PARALLEL = 'APPLICATION.APP_PARALLEL';
/** The column name for the APP_INIT_USER field */
/**
* The column name for the APP_INIT_USER field
*/
const APP_INIT_USER = 'APPLICATION.APP_INIT_USER';
/** The column name for the APP_CUR_USER field */
/**
* The column name for the APP_CUR_USER field
*/
const APP_CUR_USER = 'APPLICATION.APP_CUR_USER';
/** The column name for the APP_CREATE_DATE field */
/**
* The column name for the APP_CREATE_DATE field
*/
const APP_CREATE_DATE = 'APPLICATION.APP_CREATE_DATE';
/** The column name for the APP_INIT_DATE field */
/**
* The column name for the APP_INIT_DATE field
*/
const APP_INIT_DATE = 'APPLICATION.APP_INIT_DATE';
/** The column name for the APP_FINISH_DATE field */
/**
* The column name for the APP_FINISH_DATE field
*/
const APP_FINISH_DATE = 'APPLICATION.APP_FINISH_DATE';
/** The column name for the APP_UPDATE_DATE field */
/**
* The column name for the APP_UPDATE_DATE field
*/
const APP_UPDATE_DATE = 'APPLICATION.APP_UPDATE_DATE';
/** The column name for the APP_DATA field */
/**
* The column name for the APP_DATA field
*/
const APP_DATA = 'APPLICATION.APP_DATA';
/** The PHP to DB Name Mapping */
/**
* The PHP to DB Name Mapping
*/
private static $phpNameMap = null;
/**
@@ -106,11 +150,11 @@ abstract class ArrayBasePeer {
* First dimension keys are the type constants
* e.g. self::$fieldNames[self::TYPE_PHPNAME][0] = 'Id'
*/
private static $fieldNames = array (
BasePeer::TYPE_PHPNAME => array ('AppUid', 'AppNumber', 'AppParent', 'AppStatus', 'ProUid', 'AppProcStatus', 'AppProcCode', 'AppParallel', 'AppInitUser', 'AppCurUser', 'AppCreateDate', 'AppInitDate', 'AppFinishDate', 'AppUpdateDate', 'AppData', ),
BasePeer::TYPE_COLNAME => array (ApplicationPeer::APP_UID, ApplicationPeer::APP_NUMBER, ApplicationPeer::APP_PARENT, ApplicationPeer::APP_STATUS, ApplicationPeer::PRO_UID, ApplicationPeer::APP_PROC_STATUS, ApplicationPeer::APP_PROC_CODE, ApplicationPeer::APP_PARALLEL, ApplicationPeer::APP_INIT_USER, ApplicationPeer::APP_CUR_USER, ApplicationPeer::APP_CREATE_DATE, ApplicationPeer::APP_INIT_DATE, ApplicationPeer::APP_FINISH_DATE, ApplicationPeer::APP_UPDATE_DATE, ApplicationPeer::APP_DATA, ),
BasePeer::TYPE_FIELDNAME => array ('APP_UID', 'APP_NUMBER', 'APP_PARENT', 'APP_STATUS', 'PRO_UID', 'APP_PROC_STATUS', 'APP_PROC_CODE', 'APP_PARALLEL', 'APP_INIT_USER', 'APP_CUR_USER', 'APP_CREATE_DATE', 'APP_INIT_DATE', 'APP_FINISH_DATE', 'APP_UPDATE_DATE', 'APP_DATA', ),
BasePeer::TYPE_NUM => array (0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, )
private static $fieldNames = array (BasePeer::TYPE_PHPNAME => array ('AppUid','AppNumber','AppParent','AppStatus','ProUid','AppProcStatus','AppProcCode','AppParallel','AppInitUser','AppCurUser','AppCreateDate','AppInitDate','AppFinishDate','AppUpdateDate','AppData'
),BasePeer::TYPE_COLNAME => array (ApplicationPeer::APP_UID,ApplicationPeer::APP_NUMBER,ApplicationPeer::APP_PARENT,ApplicationPeer::APP_STATUS,ApplicationPeer::PRO_UID,ApplicationPeer::APP_PROC_STATUS,ApplicationPeer::APP_PROC_CODE,ApplicationPeer::APP_PARALLEL,ApplicationPeer::APP_INIT_USER,ApplicationPeer::APP_CUR_USER,ApplicationPeer::APP_CREATE_DATE,ApplicationPeer::APP_INIT_DATE,ApplicationPeer::APP_FINISH_DATE,ApplicationPeer::APP_UPDATE_DATE,ApplicationPeer::APP_DATA
),BasePeer::TYPE_FIELDNAME => array ('APP_UID','APP_NUMBER','APP_PARENT','APP_STATUS','PRO_UID','APP_PROC_STATUS','APP_PROC_CODE','APP_PARALLEL','APP_INIT_USER','APP_CUR_USER','APP_CREATE_DATE','APP_INIT_DATE','APP_FINISH_DATE','APP_UPDATE_DATE','APP_DATA'
),BasePeer::TYPE_NUM => array (0,1,2,3,4,5,6,7,8,9,10,11,12,13,14
)
);
/**
@@ -119,23 +163,25 @@ abstract class ArrayBasePeer {
* First dimension keys are the type constants
* e.g. self::$fieldNames[BasePeer::TYPE_PHPNAME]['Id'] = 0
*/
private static $fieldKeys = array (
BasePeer::TYPE_PHPNAME => array ('AppUid' => 0, 'AppNumber' => 1, 'AppParent' => 2, 'AppStatus' => 3, 'ProUid' => 4, 'AppProcStatus' => 5, 'AppProcCode' => 6, 'AppParallel' => 7, 'AppInitUser' => 8, 'AppCurUser' => 9, 'AppCreateDate' => 10, 'AppInitDate' => 11, 'AppFinishDate' => 12, 'AppUpdateDate' => 13, 'AppData' => 14, ),
BasePeer::TYPE_COLNAME => array (ApplicationPeer::APP_UID => 0, ApplicationPeer::APP_NUMBER => 1, ApplicationPeer::APP_PARENT => 2, ApplicationPeer::APP_STATUS => 3, ApplicationPeer::PRO_UID => 4, ApplicationPeer::APP_PROC_STATUS => 5, ApplicationPeer::APP_PROC_CODE => 6, ApplicationPeer::APP_PARALLEL => 7, ApplicationPeer::APP_INIT_USER => 8, ApplicationPeer::APP_CUR_USER => 9, ApplicationPeer::APP_CREATE_DATE => 10, ApplicationPeer::APP_INIT_DATE => 11, ApplicationPeer::APP_FINISH_DATE => 12, ApplicationPeer::APP_UPDATE_DATE => 13, ApplicationPeer::APP_DATA => 14, ),
BasePeer::TYPE_FIELDNAME => array ('APP_UID' => 0, 'APP_NUMBER' => 1, 'APP_PARENT' => 2, 'APP_STATUS' => 3, 'PRO_UID' => 4, 'APP_PROC_STATUS' => 5, 'APP_PROC_CODE' => 6, 'APP_PARALLEL' => 7, 'APP_INIT_USER' => 8, 'APP_CUR_USER' => 9, 'APP_CREATE_DATE' => 10, 'APP_INIT_DATE' => 11, 'APP_FINISH_DATE' => 12, 'APP_UPDATE_DATE' => 13, 'APP_DATA' => 14, ),
BasePeer::TYPE_NUM => array (0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, )
private static $fieldKeys = array (BasePeer::TYPE_PHPNAME => array ('AppUid' => 0,'AppNumber' => 1,'AppParent' => 2,'AppStatus' => 3,'ProUid' => 4,'AppProcStatus' => 5,'AppProcCode' => 6,'AppParallel' => 7,'AppInitUser' => 8,'AppCurUser' => 9,'AppCreateDate' => 10,'AppInitDate' => 11,'AppFinishDate' => 12,'AppUpdateDate' => 13,'AppData' => 14
),BasePeer::TYPE_COLNAME => array (ApplicationPeer::APP_UID => 0,ApplicationPeer::APP_NUMBER => 1,ApplicationPeer::APP_PARENT => 2,ApplicationPeer::APP_STATUS => 3,ApplicationPeer::PRO_UID => 4,ApplicationPeer::APP_PROC_STATUS => 5,ApplicationPeer::APP_PROC_CODE => 6,ApplicationPeer::APP_PARALLEL => 7,ApplicationPeer::APP_INIT_USER => 8,ApplicationPeer::APP_CUR_USER => 9,ApplicationPeer::APP_CREATE_DATE => 10,ApplicationPeer::APP_INIT_DATE => 11,ApplicationPeer::APP_FINISH_DATE => 12,ApplicationPeer::APP_UPDATE_DATE => 13,ApplicationPeer::APP_DATA => 14
),BasePeer::TYPE_FIELDNAME => array ('APP_UID' => 0,'APP_NUMBER' => 1,'APP_PARENT' => 2,'APP_STATUS' => 3,'PRO_UID' => 4,'APP_PROC_STATUS' => 5,'APP_PROC_CODE' => 6,'APP_PARALLEL' => 7,'APP_INIT_USER' => 8,'APP_CUR_USER' => 9,'APP_CREATE_DATE' => 10,'APP_INIT_DATE' => 11,'APP_FINISH_DATE' => 12,'APP_UPDATE_DATE' => 13,'APP_DATA' => 14
),BasePeer::TYPE_NUM => array (0,1,2,3,4,5,6,7,8,9,10,11,12,13,14
)
);
/**
*
* @return MapBuilder the map builder for this peer
* @throws PropelException Any exceptions caught during processing will be
* rethrown wrapped into a PropelException.
*/
public static function getMapBuilder()
public static function getMapBuilder ()
{
include_once 'classes/model/map/ApplicationMapBuilder.php';
return BasePeer::getMapBuilder('classes.model.map.ApplicationMapBuilder');
return BasePeer::getMapBuilder( 'classes.model.map.ApplicationMapBuilder' );
}
/**
* Gets a map (hash) of PHP names to DB column names.
*
@@ -144,12 +190,12 @@ abstract class ArrayBasePeer {
* rethrown wrapped into a PropelException.
* @deprecated Use the getFieldNames() and translateFieldName() methods instead of this.
*/
public static function getPhpNameMap()
public static function getPhpNameMap ()
{
if (self::$phpNameMap === null) {
$map = ApplicationPeer::getTableMap();
$columns = $map->getColumns();
$nameMap = array();
$nameMap = array ();
foreach ($columns as $column) {
$nameMap[$column->getPhpName()] = $column->getColumnName();
}
@@ -157,6 +203,7 @@ abstract class ArrayBasePeer {
}
return self::$phpNameMap;
}
/**
* Translates a fieldname to another type
*
@@ -166,12 +213,12 @@ abstract class ArrayBasePeer {
* @param string $toType One of the class type constants
* @return string translated name of the field.
*/
static public function translateFieldName($name, $fromType, $toType)
static public function translateFieldName ($name, $fromType, $toType)
{
$toNames = self::getFieldNames($toType);
$key = isset(self::$fieldKeys[$fromType][$name]) ? self::$fieldKeys[$fromType][$name] : null;
$toNames = self::getFieldNames( $toType );
$key = isset( self::$fieldKeys[$fromType][$name] ) ? self::$fieldKeys[$fromType][$name] : null;
if ($key === null) {
throw new PropelException("'$name' could not be found in the field names of type '$fromType'. These are: " . print_r(self::$fieldKeys[$fromType], true));
throw new PropelException( "'$name' could not be found in the field names of type '$fromType'. These are: " . print_r( self::$fieldKeys[$fromType], true ) );
}
return $toNames[$key];
}
@@ -185,10 +232,10 @@ abstract class ArrayBasePeer {
* @return array A list of field names
*/
static public function getFieldNames($type = BasePeer::TYPE_PHPNAME)
static public function getFieldNames ($type = BasePeer::TYPE_PHPNAME)
{
if (!array_key_exists($type, self::$fieldNames)) {
throw new PropelException('Method getFieldNames() expects the parameter $type to be one of the class constants TYPE_PHPNAME, TYPE_COLNAME, TYPE_FIELDNAME, TYPE_NUM. ' . $type . ' was given.');
if (! array_key_exists( $type, self::$fieldNames )) {
throw new PropelException( 'Method getFieldNames() expects the parameter $type to be one of the class constants TYPE_PHPNAME, TYPE_COLNAME, TYPE_FIELDNAME, TYPE_NUM. ' . $type . ' was given.' );
}
return self::$fieldNames[$type];
}
@@ -201,13 +248,14 @@ abstract class ArrayBasePeer {
* $c->addAlias("alias1", TablePeer::TABLE_NAME);
* $c->addJoin(TablePeer::alias("alias1", TablePeer::PRIMARY_KEY_COLUMN), TablePeer::PRIMARY_KEY_COLUMN);
* </code>
*
* @param string $alias The alias for the current table.
* @param string $column The column name for current table. (i.e. ApplicationPeer::COLUMN_NAME).
* @return string
*/
public static function alias($alias, $column)
public static function alias ($alias, $column)
{
return str_replace(ApplicationPeer::TABLE_NAME.'.', $alias.'.', $column);
return str_replace( ApplicationPeer::TABLE_NAME . '.', $alias . '.', $column );
}
/**
@@ -221,12 +269,11 @@ abstract class ArrayBasePeer {
* @throws PropelException Any exceptions caught during processing will be
* rethrown wrapped into a PropelException.
*/
public static function addSelectColumns(Criteria $criteria)
public static function addSelectColumns (Criteria $criteria)
{
}
const COUNT = 'COUNT(APPLICATION.APP_UID)';
const COUNT_DISTINCT = 'COUNT(DISTINCT APPLICATION.APP_UID)';
@@ -239,7 +286,7 @@ abstract class ArrayBasePeer {
* @return int Number of matching rows.
* @todo Review declarated constant d'not used COUNT, COUNT_DISTINCT
*/
public static function doCount(Criteria $criteria, $distinct = false, $con = null)
public static function doCount (Criteria $criteria, $distinct = false, $con = null)
{
// we're going to modify criteria, so copy it first
$criteria = clone $criteria;
@@ -254,14 +301,14 @@ abstract class ArrayBasePeer {
$criteria->addSelectColumn(ApplicationPeer::COUNT);
}
*/
$criteria->addSelectColumn( 'COUNT(*)');
$criteria->addSelectColumn( 'COUNT(*)' );
// just in case we're grouping: add those columns to the select statement
foreach($criteria->getGroupByColumns() as $column) {
$criteria->addSelectColumn($column);
foreach ($criteria->getGroupByColumns() as $column) {
$criteria->addSelectColumn( $column );
}
$rs = ArrayBasePeer::doSelectRS($criteria, $con);
$rs = ArrayBasePeer::doSelectRS( $criteria, $con );
if ($rs->next()) {
$row = $rs->getRow();
return $row[1];
@@ -270,6 +317,7 @@ abstract class ArrayBasePeer {
return 0;
}
}
/**
* Method to select one object from the DB.
*
@@ -279,11 +327,11 @@ abstract class ArrayBasePeer {
* @throws PropelException Any exceptions caught during processing will be
* rethrown wrapped into a PropelException.
*/
public static function doSelectOne(Criteria $criteria, $con = null)
public static function doSelectOne (Criteria $criteria, $con = null)
{
$critcopy = clone $criteria;
$critcopy->setLimit(1);
$objects = ApplicationPeer::doSelect($critcopy, $con);
$critcopy->setLimit( 1 );
$objects = ApplicationPeer::doSelect( $critcopy, $con );
if ($objects) {
return $objects[0];
}
@@ -299,18 +347,18 @@ abstract class ArrayBasePeer {
* @throws PropelException Any exceptions caught during processing will be
* rethrown wrapped into a PropelException.
*/
private function createSelectSql($criteria, $tableName, &$params)
private function createSelectSql ($criteria, $tableName, &$params)
{
$db = Propel::getDB($criteria->getDbName());
$db = Propel::getDB( $criteria->getDbName() );
// redundant definition $selectModifiers = array();
$selectClause = array();
$fromClause = array();
$joinClause = array();
$joinTables = array();
$whereClause = array();
$orderByClause = array();
$groupByClause = array();
$selectClause = array ();
$fromClause = array ();
$joinClause = array ();
$joinTables = array ();
$whereClause = array ();
$orderByClause = array ();
$groupByClause = array ();
$orderBy = $criteria->getOrderByColumns();
$groupBy = $criteria->getGroupByColumns();
@@ -323,12 +371,13 @@ abstract class ArrayBasePeer {
// simple copy
$selectModifiers = $criteria->getSelectModifiers();
// get selected columns
foreach($select as $columnName) {
foreach ($select as $columnName) {
$tableName = null;
$selectClause[] = $columnName; // the full column name: e.g. MAX(books.price)
$parenPos = strpos($columnName, '(');
$dotPos = strpos($columnName, '.');
$parenPos = strpos( $columnName, '(' );
$dotPos = strpos( $columnName, '.' );
// [HL] I think we really only want to worry about adding stuff to
// the fromClause if this function has a TABLE.COLUMN in it at all.
@@ -337,18 +386,18 @@ abstract class ArrayBasePeer {
if ($dotPos !== false) {
if ($parenPos === false) { // table.column
$tableName = substr($columnName, 0, $dotPos);
$tableName = substr( $columnName, 0, $dotPos );
} else { // FUNC(table.column)
$tableName = substr($columnName, $parenPos + 1, $dotPos - ($parenPos + 1));
$tableName = substr( $columnName, $parenPos + 1, $dotPos - ($parenPos + 1) );
// functions may contain qualifiers so only take the last
// word as the table name.
// COUNT(DISTINCT books.price)
$lastSpace = strpos($tableName, ' ');
$lastSpace = strpos( $tableName, ' ' );
if ($lastSpace !== false) { // COUNT(DISTINCT books.price)
$tableName = substr($tableName, $lastSpace + 1);
$tableName = substr( $tableName, $lastSpace + 1 );
}
}
$tableName2 = $criteria->getTableForAlias($tableName);
$tableName2 = $criteria->getTableForAlias( $tableName );
if ($tableName2 !== null) {
$fromClause[] = $tableName2 . ' ' . $tableName;
} else {
@@ -359,20 +408,20 @@ abstract class ArrayBasePeer {
}
// set the aliases
foreach($aliases as $alias => $col) {
foreach ($aliases as $alias => $col) {
$selectClause[] = $col . " AS " . $alias;
}
// add the criteria to WHERE clause
foreach($criteria->keys() as $key) {
foreach ($criteria->keys() as $key) {
$criterion = $criteria->getCriterion($key);
$criterion = $criteria->getCriterion( $key );
$someCriteria = $criterion->getAttachedCriterion();
$someCriteriaLength = count($someCriteria);
$someCriteriaLength = count( $someCriteria );
$table = null;
for ($i=0; $i < $someCriteriaLength; $i++) {
for ($i = 0; $i < $someCriteriaLength; $i ++) {
$tableName = $someCriteria[$i]->getTable();
$table = $criteria->getTableForAlias($tableName);
$table = $criteria->getTableForAlias( $tableName );
if ($table !== null) {
$fromClause[] = $table . ' ' . $tableName;
} else {
@@ -380,15 +429,11 @@ abstract class ArrayBasePeer {
$table = $tableName;
}
$ignoreCase =
(($criteria->isIgnoreCase()
|| $someCriteria[$i]->isIgnoreCase())
&& ($dbMap->getTable($table)->getColumn($someCriteria[$i]->getColumn())->getType() == "string" )
);
$ignoreCase = (($criteria->isIgnoreCase() || $someCriteria[$i]->isIgnoreCase()) && ($dbMap->getTable( $table )->getColumn( $someCriteria[$i]->getColumn() )->getType() == "string"));
$someCriteria[$i]->setIgnoreCase($ignoreCase);
$someCriteria[$i]->setIgnoreCase( $ignoreCase );
}
$criterion->setDB($db);
$criterion->setDB( $db );
$cri['table'] = $criterion->table;
$cri['field'] = $criterion->column;
@@ -399,56 +444,51 @@ abstract class ArrayBasePeer {
$params[] = $cri;
//$criterion->appendPsTo($sb, $params);
$whereClause[] = $sb;
}
// Unique from clause elements
$fromClause = array_unique( $fromClause );
if (!empty($orderBy)) {
if (! empty( $orderBy )) {
foreach($orderBy as $orderByColumn) {
foreach ($orderBy as $orderByColumn) {
// Add function expression as-is.
if (strpos($orderByColumn, '(') !== false) {
if (strpos( $orderByColumn, '(' ) !== false) {
$orderByClause[] = $orderByColumn;
continue;
}
// Split orderByColumn (i.e. "table.column DESC")
$dotPos = strpos($orderByColumn, '.');
$dotPos = strpos( $orderByColumn, '.' );
if ($dotPos !== false) {
$tableName = substr($orderByColumn, 0, $dotPos);
$columnName = substr($orderByColumn, $dotPos+1);
}
else {
$tableName = substr( $orderByColumn, 0, $dotPos );
$columnName = substr( $orderByColumn, $dotPos + 1 );
} else {
$tableName = '';
$columnName = $orderByColumn;
}
$spacePos = strpos($columnName, ' ');
$spacePos = strpos( $columnName, ' ' );
if ($spacePos !== false) {
$direction = substr($columnName, $spacePos);
$columnName = substr($columnName, 0, $spacePos);
}
else {
$direction = substr( $columnName, $spacePos );
$columnName = substr( $columnName, 0, $spacePos );
} else {
$direction = '';
}
$orderByClause[] = array ( 'columnName' => $columnName, 'direction' => $direction );
$orderByClause[] = array ('columnName' => $columnName,'direction' => $direction
);
}
}
// Build the SQL from the arrays we compiled
$sql = "SELECT "
.($selectModifiers ? implode(" ", $selectModifiers) . " " : "")
.implode(", ", $selectClause)
." FROM ". $fromClause[0]
.($whereClause ? " WHERE ".implode(" AND ", $whereClause) : "")
.($groupByClause ? " GROUP BY ".implode(",", $groupByClause) : "");
$sql = "SELECT " . ($selectModifiers ? implode( " ", $selectModifiers ) . " " : "") . implode( ", ", $selectClause ) . " FROM " . $fromClause[0] . ($whereClause ? " WHERE " . implode( " AND ", $whereClause ) : "") . ($groupByClause ? " GROUP BY " . implode( ",", $groupByClause ) : "");
$dataSql['selectClause'] = $selectClause;
$dataSql['fromClause'] = $fromClause;
$dataSql['whereClause'] = $whereClause;
$dataSql['orderByClause']= $orderByClause;
$dataSql['orderByClause'] = $orderByClause;
$dataSql['sql'] = $sql;
return $dataSql;
@@ -463,30 +503,32 @@ abstract class ArrayBasePeer {
* @throws PropelException Any exceptions caught during processing will be
* rethrown wrapped into a PropelException.
*/
public static function doSelect(Criteria $criteria, $tableName, $con = null)
public static function doSelect (Criteria $criteria, $tableName, $con = null)
{
$dbMap = Propel::getDatabaseMap($criteria->getDbName());
$dbMap = Propel::getDatabaseMap( $criteria->getDbName() );
$stmt = null;
try {
$params = array();
$sql = self::createSelectSql($criteria, $tableName, $params);
$params = array ();
$sql = self::createSelectSql( $criteria, $tableName, $params );
$sql['params'] = $params;
$stmt = $con->prepareStatement( $sql);
$stmt = $con->prepareStatement( $sql );
//$stmt->setLimit($criteria->getLimit());
$sql['limit']=$criteria->getLimit();
$sql['limit'] = $criteria->getLimit();
//$stmt->setOffset($criteria->getOffset());
$sql['offset']=$criteria->getOffset();
$sql['offset'] = $criteria->getOffset();
//$rs = $stmt->executeQuery(ResultSet::FETCHMODE_NUM);
$rs = $con->executeQuery($sql, ResultSet::FETCHMODE_NUM);
$rs = $con->executeQuery( $sql, ResultSet::FETCHMODE_NUM );
} catch (Exception $e) {
if ($stmt) $stmt->close();
throw new PropelException($e);
if ($stmt)
$stmt->close();
throw new PropelException( $e );
}
return $rs;
}
/**
* Prepares the Criteria object and uses the parent doSelect()
* method to get a ResultSet.
@@ -501,34 +543,34 @@ abstract class ArrayBasePeer {
* @return ResultSet The resultset object with numerically-indexed fields.
* @see BasePeer::doSelect()
*/
public static function doSelectRS(Criteria $criteria, $con = null)
public static function doSelectRS (Criteria $criteria, $con = null)
{
global $_DBArray;
if ( !isset ($_DBArray) ) {
if (! isset( $_DBArray )) {
$_DBArray = $_SESSION['_DBArray'];
}
$tableName = $criteria->getDBArrayTable();
if ( !isset ( $_DBArray[$tableName] ) ) {
throw new Exception ( "Error: the table '$tableName' doesn't exist in DBArray " );
if (! isset( $_DBArray[$tableName] )) {
throw new Exception( "Error: the table '$tableName' doesn't exist in DBArray " );
}
$arrayTable = $_DBArray[$tableName];
if ($con === null) {
$con = Propel::getConnection(self::DATABASE_NAME);
$con = Propel::getConnection( self::DATABASE_NAME );
}
if (!$criteria->getSelectColumns()) {
foreach ( array_keys ( $_DBArray[$tableName][0] ) as $key => $val )
$criteria->addSelectColumn( $tableName.'.'.$val );
if (! $criteria->getSelectColumns()) {
foreach (array_keys( $_DBArray[$tableName][0] ) as $key => $val)
$criteria->addSelectColumn( $tableName . '.' . $val );
}
// Set the correct dbName
$criteria->setDbName(self::DATABASE_NAME);
$criteria->setDbName( self::DATABASE_NAME );
// BasePeer returns a Creole ResultSet, set to return
// rows indexed numerically.
return ArrayBasePeer::doSelect($criteria,$tableName, $con);
return ArrayBasePeer::doSelect( $criteria, $tableName, $con );
}
/**
@@ -538,31 +580,33 @@ abstract class ArrayBasePeer {
* @throws PropelException Any exceptions caught during processing will be
* rethrown wrapped into a PropelException.
*/
public static function populateObjects(ResultSet $rs)
public static function populateObjects (ResultSet $rs)
{
$results = array();
$results = array ();
// set the class once to avoid overhead in the loop
$cls = ApplicationPeer::getOMClass();
$cls = Propel::import($cls);
$cls = Propel::import( $cls );
// populate the object(s)
while($rs->next()) {
while ($rs->next()) {
$obj = new $cls();
$obj->hydrate($rs);
$obj->hydrate( $rs );
$results[] = $obj;
}
return $results;
}
/**
* Returns the TableMap related to this peer.
* This method is not needed for general use but a specific application could have a need.
*
* @return TableMap
* @throws PropelException Any exceptions caught during processing will be
* rethrown wrapped into a PropelException.
*/
public static function getTableMap()
public static function getTableMap ()
{
return Propel::getDatabaseMap(self::DATABASE_NAME)->getTable(self::TABLE_NAME);
return Propel::getDatabaseMap( self::DATABASE_NAME )->getTable( self::TABLE_NAME );
}
/**
@@ -574,7 +618,7 @@ abstract class ArrayBasePeer {
*
* @return string path.to.ClassName
*/
public static function getOMClass()
public static function getOMClass ()
{
return ApplicationPeer::CLASS_DEFAULT;
}
@@ -588,10 +632,10 @@ abstract class ArrayBasePeer {
* @throws PropelException Any exceptions caught during processing will be
* rethrown wrapped into a PropelException.
*/
public static function doInsert($values, $con = null)
public static function doInsert ($values, $con = null)
{
if ($con === null) {
$con = Propel::getConnection(self::DATABASE_NAME);
$con = Propel::getConnection( self::DATABASE_NAME );
}
if ($values instanceof Criteria) {
@@ -600,17 +644,16 @@ abstract class ArrayBasePeer {
$criteria = $values->buildCriteria(); // build Criteria from Application object
}
// Set the correct dbName
$criteria->setDbName(self::DATABASE_NAME);
$criteria->setDbName( self::DATABASE_NAME );
try {
// use transaction because $criteria could contain info
// for more than one table (I guess, conceivably)
$con->begin();
$pk = BasePeer::doInsert($criteria, $con);
$pk = BasePeer::doInsert( $criteria, $con );
$con->commit();
} catch(PropelException $e) {
} catch (PropelException $e) {
$con->rollback();
throw $e;
}
@@ -627,19 +670,20 @@ abstract class ArrayBasePeer {
* @throws PropelException Any exceptions caught during processing will be
* rethrown wrapped into a PropelException.
*/
public static function doUpdate($values, $con = null)
public static function doUpdate ($values, $con = null)
{
if ($con === null) {
$con = Propel::getConnection(self::DATABASE_NAME);
$con = Propel::getConnection( self::DATABASE_NAME );
}
$selectCriteria = new Criteria(self::DATABASE_NAME);
$selectCriteria = new Criteria( self::DATABASE_NAME );
if ($values instanceof Criteria) {
$criteria = clone $values; // rename for clarity
$comparison = $criteria->getComparison(ApplicationPeer::APP_UID);
$selectCriteria->add(ApplicationPeer::APP_UID, $criteria->remove(ApplicationPeer::APP_UID), $comparison);
$comparison = $criteria->getComparison( ApplicationPeer::APP_UID );
$selectCriteria->add( ApplicationPeer::APP_UID, $criteria->remove( ApplicationPeer::APP_UID ), $comparison );
} else { // $values is Application object
$criteria = $values->buildCriteria(); // gets full criteria
@@ -647,27 +691,28 @@ abstract class ArrayBasePeer {
}
// set the correct dbName
$criteria->setDbName(self::DATABASE_NAME);
$criteria->setDbName( self::DATABASE_NAME );
return BasePeer::doUpdate($selectCriteria, $criteria, $con);
return BasePeer::doUpdate( $selectCriteria, $criteria, $con );
}
/**
* Method to DELETE all rows from the APPLICATION table.
*
* @param Connection $con The connection to use
* @return int The number of affected rows (if supported by underlying database driver).
*/
public static function doDeleteAll($con = null)
public static function doDeleteAll ($con = null)
{
if ($con === null) {
$con = Propel::getConnection(self::DATABASE_NAME);
$con = Propel::getConnection( self::DATABASE_NAME );
}
$affectedRows = 0; // initialize var to track total num of affected rows
try {
// use transaction because $criteria could contain info
// for more than one table or we could emulating ON DELETE CASCADE, etc.
$con->begin();
$affectedRows += BasePeer::doDeleteAll(ApplicationPeer::TABLE_NAME, $con);
$affectedRows += BasePeer::doDeleteAll( ApplicationPeer::TABLE_NAME, $con );
$con->commit();
return $affectedRows;
} catch (PropelException $e) {
@@ -687,10 +732,10 @@ abstract class ArrayBasePeer {
* @throws PropelException Any exceptions caught during processing will be
* rethrown wrapped into a PropelException.
*/
public static function doDelete($values, $con = null)
public static function doDelete ($values, $con = null)
{
if ($con === null) {
$con = Propel::getConnection(ApplicationPeer::DATABASE_NAME);
$con = Propel::getConnection( ApplicationPeer::DATABASE_NAME );
}
if ($values instanceof Criteria) {
@@ -700,21 +745,22 @@ abstract class ArrayBasePeer {
$criteria = $values->buildPkeyCriteria();
} else {
// it must be the primary key
$criteria = new Criteria(self::DATABASE_NAME);
$criteria->add(ApplicationPeer::APP_UID, (array) $values, Criteria::IN);
$criteria = new Criteria( self::DATABASE_NAME );
$criteria->add( ApplicationPeer::APP_UID, (array) $values, Criteria::IN );
}
}
// Set the correct dbName
$criteria->setDbName(self::DATABASE_NAME);
$criteria->setDbName( self::DATABASE_NAME );
$affectedRows = 0; // initialize var to track total num of affected rows
try {
// use transaction because $criteria could contain info
// for more than one table or we could emulating ON DELETE CASCADE, etc.
$con->begin();
$affectedRows += BasePeer::doDelete($criteria, $con);
$affectedRows += BasePeer::doDelete( $criteria, $con );
$con->commit();
return $affectedRows;
} catch (PropelException $e) {
@@ -735,32 +781,33 @@ abstract class ArrayBasePeer {
*
* @return mixed TRUE if all columns are valid or the error message of the first invalid column.
*/
public static function doValidate(Application $obj, $cols = null)
public static function doValidate (Application $obj, $cols = null)
{
$columns = array();
$columns = array ();
if ($cols) {
$dbMap = Propel::getDatabaseMap(ApplicationPeer::DATABASE_NAME);
$tableMap = $dbMap->getTable(ApplicationPeer::TABLE_NAME);
$dbMap = Propel::getDatabaseMap( ApplicationPeer::DATABASE_NAME );
$tableMap = $dbMap->getTable( ApplicationPeer::TABLE_NAME );
if (! is_array($cols)) {
$cols = array($cols);
if (! is_array( $cols )) {
$cols = array ($cols
);
}
foreach($cols as $colName) {
if ($tableMap->containsColumn($colName)) {
$get = 'get' . $tableMap->getColumn($colName)->getPhpName();
foreach ($cols as $colName) {
if ($tableMap->containsColumn( $colName )) {
$get = 'get' . $tableMap->getColumn( $colName )->getPhpName();
$columns[$colName] = $obj->$get();
}
}
} else {
if ($obj->isNew() || $obj->isColumnModified(ApplicationPeer::APP_STATUS))
if ($obj->isNew() || $obj->isColumnModified( ApplicationPeer::APP_STATUS ))
$columns[ApplicationPeer::APP_STATUS] = $obj->getAppStatus();
}
return BasePeer::doValidate(ApplicationPeer::DATABASE_NAME, ApplicationPeer::TABLE_NAME, $columns);
return BasePeer::doValidate( ApplicationPeer::DATABASE_NAME, ApplicationPeer::TABLE_NAME, $columns );
}
/**
@@ -770,20 +817,19 @@ abstract class ArrayBasePeer {
* @param Connection $con the connection to use
* @return Application
*/
public static function retrieveByPK($pk, $con = null)
public static function retrieveByPK ($pk, $con = null)
{
if ($con === null) {
$con = Propel::getConnection(self::DATABASE_NAME);
$con = Propel::getConnection( self::DATABASE_NAME );
}
$criteria = new Criteria(ApplicationPeer::DATABASE_NAME);
$criteria = new Criteria( ApplicationPeer::DATABASE_NAME );
$criteria->add(ApplicationPeer::APP_UID, $pk);
$criteria->add( ApplicationPeer::APP_UID, $pk );
$v = ApplicationPeer::doSelect( $criteria, $con );
$v = ApplicationPeer::doSelect($criteria, $con);
return !empty($v) > 0 ? $v[0] : null;
return ! empty( $v ) > 0 ? $v[0] : null;
}
/**
@@ -794,19 +840,19 @@ abstract class ArrayBasePeer {
* @throws PropelException Any exceptions caught during processing will be
* rethrown wrapped into a PropelException.
*/
public static function retrieveByPKs($pks, $con = null)
public static function retrieveByPKs ($pks, $con = null)
{
if ($con === null) {
$con = Propel::getConnection(self::DATABASE_NAME);
$con = Propel::getConnection( self::DATABASE_NAME );
}
$objs = null;
if (empty($pks)) {
$objs = array();
if (empty( $pks )) {
$objs = array ();
} else {
$criteria = new Criteria();
$criteria->add(ApplicationPeer::APP_UID, $pks, Criteria::IN);
$objs = ApplicationPeer::doSelect($criteria, $con);
$criteria->add( ApplicationPeer::APP_UID, $pks, Criteria::IN );
$objs = ApplicationPeer::doSelect( $criteria, $con );
}
return $objs;
}
@@ -821,11 +867,11 @@ if (Propel::isInit()) {
try {
BaseApplicationPeer::getMapBuilder();
} catch (Exception $e) {
Propel::log('Could not initialize Peer: ' . $e->getMessage(), Propel::LOG_ERR);
Propel::log( 'Could not initialize Peer: ' . $e->getMessage(), Propel::LOG_ERR );
}
} else {
// even if Propel is not yet initialized, the map builder class can be registered
// now and then it will be loaded when Propel initializes.
require_once 'classes/model/map/ApplicationMapBuilder.php';
Propel::registerMapBuilder('classes.model.map.ApplicationMapBuilder');
Propel::registerMapBuilder( 'classes.model.map.ApplicationMapBuilder' );
}