操作类
class pdomysql {
public static $dbtype = 'mysql';
public static $dbhost = '';
public static $dbport = '';
public static $dbname = '';
public static $dbuser = '';
public static $dbpass = '';
public static $charset = '';
public static $stmt = null;
public static $DB = null;
public static $connect = true; // 是否長连接
public static $debug = false;
private static $parms = array ();
/**
* 构造函数
*/
public function __construct() {
self::$dbtype = 'mysql';
self::$dbhost = HOST;
self::$dbport = '3306';
self::$dbname = 'tion';
self::$dbuser = 'manager';
self::$dbpass = '123';
self::$connect = true;
self::$charset = 'UTF8';
self::connect ();
self::$DB->setAttribute ( PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, true );
self::$DB->setAttribute ( PDO::ATTR_EMULATE_PREPARES, true );
self::execute ( 'SET NAMES ' . self::$charset );
}
/**
* 析构函数
*/
public function __destruct() {
self::close ();
}
/**
* *******************基本方法开始********************
*/
/**
* 作用:连結数据库
*/
public function connect() {
try {
self::$DB = new PDO ( self::$dbtype . ':host=' . self::$dbhost . ';port=' . self::$dbport . ';dbname=' . self::$dbname, self::$dbuser, self::$dbpass, array (
PDO::ATTR_PERSISTENT => self::$connect
) );
} catch ( PDOException $e ) {
die ( "Connect Error Infomation:" . $e->getMessage () );
}
}
/**
* 关闭数据连接
*/
public function close() {
self::$DB = null;
}
/**
* 對字串進行转義
*/
public function quote($str) {
return self::$DB->quote ( $str );
}
/**
* 作用:获取数据表里的欄位
* 返回:表字段结构
* 类型:数组
*/
public function getFields($table) {
self::$stmt = self::$DB->query ( "DESCRIBE $table" );
$result = self::$stmt->fetchAll ( PDO::FETCH_ASSOC );
self::$stmt = null;
return $result;
}
/**
* 作用:获得最后INSERT的主鍵ID
* 返回:最后INSERT的主鍵ID
* 类型:数字
*/
public function getLastId() {
return self::$DB->lastInsertId ();
}
/**
* 作用:執行INSERT\UPDATE\DELETE
* 返回:执行語句影响行数
* 类型:数字
*/
public function execute($sql) {
self::getPDOError ( $sql );
return self::$DB->exec ( $sql );
}
/**
* 获取要操作的数据
* 返回:合併后的SQL語句
* 类型:字串
*/
private function getCode($table, $args) {
$code = '';
if (is_array ( $args )) {
foreach ( $args as $k => $v ) {
if ($v == '') {
continue;
}
$code .= "`$k`='$v',";
}
}
$code = substr ( $code, 0, - 1 );
return $code;
}
public function optimizeTable($table) {
$sql = "OPTIMIZE TABLE $table";
self::execute ( $sql );
}
/**
* 执行具体SQL操作
* 返回:运行結果
* 类型:数组
*/
private function _fetch($sql, $type) {
$result = array ();
self::$stmt = self::$DB->query ( $sql );
self::getPDOError ( $sql );
self::$stmt->setFetchMode ( PDO::FETCH_ASSOC );
switch ($type) {
case '0' :
$result = self::$stmt->fetch ();
break;
case '1' :
$result = self::$stmt->fetchAll ();
break;
case '2' :
$result = self::$stmt->rowCount ();
break;
}
self::$stmt = null;
return $result;
}
/**
* *******************基本方法結束********************
*/
/**
* *******************Sql操作方法开始********************
*/
/**
* 作用:插入数据
* 返回:表內記录
* 类型:数组
* 參数:$db->insert('$table',array('title'=>'Zxsv'))
*/
public function add($table, $args) {
$sql = "INSERT INTO `$table` SET ";
$code = self::getCode ( $table, $args );
$sql .= $code;
return self::execute ( $sql );
}
/**
* 修改数据
* 返回:記录数
* 类型:数字
* 參数:$db->update($table,array('title'=>'Zxsv'),array('id'=>'1'),$where
* ='id=3');
*/
public function update($table, $args, $where) {
$code = self::getCode ( $table, $args );
$sql = "UPDATE `$table` SET ";
$sql .= $code;
$sql .= " Where $where";
return self::execute ( $sql );
}
/**
* 作用:刪除数据
* 返回:表內記录
* 类型:数组
* 參数:$db->delete($table,$condition = null,$where ='id=3')
*/
public function delete($table, $where) {
$sql = "DELETE FROM `$table` Where $where";
return self::execute ( $sql );
}
/**
* 作用:获取單行数据
* 返回:表內第一条記录
* 类型:数组
* 參数:$db->fetOne($table,$condition = null,$field = '*',$where ='')
*/
public function fetOne($table, $field = '*', $where = false) {
$sql = "SELECT {$field} FROM `{$table}`";
$sql .= ($where) ? " WHERE $where" : '';
return self::_fetch ( $sql, $type = '0' );
}
/**
* 作用:获取所有数据
* 返回:表內記录
* 类型:二維数组
* 參数:$db->fetAll('$table',$condition = '',$field = '*',$orderby = '',$limit
* = '',$where='')
*/
public function fetAll($table, $field = '*', $orderby = false, $where = false) {
$sql = "SELECT {$field} FROM `{$table}`";
$sql .= ($where) ? " WHERE $where" : '';
$sql .= ($orderby) ? " ORDER BY $orderby" : '';
return self::_fetch ( $sql, $type = '1' );
}
/**
* 作用:获取單行数据
* 返回:表內第一条記录
* 类型:数组
* 參数:select * from table where id='1'
*/
public function getOne($sql) {
return self::_fetch ( $sql, $type = '0' );
}
/**
* 作用:获取所有数据
* 返回:表內記录
* 类型:二維数组
* 參数:select * from table
*/
public function getAll($sql) {
return self::_fetch ( $sql, $type = '1' );
}
/**
* 作用:获取首行首列数据
* 返回:首行首列欄位值
* 类型:值
* 參数:select `a` from table where id='1'
*/
public function scalar($sql, $fieldname) {
$row = self::_fetch ( $sql, $type = '0' );
return $row [$fieldname];
}
/**
* 获取記录总数
* 返回:記录数
* 类型:数字
* 參数:$db->fetRow('$table',$condition = '',$where ='');
*/
public function fetRowCount($table, $field = '*', $where = false) {
$sql = "SELECT COUNT({$field}) AS num FROM $table";
$sql .= ($where) ? " WHERE $where" : '';
return self::_fetch ( $sql, $type = '0' );
}
/**
* 获取記录总数
* 返回:記录数
* 类型:数字
* 參数:select count(*) from table
*/
public function getRowCount($sql) {
return self::_fetch ( $sql, $type = '2' );
}
/**
* *******************Sql操作方法結束********************
*/
/**
* *******************错误处理开始********************
*/
/**
* 設置是否为调试模式
*/
public function setDebugMode($mode = true) {
return ($mode == true) ? self::$debug = true : self::$debug = false;
}
/**
* 捕获PDO错误信息
* 返回:出错信息
* 类型:字串
*/
private function getPDOError($sql) {
self::$debug ? self::errorfile ( $sql ) : '';
if (self::$DB->errorCode () != '00000') {
$info = (self::$stmt) ? self::$stmt->errorInfo () : self::$DB->errorInfo ();
echo (self::sqlError ( 'mySQL Query Error', $info [2], $sql ));
exit ();
}
}
private function getSTMTError($sql) {
self::$debug ? self::errorfile ( $sql ) : '';
if (self::$stmt->errorCode () != '00000') {
$info = (self::$stmt) ? self::$stmt->errorInfo () : self::$DB->errorInfo ();
echo (self::sqlError ( 'mySQL Query Error', $info [2], $sql ));
exit ();
}
}
/**
* 寫入错误日志
*/
private function errorfile($sql) {
echo $sql . '<br />';
$errorfile = _ROOT . './dberrorlog.php';
$sql = str_replace ( array (
"\n",
"\r",
"\t",
" ",
" ",
" "
), array (
" ",
" ",
" ",
" ",
" ",
" "
), $sql );
if (! file_exists ( $errorfile )) {
$fp = file_put_contents ( $errorfile, "<?PHP exit('Access Denied'); ?>\n" . $sql );
} else {
$fp = file_put_contents ( $errorfile, "\n" . $sql, FILE_APPEND );
}
}
/**
* 作用:运行错误信息
* 返回:运行错误信息和SQL語句
* 类型:字符
*/
private function sqlError($message = '', $info = '', $sql = '') {
$html = '';
if ($message) {
$html .= $message;
}
if ($info) {
$html .= 'SQLID: ' . $info ;
}
if ($sql) {
$html .= 'ErrorSQL: ' . $sql;
}
throw new Exception($html);
}
/**
* *******************错误处理結束********************
*/
}성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
핫 AI 도구
Undresser.AI Undress
사실적인 누드 사진을 만들기 위한 AI 기반 앱
AI Clothes Remover
사진에서 옷을 제거하는 온라인 AI 도구입니다.
Undress AI Tool
무료로 이미지를 벗다
Clothoff.io
AI 옷 제거제
AI Hentai Generator
AI Hentai를 무료로 생성하십시오.
인기 기사
R.E.P.O. 에너지 결정과 그들이하는 일 (노란색 크리스탈)
3 몇 주 전By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. 최고의 그래픽 설정
3 몇 주 전By尊渡假赌尊渡假赌尊渡假赌
어 ass 신 크리드 그림자 : 조개 수수께끼 솔루션
1 몇 주 전ByDDD
R.E.P.O. 아무도들을 수없는 경우 오디오를 수정하는 방법
3 몇 주 전By尊渡假赌尊渡假赌尊渡假赌
Atomfall에서 크레인 제어 키 카드를 찾을 수 있습니다
1 몇 주 전ByDDD
뜨거운 도구
Atom Editor Mac 버전 다운로드
가장 인기 있는 오픈 소스 편집기
드림위버 CS6
시각적 웹 개발 도구
Dreamweaver Mac版
시각적 웹 개발 도구
메모장++7.3.1
사용하기 쉬운 무료 코드 편집기
MinGW - Windows용 미니멀리스트 GNU
이 프로젝트는 osdn.net/projects/mingw로 마이그레이션되는 중입니다. 계속해서 그곳에서 우리를 팔로우할 수 있습니다. MinGW: GCC(GNU Compiler Collection)의 기본 Windows 포트로, 기본 Windows 애플리케이션을 구축하기 위한 무료 배포 가능 가져오기 라이브러리 및 헤더 파일로 C99 기능을 지원하는 MSVC 런타임에 대한 확장이 포함되어 있습니다. 모든 MinGW 소프트웨어는 64비트 Windows 플랫폼에서 실행될 수 있습니다.
