php sqlsrv 类,PHP for SQLSrv 操作类

本是古典何须时尚 2022-11-12 13:48 228阅读 0赞

自己用东拼西凑封装的

博客：http://blog.kilvn.com/

1.\[代码\]类代码 sqlsrv\_driver.php

/\*\*

\* SqlServer操作类(sqlsrv)

\* Class SQLSrv

\*/

class SQLSrv

private $dbhost;

private $dbuser;

private $dbpw;

private $dbname;

private $port;

private $result;

private $connid = 0;

private $insertid = 0;

private $cursor = 0;

public static $instance = null;

public function \_\_construct($db)

function\_exists("sqlsrv\_connect") or die("

请先安装 sqlsrv 扩展。");

$this->dbhost = !empty($db\['hostname'\]) ? $db\['hostname'\] : 'localhost';

$this->dbuser = $db\['username'\];

$this->dbpw = $db\['password'\];

$this->dbname = $db\['dbname'\];

$this->port = !empty($db\['port'\]) ? $db\['port'\] : 1433;

$this->connect();

public static function getdatabase($db)\{

if(empty(self::$instance))\{

self::$instance = new SQLSrv($db);

return self::$instance;

/\*\*

\* 连接数据库

\* @return int

\*/

private function connect()

$serverName = "\{$this->dbhost\}, \{$this->port\}";

$connectionInfo = array( "Database"=>$this->dbname, "UID"=>$this->dbuser, "PWD"=>$this->dbpw);

if(!$this->connid = @sqlsrv\_connect($serverName, $connectionInfo))\{

$this->halt(print\_r( sqlsrv\_errors(), true));

return $this->connid;

/\*\*

\* 执行sql

\* @param $sql

\* @return mixed

\*/

public function query($sql)

if(empty($sql))\{

$this->halt('SQL IS NULL!');

$result = sqlsrv\_query($this->connid, $sql);

if(!$result)\{ //调试用，sql语句出错时会自动打印出来

$this->halt('MsSQL Query Error', $sql);

$this->result = $result;

return $this->result;

/\*\*

\* 获取一条数据(一维数组)

\* @param $sql

\* @return array|bool

\*/

public function find($sql)

$this->result = $this->query($sql);

$args = $this->fetch\_array($this->result);

return $args ;

/\*\*

\* 获取多条(二维数组)

\* @param $sql

\* @param string $keyfield

\* @return array

\*/

public function findAll($sql, $keyfield = '')

$array = array();

$this->result = $this->query($sql);

while($r = $this->fetch\_array($this->result))\{

if($keyfield)\{

$key = $r\[$keyfield\];

$array\[$key\] = $r;

\}else\{

$array\[\] = $this->objectToArray($r);

return $array;

/\*\*

\* 对象转数组

\* @param $obj

\* @return array

\*/

private function objectToArray($obj)\{

$ret = array();

foreach ($obj as $key => $value) \{

if (gettype($value) == "array" || gettype($value) == "object")\{

$ret\[$key\] = $this->objectToArray($value);

\}else\{

$ret\[$key\] = $value;

return $ret;

public function fetch\_array($query, $type = SQLSRV\_FETCH\_ASSOC)

if(is\_resource($query)) return sqlsrv\_fetch\_array($query, $type);

if($this->cursor < count($query))\{

return $query\[$this->cursor++\];

return FALSE;

public function affected\_rows()

return sqlsrv\_rows\_affected($this->connid);

public function num\_rows($query)

return is\_array($query) ? count($query) : sqlsrv\_num\_rows($query);

public function num\_fields($query)

return sqlsrv\_num\_fields($query);

/\*\*

\* 释放连接资源

\* @param $query

\*/

public function free\_result($query)

if(is\_resource($query)) @sqlsrv\_free\_stmt($query);

public function insert\_id()

return $this->insertid;

public function fetch\_row($query)

return sqlsrv\_num\_rows($query);

/\*\*

\* 关闭数据库连接

\* @return bool

\*/

public function close()

return sqlsrv\_close($this->connid);

/\*\*

\* 抛出错误

\* @param string $message

\* @param string $sql

\*/

public function halt($message = '', $sql = '')

$\_sql = !empty($sql) ? "MsSQL Query:$sql  
" : '';

exit("

{$_sql}Message:$message");

/\*\*

\* 开始一个事务.

\*/

public function begin()

return sqlsrv\_begin\_transaction($this->connid);

/\*\*

\* 提交一个事务.

\*/

public function commit()

return sqlsrv\_commit($this->connid);

/\*\*

\* 回滚一个事务.

\*/

public function rollback()

return sqlsrv\_rollback($this->connid);

/\*\*

\* 返回服务器信息

\* @return array

\*/

public static function serverInfo()\{

return sqlsrv\_server\_info($this->connid);

/\*\*

\* 返回客户端信息

\* @return array|null

\*/

public static function clientInfo()\{

return sqlsrv\_client\_info($this->connid);

/\*\*

\* 析构函数,关闭数据库,垃圾回收

\*/

public function \_\_destruct()

if(!is\_resource($this->connid))\{

return;

$this->free\_result($this->result);

$this->close();

2.\[代码\]使用方法

require "database/sqlsrv\_driver.php"; //导入数据库操作类

$\_db = array( //数据库连接信息

'hostname' => 'localhost', //主机地址

'username' => 'sa', //用户名

'password' => '123', //密码

'dbname' => 'test\_db', //数据库名

'port' => 1433, //端口 默认1433

);

$db = SQLSrv::getdatabase($\_db); //数据库连接

\#最终 $db 就是你的数据库实例

\#查询示例

$sql = "select \* from table1";

\#查询单条：

$result = $db->find($sql);

\#查询多条：

$result = $db->findAll($sql);

\#执行增删改：

$result = $db->query($sql);

\#...

php sqlsrv 类,PHP for SQLSrv 操作类

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 PHP操作mongodb数据库操作类

相关 PHP 类、接口

相关 php access类,一个PHP操作Access类(PHP+ODBC+Access)

相关 php sqlsrv 类,PHP for SQLSrv 操作类

相关 php 类的数组,PHP数组array类常见操作示例

相关支持sqlsrv php3,Linux下PHP5.3+连接sql server那些坑

相关 PHP 抽象类

相关 PHP——CURL类

相关 PHP 抽象类

相关 PHP日志类