\n";
}
function importProcess() {
if (!$_POST["csv"]) {
return null; // import the sent files as SQL commands
}
$files = Adminer\get_files("csv_file", true);
if (!is_array($files)) {
echo "
" . Adminer\upload_error($files) . "\n";
return true;
}
foreach ($files as $file) {
foreach ($this->_untar($file[0], $file[1]) as $csv) {
if (!$this->_import($csv[0], $csv[1], $_POST["csv_exists"]) && $_POST["error_stops"]) {
break 2;
}
}
}
return true;
}
/** Get files stored in a TAR archive, e.g. an export of several tables to CSV
* @param string $name name of the file
* @param string $tar contents of the file
* @return list the file itself if it is not an archive
*/
protected function _untar($name, $tar) {
if (!preg_match('~\.tar(\.gz)?$~i', $name)) {
return array(array($name, $tar));
}
$return = array();
$offset = 0;
while ($offset + 512 <= strlen($tar)) { // the header of each file is 512 bytes, see tar_file()
$filename = rtrim(substr($tar, $offset, 100), "\0");
if ($filename == "") {
break; // the archive ends with zero blocks
}
$size = octdec(trim(substr($tar, $offset + 124, 12), "\0 "));
$offset += 512;
if (substr($filename, -1) != "/") { // directories have no data
$return[] = array($filename, substr($tar, $offset, $size));
}
$offset += (int) ceil($size / 512) * 512; // the data is padded to whole blocks
}
return $return;
}
/** Create a table named after the file and import the data to it, print the result
* @param string $name name of the file
* @param string $csv contents of the file
* @param string $exists what to do if the table exists: insert, truncate or drop
* @return bool
*/
protected function _import($name, $csv, $exists) {
$error_prefix = "
" . Adminer\h($name) . ": ";
if (substr($csv, 0, 3) == "\xEF\xBB\xBF") {
$csv = substr($csv, 3); // UTF-8 BOM, get_files() removes it only from the uploaded file, not from the files in an archive
}
if (!Adminer\is_utf8($csv)) {
echo $error_prefix . $this->lang('File must be in UTF-8 encoding.') . "\n";
return false;
}
if (($memory_limit = Adminer\ini_bytes("memory_limit")) != "-1") {
Adminer\ini_set("memory_limit", max($memory_limit, strval(10 * strlen($csv) + memory_get_usage() + 8e6))); // 10 - the parsed data take more memory than the file
}
$rows = Adminer\parse_csv($csv, $this->_separator($csv));
$header = array_map('Adminer\csv_value', (array) array_shift($rows));
while ($header && end($header) === "") {
array_pop($header); // the first row ends with the separator
}
$message_prefix = "
" . Adminer\h($name) . ": ";
if (!$header) {
echo $message_prefix . $this->lang('%d row(s) have been imported.', 0) . "\n";
return true;
}
$table = preg_replace('~\.csv(\.gz)?$~i', '', basename($name));
$tables = Adminer\tables_list();
$fields = array();
if (isset($tables[$table])) {
if ($exists == "drop") {
if (!Adminer\drop_tables(array($table))) {
echo $error_prefix . Adminer\adminer()->error() . "\n";
return false;
}
} else {
$fields = Adminer\fields($table);
foreach ($header as $column) {
if (!$fields[$column]) {
echo $error_prefix . $this->lang('Column %s does not exist.', "" . Adminer\h($column) . "") . "\n";
return false;
}
}
if ($exists == "truncate" && !Adminer\truncate_tables(array($table))) {
echo $error_prefix . Adminer\adminer()->error() . "\n";
return false;
}
}
}
$created = !$fields;
if ($created) {
$fields = $this->_fields($header, $rows);
$create = array();
$primary = array();
foreach ($fields as $field) {
$create[] = array("", Adminer\process_field($field, $field), "");
if ($field["primary"]) {
$primary[] = " PRIMARY KEY (" . Adminer\idf_escape($field["field"]) . ")"; // the same as in recreate_table() in the SQLite driver
}
}
$start = count(Adminer\Queries::$queries);
if (!Adminer\alter_table("", $table, $create, $primary, null, "", "", "", array())) {
echo $error_prefix . Adminer\adminer()->error() . "\n";
return false;
}
if (!$_POST["only_errors"]) {
echo "