Ticket #21663: 21663.2.diff
File 21663.2.diff, 6.0 KB (added by , 11 years ago) |
---|
-
src/wp-includes/wp-db.php
510 510 public $is_mysql = null; 511 511 512 512 /** 513 * Whether to use mysqli over mysql. 514 * 515 * @since 3.8.0 516 * @access private 517 * @var bool 518 */ 519 private $use_mysqli = false; 520 521 /** 513 522 * Connects to the database server and selects a database 514 523 * 515 524 * PHP5 style constructor for compatibility with PHP5. Does … … 530 539 if ( WP_DEBUG && WP_DEBUG_DISPLAY ) 531 540 $this->show_errors(); 532 541 542 $this->use_mysqli = apply_filters( 'use_mysqli', version_compare( phpversion(), '5.5', '>=' ) && function_exists( 'mysqli_connect' ) ); 543 533 544 $this->init_charset(); 534 545 535 546 $this->dbuser = $dbuser; … … 637 648 if ( ! isset( $collate ) ) 638 649 $collate = $this->collate; 639 650 if ( $this->has_cap( 'collation' ) && ! empty( $charset ) ) { 640 if ( function_exists( 'mysql_set_charset' ) && $this->has_cap( 'set_charset' )) {641 mysql_set_charset( $charset, $dbh);651 if ( $this->use_mysqli ) { 652 mysqli_set_charset( $dbh, $charset ); 642 653 } else { 643 $query = $this->prepare( 'SET NAMES %s', $charset ); 644 if ( ! empty( $collate ) ) 645 $query .= $this->prepare( ' COLLATE %s', $collate ); 646 mysql_query( $query, $dbh ); 654 if ( function_exists( 'mysql_set_charset' ) && $this->has_cap( 'set_charset' ) ) { 655 mysql_set_charset( $charset, $dbh ); 656 } else { 657 $query = $this->prepare( 'SET NAMES %s', $charset ); 658 if ( ! empty( $collate ) ) 659 $query .= $this->prepare( ' COLLATE %s', $collate ); 660 mysql_query( $query, $dbh ); 661 } 647 662 } 648 663 } 649 664 } … … 830 845 if ( is_null($dbh) ) 831 846 $dbh = $this->dbh; 832 847 833 if ( !@mysql_select_db( $db, $dbh ) ) { 848 $success = ( $this->use_mysqli )? @mysqli_select_db( $dbh, $db ) : @mysql_select_db( $db, $dbh ); 849 if ( ! $success ) { 834 850 $this->ready = false; 835 851 wp_load_translations_early(); 836 852 $this->bail( sprintf( __( '<h1>Can’t select database</h1> … … 877 893 */ 878 894 function _real_escape( $string ) { 879 895 if ( $this->dbh ) 880 return mysql_real_escape_string( $string, $this->dbh );896 return ( $this->use_mysqli )? mysqli_real_escape_string( $this->dbh, $string ) : mysql_real_escape_string( $string, $this->dbh ); 881 897 882 898 $class = get_class( $this ); 883 899 _doing_it_wrong( $class, "$class must set a database connection for use with escaping.", E_USER_NOTICE ); … … 1139 1155 $client_flags = defined( 'MYSQL_CLIENT_FLAGS' ) ? MYSQL_CLIENT_FLAGS : 0; 1140 1156 1141 1157 if ( WP_DEBUG ) { 1142 $this->dbh = mysql_connect( $this->dbhost, $this->dbuser, $this->dbpassword, $new_link, $client_flags ); 1158 if ( $this->use_mysqli ) { 1159 $this->dbh = mysqli_connect( $this->dbhost, $this->dbuser, $this->dbpassword ); 1160 } else { 1161 $this->dbh = mysql_connect( $this->dbhost, $this->dbuser, $this->dbpassword, $new_link, $client_flags ); 1162 } 1143 1163 } else { 1144 $this->dbh = @mysql_connect( $this->dbhost, $this->dbuser, $this->dbpassword, $new_link, $client_flags ); 1164 if ( $this->use_mysqli ) { 1165 $this->dbh = @mysqli_connect( $this->dbhost, $this->dbuser, $this->dbpassword ); 1166 } else { 1167 $this->dbh = @mysql_connect( $this->dbhost, $this->dbuser, $this->dbpassword, $new_link, $client_flags ); 1168 } 1145 1169 } 1146 1170 1147 1171 if ( !$this->dbh ) { … … 1202 1226 if ( defined( 'SAVEQUERIES' ) && SAVEQUERIES ) 1203 1227 $this->timer_start(); 1204 1228 1205 $this->result = @mysql_query( $query, $this->dbh );1229 $this->result = ( $this->use_mysqli )? @mysqli_query( $this->dbh, $query ) : @mysql_query( $query, $this->dbh ); 1206 1230 $this->num_queries++; 1207 1231 1208 1232 if ( defined( 'SAVEQUERIES' ) && SAVEQUERIES ) 1209 1233 $this->queries[] = array( $query, $this->timer_stop(), $this->get_caller() ); 1210 1234 1211 1235 // If there is an error then take note of it.. 1212 if ( $this->last_error = mysql_error( $this->dbh ) ) {1236 if ( $this->last_error = ( $this->use_mysqli )? mysqli_error( $this->dbh ) : mysql_error( $this->dbh ) ) { 1213 1237 // Clear insert_id on a subsequent failed insert. 1214 1238 if ( $this->insert_id && preg_match( '/^\s*(insert|replace)\s/i', $query ) ) 1215 1239 $this->insert_id = 0; … … 1221 1245 if ( preg_match( '/^\s*(create|alter|truncate|drop)\s/i', $query ) ) { 1222 1246 $return_val = $this->result; 1223 1247 } elseif ( preg_match( '/^\s*(insert|delete|update|replace)\s/i', $query ) ) { 1224 $this->rows_affected = mysql_affected_rows( $this->dbh );1248 $this->rows_affected = ( $this->use_mysqli )? mysqli_affected_rows( $this->dbh ) : mysql_affected_rows( $this->dbh ); 1225 1249 // Take note of the insert_id 1226 1250 if ( preg_match( '/^\s*(insert|replace)\s/i', $query ) ) { 1227 $this->insert_id = mysql_insert_id($this->dbh);1251 $this->insert_id = ( $this->use_mysqli )? mysqli_insert_id( $this->dbh ) : mysql_insert_id( $this->dbh ); 1228 1252 } 1229 1253 // Return number of rows affected 1230 1254 $return_val = $this->rows_affected; 1231 1255 } else { 1232 1256 $num_rows = 0; 1233 while ( $row = @mysql_fetch_object( $this->result ) ) {1257 while ( $row = ( $this->use_mysqli )? @mysqli_fetch_object( $this->result ) : @mysql_fetch_object( $this->result ) ) { 1234 1258 $this->last_result[$num_rows] = $row; 1235 1259 $num_rows++; 1236 1260 } … … 1574 1598 if ( $this->col_info ) 1575 1599 return; 1576 1600 1577 for ( $i = 0; $i < @mysql_num_fields( $this->result ); $i++ ) { 1578 $this->col_info[ $i ] = @mysql_fetch_field( $this->result, $i ); 1601 $num_fields = ( $this->use_mysqli )? @mysqli_num_fields( $this->result ) : @mysql_num_fields( $this->result ); 1602 for ( $i = 0; $i < $num_fields; $i++ ) { 1603 $this->col_info[ $i ] = ( $this->use_mysqli )? @mysqli_fetch_field( $this->result, $i ) : @mysql_fetch_field( $this->result, $i ); 1579 1604 } 1580 1605 } 1581 1606 … … 1747 1772 * @return false|string false on failure, version number on success 1748 1773 */ 1749 1774 function db_version() { 1750 return preg_replace( '/[^0-9.].*/', '', mysql_get_server_info( $this->dbh ) ); 1775 $server_info = ( $this->use_mysqli )? mysqli_get_server_info( $this->dbh ) : mysql_get_server_info( $this->dbh ); 1776 return preg_replace( '/[^0-9.].*/', '', $server_info ); 1751 1777 } 1752 1778 }