nka/php_sqlsrv_class
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

use prepared statements and throw error

Browse Source
This commit is contained in:
Sebastien Plante
2023-05-23 15:19:47 -04:00
parent f08d7a2d6c
commit ae968a6b3e
1 changed files with 60 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

93
sqlsrv.php
View File

@@ -1,10 +1,14 @@
<?php
/**
* @desc A simple and convenient php sqlsrv class
* @author Yaseng WwW.Yaseng.Me [Yaseng@UAUC.NET]
* @link http://yaseng.me/sqlsrv-class.html
* @desc A simple and convenient php sqlsrv class
* @author Yaseng WwW.Yaseng.Me []
* v1.3
* @link
*/
class sqlsrv{
class sqlsrv
{
var $error_log = array();
var $sql_log = array();
@@ -13,53 +17,76 @@ class sqlsrv{
var $conn;
//connection
function sqlsrv($server, $user, $pass, $dbname) {
$this->conn = @sqlsrv_connect($server, array('UID' => $user ,'PWD'=> $pass, 'Database' => $dbname));
if($this->conn === false) {
function __construct($server, $user, $pass, $dbname)
{
$this->conn = @sqlsrv_connect($server, array('UID' => $user, 'PWD' => $pass, 'Database' => $dbname));
if ($this->conn === false) {
$this->error_log[] = sqlsrv_errors();
die();
throw new Exception($this->error_log[0][0]["message"]);
}
}
//query source
function query($sql){
$stmt = sqlsrv_query($this->conn, $sql);
function query($sql, $params = null)
{
$stmt = sqlsrv_query($this->conn, $sql, $params);
$this->sql_log[] = $sql;
if($stmt === false) {
if ($stmt === false) {
$this->error_log[] = sqlsrv_errors();
throw new Exception($this->error_log[0][0]["message"]);
} else {
$this->query_id = $stmt;
$this->num_rows = $this->affectedRows();
while ($row = @sqlsrv_fetch_array($stmt, SQLSRV_FETCH_ASSOC)) {
$data[] = $row;
}
if (isset($data)) {
return $data;
}
}
}
//fetch data
function fetch_all($sql) {
$this->query($sql);
$data = array();
while($row = @sqlsrv_fetch_array($this->query_id, SQLSRV_FETCH_ASSOC)) {
$data[] = $row;
}
return $data;
}
// $DB->count(select * from users)
function fetch_one($sql){
$this->query($sql);
return sqlsrv_fetch_array($this->query_id, SQLSRV_FETCH_ASSOC);
}
// $DB->count(select count(*) from users)
function count($sql){
function count($sql)
{
$count=$this->fetch_one($sql);
$count = $this->fetch_one($sql);
return $count[""];
}
function affectedRows() {
function affectedRows()
{
return ($this->query_id) ? @sqlsrv_num_rows($this->query_id) : false;
}
}
?>
//$DB->fetch_all("SELECT * FROM table WHERE name= ?", array("name"));
function fetch_all($sql, $params = null)
{
$stmt = sqlsrv_query($this->conn, $sql, $params);
if ($stmt === false) {
throw new Exception($this->error_log[0][0]["message"]);
} else {
$data = array();
while ($row = @sqlsrv_fetch_array($stmt, SQLSRV_FETCH_ASSOC)) {
$data[] = $row;
}
return $data;
}
}
// $DB->fetch_one(select * from users)
function fetch_one($sql, $params = null)
{
$stmt = sqlsrv_query($this->conn, $sql, $params);
if ($stmt === false) {
throw new Exception($this->error_log[0][0]["message"]);
} else {
return sqlsrv_fetch_array($stmt, SQLSRV_FETCH_ASSOC);
}
}
}