FileXXXXXXXXXXX

dvadf

File manager - Edit - /home/centroca/public_html/wp/wp-content/plugins/wp-smushit/core/threads/class-json-record.php

Back
<?php namespace Smush\Core\Threads; /** * Thread-safe operations on a JSON object used as a typed record. * * The stored value is a flat JSON object whose field values are scalars * (bool, int, float, string) or nested arrays/objects. Supports atomic * field writes, reads, and integer arithmetic (increment/decrement). * * Usage: * $rec = new JSON_Record( 'my_option_name' ); * $rec->set_values( [ 'count' => 0, 'active' => true ] ); * $rec->increment_values( [ 'count' ] ); / class JSON_Record extends JSON_Data { public function init() { return $this->initialize_json_object_option(); } // ------------------------------------------------------------------------- // Typed field write / read // ------------------------------------------------------------------------- /* * Atomically set one or more typed fields on the stored JSON object. * * Supported PHP types: bool, int, float, string, array, object. * * @param array $associative_array Map of field name → value. * * @return int\|false / public function set_values( $associative_array ) { return $this->run_json_set_query( $associative_array, function ( $value_column, $key, $value ) { global $wpdb; if ( is_bool( $value ) ) { $json_bool = $value ? 'TRUE' : 'FALSE'; return $wpdb->prepare( "%s, {$json_bool}", "$.\"$key\"" ); } if ( is_int( $value ) ) { return $wpdb->prepare( "%s, %d", "$.\"$key\"", $value ); } if ( is_float( $value ) ) { return $wpdb->prepare( "%s, %f", "$.\"$key\"", $value ); } if ( is_array( $value ) \|\| is_object( $value ) ) { $prepared_json = $wpdb->prepare( '%s', wp_json_encode( $value ) ); return $wpdb->prepare( "%s", "$.\"$key\"" ) . ", JSON_EXTRACT(CONCAT('[', {$prepared_json}, ']'), '$[0]')"; } return $wpdb->prepare( "%s, %s", "$.\"$key\"", $value ); } ); } /* * Read a single field from the stored JSON object. * * @param string $key * @param mixed $default * * @return mixed / public function get_value( $key, $default = false ) { $values = $this->get(); $values = empty( $values ) ? array() : $values; return isset( $values[ $key ] ) ? $values[ $key ] : $default; } // ------------------------------------------------------------------------- // Integer field arithmetic // ------------------------------------------------------------------------- /* * Atomically increment a single field by 1 and return the new value. * * Uses MySQL's LAST_INSERT_ID(expr) trick so the increment and the read * happen inside a single UPDATE statement — no separate SELECT needed and * no two concurrent callers can claim the same value. * * Returns the new (post-increment) integer value, or false on DB error / * when the row does not exist (auto_initialize = false and row missing). * * @param string $key Field name. * * @return int\|false / public function increment_and_get( $key ) { global $wpdb; list( $table, $column, $value_column ) = $this->get_table_columns(); $this->maybe_init(); $path = "$.\"$key\""; $rows = $wpdb->query( $wpdb->prepare( "UPDATE {$table} SET {$value_column} = JSON_SET( {$value_column}, %s, LAST_INSERT_ID( CAST(JSON_UNQUOTE(IFNULL(JSON_EXTRACT({$value_column}, %s), -1)) + 1 AS UNSIGNED) ) ) WHERE {$column} = %s", $path, $path, $this->option_id ) ); if ( ! $rows ) { return false; } return (int) $wpdb->get_var( 'SELECT LAST_INSERT_ID()' ); } /* * Increment each listed field by 1. * * @param string[] $keys * * @return int\|false / public function increment_values( $keys ) { $values = array_fill_keys( $keys, 1 ); return $this->add_to_values( $values ); } /* * Add an arbitrary integer to each listed field. * * @param array $values Map of field name → addend (int). * * @return int\|false / public function add_to_values( $values ) { return $this->run_json_set_query( $values, function ( $value_column, $key, $addend ) { global $wpdb; return $wpdb->prepare( "%s, CAST(JSON_UNQUOTE(IFNULL(JSON_EXTRACT($value_column, %s), 0)) + %d AS SIGNED)", "$.\"$key\"", "$.\"$key\"", $addend ); } ); } /* * Decrement each listed field by 1. * * @param string[] $keys * * @return int\|false / public function decrement_values( $keys ) { $values = array_fill_keys( $keys, 1 ); return $this->subtract_from_values( $values ); } /* * Subtract an arbitrary integer from each listed field. * * @param array $values Map of field name → subtrahend (int). * * @return int\|false */ public function subtract_from_values( $values ) { return $this->run_json_set_query( $values, function ( $value_column, $key, $subtrahend ) { global $wpdb; return $wpdb->prepare( "%s, CAST(JSON_UNQUOTE(IFNULL(JSON_EXTRACT($value_column, %s), 0)) - %d AS SIGNED)", "$.\"$key\"", "$.\"$key\"", $subtrahend ); } ); } // ------------------------------------------------------------------------- // Private // ------------------------------------------------------------------------- private function run_json_set_query( $values, $prepare_single_value_query ) { global $wpdb; list( $table, $column, $value_column ) = $this->get_table_columns(); $this->maybe_init(); $set_values = []; foreach ( $values as $key => $value ) { $set_values[] = call_user_func( $prepare_single_value_query, $value_column, $key, $value ); } $set = implode( ', ', $set_values ); $query = " UPDATE {$table} SET $value_column = JSON_SET($value_column, $set) WHERE {$column} = %s; "; return $wpdb->query( $wpdb->prepare( $query, $this->option_id ) ); } }

dvadf

dvadf