[Sommaire] [Imprimer]

   1  <?php
   2  /* $Id: sql.php 9110 2006-06-13 15:10:08Z lem9 $ */
   3  // vim: expandtab sw=4 ts=4 sts=4:
   4  
   5  /* SQL import plugin for phpMyAdmin */
   6  
   7  if (isset($plugin_list)) {
   8      $plugin_list['sql'] = array(
   9          'text' => 'strSQL',
  10          'extension' => 'sql',
  11          'options_text' => 'strSQLImportOptions',
  12          );
  13      $compats = PMA_DBI_getCompatibilities();
  14      if (count($compats) > 0) {
  15          $values = array();
  16          foreach($compats as $val) {
  17              $values[$val] = $val;
  18          }
  19          $plugin_list['sql']['options'] = array(
  20              array('type' => 'select', 'name' => 'compatibility', 'text' => 'strSQLCompatibility', 'values' => $values, 'doc' => array('manual_MySQL_Database_Administration', 'Server_SQL_mode'))
  21              );
  22      }
  23  } else {
  24  /* We do not define function when plugin is just queried for information above */
  25      $buffer = '';
  26      // Defaults for parser
  27      $sql = '';
  28      $start_pos = 0;
  29      $i = 0;
  30      if (isset($_POST['sql_delimiter'])) {
  31          $sql_delimiter = $_POST['sql_delimiter'];
  32      } else {
  33          $sql_delimiter = ';';
  34      }
  35  
  36      // Handle compatibility option
  37      if (isset($_REQUEST['sql_compatibility'])) {
  38          PMA_DBI_try_query('SET SQL_MODE="' . $_REQUEST['sql_compatibility'] . '"');
  39      }
  40      while (!($finished && $i >= $len) && !$error && !$timeout_passed) {
  41          $data = PMA_importGetNextChunk();
  42          if ($data === FALSE) {
  43              // subtract data we didn't handle yet and stop processing
  44              $offset -= strlen($buffer);
  45              break;
  46          } elseif ($data === TRUE) {
  47              // Handle rest of buffer
  48          } else {
  49              // Append new data to buffer
  50              $buffer .= $data;
  51              // Do not parse string when we're not at the end and don't have ; inside
  52              if ((strpos($buffer, $sql_delimiter) === FALSE) && !$finished) {
  53                  continue;
  54              }
  55          }
  56          // Current length of our buffer
  57          $len = strlen($buffer);
  58          // Grab some SQL queries out of it
  59          while ($i < $len) {
  60              $found_delimiter = false;
  61              // Find first interesting character, several strpos seem to be faster than simple loop in php:
  62              //while (($i < $len) && (strpos('\'";#-/', $buffer[$i]) === FALSE)) $i++;
  63              //if ($i == $len) break;
  64              $oi = $i;
  65              $p1 = strpos($buffer, '\'', $i);
  66              if ($p1 === FALSE) {
  67                  $p1 = 2147483647;
  68              }
  69              $p2 = strpos($buffer, '"', $i);
  70              if ($p2 === FALSE) {
  71                  $p2 = 2147483647;
  72              }
  73              $p3 = strpos($buffer, $sql_delimiter, $i);
  74              if ($p3 === FALSE) {
  75                  $p3 = 2147483647;
  76              } else {
  77                  $found_delimiter = true;
  78              }
  79              $p4 = strpos($buffer, '#', $i);
  80              if ($p4 === FALSE) {
  81                  $p4 = 2147483647;
  82              }
  83              $p5 = strpos($buffer, '--', $i);
  84              if ($p5 === FALSE || $p5 >= ($len - 2) || $buffer[$p5 + 2] > ' ') {
  85                  $p5 = 2147483647;
  86              }
  87              $p6 = strpos($buffer, '/*', $i);
  88              if ($p6 === FALSE) {
  89                  $p6 = 2147483647;
  90              }
  91              $p7 = strpos($buffer, '`', $i);
  92              if ($p7 === FALSE) {
  93                  $p7 = 2147483647;
  94              }
  95              $i = min ($p1, $p2, $p3, $p4, $p5, $p6, $p7);
  96              unset($p1, $p2, $p3, $p4, $p5, $p6, $p7);
  97              if ($i == 2147483647) {
  98                  $i = $oi;
  99                  if (!$finished) {
 100                      break;
 101                  }
 102                  // at the end there might be some whitespace...
 103                  if (trim($buffer) == '') {
 104                      $buffer = '';
 105                      $len = 0;
 106                      break;
 107                  }
 108                  // We hit end of query, go there!
 109                  $i = strlen($buffer) - 1;
 110              }
 111  
 112              // Grab current character
 113              $ch = $buffer[$i];
 114  
 115              // Quotes
 116              if (!(strpos('\'"`', $ch) === FALSE)) {
 117                  $quote = $ch;
 118                  $endq = FALSE;
 119                  while (!$endq) {
 120                      // Find next quote
 121                      $pos = strpos($buffer, $quote, $i + 1);
 122                      // No quote? Too short string
 123                      if ($pos === FALSE) {
 124                          // We hit end of string => unclosed quote, but we handle it as end of query
 125                          if ($finished) {
 126                              $endq = TRUE;
 127                              $i = $len - 1;
 128                          }
 129                          break;
 130                      }
 131                      // Was not the quote escaped?
 132                      $j = $pos - 1;
 133                      while ($buffer[$j] == '\\') $j--;
 134                      // Even count means it was not escaped
 135                      $endq = (((($pos - 1) - $j) % 2) == 0);
 136                      // Skip the string
 137                      $i = $pos;
 138                  }
 139                  if (!$endq) {
 140                      break;
 141                  }
 142                  $i++;
 143                  // Aren't we at the end?
 144                  if ($finished && $i == $len) {
 145                      $i--;
 146                  } else {
 147                      continue;
 148                  }
 149              }
 150  
 151              // Not enough data to decide
 152              if ((($i == ($len - 1) && ($ch == '-' || $ch == '/'))
 153                  || ($i == ($len - 2) && (($ch == '-' && $buffer[$i + 1] == '-') || ($ch == '/' && $buffer[$i + 1] == '*')))
 154                  ) && !$finished) {
 155                  break;
 156              }
 157  
 158              // Comments
 159              if ($ch == '#'
 160                      || ($i < ($len - 1) && $ch == '-' && $buffer[$i + 1] == '-' && (($i < ($len - 2) && $buffer[$i + 2] <= ' ') || ($i == ($len - 1) && $finished)))
 161                      || ($i < ($len - 1) && $ch == '/' && $buffer[$i + 1] == '*')
 162                      ) {
 163                  // Copy current string to SQL
 164                  if ($start_pos != $i) {
 165                      $sql .= substr($buffer, $start_pos, $i - $start_pos);
 166                  }
 167                  // Skip the rest
 168                  $j = $i;
 169                  $i = strpos($buffer, $ch == '/' ? '*/' : "\n", $i);
 170                  // didn't we hit end of string?
 171                  if ($i === FALSE) {
 172                      if ($finished) {
 173                          $i = $len - 1;
 174                      } else {
 175                          break;
 176                      }
 177                  }
 178                  // Skip *
 179                  if ($ch == '/') {
 180                      // Check for MySQL conditional comments and include them as-is
 181                      if ($buffer[$j + 2] == '!') {
 182                          $comment = substr($buffer, $j + 3, $i - $j - 3);
 183                          if (preg_match('/^[0-9]{5}/', $comment, $version)) {
 184                              if ($version[0] <= PMA_MYSQL_INT_VERSION) {
 185                                  $sql .= substr($comment, 5);
 186                              }
 187                          } else {
 188                              $sql .= $comment;
 189                          }
 190                      }
 191                      $i++;
 192                  }
 193                  // Skip last char
 194                  $i++;
 195                  // Next query part will start here
 196                  $start_pos = $i;
 197                  // Aren't we at the end?
 198                  if ($i == $len) {
 199                      $i--;
 200                  } else {
 201                      continue;
 202                  }
 203              }
 204  
 205              // End of SQL
 206              if ($found_delimiter || ($finished && ($i == $len - 1))) {
 207                  $tmp_sql = $sql;
 208                  if ($start_pos < $len) {
 209                      $length_to_grab = $i - $start_pos;
 210                      if (!$found_delimiter) {
 211                          $length_to_grab++;
 212                      }
 213                      $tmp_sql .= substr($buffer, $start_pos, $length_to_grab);
 214                      unset($length_to_grab);
 215                  }
 216                  // Do not try to execute empty SQL
 217                  if (!preg_match('/^([\s]*;)*$/', trim($tmp_sql))) {
 218                      $sql = $tmp_sql;
 219                      PMA_importRunQuery($sql, substr($buffer, 0, $i + strlen($sql_delimiter)));
 220                      $buffer = substr($buffer, $i + strlen($sql_delimiter));
 221                      // Reset parser:
 222                      $len = strlen($buffer);
 223                      $sql = '';
 224                      $i = 0;
 225                      $start_pos = 0;
 226                      // Any chance we will get a complete query?
 227                      //if ((strpos($buffer, ';') === FALSE) && !$finished) {
 228                      if ((strpos($buffer, $sql_delimiter) === FALSE) && !$finished) {
 229                          break;
 230                      }
 231                  } else {
 232                      $i++;
 233                      $start_pos = $i;
 234                  }
 235              }
 236          } // End of parser loop
 237      } // End of import loop
 238      // Commit any possible data in buffers
 239      PMA_importRunQuery('', substr($buffer, 0, $len));
 240      PMA_importRunQuery();
 241  }
 242  ?>