alphadevx /
alpha
| @@ 756-796 (lines=41) @@ | ||
| 753 | * |
|
| 754 | * @see Alpha\Model\ActiveRecordProviderInterface::loadAllByDayUpdated() |
|
| 755 | */ |
|
| 756 | public function loadAllByDayUpdated($date, $start = 0, $limit = 0, $orderBy = 'OID', $order = 'ASC', $ignoreClassType = false) |
|
| 757 | { |
|
| 758 | self::$logger->debug('>>loadAllByDayUpdated(date=['.$date.'], start=['.$start.'], limit=['.$limit.'], orderBy=['.$orderBy.'], order=['.$order.'], ignoreClassType=['.$ignoreClassType.']'); |
|
| 759 | ||
| 760 | if ($start != 0 && $limit != 0) { |
|
| 761 | $limit = ' LIMIT '.$start.', '.$limit.';'; |
|
| 762 | } else { |
|
| 763 | $limit = ';'; |
|
| 764 | } |
|
| 765 | ||
| 766 | if (!$ignoreClassType && $this->BO->isTableOverloaded()) { |
|
| 767 | $sqlQuery = 'SELECT OID FROM '.$this->BO->getTableName()." WHERE updated_ts >= '".$date." 00:00:00' AND updated_ts <= '".$date." 23:59:59' AND classname = '".addslashes(get_class($this->BO))."' ORDER BY ".$orderBy.' '.$order.$limit; |
|
| 768 | } else { |
|
| 769 | $sqlQuery = 'SELECT OID FROM '.$this->BO->getTableName()." WHERE updated_ts >= '".$date." 00:00:00' AND updated_ts <= '".$date." 23:59:59' ORDER BY ".$orderBy.' '.$order.$limit; |
|
| 770 | } |
|
| 771 | ||
| 772 | $this->BO->setLastQuery($sqlQuery); |
|
| 773 | ||
| 774 | if (!$result = self::getConnection()->query($sqlQuery)) { |
|
| 775 | throw new RecordNotFoundException('Failed to load object OIDs, MySql error is ['.self::getConnection()->error.'], query ['.$this->BO->getLastQuery().']'); |
|
| 776 | self::$logger->debug('<<loadAllByDayUpdated []'); |
|
| 777 | ||
| 778 | return array(); |
|
| 779 | } |
|
| 780 | ||
| 781 | // now build an array of objects to be returned |
|
| 782 | $objects = array(); |
|
| 783 | $count = 0; |
|
| 784 | $RecordClass = get_class($this->BO); |
|
| 785 | ||
| 786 | while ($row = $result->fetch_array(MYSQLI_ASSOC)) { |
|
| 787 | $obj = new $RecordClass(); |
|
| 788 | $obj->load($row['OID']); |
|
| 789 | $objects[$count] = $obj; |
|
| 790 | ++$count; |
|
| 791 | } |
|
| 792 | ||
| 793 | self::$logger->debug('<<loadAllByDayUpdated ['.count($objects).']'); |
|
| 794 | ||
| 795 | return $objects; |
|
| 796 | } |
|
| 797 | ||
| 798 | /** |
|
| 799 | * (non-PHPdoc). |
|
| @@ 741-779 (lines=39) @@ | ||
| 738 | * |
|
| 739 | * @see Alpha\Model\ActiveRecordProviderInterface::loadAllByDayUpdated() |
|
| 740 | */ |
|
| 741 | public function loadAllByDayUpdated($date, $start = 0, $limit = 0, $orderBy = 'OID', $order = 'ASC', $ignoreClassType = false) |
|
| 742 | { |
|
| 743 | self::$logger->debug('>>loadAllByDayUpdated(date=['.$date.'], start=['.$start.'], limit=['.$limit.'], orderBy=['.$orderBy.'], order=['.$order.'], ignoreClassType=['.$ignoreClassType.']'); |
|
| 744 | ||
| 745 | if ($start != 0 && $limit != 0) { |
|
| 746 | $limit = ' LIMIT '.$limit.' OFFSET '.$start.';'; |
|
| 747 | } else { |
|
| 748 | $limit = ';'; |
|
| 749 | } |
|
| 750 | ||
| 751 | if (!$ignoreClassType && $this->BO->isTableOverloaded()) { |
|
| 752 | $sqlQuery = 'SELECT OID FROM '.$this->BO->getTableName()." WHERE updated_ts >= '".$date." 00:00:00' AND updated_ts <= '".$date." 23:59:59' AND classname = '".addslashes(get_class($this->BO))."' ORDER BY ".$orderBy.' '.$order.$limit; |
|
| 753 | } else { |
|
| 754 | $sqlQuery = 'SELECT OID FROM '.$this->BO->getTableName()." WHERE updated_ts >= '".$date." 00:00:00' AND updated_ts <= '".$date." 23:59:59' ORDER BY ".$orderBy.' '.$order.$limit; |
|
| 755 | } |
|
| 756 | ||
| 757 | $this->BO->setLastQuery($sqlQuery); |
|
| 758 | ||
| 759 | if (!$result = self::getConnection()->query($sqlQuery)) { |
|
| 760 | self::$logger->debug('<<loadAllByDayUpdated'); |
|
| 761 | throw new RecordNotFoundException('Failed to load object OIDs, SQLite error is ['.self::getLastDatabaseError().'], query ['.$this->BO->getLastQuery().']'); |
|
| 762 | } |
|
| 763 | ||
| 764 | // now build an array of objects to be returned |
|
| 765 | $objects = array(); |
|
| 766 | $count = 0; |
|
| 767 | $RecordClass = get_class($this->BO); |
|
| 768 | ||
| 769 | while ($row = $result->fetchArray()) { |
|
| 770 | $obj = new $RecordClass(); |
|
| 771 | $obj->load($row['OID']); |
|
| 772 | $objects[$count] = $obj; |
|
| 773 | ++$count; |
|
| 774 | } |
|
| 775 | ||
| 776 | self::$logger->debug('<<loadAllByDayUpdated ['.count($objects).']'); |
|
| 777 | ||
| 778 | return $objects; |
|
| 779 | } |
|
| 780 | ||
| 781 | /** |
|
| 782 | * (non-PHPdoc). |
|
