数据库

 首页 > 数据库 > SqlServer > PHP的MSSQL操作类

PHP的MSSQL操作类

分享到:
【字体:
导读:
         摘要:项目上需要用到,网上找的不太好用,自己写了一个?php/**PHP操作MSSQL类*----------------------------------------------------------------------------*Createdon2011-11-19byaklee**/classmsSQL{p...

PHP的MSSQL操作类
 项目上需要用到,网上找的不太好用,自己写了一个

/*
 * 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操作类
分享到:
PHP连MSSQL时遇到的问题
PHP连MSSQL时遇到的问题 PHP连MSSQL的问题(NTWDBLIB.DLL在作怪) 而同事就可以连,他比较了ntwdblib.dll这个文件,版本都是2000.2.8.0。唯一不同的是他的机子装了MSSQL,怀疑是这个原因。 搜索了下,发现确实是这个原因。也有不少人碰到装了MSSQL就可以连远程MSSQL,没装则不行。 试验了下,发现原因还是在于NTWDB...
SQL Server 2005的数据如何导入到SQL Ser...
SQL Server 2005的数据如何导入到SQL Server 2000   以下的文章主要向大家描述的是SQL Server 2005导入到SQL Server 2000的正确操作步骤,以及对其在实际操作中值得我们大家注意的相关事项的具体描述,以下就是文章的具体内容的介绍,望你会有所收获。   SQL Server 2005转到2000的步骤:   1. 生成for SQL Se...
  •         php迷,一个php技术的分享社区,专属您自己的技术摘抄本、收藏夹。
  • 在这里……