+++ /dev/null
-<?php
-
-namespace Drush\Sql;
-
-use PDO;
-
-class Sqlmysql extends SqlBase {
-
- public function command() {
- return 'mysql';
- }
-
- public function creds($hide_password = TRUE) {
- if ($hide_password) {
- // EMPTY password is not the same as NO password, and is valid.
- $contents = <<<EOT
-#This file was written by Drush's Sqlmysql.php.
-[client]
-user="{$this->db_spec['username']}"
-password="{$this->db_spec['password']}"
-EOT;
-
- $file = drush_save_data_to_temp_file($contents);
- $parameters['defaults-extra-file'] = $file;
- }
- else {
- // User is required. Drupal calls it 'username'. MySQL calls it 'user'.
- $parameters['user'] = $this->db_spec['username'];
- // EMPTY password is not the same as NO password, and is valid.
- if (isset($this->db_spec['password'])) {
- $parameters['password'] = $this->db_spec['password'];
- }
- }
-
- // Some drush commands (e.g. site-install) want to connect to the
- // server, but not the database. Connect to the built-in database.
- $parameters['database'] = empty($this->db_spec['database']) ? 'information_schema' : $this->db_spec['database'];
-
- // Default to unix socket if configured.
- if (!empty($this->db_spec['unix_socket'])) {
- $parameters['socket'] = $this->db_spec['unix_socket'];
- }
- // EMPTY host is not the same as NO host, and is valid (see unix_socket).
- elseif (isset($this->db_spec['host'])) {
- $parameters['host'] = $this->db_spec['host'];
- }
-
- if (!empty($this->db_spec['port'])) {
- $parameters['port'] = $this->db_spec['port'];
- }
-
- if (!empty($this->db_spec['pdo']['unix_socket'])) {
- $parameters['socket'] = $this->db_spec['pdo']['unix_socket'];
- }
-
- if (!empty($this->db_spec['pdo'][PDO::MYSQL_ATTR_SSL_CA])) {
- $parameters['ssl-ca'] = $this->db_spec['pdo'][PDO::MYSQL_ATTR_SSL_CA];
- }
-
- if (!empty($this->db_spec['pdo'][PDO::MYSQL_ATTR_SSL_CAPATH])) {
- $parameters['ssl-capath'] = $this->db_spec['pdo'][PDO::MYSQL_ATTR_SSL_CAPATH];
- }
-
- if (!empty($this->db_spec['pdo'][PDO::MYSQL_ATTR_SSL_CERT])) {
- $parameters['ssl-cert'] = $this->db_spec['pdo'][PDO::MYSQL_ATTR_SSL_CERT];
- }
-
- if (!empty($this->db_spec['pdo'][PDO::MYSQL_ATTR_SSL_CIPHER])) {
- $parameters['ssl-cipher'] = $this->db_spec['pdo'][PDO::MYSQL_ATTR_SSL_CIPHER];
- }
-
- if (!empty($this->db_spec['pdo'][PDO::MYSQL_ATTR_SSL_KEY])) {
- $parameters['ssl-key'] = $this->db_spec['pdo'][PDO::MYSQL_ATTR_SSL_KEY];
- }
-
- return $this->params_to_options($parameters);
- }
-
- public function silent() {
- return '--silent';
- }
-
- public function createdb_sql($dbname, $quoted = FALSE) {
- if ($quoted) {
- $dbname = '`' . $dbname . '`';
- }
- $sql[] = sprintf('DROP DATABASE IF EXISTS %s;', $dbname);
- $sql[] = sprintf('CREATE DATABASE %s /*!40100 DEFAULT CHARACTER SET utf8 */;', $dbname);
- $db_superuser = drush_get_option('db-su');
- if (isset($db_superuser)) {
- // - For a localhost database, create a localhost user. This is important for security.
- // localhost is special and only allows local Unix socket file connections.
- // - If the database is on a remote server, create a wilcard user with %.
- // We can't easily know what IP adderss or hostname would represent our server.
- $domain = ($this->db_spec['host'] == 'localhost') ? 'localhost' : '%';
- $sql[] = sprintf('GRANT ALL PRIVILEGES ON %s.* TO \'%s\'@\'%s\'', $dbname, $this->db_spec['username'], $domain);
- $sql[] = sprintf("IDENTIFIED BY '%s';", $this->db_spec['password']);
- $sql[] = 'FLUSH PRIVILEGES;';
- }
- return implode(' ', $sql);
- }
-
- public function db_exists() {
- $current = drush_get_context('DRUSH_SIMULATE');
- drush_set_context('DRUSH_SIMULATE', FALSE);
- // Suppress output. We only care about return value.
- $return = $this->query("SELECT 1;", NULL, drush_bit_bucket());
- drush_set_context('DRUSH_SIMULATE', $current);
- return $return;
- }
-
- public function listTables() {
- $current = drush_get_context('DRUSH_SIMULATE');
- drush_set_context('DRUSH_SIMULATE', FALSE);
- $return = $this->query('SHOW TABLES;');
- $tables = drush_shell_exec_output();
- drush_set_context('DRUSH_SIMULATE', $current);
- return $tables;
- }
-
- public function dumpCmd($table_selection) {
- $parens = FALSE;
- $skip_tables = $table_selection['skip'];
- $structure_tables = $table_selection['structure'];
- $tables = $table_selection['tables'];
-
- $ignores = array();
- $skip_tables = array_merge($structure_tables, $skip_tables);
- $data_only = drush_get_option('data-only');
- // The ordered-dump option is only supported by MySQL for now.
- // @todo add documention once a hook for drush_get_option_help() is available.
- // @see drush_get_option_help() in drush.inc
- $ordered_dump = drush_get_option('ordered-dump');
-
- $exec = 'mysqldump ';
- // mysqldump wants 'databasename' instead of 'database=databasename' for no good reason.
- $only_db_name = str_replace('--database=', ' ', $this->creds());
- $exec .= $only_db_name;
-
- // We had --skip-add-locks here for a while to help people with insufficient permissions,
- // but removed it because it slows down the import a lot. See http://drupal.org/node/1283978
- $extra = ' --no-autocommit --single-transaction --opt -Q';
- if (isset($data_only)) {
- $extra .= ' --no-create-info';
- }
- if (isset($ordered_dump)) {
- $extra .= ' --skip-extended-insert --order-by-primary';
- }
- if ($option = drush_get_option('extra', $this->query_extra)) {
- $extra .= " $option";
- }
- $exec .= $extra;
-
- if (!empty($tables)) {
- $exec .= ' ' . implode(' ', $tables);
- }
- else {
- // Append the ignore-table options.
- foreach ($skip_tables as $table) {
- $ignores[] = '--ignore-table=' . $this->db_spec['database'] . '.' . $table;
- $parens = TRUE;
- }
- $exec .= ' '. implode(' ', $ignores);
-
- // Run mysqldump again and append output if we need some structure only tables.
- if (!empty($structure_tables)) {
- $exec .= " && mysqldump " . $only_db_name . " --no-data $extra " . implode(' ', $structure_tables);
- $parens = TRUE;
- }
- }
- return $parens ? "($exec)" : $exec;
- }
-}
projects / yaffs-website / blobdiff