Rev Author Line No. Line
250 kaklik 1 <?php
2 /* $Id: ldi.php,v 1.7 2005/12/08 22:52:03 nijel Exp $ */
3 // vim: expandtab sw=4 ts=4 sts=4:
4  
5 /* CSV import plugin for phpMyAdmin */
6  
7 if ($plugin_param == 'table') {
8 if (isset($plugin_list)) {
9 if ($GLOBALS['cfg']['Import']['ldi_local_option'] == 'auto') {
10 $GLOBALS['cfg']['Import']['ldi_local_option'] = FALSE;
11  
12 if (PMA_MYSQL_INT_VERSION < 32349) {
13 $GLOBALS['cfg']['Import']['ldi_local_option'] = TRUE;
14 }
15  
16 if (PMA_MYSQL_INT_VERSION > 40003) {
17 $result = PMA_DBI_try_query('SHOW VARIABLES LIKE \'local\\_infile\';');
18 if ($result != FALSE && PMA_DBI_num_rows($result) > 0) {
19 $tmp = PMA_DBI_fetch_row($result);
20 if ($tmp[1] == 'ON') {
21 $GLOBALS['cfg']['Import']['ldi_local_option'] = TRUE;
22 }
23 }
24 PMA_DBI_free_result($result);
25 unset($result);
26 }
27 }
28 $plugin_list['ldi'] = array(
29 'text' => 'strLDI',
30 'extension' => 'ldi', // This is nonsense, however we want to default to our parser for csv
31 'options' => array(
32 array('type' => 'bool', 'name' => 'replace', 'text' => 'strReplaceTable'),
33 array('type' => 'bool', 'name' => 'ignore', 'text' => 'strIgnoreDuplicates'),
34 array('type' => 'text', 'name' => 'terminated', 'text' => 'strFieldsTerminatedBy', 'size' => 2, 'len' => 2),
35 array('type' => 'text', 'name' => 'enclosed', 'text' => 'strFieldsEnclosedBy', 'size' => 2, 'len' => 2),
36 array('type' => 'text', 'name' => 'escaped', 'text' => 'strFieldsEscapedBy', 'size' => 2, 'len' => 2),
37 array('type' => 'text', 'name' => 'new_line', 'text' => 'strLinesTerminatedBy', 'size' => 2),
38 array('type' => 'text', 'name' => 'columns', 'text' => 'strColumnNames'),
39 array('type' => 'bool', 'name' => 'local_option', 'text' => 'strLDILocal'),
40 ),
41 'options_text' => 'strLDIImportOptions',
42 );
43 } else {
44 /* We do not define function when plugin is just queried for information above */
45 if ($import_file == 'none' || $compression != 'none' || $charset_conversion) {
46 // We handle only some kind of data!
47 $message = $strInvalidLDIImport;
48 $show_error_header = TRUE;
49 $error = TRUE;
50 } else {
51 $sql = 'LOAD DATA';
52 if (isset($ldi_local_option)) {
53 $sql .= ' LOCAL';
54 }
55 $sql .= ' INFILE \'' . PMA_sqlAddslashes($import_file) . '\'';
56 if (isset($ldi_replace)) {
57 $sql .= ' REPLACE';
58 } elseif (isset($ldi_ignore)) {
59 $sql .= ' IGNORE';
60 }
61 $sql .= ' INTO TABLE ' . PMA_backquote($table);
62  
63 if (strlen($ldi_terminated) > 0) {
64 $sql .= ' FIELDS TERMINATED BY \'' . $ldi_terminated . '\'';
65 }
66 if (strlen($ldi_enclosed) > 0) {
67 $sql .= ' ENCLOSED BY \'' . PMA_sqlAddslashes($ldi_enclosed) . '\'';
68 }
69 if (strlen($ldi_escaped) > 0) {
70 $sql .= ' ESCAPED BY \'' . PMA_sqlAddslashes($ldi_escaped) . '\'';
71 }
72 if (strlen($ldi_new_line) > 0){
73 if ($ldi_new_line == 'auto') {
74 $ldi_new_line = PMA_whichCrlf() == "\n" ? '\n' : '\r\n';
75 }
76 $sql .= ' LINES TERMINATED BY \'' . $ldi_new_line . '\'';
77 }
78 if ($skip_queries > 0) {
79 $sql .= ' IGNORE ' . $skip_queries . ' LINES';
80 $skip_queries = 0;
81 }
82 if (strlen($ldi_columns) > 0) {
83 $sql .= ' (';
84 $tmp = split(',( ?)', $ldi_columns);
85 $cnt_tmp = count($tmp);
86 for ($i = 0; $i < $cnt_tmp; $i++) {
87 if ($i > 0) {
88 $sql .= ', ';
89 }
90 $sql .= PMA_backquote(trim($tmp[$i]));
91 } // end for
92 $sql .= ')';
93 }
94  
95 PMA_importRunQuery($sql, $sql);
96 PMA_importRunQuery();
97 $finished = TRUE;
98 }
99  
100 }
101 }
102 ?>