diff --git a/sql.php b/sql.php index 41c7549..3652faf 100644 --- a/sql.php +++ b/sql.php @@ -1,192 +1,192 @@ -m = $_m; - $this->pre = $_m ['pre']; - $this->salt = $_m ['salt']; - if (SQL_LOG) - $this->f = fopen ( 'sql.log', 'w' ); - - $this->h = new mysqli ( $_m ['host'], $_m ['user'], $_m ['pass'], $_m ['data'] ); - if ($this->h->connect_errno) { - return false; - } - return true; - } - public function get($que, $t = '', $p = array ()) { - // echo $que; - $this->cnt_get ++; - if (SQL_LOG) - fputs ( $this->f, str_replace ( array ( - "\n", - " " - ), array ( - ' ', - '' - ), $que ) . "\n" . print_r ( $p, true ) . "\n\n" ); - $statement = $this->h->prepare ( $que ); - if (is_array ( $p )) { - switch (count ( $p )) { - case 0 : - break; - case 1 : - $statement->bind_param ( $t, $p [0] ); - break; - case 2 : - $statement->bind_param ( $t, $p [0], $p [1] ); - break; - case 3 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2] ); - break; - case 4 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3] ); - break; - case 5 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4] ); - break; - case 6 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5] ); - break; - case 7 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6] ); - break; - case 8 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6], $p [7] ); - break; - case 9 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6], $p [7], $p [8] ); - break; - case 10 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6], $p [7], $p [8], $p [9] ); - break; - } - } else { - $statement->bind_param ( $t, $p ); - } - $statement->execute (); - - $ret = array (); - - // print_r($statement); - if (isset ( $statement->error ) && $statement->error != '') { - if (SQL_LOG) - fputs ( $this->f, $statement->error ); - return false; - } - $result = $statement->get_result (); - // print_r($result); - while ( $row = $result->fetch_assoc () ) { - $ret [] = $row; - } - return $ret; - } - public function single($que, $t = '', $p = array ()) { - $data = $this->get ( $que, $t, $p ); - if ($data) { - return $data [0]; - } - return false; - } - public function list($que, $t = '', $p = array ()) { - $data = $this->get ( $que, $t, $p ); - if ($data) { - $ret = array (); - foreach ( $data as $d ) { - foreach ( $d as $k => $v ) { - $ret [] = $v; - } - } - return $ret; - } - return false; - } - public function keyval($que, $k, $v, $t = '', $p = array ()) { - $data = $this->get ( $que, $t, $p ); - if ($data) { - $ret = array (); - foreach ( $data as $d ) { - $ret [$d [$k]] = $d [$v]; - } - return $ret; - } - return false; - } - public function set($que, $t = '', $p = array (), $id = false) { - // echo $que; - $this->cnt_set ++; - $statement = $this->h->prepare ( $que ); - if (SQL_LOG) - fputs ( $this->f, str_replace ( array ( - "\n", - " " - ), array ( - ' ', - '' - ), $que ) . "\n" . print_r ( $p, true ) . "\n\n" ); - if (is_array ( $p )) { - switch (count ( $p )) { - case 0 : - break; - case 1 : - $statement->bind_param ( $t, $p [0] ); - break; - case 2 : - $statement->bind_param ( $t, $p [0], $p [1] ); - break; - case 3 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2] ); - break; - case 4 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3] ); - break; - case 5 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4] ); - break; - case 6 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5] ); - break; - case 7 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6] ); - break; - case 8 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6], $p [7] ); - break; - case 9 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6], $p [7], $p [8] ); - break; - case 10 : - $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6], $p [7], $p [8], $p [9] ); - break; - } - } else { - $statement->bind_param ( $t, $p ); - } - $statement->execute (); - if (isset ( $statement->error ) && $statement->error != '') { - if (SQL_LOG) - fputs ( $this->f, $statement->error ); - return false; - } - - if ($id) { - return $statement->insert_id; - } else { - return $statement->affected_rows; - } - } - function __destruct() { - if (SQL_LOG) - $this->h->close (); - // echo 'DESTROY'; - } -} -?> +m = $_m; + $this->pre = $_m ['pre']; + $this->salt = $_m ['salt']; + if (SQL_LOG) + $this->f = fopen ( 'sql.log', 'w' ); + + $this->h = new mysqli ( $_m ['host'], $_m ['user'], $_m ['pass'], $_m ['data'] ); + if ($this->h->connect_errno) { + return false; + } + return true; + } + public function get($que, $t = '', $p = array ()) { + // echo $que; + $this->cnt_get ++; + if (SQL_LOG) + fputs ( $this->f, str_replace ( array ( + "\n", + " " + ), array ( + ' ', + '' + ), $que ) . "\n" . print_r ( $p, true ) . "\n\n" ); + $statement = $this->h->prepare ( $que ); + if (is_array ( $p )) { + switch (count ( $p )) { + case 0 : + break; + case 1 : + $statement->bind_param ( $t, $p [0] ); + break; + case 2 : + $statement->bind_param ( $t, $p [0], $p [1] ); + break; + case 3 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2] ); + break; + case 4 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3] ); + break; + case 5 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4] ); + break; + case 6 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5] ); + break; + case 7 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6] ); + break; + case 8 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6], $p [7] ); + break; + case 9 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6], $p [7], $p [8] ); + break; + case 10 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6], $p [7], $p [8], $p [9] ); + break; + } + } else { + $statement->bind_param ( $t, $p ); + } + $statement->execute (); + + $ret = array (); + + // print_r($statement); + if (isset ( $statement->error ) && $statement->error != '') { + if (SQL_LOG) + fputs ( $this->f, $statement->error ); + return false; + } + $result = $statement->get_result (); + // print_r($result); + while ( $row = $result->fetch_assoc () ) { + $ret [] = $row; + } + return $ret; + } + public function single($que, $t = '', $p = array ()) { + $data = $this->get ( $que, $t, $p ); + if ($data) { + return $data [0]; + } + return false; + } + public function list($que, $t = '', $p = array ()) { + $data = $this->get ( $que, $t, $p ); + if ($data) { + $ret = array (); + foreach ( $data as $d ) { + foreach ( $d as $k => $v ) { + $ret [] = $v; + } + } + return $ret; + } + return false; + } + public function keyval($que, $k, $v, $t = '', $p = array ()) { + $data = $this->get ( $que, $t, $p ); + if ($data) { + $ret = array (); + foreach ( $data as $d ) { + $ret [$d [$k]] = $d [$v]; + } + return $ret; + } + return false; + } + public function set($que, $t = '', $p = array (), $id = false) { + // echo $que; + $this->cnt_set ++; + $statement = $this->h->prepare ( $que ); + if (SQL_LOG) + fputs ( $this->f, str_replace ( array ( + "\n", + " " + ), array ( + ' ', + '' + ), $que ) . "\n" . print_r ( $p, true ) . "\n\n" ); + if (is_array ( $p )) { + switch (count ( $p )) { + case 0 : + break; + case 1 : + $statement->bind_param ( $t, $p [0] ); + break; + case 2 : + $statement->bind_param ( $t, $p [0], $p [1] ); + break; + case 3 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2] ); + break; + case 4 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3] ); + break; + case 5 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4] ); + break; + case 6 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5] ); + break; + case 7 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6] ); + break; + case 8 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6], $p [7] ); + break; + case 9 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6], $p [7], $p [8] ); + break; + case 10 : + $statement->bind_param ( $t, $p [0], $p [1], $p [2], $p [3], $p [4], $p [5], $p [6], $p [7], $p [8], $p [9] ); + break; + } + } else { + $statement->bind_param ( $t, $p ); + } + $statement->execute (); + if (isset ( $statement->error ) && $statement->error != '') { + if (SQL_LOG) + fputs ( $this->f, $statement->error ); + return false; + } + + if ($id) { + return $statement->insert_id; + } else { + return $statement->affected_rows; + } + } + function __destruct() { + if (SQL_LOG) + $this->h->close (); + // echo 'DESTROY'; + } +} +?>