diff --git a/src/classes/logstreammongodb.class.php b/src/classes/logstreammongodb.class.php index 6825661..2ea964e 100644 --- a/src/classes/logstreammongodb.class.php +++ b/src/classes/logstreammongodb.class.php @@ -501,9 +501,13 @@ class LogStreamMongoDB extends LogStream { !$this->CheckFieldnameInMapping($szTableType, $propName) && (isset($propValue) && strlen($propValue) > 0) ) - { + { // Add dynamic Property! - $arrProperitesOut[$propName] = $propValue; + if ( gettype($propValue) == "object" && get_class($propValue) == "MongoDate" ) + // Handle Date fields + $arrProperitesOut[$propName] = GetFormatedDate($propValue->sec); + else // Default handling + $arrProperitesOut[$propName] = $propValue; } } // --- @@ -817,7 +821,7 @@ class LogStreamMongoDB extends LogStream { if ( isset($arrProperitesIn[SYSLOG_UID]) && isset($arrProperitesIn[MISC_CHECKSUM]) && isset($dbmapping[$szTableType]['DBMAPPINGS'][MISC_CHECKSUM]) ) { // Create Querydata - $myMongoID = new MongoId( $this->convBaseHelper($arrProperitesIn[SYSLOG_UID], '0123456789', '0123456789abcdef') ); + $myMongoID = new MongoId( $this->convBaseHelper($arrProperitesIn[SYSLOG_UID], 10, 16) ); $queryArray = array('_id' => $myMongoID); // Create Update Data @@ -1563,8 +1567,8 @@ class LogStreamMongoDB extends LogStream { if ( $uID != UID_UNKNOWN ) { // Add uID Filter as well! - $myMongoID = new MongoId( $this->convBaseHelper($uID, '0123456789', '0123456789abcdef') ); - $this->_myMongoQuery[ $dbmapping[$szTableType]['DBMAPPINGS'][SYSLOG_UID] ] = array( '$lt' => $myMongoID ); + $myMongoID = new MongoId( $this->convBaseHelper($uID, 10, 16) ); + $this->_myMongoQuery[ $dbmapping[$szTableType]['DBMAPPINGS'][SYSLOG_UID] ] = array( '$lte' => $myMongoID ); } // Success @@ -1589,11 +1593,13 @@ class LogStreamMongoDB extends LogStream { OutputDebugMessage("LogStreamMongoDB|ReadNextRecordsFromDB: Running FIND ", DEBUG_ULTRADEBUG); // Find Data in MongoCollection - $myCursor = $this->_myMongoCollection->find($this->_myMongoQuery)->limit($this->_logStreamConfigObj->RecordsPerQuery)->sort(array("_id" => -1)); // , $this->_myMongoFields); + $myCursor = $this->_myMongoCollection->find($this->_myMongoQuery)->sort(array("_id" => -1))->limit($this->_logStreamConfigObj->RecordsPerQuery); // , $this->_myMongoFields); -// echo "
"; + +// echo ""; } catch ( MongoCursorException $e ) @@ -1608,32 +1614,36 @@ class LogStreamMongoDB extends LogStream { // Uncomment for debug! // OutputDebugMessage("LogStreamMongoDB|ReadNextRecordsFromDB: myCursor->info() ="; +// var_dump($this->_myMongoQuery); // var_dump(iterator_to_array($myCursor)); -// echo ""; +// echo "
" . var_export($myCursor->info(), true) . "", DEBUG_ULTRADEBUG); +/* MOVED to find() call aboev // Limit records -// $myCursor->limit( $this->_logStreamConfigObj->RecordsPerQuery ); + $myCursor->limit( $this->_logStreamConfigObj->RecordsPerQuery ); // OutputDebugMessage("Cursor verbose: " . var_export($myCursor->explain(), true), DEBUG_DEBUG); -// $myCursor = $myCursor->sort(array("_id" => -1)); + $myCursor = $myCursor->sort(array("_id" => -1)); +/**/ try { // Copy rows into the buffer! $iBegin = $this->_currentRecordNum; - $mongoidprev = -1; + $mongoidprev = -1; foreach ($myCursor as $mongoid => $myRow) { - // echo $this->convBaseHelper($mongoid, '0123456789abcdef', '0123456789') . "-" . $mongoid . "