wpdb::query() │ public │ WP 0.71

Виконує будь-які запити до бази даних WordPress.

Цей метод передбачає виконання всіх запитів, крім SELECT. Для SELECT є спеціальні методи: $wpdb->get_results , $wpdb->get_row , $wpdb->get_col , $wpdb->get_var .

Майте на увазі, що як і для всіх функцій класу wpdb , параметри, що передаються, потрібно очистити від SQL ін’єкцій, зробити це можна двома способами:

// спосіб 1
esc_sql( $user_entered_data_string )

// спосіб 2
$wpdb->prepare( 'query' , value_parameter[, value_parameter ... ] )

Докладніше читайте у секції “Захист запитів від SQL ін’єкцій”

{} Це метод класу: wpdb{}

Основа для:
wpdb::delete() ,
wpdb::update() ,
wpdb::get_row()

Хуки з методу

query

Повертає

int|true|false.

true— для запитів CREATE , ALTER , TRUNCATE , DROP .
Число– Задіяних рядків, для запитів: DELETE/ UPDATE/ SELECT.
false– Коли запит викликав помилку.

Використання

Global $wpdb;
$wpdb->query($query);

$query (рядок) (обов’язковий): Database query.

Приклади

#1 Видалити довільне поле ‘gargle’ та його значення біля посту 13

$wpdb->query( "DELETE FROM $wpdb->postmeta WHERE post_id = '13' AND meta_key = 'gargle'" );

#2 Встановити батьківську сторінку 7 для сторінки 15

$wpdb->query( "UPDATE $wpdb->posts SET post_parent = 7 WHERE ID = 15 AND post_status = 'static'" );

#3 Видалити осиротілі довільні поля

$wpdb->query("DELETE pm FROM $wpdb->postmeta pm LEFT JOIN wp_posts wp ON wp.ID = pm.post_id WHERE wp.ID IS NULL");

#4 Змінимо ключ у полів-повторювачів ACF

$wpdb->query( "
	UPDATE $wpdb->postmeta
	SET meta_key = REPLACE(meta_key, 'knowledge-base-type', 'knowledge-base-list')
	WHERE `meta_key` LIKE '%knowledge-base-type%'
");

список змін

З версії 0.71

Введено.

Код `wpdb::query() wpdb::query` ^{WP 6.0.2}

wp-includes/wp-db.php

public function query( $query ) {
	if (! $this->ready) {
		$this->check_current_query = true;
		return false;
	}

	/**
	 * Filters the database query.
	 *
	 * Кожен хлопчиків буде зроблено до plugins, щоб бути loaded,
	 * і thus cannot be filtered with this method.
	 *
	 * @ Since 2.1.0
	 *
	 * @param string $query Database query.
	 */
	$query = apply_filters('query', $query);

	if ( ! $query ) {
		$this->insert_id = 0;
		return false;
	}

	$this->flush();

	// Log how the function був названий.
	$this->func_call = "$db->query("$query")";

	// If we're writing to the database, make sure the query will write safely.
	if ( $this->check_current_query && ! $this->check_ascii( $query ) ) {
		$stripped_query = $this->strip_invalid_text_from_query( $query );
		// strip_invalid_text_from_query() can perform queries, so we need
		// flush again, just to make sure everything is clear.
		$this->flush();
		if ( $stripped_query !== $query ) {
			$this->insert_id = 0;
			$this->last_query = $query;

			wp_load_translations_early();

			$this->last_error = __( 'WordPress Error: Could not perform query because it contains invalid data.' );

			return false;
		}
	}

	$this->check_current_query = true;

	// Keep track of last query for debug.
	$this->last_query = $query;

	$this->_do_query( $query );

	/ / Database server має gone away, try to reconnect.
	$ mysql_errno = 0;
	if ( ! empty( $this->dbh ) ) {
		if ( $this->use_mysqli ) {
			if ( $this->dbh instanceof mysqli ) {
				$ mysql_errno = mysqli_errno( $this->dbh );
			} else {
				// $ dbh is defined, але isn't a real connection.
				// Something has gone horribly wrong, let's try a reconnect.
				$ mysql_errno = 2006;
			}
		} else {
			if ( is_resource( $this->dbh ) ) {
				$ mysql_errno = mysql_errno( $this->dbh );
			} else {
				$ mysql_errno = 2006;
			}
		}
	}

	if ( empty( $this->dbh ) || 2006 === $mysql_errno ) {
		if ( $this->check_connection() ) {
			$this->_do_query( $query );
		} else {
			$this->insert_id = 0;
			return false;
		}
	}

	// If there is an error then note of it.
	if ( $this->use_mysqli ) {
		if ( $this->dbh instanceof mysqli ) {
			$this->last_error = mysqli_error( $this->dbh );
		} else {
			$this->last_error = __( 'Unable to retrieve the error message from MySQL' );
		}
	} else {
		if ( is_resource( $this->dbh ) ) {
			$this->last_error = mysql_error( $this->dbh );
		} else {
			$this->last_error = __( 'Unable to retrieve the error message from MySQL' );
		}
	}

	if ( $this->last_error ) {
		// Clear insert_id on a subsequent failed insert.
		if ( $this->insert_id && preg_match( '/^s*(insert|replace)s/i', $query ) ) {
			$this->insert_id = 0;
		}

		$this->print_error();
		return false;
	}

	if ( preg_match( '/^s*(create|alter|truncate|drop)s/i', $query ) ) {
		$return_val = $this->result;
	} elseif ( preg_match( '/^s*(insert|delete|update|replace)s/i', $query ) ) {
		if ( $this->use_mysqli ) {
			$this->rows_affected = mysqli_affected_rows( $this->dbh );
		} else {
			$this->rows_affected = mysql_affected_rows( $this->dbh );
		}
		/ / Таке note of the insert_id.
		if ( preg_match( '/^s*(insert|replace)s/i', $query ) ) {
			if ( $this->use_mysqli ) {
				$this->insert_id = mysqli_insert_id( $this->dbh );
			} else {
				$this->insert_id = mysql_insert_id( $this->dbh );
			}
		}
		// Return number of rows affected.
		$return_val = $this->rows_affected;
	} else {
		$num_rows = 0;
		if ( $this->use_mysqli && $this->result instanceof mysqli_result ) {
			while ( $row = mysqli_fetch_object( $this->result ) ) {
				$this->last_result[ $num_rows ] = $row;
				$num_rows++;
			}
		} elseif ( is_resource( $this->result ) ) {
			while ( $row = mysql_fetch_object( $this->result ) ) {
				$this->last_result[ $num_rows ] = $row;
				$num_rows++;
			}
		}

		// Log і return the number of rows selected.
		$this->num_rows = $num_rows;
		$return_val = $num_rows;
	}

	return $return_val;
}