Edit File by line

<?php namespace la\core\db;

[0] Fix | Delete

[1] Fix | Delete

use mysqli;

[2] Fix | Delete

use SafeMySQL;

[3] Fix | Delete

[4] Fix | Delete

/**

[5] Fix | Delete

* @property mysqli $conn

[6] Fix | Delete

[7] Fix | Delete

* @author navdeykin <navdeykin@gmail.com>

[8] Fix | Delete

[9] Fix | Delete

[10] Fix | Delete

class LASafeMySQL extends SafeMySQL {

[11] Fix | Delete

function __construct( $opt = [] ) {

[12] Fix | Delete

if (FF_USE_WP && defined('FF_USE_WPDB') && FF_USE_WPDB == true) {

[13] Fix | Delete

require_once('LAWPDB.php');

[14] Fix | Delete

$wpdb = new LAWPDB($opt['user'], $opt['pass'], $opt['db'], $opt['host']);

[15] Fix | Delete

@$this->conn = $wpdb->get_connection();

[16] Fix | Delete

}

[17] Fix | Delete

else {

[18] Fix | Delete

$host = $opt['host'];

[19] Fix | Delete

$port_or_socket = strstr( $host, ':' );

[20] Fix | Delete

if ( ! empty( $port_or_socket ) ) {

[21] Fix | Delete

$opt['host'] = substr( $host, 0, strpos( $host, ':' ) );

[22] Fix | Delete

$port_or_socket = substr( $port_or_socket, 1 );

[23] Fix | Delete

if ( 0 !== strpos( $port_or_socket, '/' ) ) {

[24] Fix | Delete

$opt['port'] = intval( $port_or_socket );

[25] Fix | Delete

$maybe_socket = strstr( $port_or_socket, ':' );

[26] Fix | Delete

if ( ! empty( $maybe_socket ) ) {

[27] Fix | Delete

$opt['socket'] = substr( $maybe_socket, 1 );

[28] Fix | Delete

}

[29] Fix | Delete

} else {

[30] Fix | Delete

$opt['socket'] = $port_or_socket;

[31] Fix | Delete

}

[32] Fix | Delete

}

[33] Fix | Delete

parent::__construct($opt);

[34] Fix | Delete

}

[35] Fix | Delete

}

[36] Fix | Delete

[37] Fix | Delete

public function getIndMultiRow()

[38] Fix | Delete

{

[39] Fix | Delete

$args = func_get_args();

[40] Fix | Delete

$index = array_shift($args);

[41] Fix | Delete

$query = $this->prepareQuery($args);

[42] Fix | Delete

[43] Fix | Delete

$ret = [];

[44] Fix | Delete

if ( $res = $this->rawQuery($query) )

[45] Fix | Delete

{

[46] Fix | Delete

/** @noinspection PhpParamsInspection */

[47] Fix | Delete

while($row = $this->fetch($res))

[48] Fix | Delete

{

[49] Fix | Delete

if (!isset($ret[$row[$index]])) $ret[$row[$index]] = [];

[50] Fix | Delete

$ret[$row[$index]][] = $row;

[51] Fix | Delete

}

[52] Fix | Delete

$this->free($res);

[53] Fix | Delete

}

[54] Fix | Delete

return $ret;

[55] Fix | Delete

}

[56] Fix | Delete

[57] Fix | Delete

/**

[58] Fix | Delete

* @return mysqli

[59] Fix | Delete

[60] Fix | Delete

public function getMySQLi() {

[61] Fix | Delete

return $this->conn;

[62] Fix | Delete

}

[63] Fix | Delete

[64] Fix | Delete

/**

[65] Fix | Delete

* Helper function to get a dictionary-style array right out of query and optional arguments

[66] Fix | Delete

[67] Fix | Delete

* Examples:

[68] Fix | Delete

* $data = $db->getIndCol("name", "SELECT name, id FROM cities");

[69] Fix | Delete

[70] Fix | Delete

* @internal param string $index - name of the field which value is used to index resulting array

[71] Fix | Delete

* @internal param string $query - an SQL query with placeholders

[72] Fix | Delete

* @internal param mixed $arg unlimited number of arguments to match placeholders in the query

[73] Fix | Delete

* @return array - associative array contains key=value pairs out of result set. Empty if no rows found.

[74] Fix | Delete

[75] Fix | Delete

public function getIndCol()

[76] Fix | Delete

{

[77] Fix | Delete

$args = func_get_args();

[78] Fix | Delete

$index = array_shift($args);

[79] Fix | Delete

$query = $this->prepareQuery($args);

[80] Fix | Delete

[81] Fix | Delete

$ret = [];

[82] Fix | Delete

if ( $res = $this->rawQuery($query) )

[83] Fix | Delete

{

[84] Fix | Delete

/** @noinspection PhpParamsInspection */

[85] Fix | Delete

while($row = $this->fetch($res))

[86] Fix | Delete

{

[87] Fix | Delete

$key = $row[$index];

[88] Fix | Delete

unset($row[$index]);

[89] Fix | Delete

$ret[$key] = (is_array($row) && sizeof($row) > 1) ? $row : reset($row);

[90] Fix | Delete

}

[91] Fix | Delete

$this->free($res);

[92] Fix | Delete

}

[93] Fix | Delete

return $ret;

[94] Fix | Delete

}

[95] Fix | Delete

[96] Fix | Delete

public function beginTransaction() {

[97] Fix | Delete

return $this->autocommit(false);

[98] Fix | Delete

}

[99] Fix | Delete

[100] Fix | Delete

/**

[101] Fix | Delete

* @param bool $mode

[102] Fix | Delete

* @return bool

[103] Fix | Delete

[104] Fix | Delete

public function autocommit($mode){

[105] Fix | Delete

return $this->conn->autocommit($mode);

[106] Fix | Delete

}

[107] Fix | Delete

[108] Fix | Delete

public function commit() {

[109] Fix | Delete

return $this->conn->commit();

[110] Fix | Delete

}

[111] Fix | Delete

[112] Fix | Delete

public function rollback() {

[113] Fix | Delete

$result = $this->conn->rollback();

[114] Fix | Delete

$this->autocommit(true);

[115] Fix | Delete

return $result;

[116] Fix | Delete

}

[117] Fix | Delete

[118] Fix | Delete

public function rollbackAndClose() {

[119] Fix | Delete

$result = $this->rollback();

[120] Fix | Delete

$this->close();

[121] Fix | Delete

return $result;

[122] Fix | Delete

}

[123] Fix | Delete

[124] Fix | Delete

public function close() {

[125] Fix | Delete

return $this->conn->close();

[126] Fix | Delete

}

[127] Fix | Delete

[128] Fix | Delete

public function getError() {

[129] Fix | Delete

return $this->conn->error;

[130] Fix | Delete

}

[131] Fix | Delete

}

[132] Fix | Delete