0,0 → 1,102 |
<?php |
/* $Id: ldi.php,v 1.7 2005/12/08 22:52:03 nijel Exp $ */ |
// vim: expandtab sw=4 ts=4 sts=4: |
|
/* CSV import plugin for phpMyAdmin */ |
|
if ($plugin_param == 'table') { |
if (isset($plugin_list)) { |
if ($GLOBALS['cfg']['Import']['ldi_local_option'] == 'auto') { |
$GLOBALS['cfg']['Import']['ldi_local_option'] = FALSE; |
|
if (PMA_MYSQL_INT_VERSION < 32349) { |
$GLOBALS['cfg']['Import']['ldi_local_option'] = TRUE; |
} |
|
if (PMA_MYSQL_INT_VERSION > 40003) { |
$result = PMA_DBI_try_query('SHOW VARIABLES LIKE \'local\\_infile\';'); |
if ($result != FALSE && PMA_DBI_num_rows($result) > 0) { |
$tmp = PMA_DBI_fetch_row($result); |
if ($tmp[1] == 'ON') { |
$GLOBALS['cfg']['Import']['ldi_local_option'] = TRUE; |
} |
} |
PMA_DBI_free_result($result); |
unset($result); |
} |
} |
$plugin_list['ldi'] = array( |
'text' => 'strLDI', |
'extension' => 'ldi', // This is nonsense, however we want to default to our parser for csv |
'options' => array( |
array('type' => 'bool', 'name' => 'replace', 'text' => 'strReplaceTable'), |
array('type' => 'bool', 'name' => 'ignore', 'text' => 'strIgnoreDuplicates'), |
array('type' => 'text', 'name' => 'terminated', 'text' => 'strFieldsTerminatedBy', 'size' => 2, 'len' => 2), |
array('type' => 'text', 'name' => 'enclosed', 'text' => 'strFieldsEnclosedBy', 'size' => 2, 'len' => 2), |
array('type' => 'text', 'name' => 'escaped', 'text' => 'strFieldsEscapedBy', 'size' => 2, 'len' => 2), |
array('type' => 'text', 'name' => 'new_line', 'text' => 'strLinesTerminatedBy', 'size' => 2), |
array('type' => 'text', 'name' => 'columns', 'text' => 'strColumnNames'), |
array('type' => 'bool', 'name' => 'local_option', 'text' => 'strLDILocal'), |
), |
'options_text' => 'strLDIImportOptions', |
); |
} else { |
/* We do not define function when plugin is just queried for information above */ |
if ($import_file == 'none' || $compression != 'none' || $charset_conversion) { |
// We handle only some kind of data! |
$message = $strInvalidLDIImport; |
$show_error_header = TRUE; |
$error = TRUE; |
} else { |
$sql = 'LOAD DATA'; |
if (isset($ldi_local_option)) { |
$sql .= ' LOCAL'; |
} |
$sql .= ' INFILE \'' . PMA_sqlAddslashes($import_file) . '\''; |
if (isset($ldi_replace)) { |
$sql .= ' REPLACE'; |
} elseif (isset($ldi_ignore)) { |
$sql .= ' IGNORE'; |
} |
$sql .= ' INTO TABLE ' . PMA_backquote($table); |
|
if (strlen($ldi_terminated) > 0) { |
$sql .= ' FIELDS TERMINATED BY \'' . $ldi_terminated . '\''; |
} |
if (strlen($ldi_enclosed) > 0) { |
$sql .= ' ENCLOSED BY \'' . PMA_sqlAddslashes($ldi_enclosed) . '\''; |
} |
if (strlen($ldi_escaped) > 0) { |
$sql .= ' ESCAPED BY \'' . PMA_sqlAddslashes($ldi_escaped) . '\''; |
} |
if (strlen($ldi_new_line) > 0){ |
if ($ldi_new_line == 'auto') { |
$ldi_new_line = PMA_whichCrlf() == "\n" ? '\n' : '\r\n'; |
} |
$sql .= ' LINES TERMINATED BY \'' . $ldi_new_line . '\''; |
} |
if ($skip_queries > 0) { |
$sql .= ' IGNORE ' . $skip_queries . ' LINES'; |
$skip_queries = 0; |
} |
if (strlen($ldi_columns) > 0) { |
$sql .= ' ('; |
$tmp = split(',( ?)', $ldi_columns); |
$cnt_tmp = count($tmp); |
for ($i = 0; $i < $cnt_tmp; $i++) { |
if ($i > 0) { |
$sql .= ', '; |
} |
$sql .= PMA_backquote(trim($tmp[$i])); |
} // end for |
$sql .= ')'; |
} |
|
PMA_importRunQuery($sql, $sql); |
PMA_importRunQuery(); |
$finished = TRUE; |
} |
|
} |
} |
?> |