dbObj = Zend_Db::factory('Pdo_Mysql', array( 'host' => 'localhost', 'username' => 'DUMMY', 'password' => 'DUMMY', 'dbname' => 'DUMMY' )); $this->dbObj->getConnection(); } protected function holeDatenArray(){ $select = $this->dbObj->select(); $select->from(self::DB_TABLE_CCK_COMMENTS, array('vid', 'nid', 'field_faq_antwort_value', 'field_faq_antwort_format')); $select->order('nid ASC'); $stmt = $this->dbObj->query($select); $result = $stmt->fetchAll(); return $result; } protected function _erzeugeDrupalDatensatz(array $parDbInhalteArray){ if($parDbInhalteArray['field_faq_antwort_value'] === null){ if($this->debug){ echo ('Leerer Kommentar'); } return; } $kommentarArray = array('pid' => 0, 'nid' => $parDbInhalteArray['nid'], 'uid' => self::$uidKennung, 'subject' => 'Unser Tipp', 'comment' => $parDbInhalteArray['field_faq_antwort_value'], 'hostname' => $_SERVER['REMOTE_ADDR'], 'timestamp' => time(), 'status' => 0, 'thread' => '01/', 'name' => 'Admin', 'homepage' => 'http://www.TopScoots.com', 'format' => $parDbInhalteArray['field_faq_antwort_format'] ); //NODE-REVISION ERZEUGEN!! if($this->testmodus === false){ try { $erzeugt = $this->dbObj->insert(self::DB_TABLE_COMMENTS, $kommentarArray); $revisionLastInsertVid = $this->dbObj->lastInsertId(); $statUpdate = array('last_comment_timestamp' => time(), 'last_comment_name' => 'Admin', 'last_comment_uid' => self::$uidKennung, 'comment_count' => new Zend_Db_Expr('comment_count+1')); $this->dbObj->update(self::DB_TABLE_CCK_COMMENTS_STAT, $statUpdate,'nid='.$parDbInhalteArray['nid']); $this->dbObj->delete(self::DB_TABLE_CCK_COMMENTS, 'nid=\''.$parDbInhalteArray['nid'].'\' and vid=\''.$parDbInhalteArray['vid'].'\''); } catch(Exception $e){ echo $e; echo $erzeugt = false; } } else { //Fake $erzeugt = true; } if($this->debug){ echo('
##### BASISDATEN ######
'); echo('
'.print_r($kommentarArray, true).'
'); } if(empty($erzeugt)){ throw new Exception('Ein Datensatz konnte nicht erzeugt werden!'); } $lastInsertId = $this->dbObj->lastInsertId(); return !empty($erzeugt) and !empty($erzeugtDateien); } public function proceed(){ echo('+++++++++ Import gestartet! +++++++++
'); try { $vorbereiteteDaten = $this->holeDatenArray(); foreach ($vorbereiteteDaten as $einzelVorbereiteteDaten){ $this->_erzeugeDrupalDatensatz($einzelVorbereiteteDaten); } echo('+++++++++ Import erfolgreich beendet! +++++++++'); }catch (Exception $e){ echo('+++++++++ Import fehlgeschlagen! +++++++++'); throw $e; } } } $giObj = new FaqUpdate(); $giObj->proceed(); ?>