Logikos\Csv\CsvToMysql\LoadDataInFile

Complexity

Total Complexity

17

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

16 Methods

Rating	Name	Duplication	Size	Complexity
A	getDelimiter()	0	1	1
A	setDelimiter()	0	1	1
A	getEnclosure()	0	1	1
A	setEnclosure()	0	1	1
A	getEOL()	0	1	1
A	setEOL()	0	1	1
A	getEscape()	0	1	1
A	setEscape()	0	1	1
A	getTableName()	0	1	1
A	setTableName()	0	1	1
A	getIgnoreLines()	0	1	1
A	setIgnoreLines()	0	1	1
A	getCsvFile()	0	1	1
A	setCsvFile()	0	4	2
A	getQuery()	0	12	1
A	escape()	0	3	1

<?php

namespace Logikos\Csv\CsvToMysql;

class LoadDataInFile {

  private $delimiter   = ',';
  private $enclosure   = '"';
  private $eol         = "\\n";
  private $escape      = '\\';
  private $ignoreLines = 0;
  private $csvFile;
  private $tableName;

  public function getDelimiter()           { return $this->delimiter;  }
  public function setDelimiter($delimiter) { $this->delimiter = $delimiter;  }

  public function getEnclosure()           { return $this->enclosure;  }
  public function setEnclosure($enclosure) { $this->enclosure = $enclosure;  }

  public function getEOL()                 { return $this->eol; }
  public function setEOL($eol)             { $this->eol = $eol; }

  public function getEscape()              { return $this->escape;  }
  public function setEscape($escape)       { $this->escape = $escape;  }

  public function getTableName()           { return $this->tableName;  }
  public function setTableName($name)      { $this->tableName = $name;  }

  public function getIgnoreLines()         { return $this->ignoreLines; }
  public function setIgnoreLines($count)   { $this->ignoreLines = $count; }

  public function getCsvFile()             { return $this->csvFile; }
  public function setCsvFile($csvFile)     {
    if (!is_writable($csvFile)) throw new Exception("Could not read file {$csvFile}");
    $this->csvFile = $csvFile;
  }

  public function getQuery() {
    $sql  = "
      LOAD DATA LOCAL INFILE {$this->getCsvFile()}
      INTO TABLE {$this->getTableName()}
      FIELDS TERMINATED BY '{$this->getDelimiter()}'
      OPTIONALLY ENCLOSED BY '{$this->getEnclosure()}'
      ESCAPED BY '{$this->escape($this->getEscape())}'
      LINES TERMINATED BY '{$this->getEOL()}'
      IGNORE 2 LINES
    ";
    return $sql;
  }

  private function escape($string) {
    return addslashes($string);
  }
}