} private function __clone() { }
public function get_instance($params = array())
{ if(!(self::$_instance instanceof self)) { self::$_instance = new self($params); } return self::$_instance;
} private function _connect()
{ try { $this->conn = new pdo($this->dns, $this->username, $this->password); $this->conn->query('set names utf8'); } catch(pdoexception $e) { exit('pdoexception: ' . $e->getmessage()); } } /**
* 查询一条sql语句 * @param string $sql * @param array $parameters 需要绑定的参数 * @param int $option * @return array */ public function query($sql, $parameters = array(), $option = pdo::fetch_assoc) { $stmt = $this->conn->prepare($sql); $stmt->execute($parameters); $tmp = array();
while($row = $stmt->fetch($option)) { $tmp[] = $row; } return $tmp;
} /**
* 插入一条数据 * @param string $sql * @param array $parameters * @return int 1 or 0 返回影响行数 */ public function insert($sql, $parameters = array()) { $stmt = $this->conn->prepare($sql); $stmt->execute($parameters); return $stmt->rowcount();
} /**
* 更新一条数据 * @param string $sql * @param array $parameters * @return int 1 or 0 返回影响行数 */ bbs.it-home.org public function update($sql, $parameters = array()) { $stmt = $this->conn->prepare($sql); $stmt->execute($parameters); return $stmt->rowcount();
} /**
* 删除一条数据 * @param string $sql * @param array $parameters * @return int 1 or 0 返回影响行数 */ public function delete($sql, $parameters = array()) { $stmt = $this->conn->prepare($sql); $stmt->execute($parameters); return $stmt->rowcount();
}}
复制代码
代码链接地址：https://github.com/sumiaowen/mynotes/tree/master/pdo_mysql_class