PHP操作MSSQL数据库的封装类
PHP #mssql #数据库 #类04-27 05:51
先上代码吧。后面有例子。。。
/*
* PHP操作MSSQL类
* ----------------------------------------------------------------------------
* Created on 2011-11-19 by aklee
*
*/
class msSQL{
private $db_IP; //数据库IP
private $db_user; //数据库用户
private $db_sa; //数据库SA密码
private $db_dbName; //数据库名
private $conn; //连接标识 'conn' 及 'pconn''
private $result; //Query命令结果标识
private $sql; //SQL语句
private $row; //返回条目数
/* 构造函数 */
public function __construct($db_host,$db_user,$db_sa,$db_dbName,$conn){
$this->db_host=$db_host;
$this->db_user=$db_user;
$this->db_sa = $db_sa;
$this->db_dbName=$db_dbName;
$this->conn=$conn;
$this->connect();
}
/* 数据库连接 */
public function connect()
{
if($this->conn=="pconn"){ //永久链接
$this->conn=mssql_pconnect($this->db_host,$this->db_user,$this->db_sa);
}else{ //即时链接
$this->conn=mssql_connect($this->db_host,$this->db_user,$this->db_sa);
}
if(!mssql_select_db($this->db_dbName,$this->conn)){
die("SQL ERROR:".$this->db_dbName);
}
}
/* 增|删|改|查 */
public function query($sql)
{
if($sql == ""){
die("SQL ERROR:SQL IS NULL!");}
$this->sql = $sql;
$result = mssql_query($this->sql,$this->conn);
if(!$result){ //调试用，sql语句出错时会自动打印出来
die("SQL：".$this->sql);
}else{
$this->result = $result;
}
return $this->result;
}
//创建一个新数据库
public function create_database($database_name){
$database=$database_name;
$sqlDatabase = 'create database '.$database;
$this->query($sqlDatabase);
}
//获取记录集
public function fetch_array()
{
return mssql_fetch_array($this->result);
}
//获取关联数组
public function fetch_assoc()
{
return mssql_fetch_assoc($this->result);
}
//获取数字索引数组
public function fetch_row()
{
return mssql_fetch_row($this->result);
}
//获取对象数组 调试:‘$row->content’
public function fetch_Object()
{
return mssql_fetch_object($this->result);
}
//指向确定的一条数据记录
public function db_data_seek($id){
if($id>0){
$id=$id-1;
}
if(!@mssql_data_seek($this->result,$id)){
die('SQL ERROR:Specified data is null!');
}
return $this->result;
}
//根据查询结果集条目
public function db_num_rows(){
if($this->result==null){
die('SQL ERROR:Being empty, nothing!');
}else{
return mssql_num_rows($this->result);
}
}
//返回最后一次写入查询影响的记录数
public function db_affected_rows(){
return mssql_rows_affected();
}
//释放结果集
public function free(){
@mssql_free_result($this->result);
}
//数据库选择
public function select_db($db_database){
return mssql_select_db($db_database);
}
//获取结果的字段数
public function num_fields($table_name){
$this->query("select * from $table_name");
echo $total = mssql_num_fields($this->result);
echo "
";";
for ($i=0; $i<$total; $i++){
print_r(mssql_fetch_field($this->result,$i) );
}
echo "
echo "
}
//初始化存储过程
public function init_pro($proNme){
return mssql_init($proNme,$this->conn);
}
//析构函数,关闭数据库,垃圾回收
public function __destruct()
{
if(!empty($this->result)){
$this->free();
}
mssql_close($this->conn);
}
}
?>
例子在这里。
/*
* 示例文件
* ----------------------------------------------------------------------------
* Created on 2011-11-19 by aklee
*
*/
require_once("mssql.php");
$db=new msSQL("IP或主机名","sa","密码","数据库名","conn");
$rs=$db->query("select * from 表名");
//返回结果集条目
echo '记录数:'.$amount =$db->db_num_rows($rs);
echo '
';
//获取索引数组
echo '结果集索引数组
';
while($row = $db->fetch_array($rs)){
echo $row[id];
echo '
';
}
echo '
';
//结果字段数
echo '获取字段数并打印
';
echo $db->num_fields("表名");
echo '
';
?>
PHP操作MSSQL数据库的封装类
