Automatisches Importscript für einen Onlineshop

<?php
$data = file_get_contents('http://server.de/datei.csv');  

// debug
echo $data;

<?php

define('PATH_CSV_IMPORT', '.');  
// anhand der CSV Daten festlegen
define('CSV_DELIMITER', "\t");  
define('CSV_ENCLOSURE', '"');  

/**
 * Enter description here ...
 */
class Your_Library_Import
{
	/**
	 * Enter description here ...
	 * @var PDO
	 */
	private $_db;
	
	/**
	 * Enter description here ...
	 * @throws Exception
	 */
	public function __construct()
	{
		try  {
			$this->_db = new PDO('mysql:dbname=xtc;host=127.0.0.1', 'user', 'password');  
		} catch(PDOException $e) {
			throw new Exception('konnte nicht mit der Datenbank verbinden', null, $e);  
		}
		
		try {
			$this->_createTempTable()
				 ->_readCsv( PATH_CSV_IMPORT.PATH_SEPARATOR.'deineDatei.csv' )  
			 	 ->_transferData();
		} catch (Exception $e) {
			throw new Exception('Fehler beim Importvorgang', null, $e);  
		}
	}
	
	/**
	 * Enter description here ...
	 * @throws Exception
	 * @return Your_Library_Import
	 */
	private function _createTempTable()
	{
		$sql = <<<__SQL__
CREATE TEMPORARY TABLE IF NOT EXISTS `__tempTable` (
/*  hier deine Spalten definitionen anhand der CSV Datei angeben */
)
__SQL__;
		if (!$this->_db->exec( $sql )) {
			throw new Exception( 'Fehler beim erstellen der temp. Tabelle'."\n".print_r($this->_db->errorInfo(),true), null, $e );  
		}
		return $this;
	}
	
	/**
	 * Enter description here ...
	 * @param string $filename		Pfad und Dateiname der CSV Datei
	 * @throws Exception
	 * @return Your_Library_Import
	 */
	private function _readCsv( $filename )
	{
		if (!file_exists($filename) || !is_readable($filename)) {
			throw new Exception('Datei ('.$filename.') existiert nicht oder ist nicht lesbar');  
		}
		
		if ($handle = fopen($filename, 'r')) {  
			$sql = <<<__SQL__
INSERT INTO `__tempTable` ( /* deine Spaltennamen */ ) VALUES ( ?, ?, ? /* etc */)
__SQL__;
			try {
				$statement = $this->_db->prepare( $sql );
			} catch (PDOException $e) {
				throw new Exception( 'Fehler beim INSERT prepare'."\n".print_r($this->_db->errorInfo(),true), null, $e);  
			}
			while ($dataRow = fgetcsv($handle, null, CSV_DELIMITER, CSV_ENCLOSURE)) {
				/* ggf noch die Daten aufbereiten damit diese zum INSERT Befehl passen */
				if (!$statement->execute( $dataRow )) {
					throw new Exception('Fehler beim INSERT'."\n".print_r($this->_db->errorInfo(),true));  
				}
			}
		}
		
		return $this;
	}
	
	/**
	 * Enter description here ...
	 * @throws Exception
	 * @return Your_Library_Import
	 */
	private function _transferData()
	{
		$sql = <<<__SQL__
/* Deine SQL Anweisungen um die Daten aus der temp Tabelle in die Live-Daten-Tabellen zu übertragen */ 
__SQL__;
		try {
			$this->_db->exec($sql);
		} catch (PDOException $e) {
			throw new Exception('Fehler beim Importvorgang'."\n".print_r($this->_db->errorInfo(),true), null, $e);  
		}
		return $this;
	}
}