목차
PDO 데이터베이스는 기반입니다. PDO 연산 클래스(mysql)
백엔드 개발 PHP 튜토리얼 PHP 데이터베이스는 PDO 작업 클래스(mysql)를 기반으로 합니다.

PHP 데이터베이스는 PDO 작업 클래스(mysql)를 기반으로 합니다.

Apr 13, 2018 pm 05:57 PM
mysql php 데이터 베이스

이 글에서 공유하는 내용은 PHP 데이터베이스가 PDO 연산 클래스(mysql)를 기반으로 한다는 것입니다. 이제 모든 사람들과 공유합니다. 도움이 필요한 친구들은 이 글의 내용을 참고할 수 있습니다

PDO 데이터베이스는 기반입니다. PDO 연산 클래스(mysql)





온라인에서 찾은 MySQL에 대한 연산 클래스로, 초보자가 사용하기에 매우 적합합니다

PHP 데이터베이스는 PDO 작업 클래스(mysql)를 기반으로 합니다.

<?phpclass  Mysql {        protected static $_dbh = null; //静态属性,所有数据库实例共用,避免重复连接数据库
        protected $_dbType = &#39;mysql&#39;;        protected $_pconnect = true; //是否使用长连接
        protected $_host = &#39;localhost&#39;;        protected $_port = 3306;        protected $_user = &#39;root&#39;;        protected $_pass = &#39;&#39;;        protected $_dbName = null; //数据库名
        protected $_sql = false; //最后一条sql语句
        protected $_where = &#39;&#39;;        protected $_order = &#39;&#39;;        protected $_limit = &#39;&#39;;        protected $_field = &#39;*&#39;;        protected $_clear = 0; //状态,0表示查询条件干净,1表示查询条件污染
        protected $_trans = 0; //事务指令数 

        /**
         * 初始化类
         * @param array $conf 数据库配置         */
        public function __construct(array $conf) {            class_exists(&#39;PDO&#39;) or die("PDO: class not exists.");            $this->_host = $conf['host'];            $this->_port = $conf['port'];            $this->_user = $conf['user'];            $this->_pass = $conf['password'];            $this->_dbName = $conf['dbname'];            //连接数据库
            if ( is_null(self::$_dbh) ) {                $this->_connect();
            }
        }        /**
         * 连接数据库的方法         */
        protected function _connect() {            $dsn = $this->_dbType.':host='.$this->_host.';port='.$this->_port.';dbname='.$this->_dbName;            //持久化连接
            $options = $this->_pconnect ? array(PDO::ATTR_PERSISTENT=>true) : array();            try { 
                $dbh = new PDO($dsn, $this->_user, $this->_pass, $options);                $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);  //设置如果sql语句执行错误则抛出异常,事务会自动回滚
                $dbh->setAttribute(PDO::ATTR_EMULATE_PREPARES, false); //禁用prepared statements的仿真效果(防SQL注入)
            } catch (PDOException $e) { 
                die('Connection failed: ' . $e->getMessage());
            }            $dbh->exec('SET NAMES utf8');
            self::$_dbh = $dbh;
        }        /** 
        * 字段和表名添加 `符号
        * 保证指令中使用关键字不出错 针对mysql 
        * @param string $value 
        * @return string 
        */
        protected function _addChar($value) { 
            if ('*'==$value || false!==strpos($value,'(') || false!==strpos($value,'.') || false!==strpos($value,'`')) { 
                //如果包含* 或者 使用了sql方法 则不作处理 
            } elseif (false === strpos($value,'`') ) { 
                $value = '`'.trim($value).'`';
            } 
            return $value; 
        }        /** 
        * 取得数据表的字段信息 
        * @param string $tbName 表名
        * @return array 
        */
        protected function _tbFields($tbName) {            $sql = 'SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME="'.$tbName.'" AND TABLE_SCHEMA="'.$this->_dbName.'"';            $stmt = self::$_dbh->prepare($sql);            $stmt->execute();            $result = $stmt->fetchAll(PDO::FETCH_ASSOC);            $ret = array();            foreach ($result as $key=>$value) {                $ret[$value['COLUMN_NAME']] = 1;
            }            return $ret;
        }        /** 
        * 过滤并格式化数据表字段
        * @param string $tbName 数据表名 
        * @param array $data POST提交数据 
        * @return array $newdata 
        */
        protected function _dataFormat($tbName,$data) {            if (!is_array($data)) return array();            $table_column = $this->_tbFields($tbName);            $ret=array();            foreach ($data as $key=>$val) {                if (!is_scalar($val)) continue; //值不是标量则跳过
                if (array_key_exists($key,$table_column)) {                    $key = $this->_addChar($key);                    if (is_int($val)) { 
                        $val = intval($val); 
                    } elseif (is_float($val)) { 
                        $val = floatval($val); 
                    } elseif (preg_match('/^\(\w*(\+|\-|\*|\/)?\w*\)$/i', $val)) {                        // 支持在字段的值里面直接使用其它字段 ,例如 (score+1) (name) 必须包含括号
                        $val = $val;
                    } elseif (is_string($val)) { 
                        //将字符串中的单引号(')、双引号(")、反斜线(\)与 NUL(NULL 字符转义
                        $val = '"'.addslashes($val).'"';
                    }                    $ret[$key] = $val;
                }
            }            return $ret;
        }        /**
        * 执行查询 主要针对 SELECT, SHOW 等指令
        * @param string $sql sql指令 
        * @return mixed 
        */
        protected function _doQuery($sql='') {            $this->_sql = $sql;            $pdostmt = self::$_dbh->prepare($this->_sql); //prepare或者query 返回一个PDOStatement
            $pdostmt->execute();            $result = $pdostmt->fetchAll(PDO::FETCH_ASSOC);            return $result;
        }        /** 
        * 执行语句 针对 INSERT, UPDATE 以及DELETE,exec结果返回受影响的行数
        * @param string $sql sql指令 
        * @return integer 
        */
        protected function _doExec($sql='') {            $this->_sql = $sql;            return self::$_dbh->exec($this->_sql);
        }        /** 
        * 执行sql语句,自动判断进行查询或者执行操作 
        * @param string $sql SQL指令 
        * @return mixed 
        */
        public function doSql($sql='') {            $queryIps = 'INSERT|UPDATE|DELETE|REPLACE|CREATE|DROP|LOAD DATA|SELECT .* INTO|COPY|ALTER|GRANT|REVOKE|LOCK|UNLOCK'; 
            if (preg_match('/^\s*"?(' . $queryIps . ')\s+/i', $sql)) { 
                return $this->_doExec($sql);
            }            else {                //查询操作
                return $this->_doQuery($sql);
            }
        }        /** 
        * 获取最近一次查询的sql语句 
        * @return String 执行的SQL 
        */
        public function getLastSql() { 
            return $this->_sql;
        }        /**
         * 插入方法
         * @param string $tbName 操作的数据表名
         * @param array $data 字段-值的一维数组
         * @return int 受影响的行数         */
        public function insert($tbName,array $data){            $data = $this->_dataFormat($tbName,$data);            if (!$data) return;            $sql = "insert into ".$tbName."(".implode(',',array_keys($data)).") values(".implode(',',array_values($data)).")";            return $this->_doExec($sql);
        }        /**
         * 删除方法
         * @param string $tbName 操作的数据表名
         * @return int 受影响的行数         */
        public function delete($tbName) {            //安全考虑,阻止全表删除
            if (!trim($this->_where)) return false;            $sql = "delete from ".$tbName." ".$this->_where;            $this->_clear = 1;            $this->_clear();            return $this->_doExec($sql);
        }        /**
         * 更新函数
         * @param string $tbName 操作的数据表名
         * @param array $data 参数数组
         * @return int 受影响的行数         */
        public function update($tbName,array $data) {            //安全考虑,阻止全表更新
            if (!trim($this->_where)) return false;            $data = $this->_dataFormat($tbName,$data);            if (!$data) return;            $valArr = '';            foreach($data as $k=>$v){                $valArr[] = $k.'='.$v;
            }            $valStr = implode(',', $valArr);            $sql = "update ".trim($tbName)." set ".trim($valStr)." ".trim($this->_where);            return $this->_doExec($sql);
        }        /**
         * 查询函数
         * @param string $tbName 操作的数据表名
         * @return array 结果集         */
        public function select($tbName='') {            $sql = "select ".trim($this->_field)." from ".$tbName." ".trim($this->_where)." ".trim($this->_order)." ".trim($this->_limit);            //echo $sql;
            $this->_clear = 1;            $this->_clear();            return $this->_doQuery(trim($sql));
        }        /**
         * @param mixed $option 组合条件的二维数组,例:$option['field1'] = array(1,'=>','or')
         * @return $this         */
        public function where($option) {            if ($this->_clear>0) $this->_clear();            $this->_where = ' where ';            $logic = 'and';            if (is_string($option)) {                $this->_where .= $option;
            }            elseif (is_array($option)) {                foreach($option as $k=>$v) {                    if (is_array($v)) {                        $relative = isset($v[1]) ? $v[1] : '=';                        $logic    = isset($v[2]) ? $v[2] : 'and';                        $condition = ' ('.$this->_addChar($k).' '.$relative.' '.$v[0].') ';
                    }                    else {                        $logic = 'and';                        $condition = ' ('.$this->_addChar($k).'='.$v.') ';
                    }                    $this->_where .= isset($mark) ? $logic.$condition : $condition;                    $mark = 1;
                }
            }            return $this;
        }        /**
         * 设置排序
         * @param mixed $option 排序条件数组 例:array('sort'=>'desc')
         * @return $this         */
        public function order($option) {            if ($this->_clear>0) $this->_clear();            $this->_order = ' order by ';            if (is_string($option)) {                $this->_order .= $option;
            }            elseif (is_array($option)) {                foreach($option as $k=>$v){                    $order = $this->_addChar($k).' '.$v;                    $this->_order .= isset($mark) ? ','.$order : $order;                    $mark = 1;
                }
            }            return $this;
        }        /**
         * 设置查询行数及页数
         * @param int $page pageSize不为空时为页数,否则为行数
         * @param int $pageSize 为空则函数设定取出行数,不为空则设定取出行数及页数
         * @return $this         */
        public function limit($page,$pageSize=null) {            if ($this->_clear>0) $this->_clear();            if ($pageSize===null) {                $this->_limit = "limit ".$page;
            }            else {                $pageval = intval( ($page - 1) * $pageSize);                $this->_limit = "limit ".$pageval.",".$pageSize;
            }            return $this;
        }        /**
         * 设置查询字段
         * @param mixed $field 字段数组
         * @return $this         */
        public function field($field){            if ($this->_clear>0) $this->_clear();            if (is_string($field)) {                $field = explode(',', $field);
            }            $nField = array_map(array($this,'_addChar'), $field);            $this->_field = implode(',', $nField);            return $this;
        }        /**
         * 清理标记函数         */
        protected function _clear() {            $this->_where = '';            $this->_order = '';            $this->_limit = '';            $this->_field = '*';            $this->_clear = 0;
        }        /**
         * 手动清理标记
         * @return $this         */
        public function clearKey() {            $this->_clear();            return $this;
        }        /**
        * 启动事务 
        * @return void 
        */
        public function startTrans() { 
            //数据rollback 支持 
            if ($this->_trans==0) self::$_dbh->beginTransaction();            $this->_trans++; 
            return; 
        }        /** 
        * 用于非自动提交状态下面的查询提交 
        * @return boolen 
        */
        public function commit() {            $result = true;            if ($this->_trans>0) { 
                $result = self::$_dbh->commit(); 
                $this->_trans = 0;
            } 
            return $result;
        }        /** 
        * 事务回滚 
        * @return boolen 
        */
        public function rollback() {            $result = true;            if ($this->_trans>0) {                $result = self::$_dbh->rollback();                $this->_trans = 0;
            }            return $result;
        }        /**
        * 关闭连接
        * PHP 在脚本结束时会自动关闭连接。        */
        public function close() {            if (!is_null(self::$_dbh)) self::$_dbh = null;
        }

}
로그인 후 복사

관련 권장 사항:

PHP 데이터베이스 저장 세션 세션

php 데이터베이스 비교 도구 공유

php 데이터베이스 작업 기록

위 내용은 PHP 데이터베이스는 PDO 작업 클래스(mysql)를 기반으로 합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.

핫 AI 도구

Undresser.AI Undress

Undresser.AI Undress

사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover

AI Clothes Remover

사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool

Undress AI Tool

무료로 이미지를 벗다

Clothoff.io

Clothoff.io

AI 옷 제거제

AI Hentai Generator

AI Hentai Generator

AI Hentai를 무료로 생성하십시오.

인기 기사

R.E.P.O. 에너지 결정과 그들이하는 일 (노란색 크리스탈)
1 몇 달 전 By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. 최고의 그래픽 설정
1 몇 달 전 By 尊渡假赌尊渡假赌尊渡假赌
Will R.E.P.O. 크로스 플레이가 있습니까?
1 몇 달 전 By 尊渡假赌尊渡假赌尊渡假赌

뜨거운 도구

메모장++7.3.1

메모장++7.3.1

사용하기 쉬운 무료 코드 편집기

SublimeText3 중국어 버전

SublimeText3 중국어 버전

중국어 버전, 사용하기 매우 쉽습니다.

스튜디오 13.0.1 보내기

스튜디오 13.0.1 보내기

강력한 PHP 통합 개발 환경

드림위버 CS6

드림위버 CS6

시각적 웹 개발 도구

SublimeText3 Mac 버전

SublimeText3 Mac 버전

신 수준의 코드 편집 소프트웨어(SublimeText3)

MySQL : 세계에서 가장 인기있는 데이터베이스 소개 MySQL : 세계에서 가장 인기있는 데이터베이스 소개 Apr 12, 2025 am 12:18 AM

MySQL은 오픈 소스 관계형 데이터베이스 관리 시스템으로, 주로 데이터를 신속하고 안정적으로 저장하고 검색하는 데 사용됩니다. 작업 원칙에는 클라이언트 요청, 쿼리 해상도, 쿼리 실행 및 반환 결과가 포함됩니다. 사용의 예로는 테이블 작성, 데이터 삽입 및 쿼리 및 조인 작업과 같은 고급 기능이 포함됩니다. 일반적인 오류에는 SQL 구문, 데이터 유형 및 권한이 포함되며 최적화 제안에는 인덱스 사용, 최적화 된 쿼리 및 테이블 분할이 포함됩니다.

PHP 및 Python : 두 가지 인기있는 프로그래밍 언어를 비교합니다 PHP 및 Python : 두 가지 인기있는 프로그래밍 언어를 비교합니다 Apr 14, 2025 am 12:13 AM

PHP와 Python은 각각 고유 한 장점이 있으며 프로젝트 요구 사항에 따라 선택합니다. 1.PHP는 웹 개발, 특히 웹 사이트의 빠른 개발 및 유지 보수에 적합합니다. 2. Python은 간결한 구문을 가진 데이터 과학, 기계 학습 및 인공 지능에 적합하며 초보자에게 적합합니다.

PHP의 현재 상태 : 웹 개발 동향을 살펴보십시오 PHP의 현재 상태 : 웹 개발 동향을 살펴보십시오 Apr 13, 2025 am 12:20 AM

PHP는 현대 웹 개발, 특히 컨텐츠 관리 및 전자 상거래 플랫폼에서 중요합니다. 1) PHP는 Laravel 및 Symfony와 같은 풍부한 생태계와 강력한 프레임 워크 지원을 가지고 있습니다. 2) Opcache 및 Nginx를 통해 성능 최적화를 달성 할 수 있습니다. 3) PHP8.0은 성능을 향상시키기 위해 JIT 컴파일러를 소개합니다. 4) 클라우드 네이티브 애플리케이션은 Docker 및 Kubernetes를 통해 배포되어 유연성과 확장 성을 향상시킵니다.

MySQL을 사용하는 이유는 무엇입니까? 혜택과 장점 MySQL을 사용하는 이유는 무엇입니까? 혜택과 장점 Apr 12, 2025 am 12:17 AM

MySQL은 성능, 신뢰성, 사용 편의성 및 커뮤니티 지원을 위해 선택됩니다. 1.MYSQL은 효율적인 데이터 저장 및 검색 기능을 제공하여 여러 데이터 유형 및 고급 쿼리 작업을 지원합니다. 2. 고객-서버 아키텍처 및 다중 스토리지 엔진을 채택하여 트랜잭션 및 쿼리 최적화를 지원합니다. 3. 사용하기 쉽고 다양한 운영 체제 및 프로그래밍 언어를 지원합니다. 4. 강력한 지역 사회 지원을 받고 풍부한 자원과 솔루션을 제공합니다.

PHP : 많은 웹 사이트의 기초 PHP : 많은 웹 사이트의 기초 Apr 13, 2025 am 12:07 AM

PHP가 많은 웹 사이트에서 선호되는 기술 스택 인 이유에는 사용 편의성, 강력한 커뮤니티 지원 및 광범위한 사용이 포함됩니다. 1) 배우고 사용하기 쉽고 초보자에게 적합합니다. 2) 거대한 개발자 커뮤니티와 풍부한 자원이 있습니다. 3) WordPress, Drupal 및 기타 플랫폼에서 널리 사용됩니다. 4) 웹 서버와 밀접하게 통합하여 개발 배포를 단순화합니다.

MySQL의 장소 : 데이터베이스 및 프로그래밍 MySQL의 장소 : 데이터베이스 및 프로그래밍 Apr 13, 2025 am 12:18 AM

데이터베이스 및 프로그래밍에서 MySQL의 위치는 매우 중요합니다. 다양한 응용 프로그램 시나리오에서 널리 사용되는 오픈 소스 관계형 데이터베이스 관리 시스템입니다. 1) MySQL은 웹, 모바일 및 엔터프라이즈 레벨 시스템을 지원하는 효율적인 데이터 저장, 조직 및 검색 기능을 제공합니다. 2) 클라이언트 서버 아키텍처를 사용하고 여러 스토리지 엔진 및 인덱스 최적화를 지원합니다. 3) 기본 사용에는 테이블 작성 및 데이터 삽입이 포함되며 고급 사용에는 다중 테이블 조인 및 복잡한 쿼리가 포함됩니다. 4) SQL 구문 오류 및 성능 문제와 같은 자주 묻는 질문은 설명 명령 및 느린 쿼리 로그를 통해 디버깅 할 수 있습니다. 5) 성능 최적화 방법에는 인덱스의 합리적인 사용, 최적화 된 쿼리 및 캐시 사용이 포함됩니다. 모범 사례에는 거래 사용 및 준비된 체계가 포함됩니다

PHP : 웹 개발의 핵심 언어 PHP : 웹 개발의 핵심 언어 Apr 13, 2025 am 12:08 AM

PHP는 서버 측에서 널리 사용되는 스크립팅 언어이며 특히 웹 개발에 적합합니다. 1.PHP는 HTML을 포함하고 HTTP 요청 및 응답을 처리 할 수 ​​있으며 다양한 데이터베이스를 지원할 수 있습니다. 2.PHP는 강력한 커뮤니티 지원 및 오픈 소스 리소스를 통해 동적 웹 컨텐츠, 프로세스 양식 데이터, 액세스 데이터베이스 등을 생성하는 데 사용됩니다. 3. PHP는 해석 된 언어이며, 실행 프로세스에는 어휘 분석, 문법 분석, 편집 및 실행이 포함됩니다. 4. PHP는 사용자 등록 시스템과 같은 고급 응용 프로그램을 위해 MySQL과 결합 할 수 있습니다. 5. PHP를 디버깅 할 때 error_reporting () 및 var_dump ()와 같은 함수를 사용할 수 있습니다. 6. 캐싱 메커니즘을 사용하여 PHP 코드를 최적화하고 데이터베이스 쿼리를 최적화하며 내장 기능을 사용하십시오. 7

PHP vs. Python : 핵심 기능 및 기능 PHP vs. Python : 핵심 기능 및 기능 Apr 13, 2025 am 12:16 AM

PHP와 Python은 각각 고유 한 장점이 있으며 다양한 시나리오에 적합합니다. 1.PHP는 웹 개발에 적합하며 내장 웹 서버 및 풍부한 기능 라이브러리를 제공합니다. 2. Python은 간결한 구문과 강력한 표준 라이브러리가있는 데이터 과학 및 기계 학습에 적합합니다. 선택할 때 프로젝트 요구 사항에 따라 결정해야합니다.

See all articles