PHP基于单例模式实现的mysql类


            本文实例讲述了PHP基于单例模式实现的mysql类。分享给大家供大家参考，具体如下：





<?php

defined('ACC')||exit('Access Denied');

// 封装mysql操作类,包括连接功能,及查询功能.

class mysql extends absdb{

  protected static $ins = null;

  protected $host; // 主机名

  protected $user; // 用户名

  protected $passwd; // 密码

  protected $db;   // 数据库名

  protected $port;  // 端口

  protected $conn = null;

  // 在内部操作,获得一个对象

  public static function getIns() {

    if(self::$ins === null) {

      self::$ins = new self();

    }

    $conf = conf::getIns();

    self::$ins->host = $conf->host;

    self::$ins->user = $conf->user;

    self::$ins->passwd = $conf->pwd;

    self::$ins->db = $conf->db;

    self::$ins->port = $conf->port;

    self::$ins->connect();

    self::$ins->select_db();

    self::$ins->setChar();

    return self::$ins;

  }

  // 不让外部做new操作,

  protected function __construct() {

  }

  // 连接数据库

  public function connect() {

    $this->conn = @mysql_connect($this->host,$this->user,$this->passwd,$this->port);

    if(!$this->conn) {

      $error = new Exception('数据库连不上',9);

      throw $error;

    }

  }

  // 发送sql查询

  public function query($sql) {

    $rs = mysql_query($sql,$this->conn);

    if(!$rs) {

      log::write($sql);

    }

    return $rs;

  }

  // 封装一个getAll方法

  // 参数:$sql

  // 返回: array,false

  public function getAll($sql) {

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

    if(!$rs) {

      return false;

    }

    $list = array();

    while($row = mysql_fetch_assoc($rs)) {

      $list[] = $row;

    }

    return $list;

  }

  // 封装一个getRow方法

  // 参数:$sql

  // 返回: array,false

  public function getRow($sql) {

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

    if(!$rs) {

      return false;

    }

    return mysql_fetch_assoc($rs);

  }

  // 封装一个getOne方法,

  // 参数: $sql

  // 返回: int,str(单一的值)

  public function getOne($sql) {

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

    if(!$rs) {

      return false;

    }

    $tmp = mysql_fetch_row($rs);

    return $tmp[0];

  }

  // 封装一个afftect_rows()方法

  // 参数:无

  // 返回 int 受影响行数

  public function affected_rows() {

    return mysql_affected_rows($this->conn);

  }

  // 返回最新生成的auto_increment列的值

  public function last_id() {

    return mysql_insert_id($this->conn);

  }

  // 选库函数

  public function select_db() {

    $sql = 'use ' . $this->db;

    return $this->query($sql);

  }

  // 设置字符集的函数

  public function setChar() {

    $sql = 'set names utf8';

    return $this->query($sql);

  }

  // 自动生成insert语句,update语句并执行

  public function autoExecute($data,$table,$act='insert',$where='') {

    if($act == 'insert') {

      $sql = 'insert into ' . $table . ' (';

      $sql .= implode(',',(array_keys($data)));

      $sql .= ') values (\'';

      $sql .= implode("','",array_values($data));

      $sql .= "')";

    } else if($act == 'update') {

      if(!trim($where)) {

        return false;

      }

      $sql = 'update ' . $table . ' set ';

      foreach($data as $k=>$v) {

        $sql .= $k;

        $sql .= '=';

        $sql .= "'".$v."',";

      }

      $sql = substr($sql,0,-1);

      $sql .= ' where ';

      $sql .= $where;

    } else {

      return false;

    }

    //return $sql;

    return $this->query($sql);

  }

}







更多关于PHP数据库操作相关内容感兴趣的读者可查看本站专题：《php+mysql数据库操作入门教程》、《PHP基于pdo操作数据库技巧总结》及《php常见数据库操作技巧汇总》

希望本文所述对大家PHP程序设计有所帮助。