本文实例讲述了PHP实现的pdo公共类定义与用法。分享给大家供大家参考，具体如下：
db.class.PHP ：
rush:PHP;">
dsn = 'MysqL:host=' . $dbHost . ';dbname=' . $dbname;
$this->dbh = new \PDO($this->dsn,$dbPasswd);
$this->dbh->setAttribute(\PDO::ATTR_EMULATE_PREPARES,false);
$this->dbh->setAttribute(\PDO::ATTR_ERRMODE,\PDO::ERRMODE_EXCEPTION);
$this->dbh->exec('SET character_set_connection='.$dbCharset.';SET character_set_client='.$dbCharset.';SET character_set_results='.$dbCharset);
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public static function getInstance($dbHost,$dbCharset='utf8') {
if (self::$_instance === null) {
self::$_instance = new self($dbHost,$dbCharset);
}
return self::$_instance;
}
public function fetchAll($sql,$params = array()) {
try {
$stm = $this->dbh->prepare($sql);
if ($stm && $stm->execute($params)) {
return $stm->fetchAll(\PDO::FETCH_ASSOC);
}
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public function fetchOne($sql,$params = array()) {
try {
$result = false;
$stm = $this->dbh->prepare($sql);
if ($stm && $stm->execute($params)) {
$result = $stm->fetch(\PDO::FETCH_ASSOC);
}
return $result;
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public function fetchColumn($sql,$params = array()) {
$result = '';
try {
$stm = $this->dbh->prepare($sql);
if ($stm && $stm->execute($params)) {
$result = $stm->fetchColumn();
}
return $result;
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public function insert($table,$params = array(),$returnLastId = true) {
$_implode_field = '';
$fields = array_keys($params);
$_implode_field = implode(',',$fields);
$_implode_value = '';
foreach ($fields as $value) {
$_implode_value .= ':'. $value.',';
}
$_implode_value = trim($_implode_value,');
$sql = 'INSERT INTO ' . $table . '(' . $_implode_field . ') VALUES ('.$_implode_value.')';
try {
$stm = $this->dbh->prepare($sql);
$result = $stm->execute($params);
if ( $returnLastId ) {
$result = $this->dbh->lastInsertId();
}
return $result;
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public function update($table,$where = null) {
$_implode_field = '';
$_implode_field_arr = array();
if ( empty($where) ) {
return false;
}
$fields = array_keys($params);
foreach ($fields as $key) {
$_implode_field_arr[] = $key . '=' . ':'.$key;
}
$_implode_field = implode(',$_implode_field_arr);
$sql = 'UPDATE ' . $table . ' SET ' . $_implode_field . ' WHERE ' . $where;
try {
$stm = $this->dbh->prepare($sql);
$result = $stm->execute($params);
return $result;
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public function delete($sql,$params = array()) {
try {
$stm = $this->dbh->prepare($sql);
$result = $stm->execute($params);
return $result;
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public function exec($sql,$params = array()) {
try {
$stm = $this->dbh->prepare($sql);
$result = $stm->execute($params);
return $result;
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
private function outputError($strErrMsg) {
throw new Exception("MysqL Error: " . $strErrMsg);
}
public function __destruct() {
$this->dbh = null;
}
}
实例：
rush:PHP;">
12,);
$res = $pdo->fetchOne($sql,$parame);
var_dump($res);
$sql = 'SELECT * FROM cms_link';
$result = $db->fetchAll($sql);
print_r($result);
//查询记录数量
$sql = 'SELECT COUNT(*) FROM cms_link';
$count = $db->fetchColumn($sql);
echo $count;
$data = array(
'siteid' => 1,'linktype' => 1,'name' => 'google','url' => 'http://www.google.com','listorder' => 0,'elite' => 0,'passed' => 1,'addtime' => time()
);
$lastInsertId = $db->insert('cms_link',$data);
echo $lastInsertId;
//用 try
try {
$result = $pdo->insert('news',$essay);
} catch (Exception $e) {
error_log($e->getMessage());
error_log($e->getMessage() . ' in ' . __FILE__ . ' on line ' . __LINE__);
saveLog('url文章 : ' . $essay['link'] . ' 数据插入失败
'); continue; } $data = array( 'siteid' => 1,'addtime' => time() ); $db->insert('cms_link',$data); $sql = 'DELETE FROM cms_link WHERE linkid=4'; $result = $db->delete($sql); var_dump($result);
'); continue; } $data = array( 'siteid' => 1,'addtime' => time() ); $db->insert('cms_link',$data); $sql = 'DELETE FROM cms_link WHERE linkid=4'; $result = $db->delete($sql); var_dump($result);
更多关于PHP相关内容感兴趣的读者可查看本站专题：《》、《》、《》、《》、《》、《》及《PHP常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
