@@ -48,7 +48,7 @@ discard block |
||
| 48 | 48 | |
| 49 | 49 | /** |
| 50 | 50 | * @param TDbConnection database connection. |
| 51 | - * @return TDbCommandBuilder new command builder |
|
| 51 | + * @return TOracleCommandBuilder new command builder |
|
| 52 | 52 | */ |
| 53 | 53 | public function createCommandBuilder($connection) |
| 54 | 54 | { |
@@ -58,6 +58,8 @@ discard block |
||
| 58 | 58 | /** |
| 59 | 59 | * @param string information array key name |
| 60 | 60 | * @param mixed default value if information array value is null |
| 61 | + * @param string $name |
|
| 62 | + * @param boolean $default |
|
| 61 | 63 | * @return mixed information array value. |
| 62 | 64 | */ |
| 63 | 65 | public function getInfo($name, $default = null) |
@@ -25,7 +25,7 @@ discard block |
||
| 25 | 25 | */ |
| 26 | 26 | class TOracleTableInfo extends \Prado\TComponent |
| 27 | 27 | { |
| 28 | - private $_info = []; |
|
| 28 | + private $_info=[]; |
|
| 29 | 29 | |
| 30 | 30 | private $_primaryKeys; |
| 31 | 31 | private $_foreignKeys; |
@@ -38,12 +38,12 @@ discard block |
||
| 38 | 38 | * Sets the database table meta data information. |
| 39 | 39 | * @param array table column information. |
| 40 | 40 | */ |
| 41 | - public function __construct($tableInfo = [], $primary = [], $foreign = []) |
|
| 41 | + public function __construct($tableInfo=[], $primary=[], $foreign=[]) |
|
| 42 | 42 | { |
| 43 | - $this->_info = $tableInfo; |
|
| 44 | - $this->_primaryKeys = $primary; |
|
| 45 | - $this->_foreignKeys = $foreign; |
|
| 46 | - $this->_columns = new TMap; |
|
| 43 | + $this->_info=$tableInfo; |
|
| 44 | + $this->_primaryKeys=$primary; |
|
| 45 | + $this->_foreignKeys=$foreign; |
|
| 46 | + $this->_columns=new TMap; |
|
| 47 | 47 | } |
| 48 | 48 | |
| 49 | 49 | /** |
@@ -60,7 +60,7 @@ discard block |
||
| 60 | 60 | * @param mixed default value if information array value is null |
| 61 | 61 | * @return mixed information array value. |
| 62 | 62 | */ |
| 63 | - public function getInfo($name, $default = null) |
|
| 63 | + public function getInfo($name, $default=null) |
|
| 64 | 64 | { |
| 65 | 65 | return isset($this->_info[$name]) ? $this->_info[$name] : $default; |
| 66 | 66 | } |
@@ -71,7 +71,7 @@ discard block |
||
| 71 | 71 | */ |
| 72 | 72 | protected function setInfo($name, $value) |
| 73 | 73 | { |
| 74 | - $this->_info[$name] = $value; |
|
| 74 | + $this->_info[$name]=$value; |
|
| 75 | 75 | } |
| 76 | 76 | |
| 77 | 77 | /** |
@@ -87,7 +87,7 @@ discard block |
||
| 87 | 87 | */ |
| 88 | 88 | public function getTableFullName() |
| 89 | 89 | { |
| 90 | - return $this->_info['SchemaName'] . '.' . $this->getTableName(); |
|
| 90 | + return $this->_info['SchemaName'].'.'.$this->getTableName(); |
|
| 91 | 91 | } |
| 92 | 92 | |
| 93 | 93 | /** |
@@ -112,7 +112,7 @@ discard block |
||
| 112 | 112 | */ |
| 113 | 113 | public function getColumn($name) |
| 114 | 114 | { |
| 115 | - if(($column = $this->_columns->itemAt($name)) !== null) |
|
| 115 | + if(($column=$this->_columns->itemAt($name))!==null) |
|
| 116 | 116 | return $column; |
| 117 | 117 | throw new TDbException('dbtableinfo_invalid_column_name', $name, $this->getTableFullName()); |
| 118 | 118 | } |
@@ -124,7 +124,7 @@ discard block |
||
| 124 | 124 | public function getColumnNames() |
| 125 | 125 | { |
| 126 | 126 | foreach($this->getColumns() as $column) |
| 127 | - $names[] = $column->getColumnName(); |
|
| 127 | + $names[]=$column->getColumnName(); |
|
| 128 | 128 | return $names; |
| 129 | 129 | } |
| 130 | 130 | |
@@ -149,11 +149,11 @@ discard block |
||
| 149 | 149 | */ |
| 150 | 150 | public function getLowerCaseColumnNames() |
| 151 | 151 | { |
| 152 | - if($this->_lowercase === null) |
|
| 152 | + if($this->_lowercase===null) |
|
| 153 | 153 | { |
| 154 | - $this->_lowercase = []; |
|
| 154 | + $this->_lowercase=[]; |
|
| 155 | 155 | foreach($this->getColumns()->getKeys() as $key) |
| 156 | - $this->_lowercase[strtolower($key)] = $key; |
|
| 156 | + $this->_lowercase[strtolower($key)]=$key; |
|
| 157 | 157 | } |
| 158 | 158 | return $this->_lowercase; |
| 159 | 159 | } |
@@ -38,6 +38,7 @@ |
||
| 38 | 38 | /** |
| 39 | 39 | * @param string information array key name |
| 40 | 40 | * @param mixed default value if information array value is null |
| 41 | + * @param string $name |
|
| 41 | 42 | * @return mixed information array value. |
| 42 | 43 | */ |
| 43 | 44 | protected function getInfo($name, $default = null) |
@@ -22,9 +22,9 @@ discard block |
||
| 22 | 22 | */ |
| 23 | 23 | class TDbTableColumn extends \Prado\TComponent |
| 24 | 24 | { |
| 25 | - const UNDEFINED_VALUE = INF; //use infinity for undefined value |
|
| 25 | + const UNDEFINED_VALUE=INF; //use infinity for undefined value |
|
| 26 | 26 | |
| 27 | - private $_info = []; |
|
| 27 | + private $_info=[]; |
|
| 28 | 28 | |
| 29 | 29 | /** |
| 30 | 30 | * Sets the table column meta data. |
@@ -32,7 +32,7 @@ discard block |
||
| 32 | 32 | */ |
| 33 | 33 | public function __construct($columnInfo) |
| 34 | 34 | { |
| 35 | - $this->_info = $columnInfo; |
|
| 35 | + $this->_info=$columnInfo; |
|
| 36 | 36 | } |
| 37 | 37 | |
| 38 | 38 | /** |
@@ -40,7 +40,7 @@ discard block |
||
| 40 | 40 | * @param mixed default value if information array value is null |
| 41 | 41 | * @return mixed information array value. |
| 42 | 42 | */ |
| 43 | - protected function getInfo($name, $default = null) |
|
| 43 | + protected function getInfo($name, $default=null) |
|
| 44 | 44 | { |
| 45 | 45 | return isset($this->_info[$name]) ? $this->_info[$name] : $default; |
| 46 | 46 | } |
@@ -51,7 +51,7 @@ discard block |
||
| 51 | 51 | */ |
| 52 | 52 | protected function setInfo($name, $value) |
| 53 | 53 | { |
| 54 | - $this->_info[$name] = $value; |
|
| 54 | + $this->_info[$name]=$value; |
|
| 55 | 55 | } |
| 56 | 56 | |
| 57 | 57 | /** |
@@ -151,10 +151,10 @@ discard block |
||
| 151 | 151 | |
| 152 | 152 | public function getMaxiumNumericConstraint() |
| 153 | 153 | { |
| 154 | - if(($precision = $this->getNumericPrecision()) !== null) |
|
| 154 | + if(($precision=$this->getNumericPrecision())!==null) |
|
| 155 | 155 | { |
| 156 | - $scale = $this->getNumericScale(); |
|
| 157 | - return $scale === null ? pow(10, $precision) : pow(10, $precision - $scale); |
|
| 156 | + $scale=$this->getNumericScale(); |
|
| 157 | + return $scale===null ? pow(10, $precision) : pow(10, $precision - $scale); |
|
| 158 | 158 | } |
| 159 | 159 | } |
| 160 | 160 | |
@@ -187,7 +187,7 @@ discard block |
||
| 187 | 187 | */ |
| 188 | 188 | public function hasSequence() |
| 189 | 189 | { |
| 190 | - return $this->getSequenceName() !== null; |
|
| 190 | + return $this->getSequenceName()!==null; |
|
| 191 | 191 | } |
| 192 | 192 | |
| 193 | 193 | /** |
@@ -63,6 +63,8 @@ |
||
| 63 | 63 | /** |
| 64 | 64 | * @param string information array key name |
| 65 | 65 | * @param mixed default value if information array value is null |
| 66 | + * @param string $name |
|
| 67 | + * @param boolean $default |
|
| 66 | 68 | * @return mixed information array value. |
| 67 | 69 | */ |
| 68 | 70 | protected function getInfo($name, $default = null) |
@@ -24,7 +24,7 @@ discard block |
||
| 24 | 24 | */ |
| 25 | 25 | class TDbTableInfo extends \Prado\TComponent |
| 26 | 26 | { |
| 27 | - private $_info = []; |
|
| 27 | + private $_info=[]; |
|
| 28 | 28 | |
| 29 | 29 | private $_primaryKeys; |
| 30 | 30 | private $_foreignKeys; |
@@ -43,12 +43,12 @@ discard block |
||
| 43 | 43 | * Sets the database table meta data information. |
| 44 | 44 | * @param array table column information. |
| 45 | 45 | */ |
| 46 | - public function __construct($tableInfo = [], $primary = [], $foreign = []) |
|
| 46 | + public function __construct($tableInfo=[], $primary=[], $foreign=[]) |
|
| 47 | 47 | { |
| 48 | - $this->_info = $tableInfo; |
|
| 49 | - $this->_primaryKeys = $primary; |
|
| 50 | - $this->_foreignKeys = $foreign; |
|
| 51 | - $this->_columns = new TMap; |
|
| 48 | + $this->_info=$tableInfo; |
|
| 49 | + $this->_primaryKeys=$primary; |
|
| 50 | + $this->_foreignKeys=$foreign; |
|
| 51 | + $this->_columns=new TMap; |
|
| 52 | 52 | } |
| 53 | 53 | |
| 54 | 54 | /** |
@@ -65,7 +65,7 @@ discard block |
||
| 65 | 65 | * @param mixed default value if information array value is null |
| 66 | 66 | * @return mixed information array value. |
| 67 | 67 | */ |
| 68 | - protected function getInfo($name, $default = null) |
|
| 68 | + protected function getInfo($name, $default=null) |
|
| 69 | 69 | { |
| 70 | 70 | return isset($this->_info[$name]) ? $this->_info[$name] : $default; |
| 71 | 71 | } |
@@ -76,7 +76,7 @@ discard block |
||
| 76 | 76 | */ |
| 77 | 77 | protected function setInfo($name, $value) |
| 78 | 78 | { |
| 79 | - $this->_info[$name] = $value; |
|
| 79 | + $this->_info[$name]=$value; |
|
| 80 | 80 | } |
| 81 | 81 | |
| 82 | 82 | /** |
@@ -117,7 +117,7 @@ discard block |
||
| 117 | 117 | */ |
| 118 | 118 | public function getColumn($name) |
| 119 | 119 | { |
| 120 | - if(($column = $this->_columns->itemAt($name)) !== null) |
|
| 120 | + if(($column=$this->_columns->itemAt($name))!==null) |
|
| 121 | 121 | return $column; |
| 122 | 122 | throw new TDbException('dbtableinfo_invalid_column_name', $name, $this->getTableFullName()); |
| 123 | 123 | } |
@@ -128,11 +128,11 @@ discard block |
||
| 128 | 128 | */ |
| 129 | 129 | public function getColumnNames() |
| 130 | 130 | { |
| 131 | - if($this->_names === null) |
|
| 131 | + if($this->_names===null) |
|
| 132 | 132 | { |
| 133 | - $this->_names = []; |
|
| 133 | + $this->_names=[]; |
|
| 134 | 134 | foreach($this->getColumns() as $column) |
| 135 | - $this->_names[] = $column->getColumnName(); |
|
| 135 | + $this->_names[]=$column->getColumnName(); |
|
| 136 | 136 | } |
| 137 | 137 | return $this->_names; |
| 138 | 138 | } |
@@ -158,11 +158,11 @@ discard block |
||
| 158 | 158 | */ |
| 159 | 159 | public function getLowerCaseColumnNames() |
| 160 | 160 | { |
| 161 | - if($this->_lowercase === null) |
|
| 161 | + if($this->_lowercase===null) |
|
| 162 | 162 | { |
| 163 | - $this->_lowercase = []; |
|
| 163 | + $this->_lowercase=[]; |
|
| 164 | 164 | foreach($this->getColumns()->getKeys() as $key) |
| 165 | - $this->_lowercase[strtolower($key)] = $key; |
|
| 165 | + $this->_lowercase[strtolower($key)]=$key; |
|
| 166 | 166 | } |
| 167 | 167 | return $this->_lowercase; |
| 168 | 168 | } |
@@ -103,6 +103,7 @@ discard block |
||
| 103 | 103 | |
| 104 | 104 | /** |
| 105 | 105 | * @param TDbTableInfo table or view information. |
| 106 | + * @param TDbTableInfo $tableInfo |
|
| 106 | 107 | */ |
| 107 | 108 | protected function setTableInfo($tableInfo) |
| 108 | 109 | { |
@@ -113,6 +114,7 @@ discard block |
||
| 113 | 114 | /** |
| 114 | 115 | * Sets up the command builder for the given table. |
| 115 | 116 | * @param string table or view name. |
| 117 | + * @param string $tableName |
|
| 116 | 118 | */ |
| 117 | 119 | protected function setTableName($tableName) |
| 118 | 120 | { |
@@ -224,6 +226,7 @@ discard block |
||
| 224 | 226 | * |
| 225 | 227 | * @param string|TSqlCriteria SQL condition or criteria object. |
| 226 | 228 | * @param mixed parameter values. |
| 229 | + * @param TSqlCriteria $criteria |
|
| 227 | 230 | * @return array matching record object. |
| 228 | 231 | */ |
| 229 | 232 | public function find($criteria, $parameters = []) |
@@ -237,6 +240,7 @@ discard block |
||
| 237 | 240 | * Accepts same parameters as find(), but returns TDbDataReader instead. |
| 238 | 241 | * @param string|TSqlCriteria SQL condition or criteria object. |
| 239 | 242 | * @param mixed parameter values. |
| 243 | + * @param TSqlCriteria $criteria |
|
| 240 | 244 | * @return TDbDataReader matching records. |
| 241 | 245 | */ |
| 242 | 246 | public function findAll($criteria = null, $parameters = []) |
@@ -299,6 +303,7 @@ discard block |
||
| 299 | 303 | * </code> |
| 300 | 304 | * @param string delete condition. |
| 301 | 305 | * @param array condition parameters. |
| 306 | + * @param TSqlCriteria $criteria |
|
| 302 | 307 | * @return integer number of records deleted. |
| 303 | 308 | */ |
| 304 | 309 | public function deleteAll($criteria, $parameters = []) |
@@ -92,7 +92,7 @@ discard block |
||
| 92 | 92 | */ |
| 93 | 93 | public function __construct($table, $connection) |
| 94 | 94 | { |
| 95 | - $this->_connection = $connection; |
|
| 95 | + $this->_connection=$connection; |
|
| 96 | 96 | if(is_string($table)) |
| 97 | 97 | $this->setTableName($table); |
| 98 | 98 | elseif($table instanceof TDbTableInfo) |
@@ -106,7 +106,7 @@ discard block |
||
| 106 | 106 | */ |
| 107 | 107 | protected function setTableInfo($tableInfo) |
| 108 | 108 | { |
| 109 | - $builder = $tableInfo->createCommandBuilder($this->getDbConnection()); |
|
| 109 | + $builder=$tableInfo->createCommandBuilder($this->getDbConnection()); |
|
| 110 | 110 | $this->initCommandBuilder($builder); |
| 111 | 111 | } |
| 112 | 112 | |
@@ -116,7 +116,7 @@ discard block |
||
| 116 | 116 | */ |
| 117 | 117 | protected function setTableName($tableName) |
| 118 | 118 | { |
| 119 | - $meta = TDbMetaData::getInstance($this->getDbConnection()); |
|
| 119 | + $meta=TDbMetaData::getInstance($this->getDbConnection()); |
|
| 120 | 120 | $this->initCommandBuilder($meta->createCommandBuilder($tableName)); |
| 121 | 121 | } |
| 122 | 122 | |
@@ -135,9 +135,9 @@ discard block |
||
| 135 | 135 | */ |
| 136 | 136 | protected function initCommandBuilder($builder) |
| 137 | 137 | { |
| 138 | - $this->_command = new TDataGatewayCommand($builder); |
|
| 139 | - $this->_command->OnCreateCommand[] = [$this, 'onCreateCommand']; |
|
| 140 | - $this->_command->OnExecuteCommand[] = [$this, 'onExecuteCommand']; |
|
| 138 | + $this->_command=new TDataGatewayCommand($builder); |
|
| 139 | + $this->_command->OnCreateCommand[]=[$this, 'onCreateCommand']; |
|
| 140 | + $this->_command->OnExecuteCommand[]=[$this, 'onExecuteCommand']; |
|
| 141 | 141 | } |
| 142 | 142 | |
| 143 | 143 | /** |
@@ -189,10 +189,10 @@ discard block |
||
| 189 | 189 | * @param array binding parameters, positional or named. |
| 190 | 190 | * @return array query results. |
| 191 | 191 | */ |
| 192 | - public function findBySql($sql, $parameters = []) |
|
| 192 | + public function findBySql($sql, $parameters=[]) |
|
| 193 | 193 | { |
| 194 | - $args = func_num_args() > 1 ? array_slice(func_get_args(), 1) : null; |
|
| 195 | - $criteria = $this->getCriteria($sql, $parameters, $args); |
|
| 194 | + $args=func_num_args() > 1 ? array_slice(func_get_args(), 1) : null; |
|
| 195 | + $criteria=$this->getCriteria($sql, $parameters, $args); |
|
| 196 | 196 | return $this->getCommand()->findBySql($criteria); |
| 197 | 197 | } |
| 198 | 198 | |
@@ -202,10 +202,10 @@ discard block |
||
| 202 | 202 | * @param array binding parameters, positional or named. |
| 203 | 203 | * @return TDbDataReader query results. |
| 204 | 204 | */ |
| 205 | - public function findAllBySql($sql, $parameters = []) |
|
| 205 | + public function findAllBySql($sql, $parameters=[]) |
|
| 206 | 206 | { |
| 207 | - $args = func_num_args() > 1 ? array_slice(func_get_args(), 1) : null; |
|
| 208 | - $criteria = $this->getCriteria($sql, $parameters, $args); |
|
| 207 | + $args=func_num_args() > 1 ? array_slice(func_get_args(), 1) : null; |
|
| 208 | + $criteria=$this->getCriteria($sql, $parameters, $args); |
|
| 209 | 209 | return $this->getCommand()->findAllBySql($criteria); |
| 210 | 210 | } |
| 211 | 211 | |
@@ -226,10 +226,10 @@ discard block |
||
| 226 | 226 | * @param mixed parameter values. |
| 227 | 227 | * @return array matching record object. |
| 228 | 228 | */ |
| 229 | - public function find($criteria, $parameters = []) |
|
| 229 | + public function find($criteria, $parameters=[]) |
|
| 230 | 230 | { |
| 231 | - $args = func_num_args() > 1 ? array_slice(func_get_args(), 1) : null; |
|
| 232 | - $criteria = $this->getCriteria($criteria, $parameters, $args); |
|
| 231 | + $args=func_num_args() > 1 ? array_slice(func_get_args(), 1) : null; |
|
| 232 | + $criteria=$this->getCriteria($criteria, $parameters, $args); |
|
| 233 | 233 | return $this->getCommand()->find($criteria); |
| 234 | 234 | } |
| 235 | 235 | |
@@ -239,11 +239,11 @@ discard block |
||
| 239 | 239 | * @param mixed parameter values. |
| 240 | 240 | * @return TDbDataReader matching records. |
| 241 | 241 | */ |
| 242 | - public function findAll($criteria = null, $parameters = []) |
|
| 242 | + public function findAll($criteria=null, $parameters=[]) |
|
| 243 | 243 | { |
| 244 | - $args = func_num_args() > 1 ? array_slice(func_get_args(), 1) : null; |
|
| 245 | - if($criteria !== null) |
|
| 246 | - $criteria = $this->getCriteria($criteria, $parameters, $args); |
|
| 244 | + $args=func_num_args() > 1 ? array_slice(func_get_args(), 1) : null; |
|
| 245 | + if($criteria!==null) |
|
| 246 | + $criteria=$this->getCriteria($criteria, $parameters, $args); |
|
| 247 | 247 | return $this->getCommand()->findAll($criteria); |
| 248 | 248 | } |
| 249 | 249 | |
@@ -262,7 +262,7 @@ discard block |
||
| 262 | 262 | public function findByPk($keys) |
| 263 | 263 | { |
| 264 | 264 | if(func_num_args() > 1) |
| 265 | - $keys = func_get_args(); |
|
| 265 | + $keys=func_get_args(); |
|
| 266 | 266 | return $this->getCommand()->findByPk($keys); |
| 267 | 267 | } |
| 268 | 268 | |
@@ -286,7 +286,7 @@ discard block |
||
| 286 | 286 | public function findAllByPks($keys) |
| 287 | 287 | { |
| 288 | 288 | if(func_num_args() > 1) |
| 289 | - $keys = func_get_args(); |
|
| 289 | + $keys=func_get_args(); |
|
| 290 | 290 | return $this->getCommand()->findAllByPk($keys); |
| 291 | 291 | } |
| 292 | 292 | |
@@ -301,10 +301,10 @@ discard block |
||
| 301 | 301 | * @param array condition parameters. |
| 302 | 302 | * @return integer number of records deleted. |
| 303 | 303 | */ |
| 304 | - public function deleteAll($criteria, $parameters = []) |
|
| 304 | + public function deleteAll($criteria, $parameters=[]) |
|
| 305 | 305 | { |
| 306 | - $args = func_num_args() > 1 ? array_slice(func_get_args(), 1) : null; |
|
| 307 | - $criteria = $this->getCriteria($criteria, $parameters, $args); |
|
| 306 | + $args=func_num_args() > 1 ? array_slice(func_get_args(), 1) : null; |
|
| 307 | + $criteria=$this->getCriteria($criteria, $parameters, $args); |
|
| 308 | 308 | return $this->getCommand()->delete($criteria); |
| 309 | 309 | } |
| 310 | 310 | |
@@ -334,7 +334,7 @@ discard block |
||
| 334 | 334 | public function deleteByPk($keys) |
| 335 | 335 | { |
| 336 | 336 | if(func_num_args() > 1) |
| 337 | - $keys = func_get_args(); |
|
| 337 | + $keys=func_get_args(); |
|
| 338 | 338 | return $this->getCommand()->deleteByPk($keys); |
| 339 | 339 | } |
| 340 | 340 | |
@@ -344,7 +344,7 @@ discard block |
||
| 344 | 344 | public function deleteAllByPks($keys) |
| 345 | 345 | { |
| 346 | 346 | if(func_num_args() > 1) |
| 347 | - $keys = func_get_args(); |
|
| 347 | + $keys=func_get_args(); |
|
| 348 | 348 | return $this->deleteByPk($keys); |
| 349 | 349 | } |
| 350 | 350 | |
@@ -354,11 +354,11 @@ discard block |
||
| 354 | 354 | * @param mixed parameter values. |
| 355 | 355 | * @return int number of records. |
| 356 | 356 | */ |
| 357 | - public function count($criteria = null, $parameters = []) |
|
| 357 | + public function count($criteria=null, $parameters=[]) |
|
| 358 | 358 | { |
| 359 | - $args = func_num_args() > 1 ? array_slice(func_get_args(), 1) : null; |
|
| 360 | - if($criteria !== null) |
|
| 361 | - $criteria = $this->getCriteria($criteria, $parameters, $args); |
|
| 359 | + $args=func_num_args() > 1 ? array_slice(func_get_args(), 1) : null; |
|
| 360 | + if($criteria!==null) |
|
| 361 | + $criteria=$this->getCriteria($criteria, $parameters, $args); |
|
| 362 | 362 | return $this->getCommand()->count($criteria); |
| 363 | 363 | } |
| 364 | 364 | |
@@ -376,10 +376,10 @@ discard block |
||
| 376 | 376 | * @param array additional binding name-value pairs. |
| 377 | 377 | * @return integer number of records updated. |
| 378 | 378 | */ |
| 379 | - public function update($data, $criteria, $parameters = []) |
|
| 379 | + public function update($data, $criteria, $parameters=[]) |
|
| 380 | 380 | { |
| 381 | - $args = func_num_args() > 2 ? array_slice(func_get_args(), 2) : null; |
|
| 382 | - $criteria = $this->getCriteria($criteria, $parameters, $args); |
|
| 381 | + $args=func_num_args() > 2 ? array_slice(func_get_args(), 2) : null; |
|
| 382 | + $criteria=$this->getCriteria($criteria, $parameters, $args); |
|
| 383 | 383 | return $this->getCommand()->update($data, $criteria); |
| 384 | 384 | } |
| 385 | 385 | |
@@ -416,7 +416,7 @@ discard block |
||
| 416 | 416 | { |
| 417 | 417 | if(is_string($criteria)) |
| 418 | 418 | { |
| 419 | - $useArgs = !is_array($parameters) && is_array($args); |
|
| 419 | + $useArgs=!is_array($parameters) && is_array($args); |
|
| 420 | 420 | return new TSqlCriteria($criteria, $useArgs ? $args : $parameters); |
| 421 | 421 | } |
| 422 | 422 | elseif($criteria instanceof TSqlCriteria) |
@@ -456,19 +456,19 @@ discard block |
||
| 456 | 456 | */ |
| 457 | 457 | public function __call($method, $args) |
| 458 | 458 | { |
| 459 | - $delete = false; |
|
| 460 | - if($findOne = substr(strtolower($method), 0, 6) === 'findby') |
|
| 461 | - $condition = $method[6] === '_' ? substr($method, 7) : substr($method, 6); |
|
| 462 | - elseif(substr(strtolower($method), 0, 9) === 'findallby') |
|
| 463 | - $condition = $method[9] === '_' ? substr($method, 10) : substr($method, 9); |
|
| 464 | - elseif($delete = substr(strtolower($method), 0, 8) === 'deleteby') |
|
| 465 | - $condition = $method[8] === '_' ? substr($method, 9) : substr($method, 8); |
|
| 466 | - elseif($delete = substr(strtolower($method), 0, 11) === 'deleteallby') |
|
| 467 | - $condition = $method[11] === '_' ? substr($method, 12) : substr($method, 11); |
|
| 459 | + $delete=false; |
|
| 460 | + if($findOne=substr(strtolower($method), 0, 6)==='findby') |
|
| 461 | + $condition=$method[6]==='_' ? substr($method, 7) : substr($method, 6); |
|
| 462 | + elseif(substr(strtolower($method), 0, 9)==='findallby') |
|
| 463 | + $condition=$method[9]==='_' ? substr($method, 10) : substr($method, 9); |
|
| 464 | + elseif($delete=substr(strtolower($method), 0, 8)==='deleteby') |
|
| 465 | + $condition=$method[8]==='_' ? substr($method, 9) : substr($method, 8); |
|
| 466 | + elseif($delete=substr(strtolower($method), 0, 11)==='deleteallby') |
|
| 467 | + $condition=$method[11]==='_' ? substr($method, 12) : substr($method, 11); |
|
| 468 | 468 | else |
| 469 | 469 | return null; |
| 470 | 470 | |
| 471 | - $criteria = $this->getCommand()->createCriteriaFromString($method, $condition, $args); |
|
| 471 | + $criteria=$this->getCommand()->createCriteriaFromString($method, $condition, $args); |
|
| 472 | 472 | if($delete) |
| 473 | 473 | return $this->deleteAll($criteria); |
| 474 | 474 | else |
@@ -270,6 +270,7 @@ |
||
| 270 | 270 | * @param TSqlMapTypeHandlerRegistry type handler registry |
| 271 | 271 | * @param string result class name. |
| 272 | 272 | * @param array result data. |
| 273 | + * @param string $type |
|
| 273 | 274 | * @return mixed result object. |
| 274 | 275 | */ |
| 275 | 276 | protected function createInstanceOf($registry, $type, $row = null) |
@@ -57,7 +57,7 @@ discard block |
||
| 57 | 57 | */ |
| 58 | 58 | public function setID($value) |
| 59 | 59 | { |
| 60 | - $this->_ID = $value; |
|
| 60 | + $this->_ID=$value; |
|
| 61 | 61 | } |
| 62 | 62 | |
| 63 | 63 | /** |
@@ -75,7 +75,7 @@ discard block |
||
| 75 | 75 | */ |
| 76 | 76 | public function setParameterMap($value) |
| 77 | 77 | { |
| 78 | - $this->_parameterMapName = $value; |
|
| 78 | + $this->_parameterMapName=$value; |
|
| 79 | 79 | } |
| 80 | 80 | |
| 81 | 81 | /** |
@@ -94,7 +94,7 @@ discard block |
||
| 94 | 94 | */ |
| 95 | 95 | public function setParameterClass($value) |
| 96 | 96 | { |
| 97 | - $this->_parameterClassName = $value; |
|
| 97 | + $this->_parameterClassName=$value; |
|
| 98 | 98 | } |
| 99 | 99 | |
| 100 | 100 | /** |
@@ -112,7 +112,7 @@ discard block |
||
| 112 | 112 | */ |
| 113 | 113 | public function setResultMap($value) |
| 114 | 114 | { |
| 115 | - $this->_resultMapName = $value; |
|
| 115 | + $this->_resultMapName=$value; |
|
| 116 | 116 | } |
| 117 | 117 | |
| 118 | 118 | /** |
@@ -133,7 +133,7 @@ discard block |
||
| 133 | 133 | */ |
| 134 | 134 | public function setResultClass($value) |
| 135 | 135 | { |
| 136 | - $this->_resultClassName = $value; |
|
| 136 | + $this->_resultClassName=$value; |
|
| 137 | 137 | } |
| 138 | 138 | |
| 139 | 139 | /** |
@@ -149,7 +149,7 @@ discard block |
||
| 149 | 149 | */ |
| 150 | 150 | public function setCacheModel($value) |
| 151 | 151 | { |
| 152 | - $this->_cacheModelName = $value; |
|
| 152 | + $this->_cacheModelName=$value; |
|
| 153 | 153 | } |
| 154 | 154 | |
| 155 | 155 | /** |
@@ -165,7 +165,7 @@ discard block |
||
| 165 | 165 | */ |
| 166 | 166 | public function setCache($value) |
| 167 | 167 | { |
| 168 | - $this->_cache = $value; |
|
| 168 | + $this->_cache=$value; |
|
| 169 | 169 | } |
| 170 | 170 | |
| 171 | 171 | /** |
@@ -181,7 +181,7 @@ discard block |
||
| 181 | 181 | */ |
| 182 | 182 | public function setSqlText($value) |
| 183 | 183 | { |
| 184 | - $this->_SQL = $value; |
|
| 184 | + $this->_SQL=$value; |
|
| 185 | 185 | } |
| 186 | 186 | |
| 187 | 187 | /** |
@@ -198,7 +198,7 @@ discard block |
||
| 198 | 198 | */ |
| 199 | 199 | public function setListClass($value) |
| 200 | 200 | { |
| 201 | - $this->_listClass = $value; |
|
| 201 | + $this->_listClass=$value; |
|
| 202 | 202 | } |
| 203 | 203 | |
| 204 | 204 | /** |
@@ -214,7 +214,7 @@ discard block |
||
| 214 | 214 | */ |
| 215 | 215 | public function setExtends($value) |
| 216 | 216 | { |
| 217 | - $this->_extendStatement = $value; |
|
| 217 | + $this->_extendStatement=$value; |
|
| 218 | 218 | } |
| 219 | 219 | |
| 220 | 220 | /** |
@@ -240,7 +240,7 @@ discard block |
||
| 240 | 240 | */ |
| 241 | 241 | public function setInlineParameterMap($map) |
| 242 | 242 | { |
| 243 | - $this->_parameterMap = $map; |
|
| 243 | + $this->_parameterMap=$map; |
|
| 244 | 244 | } |
| 245 | 245 | |
| 246 | 246 | /** |
@@ -249,9 +249,9 @@ discard block |
||
| 249 | 249 | public function initialize($manager) |
| 250 | 250 | { |
| 251 | 251 | if(strlen($this->_resultMapName) > 0) |
| 252 | - $this->_resultMap = $manager->getResultMap($this->_resultMapName); |
|
| 252 | + $this->_resultMap=$manager->getResultMap($this->_resultMapName); |
|
| 253 | 253 | if(strlen($this->_parameterMapName) > 0) |
| 254 | - $this->_parameterMap = $manager->getParameterMap($this->_parameterMapName); |
|
| 254 | + $this->_parameterMap=$manager->getParameterMap($this->_parameterMapName); |
|
| 255 | 255 | } |
| 256 | 256 | |
| 257 | 257 | /** |
@@ -260,7 +260,7 @@ discard block |
||
| 260 | 260 | */ |
| 261 | 261 | public function createInstanceOfListClass($registry) |
| 262 | 262 | { |
| 263 | - if(strlen($type = $this->getListClass()) > 0) |
|
| 263 | + if(strlen($type=$this->getListClass()) > 0) |
|
| 264 | 264 | return $this->createInstanceOf($registry, $type); |
| 265 | 265 | return []; |
| 266 | 266 | } |
@@ -272,10 +272,10 @@ discard block |
||
| 272 | 272 | * @param array result data. |
| 273 | 273 | * @return mixed result object. |
| 274 | 274 | */ |
| 275 | - protected function createInstanceOf($registry, $type, $row = null) |
|
| 275 | + protected function createInstanceOf($registry, $type, $row=null) |
|
| 276 | 276 | { |
| 277 | - $handler = $registry->getTypeHandler($type); |
|
| 278 | - if($handler !== null) |
|
| 277 | + $handler=$registry->getTypeHandler($type); |
|
| 278 | + if($handler!==null) |
|
| 279 | 279 | return $handler->createNewInstance($row); |
| 280 | 280 | else |
| 281 | 281 | return $registry->createInstanceOf($type); |
@@ -289,26 +289,26 @@ discard block |
||
| 289 | 289 | */ |
| 290 | 290 | public function createInstanceOfResultClass($registry, $row) |
| 291 | 291 | { |
| 292 | - if(strlen($type = $this->getResultClass()) > 0) |
|
| 292 | + if(strlen($type=$this->getResultClass()) > 0) |
|
| 293 | 293 | return $this->createInstanceOf($registry, $type, $row); |
| 294 | 294 | } |
| 295 | 295 | |
| 296 | 296 | public function __sleep() |
| 297 | 297 | { |
| 298 | - $cn = __CLASS__; |
|
| 299 | - $exprops = ["\0$cn\0_resultMap"]; |
|
| 300 | - if (!$this->_parameterMapName) $exprops[] = "\0$cn\0_parameterMapName"; |
|
| 301 | - if (!$this->_parameterMap) $exprops[] = "\0$cn\0_parameterMap"; |
|
| 302 | - if (!$this->_parameterClassName) $exprops[] = "\0$cn\0_parameterClassName"; |
|
| 303 | - if (!$this->_resultMapName) $exprops[] = "\0$cn\0_resultMapName"; |
|
| 304 | - if (!$this->_resultMap) $exprops[] = "\0$cn\0_resultMap"; |
|
| 305 | - if (!$this->_resultClassName) $exprops[] = "\0$cn\0_resultClassName"; |
|
| 306 | - if (!$this->_cacheModelName) $exprops[] = "\0$cn\0_cacheModelName"; |
|
| 307 | - if (!$this->_SQL) $exprops[] = "\0$cn\0_SQL"; |
|
| 308 | - if (!$this->_listClass) $exprops[] = "\0$cn\0_listClass"; |
|
| 309 | - if (!$this->_typeHandler) $exprops[] = "\0$cn\0_typeHandler"; |
|
| 310 | - if (!$this->_extendStatement) $exprops[] = "\0$cn\0_extendStatement"; |
|
| 311 | - if (!$this->_cache) $exprops[] = "\0$cn\0_cache"; |
|
| 298 | + $cn=__CLASS__; |
|
| 299 | + $exprops=["\0$cn\0_resultMap"]; |
|
| 300 | + if(!$this->_parameterMapName) $exprops[]="\0$cn\0_parameterMapName"; |
|
| 301 | + if(!$this->_parameterMap) $exprops[]="\0$cn\0_parameterMap"; |
|
| 302 | + if(!$this->_parameterClassName) $exprops[]="\0$cn\0_parameterClassName"; |
|
| 303 | + if(!$this->_resultMapName) $exprops[]="\0$cn\0_resultMapName"; |
|
| 304 | + if(!$this->_resultMap) $exprops[]="\0$cn\0_resultMap"; |
|
| 305 | + if(!$this->_resultClassName) $exprops[]="\0$cn\0_resultClassName"; |
|
| 306 | + if(!$this->_cacheModelName) $exprops[]="\0$cn\0_cacheModelName"; |
|
| 307 | + if(!$this->_SQL) $exprops[]="\0$cn\0_SQL"; |
|
| 308 | + if(!$this->_listClass) $exprops[]="\0$cn\0_listClass"; |
|
| 309 | + if(!$this->_typeHandler) $exprops[]="\0$cn\0_typeHandler"; |
|
| 310 | + if(!$this->_extendStatement) $exprops[]="\0$cn\0_extendStatement"; |
|
| 311 | + if(!$this->_cache) $exprops[]="\0$cn\0_cache"; |
|
| 312 | 312 | |
| 313 | 313 | return array_diff(parent::__sleep(), $exprops); |
| 314 | 314 | } |
@@ -27,7 +27,7 @@ discard block |
||
| 27 | 27 | * Create an instance of an object give by the attribute named 'class' in the |
| 28 | 28 | * node and set the properties on the object given by attribute names and values. |
| 29 | 29 | * @param SimpleXmlNode property node |
| 30 | - * @return Object new instance of class with class name given by 'class' attribute value. |
|
| 30 | + * @return \Prado\TComponent new instance of class with class name given by 'class' attribute value. |
|
| 31 | 31 | */ |
| 32 | 32 | protected function createObjectFromNode($node) |
| 33 | 33 | { |
@@ -47,6 +47,7 @@ discard block |
||
| 47 | 47 | * @param Object object instance |
| 48 | 48 | * @param SimpleXmlNode property node |
| 49 | 49 | * @param array exception property name |
| 50 | + * @param \Prado\TComponent $obj |
|
| 50 | 51 | */ |
| 51 | 52 | protected function setObjectPropFromNode($obj, $node, $except = []) |
| 52 | 53 | { |
@@ -67,6 +68,8 @@ discard block |
||
| 67 | 68 | * Gets the filename relative to the basefile. |
| 68 | 69 | * @param string base filename |
| 69 | 70 | * @param string relative filename |
| 71 | + * @param string $basefile |
|
| 72 | + * @param string $resource |
|
| 70 | 73 | * @return string absolute filename. |
| 71 | 74 | */ |
| 72 | 75 | protected function getAbsoluteFilePath($basefile, $resource) |
@@ -84,7 +87,7 @@ discard block |
||
| 84 | 87 | /** |
| 85 | 88 | * Load document using simple xml. |
| 86 | 89 | * @param string filename. |
| 87 | - * @return SimpleXmlElement xml document. |
|
| 90 | + * @return \SimpleXMLElement xml document. |
|
| 88 | 91 | */ |
| 89 | 92 | protected function loadXmlDocument($filename, TSqlMapXmlConfiguration $config) |
| 90 | 93 | { |
@@ -97,9 +100,10 @@ discard block |
||
| 97 | 100 | } |
| 98 | 101 | /** |
| 99 | 102 | * Get element node by ID value (try for attribute name ID as case insensitive). |
| 100 | - * @param SimpleXmlDocument $document |
|
| 103 | + * @param \SimpleXMLElement $document |
|
| 101 | 104 | * @param string tag name. |
| 102 | 105 | * @param string id value. |
| 106 | + * @param string $tag |
|
| 103 | 107 | * @return SimpleXmlElement node if found, null otherwise. |
| 104 | 108 | */ |
| 105 | 109 | protected function getElementByIdValue($document, $tag, $value) |
@@ -33,7 +33,7 @@ discard block |
||
| 33 | 33 | { |
| 34 | 34 | if(isset($node['class'])) |
| 35 | 35 | { |
| 36 | - $obj = Prado::createComponent((string)$node['class']); |
|
| 36 | + $obj=Prado::createComponent((string) $node['class']); |
|
| 37 | 37 | $this->setObjectPropFromNode($obj, $node, ['class']); |
| 38 | 38 | return $obj; |
| 39 | 39 | } |
@@ -48,14 +48,14 @@ discard block |
||
| 48 | 48 | * @param SimpleXmlNode property node |
| 49 | 49 | * @param array exception property name |
| 50 | 50 | */ |
| 51 | - protected function setObjectPropFromNode($obj, $node, $except = []) |
|
| 51 | + protected function setObjectPropFromNode($obj, $node, $except=[]) |
|
| 52 | 52 | { |
| 53 | 53 | foreach($node->attributes() as $name => $value) |
| 54 | 54 | { |
| 55 | 55 | if(!in_array($name, $except)) |
| 56 | 56 | { |
| 57 | 57 | if($obj->canSetProperty($name)) |
| 58 | - $obj->{$name} = (string)$value; |
|
| 58 | + $obj->{$name}=(string) $value; |
|
| 59 | 59 | else |
| 60 | 60 | throw new TSqlMapConfigurationException( |
| 61 | 61 | 'sqlmap_invalid_property', $name, get_class($obj), |
@@ -71,10 +71,10 @@ discard block |
||
| 71 | 71 | */ |
| 72 | 72 | protected function getAbsoluteFilePath($basefile, $resource) |
| 73 | 73 | { |
| 74 | - $basedir = dirname($basefile); |
|
| 75 | - $file = realpath($basedir . DIRECTORY_SEPARATOR . $resource); |
|
| 74 | + $basedir=dirname($basefile); |
|
| 75 | + $file=realpath($basedir.DIRECTORY_SEPARATOR.$resource); |
|
| 76 | 76 | if(!is_string($file) || !is_file($file)) |
| 77 | - $file = realpath($resource); |
|
| 77 | + $file=realpath($resource); |
|
| 78 | 78 | if(is_string($file) && is_file($file)) |
| 79 | 79 | return $file; |
| 80 | 80 | else |
@@ -88,8 +88,8 @@ discard block |
||
| 88 | 88 | */ |
| 89 | 89 | protected function loadXmlDocument($filename, TSqlMapXmlConfiguration $config) |
| 90 | 90 | { |
| 91 | - if(strpos($filename, '${') !== false) |
|
| 92 | - $filename = $config->replaceProperties($filename); |
|
| 91 | + if(strpos($filename, '${')!==false) |
|
| 92 | + $filename=$config->replaceProperties($filename); |
|
| 93 | 93 | if(!is_file($filename)) |
| 94 | 94 | throw new TSqlMapConfigurationException( |
| 95 | 95 | 'sqlmap_unable_to_find_config', $filename); |
@@ -105,9 +105,9 @@ discard block |
||
| 105 | 105 | protected function getElementByIdValue($document, $tag, $value) |
| 106 | 106 | { |
| 107 | 107 | //hack to allow upper case and lower case attribute names. |
| 108 | - foreach(['id','ID','Id', 'iD'] as $id) |
|
| 108 | + foreach(['id', 'ID', 'Id', 'iD'] as $id) |
|
| 109 | 109 | { |
| 110 | - $xpath = "//{$tag}[@{$id}='{$value}']"; |
|
| 110 | + $xpath="//{$tag}[@{$id}='{$value}']"; |
|
| 111 | 111 | foreach($document->xpath($xpath) as $node) |
| 112 | 112 | return $node; |
| 113 | 113 | } |
@@ -46,6 +46,7 @@ discard block |
||
| 46 | 46 | * @param int page size |
| 47 | 47 | * @param mixed delegate for each data row retrieved. |
| 48 | 48 | * @param int number of page to fetch on initialization |
| 49 | + * @param integer $pageSize |
|
| 49 | 50 | */ |
| 50 | 51 | public function __construct(IMappedStatement $statement, $parameter, $pageSize, $delegate = null, $page = 0) |
| 51 | 52 | { |
@@ -61,6 +62,8 @@ discard block |
||
| 61 | 62 | * @param mixed query parameters |
| 62 | 63 | * @param int page size. |
| 63 | 64 | * @param int number of page. |
| 65 | + * @param IMappedStatement $statement |
|
| 66 | + * @param integer $page |
|
| 64 | 67 | */ |
| 65 | 68 | protected function initialize($statement, $parameter, $pageSize, $page) |
| 66 | 69 | { |
@@ -47,12 +47,12 @@ discard block |
||
| 47 | 47 | * @param mixed delegate for each data row retrieved. |
| 48 | 48 | * @param int number of page to fetch on initialization |
| 49 | 49 | */ |
| 50 | - public function __construct(IMappedStatement $statement, $parameter, $pageSize, $delegate = null, $page = 0) |
|
| 50 | + public function __construct(IMappedStatement $statement, $parameter, $pageSize, $delegate=null, $page=0) |
|
| 51 | 51 | { |
| 52 | 52 | parent::__construct(); |
| 53 | 53 | parent::setCustomPaging(true); |
| 54 | 54 | $this->initialize($statement, $parameter, $pageSize, $page); |
| 55 | - $this->_delegate = $delegate; |
|
| 55 | + $this->_delegate=$delegate; |
|
| 56 | 56 | } |
| 57 | 57 | |
| 58 | 58 | /** |
@@ -64,8 +64,8 @@ discard block |
||
| 64 | 64 | */ |
| 65 | 65 | protected function initialize($statement, $parameter, $pageSize, $page) |
| 66 | 66 | { |
| 67 | - $this->_statement = $statement; |
|
| 68 | - $this->_parameter = $parameter; |
|
| 67 | + $this->_statement=$statement; |
|
| 68 | + $this->_parameter=$parameter; |
|
| 69 | 69 | $this->setPageSize($pageSize); |
| 70 | 70 | $this->attachEventHandler('OnFetchData', [$this, 'fetchDataFromStatement']); |
| 71 | 71 | $this->gotoPage($page); |
@@ -86,9 +86,9 @@ discard block |
||
| 86 | 86 | */ |
| 87 | 87 | protected function fetchDataFromStatement($sender, $param) |
| 88 | 88 | { |
| 89 | - $limit = $this->getOffsetAndLimit($param); |
|
| 90 | - $connection = $this->_statement->getManager()->getDbConnection(); |
|
| 91 | - $data = $this->_statement->executeQueryForList($connection, |
|
| 89 | + $limit=$this->getOffsetAndLimit($param); |
|
| 90 | + $connection=$this->_statement->getManager()->getDbConnection(); |
|
| 91 | + $data=$this->_statement->executeQueryForList($connection, |
|
| 92 | 92 | $this->_parameter, null, $limit[0], $limit[1], $this->_delegate); |
| 93 | 93 | $this->populateData($param, $data); |
| 94 | 94 | } |
@@ -118,49 +118,49 @@ discard block |
||
| 118 | 118 | */ |
| 119 | 119 | protected function populateData($param, $data) |
| 120 | 120 | { |
| 121 | - $total = $data instanceof TList ? $data->getCount() : count($data); |
|
| 122 | - $pageSize = $this->getPageSize(); |
|
| 121 | + $total=$data instanceof TList ? $data->getCount() : count($data); |
|
| 122 | + $pageSize=$this->getPageSize(); |
|
| 123 | 123 | if($total < 1) |
| 124 | 124 | { |
| 125 | 125 | $param->setData($data); |
| 126 | - $this->_prevPageList = null; |
|
| 127 | - $this->_nextPageList = null; |
|
| 126 | + $this->_prevPageList=null; |
|
| 127 | + $this->_nextPageList=null; |
|
| 128 | 128 | return; |
| 129 | 129 | } |
| 130 | 130 | |
| 131 | 131 | if($param->getNewPageIndex() < 1) |
| 132 | 132 | { |
| 133 | - $this->_prevPageList = null; |
|
| 133 | + $this->_prevPageList=null; |
|
| 134 | 134 | if($total <= $pageSize) |
| 135 | 135 | { |
| 136 | 136 | $param->setData($data); |
| 137 | - $this->_nextPageList = null; |
|
| 137 | + $this->_nextPageList=null; |
|
| 138 | 138 | } |
| 139 | 139 | else |
| 140 | 140 | { |
| 141 | 141 | $param->setData(array_slice($data, 0, $pageSize)); |
| 142 | - $this->_nextPageList = array_slice($data, $pageSize - 1, $total); |
|
| 142 | + $this->_nextPageList=array_slice($data, $pageSize - 1, $total); |
|
| 143 | 143 | } |
| 144 | 144 | } |
| 145 | 145 | else |
| 146 | 146 | { |
| 147 | 147 | if($total <= $pageSize) |
| 148 | 148 | { |
| 149 | - $this->_prevPageList = array_slice($data, 0, $total); |
|
| 149 | + $this->_prevPageList=array_slice($data, 0, $total); |
|
| 150 | 150 | $param->setData([]); |
| 151 | - $this->_nextPageList = null; |
|
| 151 | + $this->_nextPageList=null; |
|
| 152 | 152 | } |
| 153 | 153 | elseif($total <= $pageSize * 2) |
| 154 | 154 | { |
| 155 | - $this->_prevPageList = array_slice($data, 0, $pageSize); |
|
| 155 | + $this->_prevPageList=array_slice($data, 0, $pageSize); |
|
| 156 | 156 | $param->setData(array_slice($data, $pageSize, $total)); |
| 157 | - $this->_nextPageList = null; |
|
| 157 | + $this->_nextPageList=null; |
|
| 158 | 158 | } |
| 159 | 159 | else |
| 160 | 160 | { |
| 161 | - $this->_prevPageList = array_slice($data, 0, $pageSize); |
|
| 161 | + $this->_prevPageList=array_slice($data, 0, $pageSize); |
|
| 162 | 162 | $param->setData(array_slice($data, $pageSize, $pageSize)); |
| 163 | - $this->_nextPageList = array_slice($data, $pageSize * 2, $total - $pageSize * 2); |
|
| 163 | + $this->_nextPageList=array_slice($data, $pageSize * 2, $total - $pageSize * 2); |
|
| 164 | 164 | } |
| 165 | 165 | } |
| 166 | 166 | } |
@@ -172,8 +172,8 @@ discard block |
||
| 172 | 172 | */ |
| 173 | 173 | protected function getOffsetAndLimit($param) |
| 174 | 174 | { |
| 175 | - $index = $param->getNewPageIndex(); |
|
| 176 | - $pageSize = $this->getPageSize(); |
|
| 175 | + $index=$param->getNewPageIndex(); |
|
| 176 | + $pageSize=$this->getPageSize(); |
|
| 177 | 177 | return $index < 1 ? [$index, $pageSize * 2] : [($index - 1) * $pageSize, $pageSize * 3]; |
| 178 | 178 | } |
| 179 | 179 | |
@@ -182,7 +182,7 @@ discard block |
||
| 182 | 182 | */ |
| 183 | 183 | public function getIsNextPageAvailable() |
| 184 | 184 | { |
| 185 | - return $this->_nextPageList !== null; |
|
| 185 | + return $this->_nextPageList!==null; |
|
| 186 | 186 | } |
| 187 | 187 | |
| 188 | 188 | /** |
@@ -190,7 +190,7 @@ discard block |
||
| 190 | 190 | */ |
| 191 | 191 | public function getIsPreviousPageAvailable() |
| 192 | 192 | { |
| 193 | - return $this->_prevPageList !== null; |
|
| 193 | + return $this->_prevPageList!==null; |
|
| 194 | 194 | } |
| 195 | 195 | |
| 196 | 196 | /** |
@@ -198,7 +198,7 @@ discard block |
||
| 198 | 198 | */ |
| 199 | 199 | public function getIsLastPage() |
| 200 | 200 | { |
| 201 | - return ($this->_nextPageList === null) || $this->_nextPageList->getCount() < 1; |
|
| 201 | + return ($this->_nextPageList===null) || $this->_nextPageList->getCount() < 1; |
|
| 202 | 202 | } |
| 203 | 203 | |
| 204 | 204 | /** |
@@ -135,28 +135,24 @@ |
||
| 135 | 135 | { |
| 136 | 136 | $param->setData($data); |
| 137 | 137 | $this->_nextPageList = null; |
| 138 | - } |
|
| 139 | - else |
|
| 138 | + } else |
|
| 140 | 139 | { |
| 141 | 140 | $param->setData(array_slice($data, 0, $pageSize)); |
| 142 | 141 | $this->_nextPageList = array_slice($data, $pageSize - 1, $total); |
| 143 | 142 | } |
| 144 | - } |
|
| 145 | - else |
|
| 143 | + } else |
|
| 146 | 144 | { |
| 147 | 145 | if($total <= $pageSize) |
| 148 | 146 | { |
| 149 | 147 | $this->_prevPageList = array_slice($data, 0, $total); |
| 150 | 148 | $param->setData([]); |
| 151 | 149 | $this->_nextPageList = null; |
| 152 | - } |
|
| 153 | - elseif($total <= $pageSize * 2) |
|
| 150 | + } elseif($total <= $pageSize * 2) |
|
| 154 | 151 | { |
| 155 | 152 | $this->_prevPageList = array_slice($data, 0, $pageSize); |
| 156 | 153 | $param->setData(array_slice($data, $pageSize, $total)); |
| 157 | 154 | $this->_nextPageList = null; |
| 158 | - } |
|
| 159 | - else |
|
| 155 | + } else |
|
| 160 | 156 | { |
| 161 | 157 | $this->_prevPageList = array_slice($data, 0, $pageSize); |
| 162 | 158 | $param->setData(array_slice($data, $pageSize, $pageSize)); |
@@ -101,6 +101,10 @@ |
||
| 101 | 101 | return $cacheKey->getHash(); |
| 102 | 102 | } |
| 103 | 103 | |
| 104 | + /** |
|
| 105 | + * @param integer $skip |
|
| 106 | + * @param integer $max |
|
| 107 | + */ |
|
| 104 | 108 | protected function createCommand($connection, $parameter, $skip = null, $max = null) |
| 105 | 109 | { |
| 106 | 110 | return $this->_mappedStatement->getCommand()->create($this->getManager(), |
@@ -26,7 +26,7 @@ discard block |
||
| 26 | 26 | |
| 27 | 27 | public function __construct(TMappedStatement $statement) |
| 28 | 28 | { |
| 29 | - $this->_mappedStatement = $statement; |
|
| 29 | + $this->_mappedStatement=$statement; |
|
| 30 | 30 | } |
| 31 | 31 | |
| 32 | 32 | public function getID() |
@@ -44,14 +44,14 @@ discard block |
||
| 44 | 44 | return $this->_mappedStatement->getManager(); |
| 45 | 45 | } |
| 46 | 46 | |
| 47 | - public function executeQueryForMap($connection, $parameter, $keyProperty, $valueProperty = null, $skip = -1, $max = -1, $delegate = null) |
|
| 47 | + public function executeQueryForMap($connection, $parameter, $keyProperty, $valueProperty=null, $skip=-1, $max=-1, $delegate=null) |
|
| 48 | 48 | { |
| 49 | - $sql = $this->createCommand($connection, $parameter, $skip, $max); |
|
| 50 | - $key = $this->getCacheKey([clone($sql), $keyProperty, $valueProperty,$skip, $max]); |
|
| 51 | - $map = $this->getStatement()->getCache()->get($key); |
|
| 52 | - if($map === null) |
|
| 49 | + $sql=$this->createCommand($connection, $parameter, $skip, $max); |
|
| 50 | + $key=$this->getCacheKey([clone($sql), $keyProperty, $valueProperty, $skip, $max]); |
|
| 51 | + $map=$this->getStatement()->getCache()->get($key); |
|
| 52 | + if($map===null) |
|
| 53 | 53 | { |
| 54 | - $map = $this->_mappedStatement->runQueryForMap( |
|
| 54 | + $map=$this->_mappedStatement->runQueryForMap( |
|
| 55 | 55 | $connection, $parameter, $sql, $keyProperty, $valueProperty, $delegate); |
| 56 | 56 | $this->getStatement()->getCache()->set($key, $map); |
| 57 | 57 | } |
@@ -68,28 +68,28 @@ discard block |
||
| 68 | 68 | return $this->executeInsert($connection, $parameter); |
| 69 | 69 | } |
| 70 | 70 | |
| 71 | - public function executeQueryForList($connection, $parameter, $result = null, $skip = -1, $max = -1, $delegate = null) |
|
| 71 | + public function executeQueryForList($connection, $parameter, $result=null, $skip=-1, $max=-1, $delegate=null) |
|
| 72 | 72 | { |
| 73 | - $sql = $this->createCommand($connection, $parameter, $skip, $max); |
|
| 74 | - $key = $this->getCacheKey([clone($sql), $parameter, $skip, $max]); |
|
| 75 | - $list = $this->getStatement()->getCache()->get($key); |
|
| 76 | - if($list === null) |
|
| 73 | + $sql=$this->createCommand($connection, $parameter, $skip, $max); |
|
| 74 | + $key=$this->getCacheKey([clone($sql), $parameter, $skip, $max]); |
|
| 75 | + $list=$this->getStatement()->getCache()->get($key); |
|
| 76 | + if($list===null) |
|
| 77 | 77 | { |
| 78 | - $list = $this->_mappedStatement->runQueryForList( |
|
| 78 | + $list=$this->_mappedStatement->runQueryForList( |
|
| 79 | 79 | $connection, $parameter, $sql, $result, $delegate); |
| 80 | 80 | $this->getStatement()->getCache()->set($key, $list); |
| 81 | 81 | } |
| 82 | 82 | return $list; |
| 83 | 83 | } |
| 84 | 84 | |
| 85 | - public function executeQueryForObject($connection, $parameter, $result = null) |
|
| 85 | + public function executeQueryForObject($connection, $parameter, $result=null) |
|
| 86 | 86 | { |
| 87 | - $sql = $this->createCommand($connection, $parameter); |
|
| 88 | - $key = $this->getCacheKey([clone($sql), $parameter]); |
|
| 89 | - $object = $this->getStatement()->getCache()->get($key); |
|
| 90 | - if($object === null) |
|
| 87 | + $sql=$this->createCommand($connection, $parameter); |
|
| 88 | + $key=$this->getCacheKey([clone($sql), $parameter]); |
|
| 89 | + $object=$this->getStatement()->getCache()->get($key); |
|
| 90 | + if($object===null) |
|
| 91 | 91 | { |
| 92 | - $object = $this->_mappedStatement->runQueryForObject($connection, $sql, $result); |
|
| 92 | + $object=$this->_mappedStatement->runQueryForObject($connection, $sql, $result); |
|
| 93 | 93 | $this->getStatement()->getCache()->set($key, $object); |
| 94 | 94 | } |
| 95 | 95 | return $object; |
@@ -97,11 +97,11 @@ discard block |
||
| 97 | 97 | |
| 98 | 98 | protected function getCacheKey($object) |
| 99 | 99 | { |
| 100 | - $cacheKey = new TSqlMapCacheKey($object); |
|
| 100 | + $cacheKey=new TSqlMapCacheKey($object); |
|
| 101 | 101 | return $cacheKey->getHash(); |
| 102 | 102 | } |
| 103 | 103 | |
| 104 | - protected function createCommand($connection, $parameter, $skip = null, $max = null) |
|
| 104 | + protected function createCommand($connection, $parameter, $skip=null, $max=null) |
|
| 105 | 105 | { |
| 106 | 106 | return $this->_mappedStatement->getCommand()->create($this->getManager(), |
| 107 | 107 | $connection, $this->getStatement(), $parameter, $skip, $max); |
@@ -97,7 +97,7 @@ discard block |
||
| 97 | 97 | } |
| 98 | 98 | |
| 99 | 99 | /** |
| 100 | - * @return TSqlMapper The SqlMap used by this MappedStatement |
|
| 100 | + * @return TSqlMapManager The SqlMap used by this MappedStatement |
|
| 101 | 101 | */ |
| 102 | 102 | public function getManager() |
| 103 | 103 | { |
@@ -482,6 +482,7 @@ discard block |
||
| 482 | 482 | * @param IDbConnection database connection |
| 483 | 483 | * @param mixed insert statement parameter |
| 484 | 484 | * @param TSqlMapSelectKey select key statement |
| 485 | + * @param \Prado\Data\SqlMap\Configuration\TSqlMapSelectKey $selectKey |
|
| 485 | 486 | * @return string last insert ID. |
| 486 | 487 | */ |
| 487 | 488 | protected function executeSelectKey($connection, $parameter, $selectKey) |
@@ -582,6 +583,7 @@ discard block |
||
| 582 | 583 | * @param string result object class name |
| 583 | 584 | * @param array a result set row retrieved from the database |
| 584 | 585 | * @param object the result object, will create if necessary. |
| 586 | + * @param string $resultClass |
|
| 585 | 587 | * @return object result object filled with data |
| 586 | 588 | */ |
| 587 | 589 | protected function fillResultClass($resultClass, $row, $resultObject) |
@@ -604,6 +606,7 @@ discard block |
||
| 604 | 606 | * Apply the result to a TList or an array. |
| 605 | 607 | * @param array a result set row retrieved from the database |
| 606 | 608 | * @param object result object, array or list |
| 609 | + * @param \ArrayAccess $resultObject |
|
| 607 | 610 | * @return object result filled with data. |
| 608 | 611 | */ |
| 609 | 612 | protected function fillResultArrayList($row, $resultObject) |
@@ -646,6 +649,7 @@ discard block |
||
| 646 | 649 | * @param string result map name. |
| 647 | 650 | * @param array a result set row retrieved from the database |
| 648 | 651 | * @param object result object to fill, will create new instances if required. |
| 652 | + * @param string $parentGroup |
|
| 649 | 653 | * @return object result object filled with data. |
| 650 | 654 | */ |
| 651 | 655 | protected function fillResultMap($resultMapName, $row, $parentGroup = null, &$resultObject = null) |
@@ -785,6 +789,7 @@ discard block |
||
| 785 | 789 | * Converts the first array value to scalar value of given type. |
| 786 | 790 | * @param array list of results |
| 787 | 791 | * @param string scalar type. |
| 792 | + * @param string $type |
|
| 788 | 793 | * @return mixed scalar value. |
| 789 | 794 | */ |
| 790 | 795 | protected function getScalarResult($result, $type) |
@@ -52,12 +52,12 @@ discard block |
||
| 52 | 52 | /** |
| 53 | 53 | * @var TPostSelectBinding[] post select statement queue. |
| 54 | 54 | */ |
| 55 | - private $_selectQueue = []; |
|
| 55 | + private $_selectQueue=[]; |
|
| 56 | 56 | |
| 57 | 57 | /** |
| 58 | 58 | * @var boolean true when data is mapped to a particular row. |
| 59 | 59 | */ |
| 60 | - private $_IsRowDataFound = false; |
|
| 60 | + private $_IsRowDataFound=false; |
|
| 61 | 61 | |
| 62 | 62 | /** |
| 63 | 63 | * @var TSQLMapObjectCollectionTree group by object collection tree |
@@ -67,17 +67,17 @@ discard block |
||
| 67 | 67 | /** |
| 68 | 68 | * @var Post select is to query for list. |
| 69 | 69 | */ |
| 70 | - const QUERY_FOR_LIST = 0; |
|
| 70 | + const QUERY_FOR_LIST=0; |
|
| 71 | 71 | |
| 72 | 72 | /** |
| 73 | 73 | * @var Post select is to query for list. |
| 74 | 74 | */ |
| 75 | - const QUERY_FOR_ARRAY = 1; |
|
| 75 | + const QUERY_FOR_ARRAY=1; |
|
| 76 | 76 | |
| 77 | 77 | /** |
| 78 | 78 | * @var Post select is to query for object. |
| 79 | 79 | */ |
| 80 | - const QUERY_FOR_OBJECT = 2; |
|
| 80 | + const QUERY_FOR_OBJECT=2; |
|
| 81 | 81 | |
| 82 | 82 | /** |
| 83 | 83 | * @return string Name used to identify the TMappedStatement amongst the others. |
@@ -117,7 +117,7 @@ discard block |
||
| 117 | 117 | */ |
| 118 | 118 | protected function initialGroupByResults() |
| 119 | 119 | { |
| 120 | - $this->_groupBy = new TSqlMapObjectCollectionTree(); |
|
| 120 | + $this->_groupBy=new TSqlMapObjectCollectionTree(); |
|
| 121 | 121 | } |
| 122 | 122 | |
| 123 | 123 | /** |
@@ -127,9 +127,9 @@ discard block |
||
| 127 | 127 | */ |
| 128 | 128 | public function __construct(TSqlMapManager $sqlMap, TSqlMapStatement $statement) |
| 129 | 129 | { |
| 130 | - $this->_manager = $sqlMap; |
|
| 131 | - $this->_statement = $statement; |
|
| 132 | - $this->_command = new TPreparedCommand(); |
|
| 130 | + $this->_manager=$sqlMap; |
|
| 131 | + $this->_statement=$statement; |
|
| 132 | + $this->_command=new TPreparedCommand(); |
|
| 133 | 133 | $this->initialGroupByResults(); |
| 134 | 134 | } |
| 135 | 135 | |
@@ -176,9 +176,9 @@ discard block |
||
| 176 | 176 | { |
| 177 | 177 | if($max > -1 || $skip > -1) |
| 178 | 178 | { |
| 179 | - $maxStr = $max > 0?' LIMIT ' . $max:''; |
|
| 180 | - $skipStr = $skip > 0?' OFFSET ' . $skip:''; |
|
| 181 | - $command->setText($command->getText() . $maxStr . $skipStr); |
|
| 179 | + $maxStr=$max > 0 ? ' LIMIT '.$max : ''; |
|
| 180 | + $skipStr=$skip > 0 ? ' OFFSET '.$skip : ''; |
|
| 181 | + $command->setText($command->getText().$maxStr.$skipStr); |
|
| 182 | 182 | } |
| 183 | 183 | $connection->setActive(true); |
| 184 | 184 | return $command->query(); |
@@ -212,9 +212,9 @@ discard block |
||
| 212 | 212 | * @param callback row delegate handler |
| 213 | 213 | * @see executeQueryForList() |
| 214 | 214 | */ |
| 215 | - public function executeQueryForList($connection, $parameter, $result = null, $skip = -1, $max = -1, $delegate = null) |
|
| 215 | + public function executeQueryForList($connection, $parameter, $result=null, $skip=-1, $max=-1, $delegate=null) |
|
| 216 | 216 | { |
| 217 | - $sql = $this->_command->create($this->_manager, $connection, $this->_statement, $parameter, $skip, $max); |
|
| 217 | + $sql=$this->_command->create($this->_manager, $connection, $this->_statement, $parameter, $skip, $max); |
|
| 218 | 218 | return $this->runQueryForList($connection, $parameter, $sql, $result, $delegate); |
| 219 | 219 | } |
| 220 | 220 | |
@@ -234,20 +234,19 @@ discard block |
||
| 234 | 234 | * @return array a list of result objects |
| 235 | 235 | * @see executeQueryForList() |
| 236 | 236 | */ |
| 237 | - public function runQueryForList($connection, $parameter, $sql, $result, $delegate = null) |
|
| 237 | + public function runQueryForList($connection, $parameter, $sql, $result, $delegate=null) |
|
| 238 | 238 | { |
| 239 | - $registry = $this->getManager()->getTypeHandlers(); |
|
| 240 | - $list = $result instanceof \ArrayAccess ? $result : |
|
| 241 | - $this->_statement->createInstanceOfListClass($registry); |
|
| 239 | + $registry=$this->getManager()->getTypeHandlers(); |
|
| 240 | + $list=$result instanceof \ArrayAccess ? $result : $this->_statement->createInstanceOfListClass($registry); |
|
| 242 | 241 | $connection->setActive(true); |
| 243 | - $reader = $sql->query(); |
|
| 242 | + $reader=$sql->query(); |
|
| 244 | 243 | //$reader = $this->executeSQLQueryLimit($connection, $sql, $max, $skip); |
| 245 | - if($delegate !== null) |
|
| 244 | + if($delegate!==null) |
|
| 246 | 245 | { |
| 247 | 246 | foreach($reader as $row) |
| 248 | 247 | { |
| 249 | - $obj = $this->applyResultMap($row); |
|
| 250 | - $param = new TResultSetListItemParameter($obj, $parameter, $list); |
|
| 248 | + $obj=$this->applyResultMap($row); |
|
| 249 | + $param=new TResultSetListItemParameter($obj, $parameter, $list); |
|
| 251 | 250 | $this->raiseRowDelegate($delegate, $param); |
| 252 | 251 | } |
| 253 | 252 | } |
@@ -257,13 +256,13 @@ discard block |
||
| 257 | 256 | foreach($reader as $row) |
| 258 | 257 | { |
| 259 | 258 | // var_dump($row); |
| 260 | - $list[] = $this->applyResultMap($row); |
|
| 259 | + $list[]=$this->applyResultMap($row); |
|
| 261 | 260 | } |
| 262 | 261 | } |
| 263 | 262 | |
| 264 | 263 | if(!$this->_groupBy->isEmpty()) |
| 265 | 264 | { |
| 266 | - $list = $this->_groupBy->collect(); |
|
| 265 | + $list=$this->_groupBy->collect(); |
|
| 267 | 266 | $this->initialGroupByResults(); |
| 268 | 267 | } |
| 269 | 268 | |
@@ -285,9 +284,9 @@ discard block |
||
| 285 | 284 | * @param callback row delegate handler |
| 286 | 285 | * @return array An array of object containing the rows keyed by keyProperty. |
| 287 | 286 | */ |
| 288 | - public function executeQueryForMap($connection, $parameter, $keyProperty, $valueProperty = null, $skip = -1, $max = -1, $delegate = null) |
|
| 287 | + public function executeQueryForMap($connection, $parameter, $keyProperty, $valueProperty=null, $skip=-1, $max=-1, $delegate=null) |
|
| 289 | 288 | { |
| 290 | - $sql = $this->_command->create($this->_manager, $connection, $this->_statement, $parameter, $skip, $max); |
|
| 289 | + $sql=$this->_command->create($this->_manager, $connection, $this->_statement, $parameter, $skip, $max); |
|
| 291 | 290 | return $this->runQueryForMap($connection, $parameter, $sql, $keyProperty, $valueProperty, $delegate); |
| 292 | 291 | } |
| 293 | 292 | |
@@ -309,22 +308,21 @@ discard block |
||
| 309 | 308 | * @return array An array of object containing the rows keyed by keyProperty. |
| 310 | 309 | * @see executeQueryForMap() |
| 311 | 310 | */ |
| 312 | - public function runQueryForMap($connection, $parameter, $command, $keyProperty, $valueProperty = null, $delegate = null) |
|
| 311 | + public function runQueryForMap($connection, $parameter, $command, $keyProperty, $valueProperty=null, $delegate=null) |
|
| 313 | 312 | { |
| 314 | - $map = []; |
|
| 313 | + $map=[]; |
|
| 315 | 314 | //$recordSet = $this->executeSQLQuery($connection, $sql); |
| 316 | 315 | $connection->setActive(true); |
| 317 | - $reader = $command->query(); |
|
| 318 | - if($delegate !== null) |
|
| 316 | + $reader=$command->query(); |
|
| 317 | + if($delegate!==null) |
|
| 319 | 318 | { |
| 320 | 319 | //while($row = $recordSet->fetchRow()) |
| 321 | 320 | foreach($reader as $row) |
| 322 | 321 | { |
| 323 | - $obj = $this->applyResultMap($row); |
|
| 324 | - $key = TPropertyAccess::get($obj, $keyProperty); |
|
| 325 | - $value = ($valueProperty === null) ? $obj : |
|
| 326 | - TPropertyAccess::get($obj, $valueProperty); |
|
| 327 | - $param = new TResultSetMapItemParameter($key, $value, $parameter, $map); |
|
| 322 | + $obj=$this->applyResultMap($row); |
|
| 323 | + $key=TPropertyAccess::get($obj, $keyProperty); |
|
| 324 | + $value=($valueProperty===null) ? $obj : TPropertyAccess::get($obj, $valueProperty); |
|
| 325 | + $param=new TResultSetMapItemParameter($key, $value, $parameter, $map); |
|
| 328 | 326 | $this->raiseRowDelegate($delegate, $param); |
| 329 | 327 | } |
| 330 | 328 | } |
@@ -333,10 +331,9 @@ discard block |
||
| 333 | 331 | //while($row = $recordSet->fetchRow()) |
| 334 | 332 | foreach($reader as $row) |
| 335 | 333 | { |
| 336 | - $obj = $this->applyResultMap($row); |
|
| 337 | - $key = TPropertyAccess::get($obj, $keyProperty); |
|
| 338 | - $map[$key] = ($valueProperty === null) ? $obj : |
|
| 339 | - TPropertyAccess::get($obj, $valueProperty); |
|
| 334 | + $obj=$this->applyResultMap($row); |
|
| 335 | + $key=TPropertyAccess::get($obj, $keyProperty); |
|
| 336 | + $map[$key]=($valueProperty===null) ? $obj : TPropertyAccess::get($obj, $valueProperty); |
|
| 340 | 337 | } |
| 341 | 338 | } |
| 342 | 339 | $this->onExecuteQuery($command); |
@@ -358,15 +355,15 @@ discard block |
||
| 358 | 355 | elseif(is_callable($handler, true)) |
| 359 | 356 | { |
| 360 | 357 | // an array: 0 - object, 1 - method name/path |
| 361 | - list($object, $method) = $handler; |
|
| 358 | + list($object, $method)=$handler; |
|
| 362 | 359 | if(is_string($object)) // static method call |
| 363 | 360 | call_user_func($handler, $this, $param); |
| 364 | 361 | else |
| 365 | 362 | { |
| 366 | - if(($pos = strrpos($method, '.')) !== false) |
|
| 363 | + if(($pos=strrpos($method, '.'))!==false) |
|
| 367 | 364 | { |
| 368 | - $object = $this->getSubProperty(substr($method, 0, $pos)); |
|
| 369 | - $method = substr($method, $pos + 1); |
|
| 365 | + $object=$this->getSubProperty(substr($method, 0, $pos)); |
|
| 366 | + $method=substr($method, $pos + 1); |
|
| 370 | 367 | } |
| 371 | 368 | $object->$method($this, $param); |
| 372 | 369 | } |
@@ -383,9 +380,9 @@ discard block |
||
| 383 | 380 | * @param mixed The result object. |
| 384 | 381 | * @return ${return} |
| 385 | 382 | */ |
| 386 | - public function executeQueryForObject($connection, $parameter, $result = null) |
|
| 383 | + public function executeQueryForObject($connection, $parameter, $result=null) |
|
| 387 | 384 | { |
| 388 | - $sql = $this->_command->create($this->_manager, $connection, $this->_statement, $parameter); |
|
| 385 | + $sql=$this->_command->create($this->_manager, $connection, $this->_statement, $parameter); |
|
| 389 | 386 | return $this->runQueryForObject($connection, $sql, $result); |
| 390 | 387 | } |
| 391 | 388 | |
@@ -404,16 +401,16 @@ discard block |
||
| 404 | 401 | */ |
| 405 | 402 | public function runQueryForObject($connection, $command, &$result) |
| 406 | 403 | { |
| 407 | - $object = null; |
|
| 404 | + $object=null; |
|
| 408 | 405 | $connection->setActive(true); |
| 409 | 406 | foreach($command->query() as $row) |
| 410 | - $object = $this->applyResultMap($row, $result); |
|
| 407 | + $object=$this->applyResultMap($row, $result); |
|
| 411 | 408 | |
| 412 | 409 | if(!$this->_groupBy->isEmpty()) |
| 413 | 410 | { |
| 414 | - $list = $this->_groupBy->collect(); |
|
| 411 | + $list=$this->_groupBy->collect(); |
|
| 415 | 412 | $this->initialGroupByResults(); |
| 416 | - $object = $list[0]; |
|
| 413 | + $object=$list[0]; |
|
| 417 | 414 | } |
| 418 | 415 | |
| 419 | 416 | $this->executePostSelect($connection); |
@@ -431,14 +428,14 @@ discard block |
||
| 431 | 428 | */ |
| 432 | 429 | public function executeInsert($connection, $parameter) |
| 433 | 430 | { |
| 434 | - $generatedKey = $this->getPreGeneratedSelectKey($connection, $parameter); |
|
| 431 | + $generatedKey=$this->getPreGeneratedSelectKey($connection, $parameter); |
|
| 435 | 432 | |
| 436 | - $command = $this->_command->create($this->_manager, $connection, $this->_statement, $parameter); |
|
| 433 | + $command=$this->_command->create($this->_manager, $connection, $this->_statement, $parameter); |
|
| 437 | 434 | // var_dump($command,$parameter); |
| 438 | - $result = $command->execute(); |
|
| 435 | + $result=$command->execute(); |
|
| 439 | 436 | |
| 440 | - if($generatedKey === null) |
|
| 441 | - $generatedKey = $this->getPostGeneratedSelectKey($connection, $parameter); |
|
| 437 | + if($generatedKey===null) |
|
| 438 | + $generatedKey=$this->getPostGeneratedSelectKey($connection, $parameter); |
|
| 442 | 439 | |
| 443 | 440 | $this->executePostSelect($connection); |
| 444 | 441 | $this->onExecuteQuery($command); |
@@ -455,8 +452,8 @@ discard block |
||
| 455 | 452 | { |
| 456 | 453 | if($this->_statement instanceof TSqlMapInsert) |
| 457 | 454 | { |
| 458 | - $selectKey = $this->_statement->getSelectKey(); |
|
| 459 | - if(($selectKey !== null) && !$selectKey->getIsAfter()) |
|
| 455 | + $selectKey=$this->_statement->getSelectKey(); |
|
| 456 | + if(($selectKey!==null) && !$selectKey->getIsAfter()) |
|
| 460 | 457 | return $this->executeSelectKey($connection, $parameter, $selectKey); |
| 461 | 458 | } |
| 462 | 459 | } |
@@ -471,8 +468,8 @@ discard block |
||
| 471 | 468 | { |
| 472 | 469 | if($this->_statement instanceof TSqlMapInsert) |
| 473 | 470 | { |
| 474 | - $selectKey = $this->_statement->getSelectKey(); |
|
| 475 | - if(($selectKey !== null) && $selectKey->getIsAfter()) |
|
| 471 | + $selectKey=$this->_statement->getSelectKey(); |
|
| 472 | + if(($selectKey!==null) && $selectKey->getIsAfter()) |
|
| 476 | 473 | return $this->executeSelectKey($connection, $parameter, $selectKey); |
| 477 | 474 | } |
| 478 | 475 | } |
@@ -486,10 +483,10 @@ discard block |
||
| 486 | 483 | */ |
| 487 | 484 | protected function executeSelectKey($connection, $parameter, $selectKey) |
| 488 | 485 | { |
| 489 | - $mappedStatement = $this->getManager()->getMappedStatement($selectKey->getID()); |
|
| 490 | - $generatedKey = $mappedStatement->executeQueryForObject( |
|
| 486 | + $mappedStatement=$this->getManager()->getMappedStatement($selectKey->getID()); |
|
| 487 | + $generatedKey=$mappedStatement->executeQueryForObject( |
|
| 491 | 488 | $connection, $parameter, null); |
| 492 | - if(strlen($prop = $selectKey->getProperty()) > 0) |
|
| 489 | + if(strlen($prop=$selectKey->getProperty()) > 0) |
|
| 493 | 490 | TPropertyAccess::set($parameter, $prop, $generatedKey); |
| 494 | 491 | return $generatedKey; |
| 495 | 492 | } |
@@ -503,8 +500,8 @@ discard block |
||
| 503 | 500 | */ |
| 504 | 501 | public function executeUpdate($connection, $parameter) |
| 505 | 502 | { |
| 506 | - $sql = $this->_command->create($this->getManager(), $connection, $this->_statement, $parameter); |
|
| 507 | - $affectedRows = $sql->execute(); |
|
| 503 | + $sql=$this->_command->create($this->getManager(), $connection, $this->_statement, $parameter); |
|
| 504 | + $affectedRows=$sql->execute(); |
|
| 508 | 505 | //$this->executeSQLQuery($connection, $sql); |
| 509 | 506 | $this->executePostSelect($connection); |
| 510 | 507 | $this->onExecuteQuery($sql); |
@@ -519,24 +516,24 @@ discard block |
||
| 519 | 516 | { |
| 520 | 517 | while(count($this->_selectQueue)) |
| 521 | 518 | { |
| 522 | - $postSelect = array_shift($this->_selectQueue); |
|
| 523 | - $method = $postSelect->getMethod(); |
|
| 524 | - $statement = $postSelect->getStatement(); |
|
| 525 | - $property = $postSelect->getResultProperty()->getProperty(); |
|
| 526 | - $keys = $postSelect->getKeys(); |
|
| 527 | - $resultObject = $postSelect->getResultObject(); |
|
| 528 | - |
|
| 529 | - if($method == self::QUERY_FOR_LIST || $method == self::QUERY_FOR_ARRAY) |
|
| 519 | + $postSelect=array_shift($this->_selectQueue); |
|
| 520 | + $method=$postSelect->getMethod(); |
|
| 521 | + $statement=$postSelect->getStatement(); |
|
| 522 | + $property=$postSelect->getResultProperty()->getProperty(); |
|
| 523 | + $keys=$postSelect->getKeys(); |
|
| 524 | + $resultObject=$postSelect->getResultObject(); |
|
| 525 | + |
|
| 526 | + if($method==self::QUERY_FOR_LIST || $method==self::QUERY_FOR_ARRAY) |
|
| 530 | 527 | { |
| 531 | - $values = $statement->executeQueryForList($connection, $keys, null); |
|
| 528 | + $values=$statement->executeQueryForList($connection, $keys, null); |
|
| 532 | 529 | |
| 533 | - if($method == self::QUERY_FOR_ARRAY) |
|
| 534 | - $values = $values->toArray(); |
|
| 530 | + if($method==self::QUERY_FOR_ARRAY) |
|
| 531 | + $values=$values->toArray(); |
|
| 535 | 532 | TPropertyAccess::set($resultObject, $property, $values); |
| 536 | 533 | } |
| 537 | - elseif($method == self::QUERY_FOR_OBJECT) |
|
| 534 | + elseif($method==self::QUERY_FOR_OBJECT) |
|
| 538 | 535 | { |
| 539 | - $value = $statement->executeQueryForObject($connection, $keys, null); |
|
| 536 | + $value=$statement->executeQueryForObject($connection, $keys, null); |
|
| 540 | 537 | TPropertyAccess::set($resultObject, $property, $value); |
| 541 | 538 | } |
| 542 | 539 | } |
@@ -557,23 +554,23 @@ discard block |
||
| 557 | 554 | * @param object the result object, will create if necessary. |
| 558 | 555 | * @return object the result filled with data, null if not filled. |
| 559 | 556 | */ |
| 560 | - protected function applyResultMap($row, &$resultObject = null) |
|
| 557 | + protected function applyResultMap($row, &$resultObject=null) |
|
| 561 | 558 | { |
| 562 | - if($row === false) return null; |
|
| 559 | + if($row===false) return null; |
|
| 563 | 560 | |
| 564 | - $resultMapName = $this->_statement->getResultMap(); |
|
| 565 | - $resultClass = $this->_statement->getResultClass(); |
|
| 561 | + $resultMapName=$this->_statement->getResultMap(); |
|
| 562 | + $resultClass=$this->_statement->getResultClass(); |
|
| 566 | 563 | |
| 567 | - $obj = null; |
|
| 564 | + $obj=null; |
|
| 568 | 565 | if($this->getManager()->getResultMaps()->contains($resultMapName)) |
| 569 | - $obj = $this->fillResultMap($resultMapName, $row, null, $resultObject); |
|
| 566 | + $obj=$this->fillResultMap($resultMapName, $row, null, $resultObject); |
|
| 570 | 567 | elseif(strlen($resultClass) > 0) |
| 571 | - $obj = $this->fillResultClass($resultClass, $row, $resultObject); |
|
| 568 | + $obj=$this->fillResultClass($resultClass, $row, $resultObject); |
|
| 572 | 569 | else |
| 573 | - $obj = $this->fillDefaultResultMap(null, $row, $resultObject); |
|
| 570 | + $obj=$this->fillDefaultResultMap(null, $row, $resultObject); |
|
| 574 | 571 | if(class_exists('TActiveRecord', false) && $obj instanceof TActiveRecord) |
| 575 | 572 | //Create a new clean active record. |
| 576 | - $obj = TActiveRecord::createRecord(get_class($obj), $obj); |
|
| 573 | + $obj=TActiveRecord::createRecord(get_class($obj), $obj); |
|
| 577 | 574 | return $obj; |
| 578 | 575 | } |
| 579 | 576 | |
@@ -586,10 +583,10 @@ discard block |
||
| 586 | 583 | */ |
| 587 | 584 | protected function fillResultClass($resultClass, $row, $resultObject) |
| 588 | 585 | { |
| 589 | - if($resultObject === null) |
|
| 586 | + if($resultObject===null) |
|
| 590 | 587 | { |
| 591 | - $registry = $this->getManager()->getTypeHandlers(); |
|
| 592 | - $resultObject = $this->_statement->createInstanceOfResultClass($registry, $row); |
|
| 588 | + $registry=$this->getManager()->getTypeHandlers(); |
|
| 589 | + $resultObject=$this->_statement->createInstanceOfResultClass($registry, $row); |
|
| 593 | 590 | } |
| 594 | 591 | |
| 595 | 592 | if($resultObject instanceof \ArrayAccess) |
@@ -610,10 +607,10 @@ discard block |
||
| 610 | 607 | { |
| 611 | 608 | if($resultObject instanceof TList) |
| 612 | 609 | foreach($row as $v) |
| 613 | - $resultObject[] = $v; |
|
| 610 | + $resultObject[]=$v; |
|
| 614 | 611 | else |
| 615 | 612 | foreach($row as $k => $v) |
| 616 | - $resultObject[$k] = $v; |
|
| 613 | + $resultObject[$k]=$v; |
|
| 617 | 614 | return $resultObject; |
| 618 | 615 | } |
| 619 | 616 | |
@@ -625,17 +622,17 @@ discard block |
||
| 625 | 622 | */ |
| 626 | 623 | protected function fillResultObjectProperty($row, $resultObject) |
| 627 | 624 | { |
| 628 | - $index = 0; |
|
| 629 | - $registry = $this->getManager()->getTypeHandlers(); |
|
| 625 | + $index=0; |
|
| 626 | + $registry=$this->getManager()->getTypeHandlers(); |
|
| 630 | 627 | foreach($row as $k => $v) |
| 631 | 628 | { |
| 632 | - $property = new TResultProperty; |
|
| 629 | + $property=new TResultProperty; |
|
| 633 | 630 | if(is_string($k) && strlen($k) > 0) |
| 634 | 631 | $property->setColumn($k); |
| 635 | 632 | $property->setColumnIndex(++$index); |
| 636 | - $type = gettype(TPropertyAccess::get($resultObject, $k)); |
|
| 633 | + $type=gettype(TPropertyAccess::get($resultObject, $k)); |
|
| 637 | 634 | $property->setType($type); |
| 638 | - $value = $property->getPropertyValue($registry, $row); |
|
| 635 | + $value=$property->getPropertyValue($registry, $row); |
|
| 639 | 636 | TPropertyAccess::set($resultObject, $k, $value); |
| 640 | 637 | } |
| 641 | 638 | return $resultObject; |
@@ -648,14 +645,14 @@ discard block |
||
| 648 | 645 | * @param object result object to fill, will create new instances if required. |
| 649 | 646 | * @return object result object filled with data. |
| 650 | 647 | */ |
| 651 | - protected function fillResultMap($resultMapName, $row, $parentGroup = null, &$resultObject = null) |
|
| 648 | + protected function fillResultMap($resultMapName, $row, $parentGroup=null, &$resultObject=null) |
|
| 652 | 649 | { |
| 653 | - $resultMap = $this->getManager()->getResultMap($resultMapName); |
|
| 654 | - $registry = $this->getManager()->getTypeHandlers(); |
|
| 655 | - $resultMap = $resultMap->resolveSubMap($registry, $row); |
|
| 650 | + $resultMap=$this->getManager()->getResultMap($resultMapName); |
|
| 651 | + $registry=$this->getManager()->getTypeHandlers(); |
|
| 652 | + $resultMap=$resultMap->resolveSubMap($registry, $row); |
|
| 656 | 653 | |
| 657 | - if($resultObject === null) |
|
| 658 | - $resultObject = $resultMap->createInstanceOfResult($registry); |
|
| 654 | + if($resultObject===null) |
|
| 655 | + $resultObject=$resultMap->createInstanceOfResult($registry); |
|
| 659 | 656 | |
| 660 | 657 | if(is_object($resultObject)) |
| 661 | 658 | { |
@@ -667,7 +664,7 @@ discard block |
||
| 667 | 664 | } |
| 668 | 665 | else |
| 669 | 666 | { |
| 670 | - $resultObject = $this->fillDefaultResultMap($resultMap, $row, $resultObject); |
|
| 667 | + $resultObject=$this->fillDefaultResultMap($resultMap, $row, $resultObject); |
|
| 671 | 668 | } |
| 672 | 669 | return $resultObject; |
| 673 | 670 | } |
@@ -682,11 +679,11 @@ discard block |
||
| 682 | 679 | */ |
| 683 | 680 | protected function addResultMapGroupBy($resultMap, $row, $parent, &$resultObject) |
| 684 | 681 | { |
| 685 | - $group = $this->getResultMapGroupKey($resultMap, $row); |
|
| 682 | + $group=$this->getResultMapGroupKey($resultMap, $row); |
|
| 686 | 683 | |
| 687 | 684 | if(empty($parent)) |
| 688 | 685 | { |
| 689 | - $rootObject = ['object' => $resultObject, 'property' => null]; |
|
| 686 | + $rootObject=['object' => $resultObject, 'property' => null]; |
|
| 690 | 687 | $this->_groupBy->add(null, $group, $rootObject); |
| 691 | 688 | } |
| 692 | 689 | |
@@ -694,23 +691,23 @@ discard block |
||
| 694 | 691 | { |
| 695 | 692 | //set properties. |
| 696 | 693 | $this->setObjectProperty($resultMap, $property, $row, $resultObject); |
| 697 | - $nested = $property->getResultMapping(); |
|
| 694 | + $nested=$property->getResultMapping(); |
|
| 698 | 695 | |
| 699 | 696 | //nested property |
| 700 | 697 | if($this->getManager()->getResultMaps()->contains($nested)) |
| 701 | 698 | { |
| 702 | - $nestedMap = $this->getManager()->getResultMap($nested); |
|
| 703 | - $groupKey = $this->getResultMapGroupKey($nestedMap, $row); |
|
| 699 | + $nestedMap=$this->getManager()->getResultMap($nested); |
|
| 700 | + $groupKey=$this->getResultMapGroupKey($nestedMap, $row); |
|
| 704 | 701 | |
| 705 | 702 | //add the node reference first |
| 706 | 703 | if(empty($parent)) |
| 707 | 704 | $this->_groupBy->add($group, $groupKey, ''); |
| 708 | 705 | |
| 709 | 706 | //get the nested result mapping value |
| 710 | - $value = $this->fillResultMap($nested, $row, $groupKey); |
|
| 707 | + $value=$this->fillResultMap($nested, $row, $groupKey); |
|
| 711 | 708 | |
| 712 | 709 | //add it to the object tree graph |
| 713 | - $groupObject = ['object' => $value, 'property' => $property->getProperty()]; |
|
| 710 | + $groupObject=['object' => $value, 'property' => $property->getProperty()]; |
|
| 714 | 711 | if(empty($parent)) |
| 715 | 712 | $this->_groupBy->add($group, $groupKey, $groupObject); |
| 716 | 713 | else |
@@ -728,11 +725,11 @@ discard block |
||
| 728 | 725 | */ |
| 729 | 726 | protected function getResultMapGroupKey($resultMap, $row) |
| 730 | 727 | { |
| 731 | - $groupBy = $resultMap->getGroupBy(); |
|
| 728 | + $groupBy=$resultMap->getGroupBy(); |
|
| 732 | 729 | if(isset($row[$groupBy])) |
| 733 | - return $resultMap->getID() . $row[$groupBy]; |
|
| 730 | + return $resultMap->getID().$row[$groupBy]; |
|
| 734 | 731 | else |
| 735 | - return $resultMap->getID() . crc32(serialize($row)); |
|
| 732 | + return $resultMap->getID().crc32(serialize($row)); |
|
| 736 | 733 | } |
| 737 | 734 | |
| 738 | 735 | /** |
@@ -745,16 +742,16 @@ discard block |
||
| 745 | 742 | */ |
| 746 | 743 | protected function fillDefaultResultMap($resultMap, $row, $resultObject) |
| 747 | 744 | { |
| 748 | - if($resultObject === null) |
|
| 749 | - $resultObject = ''; |
|
| 745 | + if($resultObject===null) |
|
| 746 | + $resultObject=''; |
|
| 750 | 747 | |
| 751 | - if($resultMap !== null) |
|
| 752 | - $result = $this->fillArrayResultMap($resultMap, $row, $resultObject); |
|
| 748 | + if($resultMap!==null) |
|
| 749 | + $result=$this->fillArrayResultMap($resultMap, $row, $resultObject); |
|
| 753 | 750 | else |
| 754 | - $result = $row; |
|
| 751 | + $result=$row; |
|
| 755 | 752 | |
| 756 | 753 | //if scalar result types |
| 757 | - if(count($result) == 1 && ($type = gettype($resultObject)) != 'array') |
|
| 754 | + if(count($result)==1 && ($type=gettype($resultObject))!='array') |
|
| 758 | 755 | return $this->getScalarResult($result, $type); |
| 759 | 756 | else |
| 760 | 757 | return $result; |
@@ -769,14 +766,14 @@ discard block |
||
| 769 | 766 | */ |
| 770 | 767 | protected function fillArrayResultMap($resultMap, $row, $resultObject) |
| 771 | 768 | { |
| 772 | - $result = []; |
|
| 773 | - $registry = $this->getManager()->getTypeHandlers(); |
|
| 769 | + $result=[]; |
|
| 770 | + $registry=$this->getManager()->getTypeHandlers(); |
|
| 774 | 771 | foreach($resultMap->getColumns() as $column) |
| 775 | 772 | { |
| 776 | - if(($column->getType() === null) |
|
| 777 | - && ($resultObject !== null) && !is_object($resultObject)) |
|
| 773 | + if(($column->getType()===null) |
|
| 774 | + && ($resultObject!==null) && !is_object($resultObject)) |
|
| 778 | 775 | $column->setType(gettype($resultObject)); |
| 779 | - $result[$column->getProperty()] = $column->getPropertyValue($registry, $row); |
|
| 776 | + $result[$column->getProperty()]=$column->getPropertyValue($registry, $row); |
|
| 780 | 777 | } |
| 781 | 778 | return $result; |
| 782 | 779 | } |
@@ -789,7 +786,7 @@ discard block |
||
| 789 | 786 | */ |
| 790 | 787 | protected function getScalarResult($result, $type) |
| 791 | 788 | { |
| 792 | - $scalar = array_shift($result); |
|
| 789 | + $scalar=array_shift($result); |
|
| 793 | 790 | settype($scalar, $type); |
| 794 | 791 | return $scalar; |
| 795 | 792 | } |
@@ -803,25 +800,25 @@ discard block |
||
| 803 | 800 | */ |
| 804 | 801 | protected function setObjectProperty($resultMap, $property, $row, &$resultObject) |
| 805 | 802 | { |
| 806 | - $select = $property->getSelect(); |
|
| 807 | - $key = $property->getProperty(); |
|
| 808 | - $nested = $property->getNestedResultMap(); |
|
| 809 | - $registry = $this->getManager()->getTypeHandlers(); |
|
| 810 | - if($key === '') |
|
| 803 | + $select=$property->getSelect(); |
|
| 804 | + $key=$property->getProperty(); |
|
| 805 | + $nested=$property->getNestedResultMap(); |
|
| 806 | + $registry=$this->getManager()->getTypeHandlers(); |
|
| 807 | + if($key==='') |
|
| 811 | 808 | { |
| 812 | - $resultObject = $property->getPropertyValue($registry, $row); |
|
| 809 | + $resultObject=$property->getPropertyValue($registry, $row); |
|
| 813 | 810 | } |
| 814 | - elseif(strlen($select) == 0 && ($nested === null)) |
|
| 811 | + elseif(strlen($select)==0 && ($nested===null)) |
|
| 815 | 812 | { |
| 816 | - $value = $property->getPropertyValue($registry, $row); |
|
| 813 | + $value=$property->getPropertyValue($registry, $row); |
|
| 817 | 814 | |
| 818 | - $this->_IsRowDataFound = $this->_IsRowDataFound || ($value != null); |
|
| 815 | + $this->_IsRowDataFound=$this->_IsRowDataFound || ($value!=null); |
|
| 819 | 816 | if(is_array($resultObject) || is_object($resultObject)) |
| 820 | 817 | TPropertyAccess::set($resultObject, $key, $value); |
| 821 | 818 | else |
| 822 | - $resultObject = $value; |
|
| 819 | + $resultObject=$value; |
|
| 823 | 820 | } |
| 824 | - elseif($nested !== null) |
|
| 821 | + elseif($nested!==null) |
|
| 825 | 822 | { |
| 826 | 823 | if($property->instanceOfListType($resultObject) || $property->instanceOfArrayType($resultObject)) |
| 827 | 824 | { |
@@ -832,9 +829,9 @@ discard block |
||
| 832 | 829 | } |
| 833 | 830 | else |
| 834 | 831 | { |
| 835 | - $obj = $nested->createInstanceOfResult($this->getManager()->getTypeHandlers()); |
|
| 836 | - if($this->fillPropertyWithResultMap($nested, $row, $obj) == false) |
|
| 837 | - $obj = null; |
|
| 832 | + $obj=$nested->createInstanceOfResult($this->getManager()->getTypeHandlers()); |
|
| 833 | + if($this->fillPropertyWithResultMap($nested, $row, $obj)==false) |
|
| 834 | + $obj=null; |
|
| 838 | 835 | TPropertyAccess::set($resultObject, $key, $obj); |
| 839 | 836 | } |
| 840 | 837 | } |
@@ -854,9 +851,9 @@ discard block |
||
| 854 | 851 | */ |
| 855 | 852 | protected function enquequePostSelect($select, $resultMap, $property, $row, $resultObject) |
| 856 | 853 | { |
| 857 | - $statement = $this->getManager()->getMappedStatement($select); |
|
| 858 | - $key = $this->getPostSelectKeys($resultMap, $property, $row); |
|
| 859 | - $postSelect = new TPostSelectBinding; |
|
| 854 | + $statement=$this->getManager()->getMappedStatement($select); |
|
| 855 | + $key=$this->getPostSelectKeys($resultMap, $property, $row); |
|
| 856 | + $postSelect=new TPostSelectBinding; |
|
| 860 | 857 | $postSelect->setStatement($statement); |
| 861 | 858 | $postSelect->setResultObject($resultObject); |
| 862 | 859 | $postSelect->setResultProperty($property); |
@@ -864,10 +861,10 @@ discard block |
||
| 864 | 861 | |
| 865 | 862 | if($property->instanceOfListType($resultObject)) |
| 866 | 863 | { |
| 867 | - $values = null; |
|
| 864 | + $values=null; |
|
| 868 | 865 | if($property->getLazyLoad()) |
| 869 | 866 | { |
| 870 | - $values = TLazyLoadList::newInstance($statement, $key, |
|
| 867 | + $values=TLazyLoadList::newInstance($statement, $key, |
|
| 871 | 868 | $resultObject, $property->getProperty()); |
| 872 | 869 | TPropertyAccess::set($resultObject, $property->getProperty(), $values); |
| 873 | 870 | } |
@@ -880,7 +877,7 @@ discard block |
||
| 880 | 877 | $postSelect->setMethod(self::QUERY_FOR_OBJECT); |
| 881 | 878 | |
| 882 | 879 | if(!$property->getLazyLoad()) |
| 883 | - $this->_selectQueue[] = $postSelect; |
|
| 880 | + $this->_selectQueue[]=$postSelect; |
|
| 884 | 881 | } |
| 885 | 882 | |
| 886 | 883 | /** |
@@ -892,20 +889,20 @@ discard block |
||
| 892 | 889 | */ |
| 893 | 890 | protected function getPostSelectKeys($resultMap, $property, $row) |
| 894 | 891 | { |
| 895 | - $value = $property->getColumn(); |
|
| 896 | - if(is_int(strpos($value . ',', 0)) || is_int(strpos($value, '=', 0))) |
|
| 892 | + $value=$property->getColumn(); |
|
| 893 | + if(is_int(strpos($value.',', 0)) || is_int(strpos($value, '=', 0))) |
|
| 897 | 894 | { |
| 898 | - $keys = []; |
|
| 895 | + $keys=[]; |
|
| 899 | 896 | foreach(explode(',', $value) as $entry) |
| 900 | 897 | { |
| 901 | - $pair = explode('=', $entry); |
|
| 902 | - $keys[trim($pair[0])] = $row[trim($pair[1])]; |
|
| 898 | + $pair=explode('=', $entry); |
|
| 899 | + $keys[trim($pair[0])]=$row[trim($pair[1])]; |
|
| 903 | 900 | } |
| 904 | 901 | return $keys; |
| 905 | 902 | } |
| 906 | 903 | else |
| 907 | 904 | { |
| 908 | - $registry = $this->getManager()->getTypeHandlers(); |
|
| 905 | + $registry=$this->getManager()->getTypeHandlers(); |
|
| 909 | 906 | return $property->getPropertyValue($registry, $row); |
| 910 | 907 | } |
| 911 | 908 | } |
@@ -919,28 +916,28 @@ discard block |
||
| 919 | 916 | */ |
| 920 | 917 | protected function fillPropertyWithResultMap($resultMap, $row, &$resultObject) |
| 921 | 918 | { |
| 922 | - $dataFound = false; |
|
| 919 | + $dataFound=false; |
|
| 923 | 920 | foreach($resultMap->getColumns() as $property) |
| 924 | 921 | { |
| 925 | - $this->_IsRowDataFound = false; |
|
| 922 | + $this->_IsRowDataFound=false; |
|
| 926 | 923 | $this->setObjectProperty($resultMap, $property, $row, $resultObject); |
| 927 | - $dataFound = $dataFound || $this->_IsRowDataFound; |
|
| 924 | + $dataFound=$dataFound || $this->_IsRowDataFound; |
|
| 928 | 925 | } |
| 929 | - $this->_IsRowDataFound = $dataFound; |
|
| 926 | + $this->_IsRowDataFound=$dataFound; |
|
| 930 | 927 | return $dataFound; |
| 931 | 928 | } |
| 932 | 929 | |
| 933 | 930 | public function __wakeup() |
| 934 | 931 | { |
| 935 | - if (null === $this->_selectQueue) $this->_selectQueue = []; |
|
| 932 | + if(null===$this->_selectQueue) $this->_selectQueue=[]; |
|
| 936 | 933 | } |
| 937 | 934 | |
| 938 | 935 | public function __sleep() |
| 939 | 936 | { |
| 940 | - $exprops = []; $cn = __CLASS__; |
|
| 941 | - if (!count($this->_selectQueue)) $exprops[] = "\0$cn\0_selectQueue"; |
|
| 942 | - if (null === $this->_groupBy) $exprops[] = "\0$cn\0_groupBy"; |
|
| 943 | - if (!$this->_IsRowDataFound) $exprops[] = "\0$cn\0_IsRowDataFound"; |
|
| 937 | + $exprops=[]; $cn=__CLASS__; |
|
| 938 | + if(!count($this->_selectQueue)) $exprops[]="\0$cn\0_selectQueue"; |
|
| 939 | + if(null===$this->_groupBy) $exprops[]="\0$cn\0_groupBy"; |
|
| 940 | + if(!$this->_IsRowDataFound) $exprops[]="\0$cn\0_IsRowDataFound"; |
|
| 944 | 941 | return array_diff(parent::__sleep(), $exprops); |
| 945 | 942 | } |
| 946 | 943 | } |
| 947 | 944 | \ No newline at end of file |
@@ -250,8 +250,7 @@ discard block |
||
| 250 | 250 | $param = new TResultSetListItemParameter($obj, $parameter, $list); |
| 251 | 251 | $this->raiseRowDelegate($delegate, $param); |
| 252 | 252 | } |
| 253 | - } |
|
| 254 | - else |
|
| 253 | + } else |
|
| 255 | 254 | { |
| 256 | 255 | //var_dump($sql,$parameter); |
| 257 | 256 | foreach($reader as $row) |
@@ -327,8 +326,7 @@ discard block |
||
| 327 | 326 | $param = new TResultSetMapItemParameter($key, $value, $parameter, $map); |
| 328 | 327 | $this->raiseRowDelegate($delegate, $param); |
| 329 | 328 | } |
| 330 | - } |
|
| 331 | - else |
|
| 329 | + } else |
|
| 332 | 330 | { |
| 333 | 331 | //while($row = $recordSet->fetchRow()) |
| 334 | 332 | foreach($reader as $row) |
@@ -354,8 +352,7 @@ discard block |
||
| 354 | 352 | if(is_string($handler)) |
| 355 | 353 | { |
| 356 | 354 | call_user_func($handler, $this, $param); |
| 357 | - } |
|
| 358 | - elseif(is_callable($handler, true)) |
|
| 355 | + } elseif(is_callable($handler, true)) |
|
| 359 | 356 | { |
| 360 | 357 | // an array: 0 - object, 1 - method name/path |
| 361 | 358 | list($object, $method) = $handler; |
@@ -370,8 +367,7 @@ discard block |
||
| 370 | 367 | } |
| 371 | 368 | $object->$method($this, $param); |
| 372 | 369 | } |
| 373 | - } |
|
| 374 | - else |
|
| 370 | + } else |
|
| 375 | 371 | throw new TInvalidDataValueException('sqlmap_invalid_delegate', $this->getID(), $handler); |
| 376 | 372 | } |
| 377 | 373 | |
@@ -533,8 +529,7 @@ discard block |
||
| 533 | 529 | if($method == self::QUERY_FOR_ARRAY) |
| 534 | 530 | $values = $values->toArray(); |
| 535 | 531 | TPropertyAccess::set($resultObject, $property, $values); |
| 536 | - } |
|
| 537 | - elseif($method == self::QUERY_FOR_OBJECT) |
|
| 532 | + } elseif($method == self::QUERY_FOR_OBJECT) |
|
| 538 | 533 | { |
| 539 | 534 | $value = $statement->executeQueryForObject($connection, $keys, null); |
| 540 | 535 | TPropertyAccess::set($resultObject, $property, $value); |
@@ -664,8 +659,7 @@ discard block |
||
| 664 | 659 | else |
| 665 | 660 | foreach($resultMap->getColumns() as $property) |
| 666 | 661 | $this->setObjectProperty($resultMap, $property, $row, $resultObject); |
| 667 | - } |
|
| 668 | - else |
|
| 662 | + } else |
|
| 669 | 663 | { |
| 670 | 664 | $resultObject = $this->fillDefaultResultMap($resultMap, $row, $resultObject); |
| 671 | 665 | } |
@@ -810,8 +804,7 @@ discard block |
||
| 810 | 804 | if($key === '') |
| 811 | 805 | { |
| 812 | 806 | $resultObject = $property->getPropertyValue($registry, $row); |
| 813 | - } |
|
| 814 | - elseif(strlen($select) == 0 && ($nested === null)) |
|
| 807 | + } elseif(strlen($select) == 0 && ($nested === null)) |
|
| 815 | 808 | { |
| 816 | 809 | $value = $property->getPropertyValue($registry, $row); |
| 817 | 810 | |
@@ -820,8 +813,7 @@ discard block |
||
| 820 | 813 | TPropertyAccess::set($resultObject, $key, $value); |
| 821 | 814 | else |
| 822 | 815 | $resultObject = $value; |
| 823 | - } |
|
| 824 | - elseif($nested !== null) |
|
| 816 | + } elseif($nested !== null) |
|
| 825 | 817 | { |
| 826 | 818 | if($property->instanceOfListType($resultObject) || $property->instanceOfArrayType($resultObject)) |
| 827 | 819 | { |
@@ -829,16 +821,14 @@ discard block |
||
| 829 | 821 | throw new TSqlMapExecutionException( |
| 830 | 822 | 'sqlmap_non_groupby_array_list_type', $resultMap->getID(), |
| 831 | 823 | get_class($resultObject), $key); |
| 832 | - } |
|
| 833 | - else |
|
| 824 | + } else |
|
| 834 | 825 | { |
| 835 | 826 | $obj = $nested->createInstanceOfResult($this->getManager()->getTypeHandlers()); |
| 836 | 827 | if($this->fillPropertyWithResultMap($nested, $row, $obj) == false) |
| 837 | 828 | $obj = null; |
| 838 | 829 | TPropertyAccess::set($resultObject, $key, $obj); |
| 839 | 830 | } |
| 840 | - } |
|
| 841 | - else //'select' ResultProperty |
|
| 831 | + } else //'select' ResultProperty |
|
| 842 | 832 | { |
| 843 | 833 | $this->enquequePostSelect($select, $resultMap, $property, $row, $resultObject); |
| 844 | 834 | } |
@@ -870,11 +860,9 @@ discard block |
||
| 870 | 860 | $values = TLazyLoadList::newInstance($statement, $key, |
| 871 | 861 | $resultObject, $property->getProperty()); |
| 872 | 862 | TPropertyAccess::set($resultObject, $property->getProperty(), $values); |
| 873 | - } |
|
| 874 | - else |
|
| 863 | + } else |
|
| 875 | 864 | $postSelect->setMethod(self::QUERY_FOR_LIST); |
| 876 | - } |
|
| 877 | - elseif($property->instanceOfArrayType($resultObject)) |
|
| 865 | + } elseif($property->instanceOfArrayType($resultObject)) |
|
| 878 | 866 | $postSelect->setMethod(self::QUERY_FOR_ARRAY); |
| 879 | 867 | else |
| 880 | 868 | $postSelect->setMethod(self::QUERY_FOR_OBJECT); |
@@ -902,8 +890,7 @@ discard block |
||
| 902 | 890 | $keys[trim($pair[0])] = $row[trim($pair[1])]; |
| 903 | 891 | } |
| 904 | 892 | return $keys; |
| 905 | - } |
|
| 906 | - else |
|
| 893 | + } else |
|
| 907 | 894 | { |
| 908 | 895 | $registry = $this->getManager()->getTypeHandlers(); |
| 909 | 896 | return $property->getPropertyValue($registry, $row); |