<?php
/*
*class:Mssql
*time:2009-12-10
*author:Libaochang
*version:1.0b
*description:mssqldatabaseaccessclass,itcanexecutetheprocedurorsql
*/
classMssqlUtil
{
var$user=null;//databaseusername
var$keys=null;//databaseuserpassword
var$host='localhost';//databasehostname/ipandport
var$base=null;//databasename
var$link=null;//createlink
/**
*constructfunctioninitallparmeters
*@param<type>$hostdatabasehostname/ipandport
*@param<type>$userdatabaseusername
*@param<type>$keysdatabaseuserpassword
*@param<type>$basedatabasename
*/
function__construct($host,$user,$keys,$base)
{
$this->host=$host;
$this->user=$user;
$this->keys=$keys;
$this->base=$base;
}
/**
*createtheconnection
*/
functionconnect()
{
$this->link=mssql_connect($this->host,$this->user,$this->keys);
if(!$this->link)
{
die('connectingfailed...checkthemoduleandsetting...');
}
$select=mssql_select_db($this->base,$this->link);
if(!$select)
{
die('databaseisnotexist...,pleasecheckeit...');
}
}
/**
*executetheprocedurwidththeparameter
*@param<type>$pNameprocedurname
*@param<type>$parNameparametersit'slikethis$par=array('@a'=>'a')
*@param<type>$sqlTyletheprocedur'sparametertype,it'sllikethis$sqlType=array(SQLVARCHAR,SQLVARCHAR);andthereisnotthecharsinglequotemark(').
*@return<type>objectarray
*/
functionexecuteProcedur($pName,$parName,$sqlTyle)
{
$this->connect();
$stmt=mssql_init($pName,$this->link);
if(isset($parName))
{
$i=0;
foreach($parNameas$par=>$value)
{
mssql_bind($stmt,$par,$value,$sqlTyle[$i]);
++$i;
}
$res=mssql_execute($stmt);
$this->close();
while($row=mssql_fetch_assoc($res))
{
$r[]=$row;
}
unset($i);
mssql_free_result($res);
mssql_free_statement($stmt);
return$r;
}
}
/**
*executeprocedurwithouttheparameter
*@param<type>$pNameProcedurName
*@return<type>objectarray
*/
functionexecuteProcedurNoPar($pName)
{
$this->connect();
$stmt=mssql_init($pName,$this->link);
$res=mssql_execute($stmt);
$this->close();
while($row=mssql_fetch_assoc($res))
{
$r[]=$row;
}
mssql_free_result($res);
mssql_free_statement($stmt);
return$r;
}
/**
*GetonerowreturnArray
*@param<type>$sql
*@return<type>Array
*/
functiongetRowArray($sql)
{
$res=$this->query($sql);
$r=mssql_fetch_row($res);
mssql_free_result($res);
return$r;
}
/**
*Getonerowreturnobject
*@param<type>$sqlSql
*@return<type>Object
*/
functiongetRowObject($sql)
{
$res=$this->query($sql);
$r=mssql_fetch_assoc($res);
return$r;
}
/**
*Executeonesql
*@param<type>$sqlSql
*@return<type>result
*/
functionquery($sql)
{
$this->connect();
$res=mssql_query($sql,$this->link);
$this->close();
return$res;
}
/**
*GeteveryrowfromresultbyObject,ReturnaArraywitheveryelementisObject
*@param<type>$sql
*@return<type>ObjectArrayresult
*/
functiongetResult($sql)
{
$res=$this->query($sql);
while($row=mssql_fetch_assoc($res))
{
$r[]=$row;
}
unset($row);
mssql_free_result($res);
return$r;
}
/**
*executeasql
*@param<type>$sqlSql
*/
functionexecuteSql($sql)
{
return$this->query($sql);
}
/**
*executeasqlstatement
*@param<type>$sql
*@return<type>int$affectedrows
*/
functionquerySql($sql)
{
$this->connect();
mssql_query($sql,$this->link);
$affected=mssql_rows_affected($this->link);
$this->close();
return$affected;
}
/**
*closeconnection
*/
functionclose()
{
mssql_close();
}
}
?>
下面说下调用
function __autoload($MssqlUtil)
{
require $MssqlUtil.'.php';
}
$db = new MssqlUtil($config['host'],$config['user'],$config['keys'],$config['base']);
主要说下带参数的存储过程调用
$pName 存储过程名字
$parName 参数,参数形式很重要,是数组类型,对应关系为
array('@a'=>'a') @a 为存储过程里面的参数,a为要传递的值
$sqlTyle 是存储过程参数的数据类型,是数组形式,也很重要
array(SQLCHAR,SQLVARCHAR),注意不要加单引号等,因为SQLVARCHAR是SQL的一些常量
带参数存储过程
$db->executeProcedur($pName,$parName,$sqlTyle);
无参数存储过程
$db->executeProcedurNoPar($pName);
优质内容筛选与推荐>>
1、rem与px的转换2、微信小程序 与后台交互----获取服务器时间3、肾虚老的快,有着些症状说明肾虚了4、【转】快速读懂Android装置测试要领--浅谈常见产品问题风险与验证架构5、js获取对象位置的方法