<?php
/* $Id: ldi.php 8160 2005-12-08 22:52:03Z nijel $ */
// 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;
        }
        
    }
}
?>