<?php

[0] Fix | Delete

[1] Fix | Delete

namespace Nextend\Framework\Database\WordPress;

[2] Fix | Delete

[3] Fix | Delete

use Nextend\Framework\Database\AbstractPlatformConnector;

[4] Fix | Delete

use Nextend\Framework\Notification\Notification;

[5] Fix | Delete

use Nextend\SmartSlider3\Platform\SmartSlider3Platform;

[6] Fix | Delete

use wpdb;

[7] Fix | Delete

[8] Fix | Delete

class WordPressConnector extends AbstractPlatformConnector {

[9] Fix | Delete

[10] Fix | Delete

/** @var wpdb $wpdb */

[11] Fix | Delete

private $db;

[12] Fix | Delete

[13] Fix | Delete

public function __construct() {

[14] Fix | Delete

/** @var wpdb $wpdb */ global $wpdb;

[15] Fix | Delete

$this->db = $wpdb;

[16] Fix | Delete

$this->_prefix = $wpdb->prefix;

[17] Fix | Delete

[18] Fix | Delete

WordPressConnectorTable::init($this, $this->db);

[19] Fix | Delete

}

[20] Fix | Delete

[21] Fix | Delete

public function query($query, $attributes = false) {

[22] Fix | Delete

if ($attributes) {

[23] Fix | Delete

foreach ($attributes as $key => $value) {

[24] Fix | Delete

$replaceTo = is_numeric($value) ? $value : $this->db->prepare('%s', $value);

[25] Fix | Delete

$query = str_replace($key, $replaceTo, $query);

[26] Fix | Delete

}

[27] Fix | Delete

}

[28] Fix | Delete

[29] Fix | Delete

return $this->checkError($this->db->query($query));

[30] Fix | Delete

}

[31] Fix | Delete

[32] Fix | Delete

public function insertId() {

[33] Fix | Delete

return $this->db->insert_id;

[34] Fix | Delete

}

[35] Fix | Delete

[36] Fix | Delete

private function _querySQL($query, $attributes = false) {

[37] Fix | Delete

[38] Fix | Delete

$args = array('');

[39] Fix | Delete

[40] Fix | Delete

if ($attributes) {

[41] Fix | Delete

foreach ($attributes as $key => $value) {

[42] Fix | Delete

$replaceTo = is_numeric($value) ? '%d' : '%s';

[43] Fix | Delete

$query = str_replace($key, $replaceTo, $query);

[44] Fix | Delete

$args[] = $value;

[45] Fix | Delete

}

[46] Fix | Delete

}

[47] Fix | Delete

[48] Fix | Delete

[49] Fix | Delete

if (count($args) > 1) {

[50] Fix | Delete

$args[0] = $query;

[51] Fix | Delete

[52] Fix | Delete

return call_user_func_array(array(

[53] Fix | Delete

$this->db,

[54] Fix | Delete

'prepare'

[55] Fix | Delete

), $args);

[56] Fix | Delete

} else {

[57] Fix | Delete

return $query;

[58] Fix | Delete

}

[59] Fix | Delete

}

[60] Fix | Delete

[61] Fix | Delete

public function queryRow($query, $attributes = false) {

[62] Fix | Delete

return $this->checkError($this->db->get_row($this->_querySQL($query, $attributes), ARRAY_A));

[63] Fix | Delete

}

[64] Fix | Delete

[65] Fix | Delete

public function queryAll($query, $attributes = false, $type = "assoc", $key = null) {

[66] Fix | Delete

$result = $this->checkError($this->db->get_results($this->_querySQL($query, $attributes), $type == 'assoc' ? ARRAY_A : OBJECT_K));

[67] Fix | Delete

if (!$key) {

[68] Fix | Delete

return $result;

[69] Fix | Delete

}

[70] Fix | Delete

$realResult = array();

[71] Fix | Delete

[72] Fix | Delete

for ($i = 0; $i < count($result); $i++) {

[73] Fix | Delete

$key = $type == 'assoc' ? $result[i][$key] : $result[i]->{$key};

[74] Fix | Delete

$realResult[$key] = $result[i];

[75] Fix | Delete

}

[76] Fix | Delete

[77] Fix | Delete

return $realResult;

[78] Fix | Delete

}

[79] Fix | Delete

[80] Fix | Delete

public function quote($text, $escape = true) {

[81] Fix | Delete

return '\'' . (esc_sql($text)) . '\'';

[82] Fix | Delete

}

[83] Fix | Delete

[84] Fix | Delete

public function quoteName($name, $as = null) {

[85] Fix | Delete

if (strpos($name, '.') !== false) {

[86] Fix | Delete

return $name;

[87] Fix | Delete

} else {

[88] Fix | Delete

$q = '`';

[89] Fix | Delete

if (strlen($q) == 1) {

[90] Fix | Delete

return $q . $name . $q;

[91] Fix | Delete

} else {

[92] Fix | Delete

return $q[0] . $name . $q[1];

[93] Fix | Delete

}

[94] Fix | Delete

}

[95] Fix | Delete

}

[96] Fix | Delete

[97] Fix | Delete

public function checkError($result) {

[98] Fix | Delete

if (!empty($this->db->last_error)) {

[99] Fix | Delete

if (is_admin()) {

[100] Fix | Delete

$lastError = $this->db->last_error;

[101] Fix | Delete

$lastQuery = $this->db->last_query;

[102] Fix | Delete

[103] Fix | Delete

$possibleErrors = array(

[104] Fix | Delete

'Duplicate entry' => 'Your table column doesn\'t have auto increment, while it should have.',

[105] Fix | Delete

'command denied' => 'Your database user has limited access and isn\'t able to run all commands which are necessary for our code to work.',

[106] Fix | Delete

'Duplicate key name' => 'Your database user has limited access and isn\'t able to run DROP or ALTER database commands.',

[107] Fix | Delete

'Can\'t DROP' => 'Your database user has limited access and isn\'t able to run DROP or ALTER database commands.'

[108] Fix | Delete

);

[109] Fix | Delete

[110] Fix | Delete

$errorMessage = sprintf(n2_('If you see this message after the repair database process, please %1$scontact us%2$s with the log:'), '<a href="https://smartslider3.com/contact-us/support/" target="_blank">', '</a>');

[111] Fix | Delete

[112] Fix | Delete

foreach ($possibleErrors as $error => $cause) {

[113] Fix | Delete

if (strpos($lastError, $error) !== false) {

[114] Fix | Delete

$errorMessage = n2_($cause) . ' ' . n2_('Contact your server host and ask them to fix this for you!');

[115] Fix | Delete

break;

[116] Fix | Delete

}

[117] Fix | Delete

}

[118] Fix | Delete

[119] Fix | Delete

$message = array(

[120] Fix | Delete

n2_('Unexpected database error.'),

[121] Fix | Delete

'',

[122] Fix | Delete

'<a href="' . wp_nonce_url(add_query_arg(array('repairss3' => '1'), SmartSlider3Platform::getAdminUrl()), 'repairss3') . '" class="n2_button n2_button--big n2_button--blue">' . n2_('Try to repair database') . '</a>',

[123] Fix | Delete

'',

[124] Fix | Delete

$errorMessage,

[125] Fix | Delete

'',

[126] Fix | Delete

'<b>' . $lastError . '</b>',

[127] Fix | Delete

$lastQuery

[128] Fix | Delete

);

[129] Fix | Delete

Notification::error(implode('<br>', $message), array(

[130] Fix | Delete

'wide' => true

[131] Fix | Delete

));

[132] Fix | Delete

}

[133] Fix | Delete

}

[134] Fix | Delete

[135] Fix | Delete

return $result;

[136] Fix | Delete

}

[137] Fix | Delete

[138] Fix | Delete

public function getCharsetCollate() {

[139] Fix | Delete

[140] Fix | Delete

return $this->db->get_charset_collate();

[141] Fix | Delete

}

[142] Fix | Delete

}

[143] Fix | Delete