一步步编写PHP的Framework(十七)
由于模型中D这一部分是比较基础的,所以我们先把D这一部分做了。
D中最重要的是驱动类的编写,所以我们就先写驱动类,由于在驱动类中需要用到日志,所以我们先做一个简单的Logger类,这个类只有一个log的静态方法,如果debug开启,那么直接在浏览器上面输出信息,否则记录到日志中。
01 |
02 | class Logger extends Base { |
03 | public static function log($param) { |
04 | if(is_object($param)) { |
05 | if(true === C('debug')) { |
06 | throw $param; |
07 | } else { |
08 | file_put_contents(APP_PATH . '/log',$param,FILE_APPEND); |
09 | } |
10 | } elseif(is_string($param)) { |
11 | if(true === C('debug')) { |
12 | echo $param; |
13 | } else { |
14 | file_put_contents(APP_PATH . '/log',$param,FILE_APPEND); |
15 | } |
16 | } else {} |
17 | } |
18 | } |
现在假设通过Logger::log传递的参数是对象,则代表是抛出了异常,如果是字符串,那么则可能是程序需要输出的警告或者Error信息,如果是其他类型,则不处理。
出于简化代码的目的,所以整个类代码非常少,只是判定了一下是否debug开启了,如果开启,则记录到日志,否则,直接打印出来。
如果你们对这个有兴趣,可以自己尝试做一个功能强大的日志系统,我这儿就不说了啊。。。
日志类写完之后,马上就开始编写驱动类吧,在写驱动类之前,我们还是按照上一次讲的将契约编写了,契约代码如下:
01 |
02 | interface IDbDriver { |
03 | function execute($sql); |
04 | function connect(); |
05 | function close(); |
06 | function getAllByObject(); |
07 | function getAllByAssoArray(); |
08 | function getAllByArray(); |
09 | function beginTrans(); |
10 | function commit(); |
11 | function rollback(); |
12 | } |
因为马上我将用PDO来做驱动类,为了让大家能够习惯PDO这种预处理,还有就是简化这个接口,因为我写这个的时间有限,所以将这个契约修改成为如下:
01 |
02 | interface IDbDriver { |
03 | function prepare($sql); |
04 | function execute(Array $arr); |
05 | function connect(); |
06 | function close(); |
07 | function getAllByAssocArray(); |
08 | function beginTrans(); |
09 | function commit(); |
10 | function rollback(); |
11 | } |
如果你学过Java的JDBC,你会对PDO这种方式非常习惯,当然,如果你习惯使用mysql_*这种接口,那么你可能需要转变观点了,当然,你如果还是要用msyql_*这种来做驱动类,那么不好意思,你要自己做prepare了,因为mysql_*没有提供这种机制。
然后我们就是编写PDO的驱动类,代码如下:
01 |
02 | class PdoDriver extends Base implements IDbDriver { |
03 | private $_db = null; |
04 | private $_pstmt = null; |
05 | public function __construct() { |
06 | $this->connect(); |
07 | } |
08 | public function connect() { |
09 | try { |
10 | $this->_db = newPDO(C('db=>dsn'),C('db=>user'),C('db=>pwd'),array(PDO::MYSQL_ATTR_INIT_COMMAND=>'SET NAMES "UTF8";')); |
11 | if(null !== $this->_db) { |
12 | Logger::log('[Notice]connect success!'); |
13 | } else { |
14 | Logger::log('[Error]:connect failed'); |
15 | } |
16 | } catch(PDOException $e) { |
17 | Logger::log( $e); |
18 | } |
19 | } |
20 | public function close() { |
21 | if(null !== $this->_db) { |
22 | unset($this->_db); |
23 | } |
24 | } |
25 | public function prepare($sql) { |
26 | if(null !== $this->_pstmt) { |
27 | $this->_pstmt = null; |
28 | } |
29 | $this->_pstmt = $this->_db->prepare($sql); |
30 | } |
31 | public function execute(Array $arr) { |
32 | if(null === $this->_pstmt) { |
33 | Logger::log('[Error]not prepared statement'); |
34 | } else { |
35 | if(false === $this->_pstmt->execute($arr)) { |
36 | Logger::log('[Error]sql error,error info is : ' . $this->_ptstmt->errorInfo()); |
37 | } else { |
38 | Logger::log('[Notice]:execute success'); |
39 | } |
40 | } |
41 | } |
42 | public function getAllByAssocArray() { |
43 | return $this->_pstmt->fetchAll(PDO::FETCH_ASSOC); |
44 | } |
45 | public function beginTrans() { |
46 | $this->_db->beginTransaction(); |
47 | } |
48 | public function commit() { |
49 | $this->_db->commit(); |
50 | } |
51 | public function rollback() { |
52 | $this->_db->rollback(); |
53 | } |
54 | } |
首先,当实例化这个类的时候,它就自动连接DB,也就是调用connect方法。
PDO连接DB是使用了DSN这种方式,当然,如果你还是习惯普通的使用数组搞定,那么你可能需要编写一些额外的代码,我这儿就不说了啊,我就直接使用DSN这种方式来做了。
大家看到的
1 | C('db=>dsn'),C('db=>user'),C('db=>pwd') |
这个我之前讲过,实际上读取的是配置文件中的内容,配置文件的内容如下:
01 |
02 | return array( |
03 | 'defaultController' => 'Index', |
04 | 'defaultAction' => 'index', |
05 | 'debug' => true, |
06 | 'errorReporting' => -1, |
07 | 'timeZone' => 'PRC', |
08 | 'db' => array( |
09 | 'dsn' => 'mysql:dbname=test;host=localhost', |
10 | 'user' => 'test', |
11 | 'pwd' => 'test', |
12 |
13 | ) |
14 | ); |
C函数负责将这个文件的配置项读取出来,非常方便,熟悉Thinkphp的童鞋可能对这个也很熟悉 !!
PDO::MYSQL_ATTR_INIT_COMMAND=>'SET NAMES "UTF8";'这一句是有问题的,这句话是解决的mysql的中文乱码问题,由于PDO实际上提供的是统一的接口,本来我是需要判定数据库是那种类型,如果是mysql然后才使用这句话,但是为了简便,我就直接这么搞了,你们只要清楚这样是不行的就OK!!!
实际上刚才这句话还有一个问题,这里我完全将编码方式写死了,必须是utf-8,但是实际上如果我们写在配置文件中更好!!
由于下面这几个函数都是调用了PDO自己的接口,所以我就不怎么具体讲了,具体的内容可参照PHP手册的PDO这一部分。
刚才这个PDO的驱动类只能完成mysql的操作,如果换成其他数据库,可能存在一定问题,就比如PDO::MYSQL_ATTR_INIT_COMMAND=>'SET NAMES "UTF8";',实际上我们也可以不修改这段代码,而针对其他数据库做一个适配器,具体的你可以网上百度一下。
写完驱动类之后,我们需要测试一下,我们在控制器中来测一下:
01 |
02 | class TestController extends Controller { |
03 | public function test() { |
04 | $test = new PdoDriver(); |
05 | $test->prepare('select * from test where id > :id'); |
06 | $test->execute(array( |
07 | 'id' => '2' |
08 | )); |
09 | var_dump($test->getAllByAssocArray()); |
10 | } |
11 | } |
注意:在模型这一块儿写完之后,就不能直接这么调用了,因为外部控制器直接能访问的部分是E,E调用C和F的内容,C又调用D的内容。
刚才我们说了怎么用PDO来实现驱动类,如果针对mysql,也可以使用mysql_*或者mysqli,我这儿稍微说一下mysql_*,实际上对于mysql_*,实现上面的接口也没有什么难度,也就是调用mysql_*这种接口而已,在prepare这一块儿可能需要你们自己好好想想该怎么做,其实最简单的方式就可以在执行execute的时候使用:
str_replace(array_keys($arr),array_values($arr),$sql);
$sql是调用prepare传递进去的字符串,$arr是execute传递的数组,但是注意,这里的数组的key需要处理一下,因为prepare时SQL参数占位符是如:id这种形式,而execute传递进来的直接入'id' => 2这种形式,所以首先需要将数组每个key添加字符:,然后给每个value进行字符串转义,然后再执行str_replace。
当然,我这种方式是最弱的方式,你可以自己用其他方式实现。
还有一个可能大家不太会的,就是mysql_*怎么处理Mysql事务呢,实际上非常简单,如果大家用过mysql的终端,就会熟悉mysql中有这样几条命令:begin,commit,rollback,所以,我们可以使用mysql_query来执行一条命令,如mysql_query('begin',$this->_db),这样就开启了一个事务,实际上这些接口都是按照mysql的功能来做的,所以,mysql支持的这些接口才支持,mysql不支持的,这些接口也搞不定了。

핫 AI 도구

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

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

Undress AI Tool
무료로 이미지를 벗다

Clothoff.io
AI 옷 제거제

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

인기 기사

뜨거운 도구

메모장++7.3.1
사용하기 쉬운 무료 코드 편집기

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

스튜디오 13.0.1 보내기
강력한 PHP 통합 개발 환경

드림위버 CS6
시각적 웹 개발 도구

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

뜨거운 주제











MySQL은 설치가 간단하고 강력하며 데이터를 쉽게 관리하기 쉽기 때문에 초보자에게 적합합니다. 1. 다양한 운영 체제에 적합한 간단한 설치 및 구성. 2. 데이터베이스 및 테이블 작성, 삽입, 쿼리, 업데이트 및 삭제와 같은 기본 작업을 지원합니다. 3. 조인 작업 및 하위 쿼리와 같은 고급 기능을 제공합니다. 4. 인덱싱, 쿼리 최적화 및 테이블 파티셔닝을 통해 성능을 향상시킬 수 있습니다. 5. 데이터 보안 및 일관성을 보장하기위한 지원 백업, 복구 및 보안 조치.

Navicat Premium을 사용하여 데이터베이스 생성 : 데이터베이스 서버에 연결하고 연결 매개 변수를 입력하십시오. 서버를 마우스 오른쪽 버튼으로 클릭하고 데이터베이스 생성을 선택하십시오. 새 데이터베이스의 이름과 지정된 문자 세트 및 Collation의 이름을 입력하십시오. 새 데이터베이스에 연결하고 객체 브라우저에서 테이블을 만듭니다. 테이블을 마우스 오른쪽 버튼으로 클릭하고 데이터 삽입을 선택하여 데이터를 삽입하십시오.

Navicat 자체는 데이터베이스 비밀번호를 저장하지 않으며 암호화 된 암호 만 검색 할 수 있습니다. 솔루션 : 1. 비밀번호 관리자를 확인하십시오. 2. Navicat의 "비밀번호 기억"기능을 확인하십시오. 3. 데이터베이스 비밀번호를 재설정합니다. 4. 데이터베이스 관리자에게 문의하십시오.

MySQL은 오픈 소스 관계형 데이터베이스 관리 시스템입니다. 1) 데이터베이스 및 테이블 작성 : CreateAbase 및 CreateTable 명령을 사용하십시오. 2) 기본 작업 : 삽입, 업데이트, 삭제 및 선택. 3) 고급 운영 : 가입, 하위 쿼리 및 거래 처리. 4) 디버깅 기술 : 확인, 데이터 유형 및 권한을 확인하십시오. 5) 최적화 제안 : 인덱스 사용, 선택을 피하고 거래를 사용하십시오.

MariaDB 용 Navicat은 암호가 암호화 된 양식으로 저장되므로 데이터베이스 비밀번호를 직접 볼 수 없습니다. 데이터베이스 보안을 보장하려면 비밀번호를 재설정하는 세 가지 방법이 있습니다. Navicat을 통해 비밀번호를 재설정하고 복잡한 비밀번호를 설정하십시오. 구성 파일을 봅니다 (권장되지 않음, 위험이 높음). 시스템 명령 줄 도구를 사용하십시오 (권장되지 않으면 명령 줄 도구에 능숙해야 함).

MySQL 및 SQL은 개발자에게 필수적인 기술입니다. 1.MySQL은 오픈 소스 관계형 데이터베이스 관리 시스템이며 SQL은 데이터베이스를 관리하고 작동하는 데 사용되는 표준 언어입니다. 2.MYSQL은 효율적인 데이터 저장 및 검색 기능을 통해 여러 스토리지 엔진을 지원하며 SQL은 간단한 문을 통해 복잡한 데이터 작업을 완료합니다. 3. 사용의 예에는 기본 쿼리 및 조건 별 필터링 및 정렬과 같은 고급 쿼리가 포함됩니다. 4. 일반적인 오류에는 구문 오류 및 성능 문제가 포함되며 SQL 문을 확인하고 설명 명령을 사용하여 최적화 할 수 있습니다. 5. 성능 최적화 기술에는 인덱스 사용, 전체 테이블 스캔 피하기, 조인 작업 최적화 및 코드 가독성 향상이 포함됩니다.

응용 프로그램을 열고 새로운 연결 (Ctrl n)을 선택하여 Navicat에서 새로운 MySQL 연결을 만들 수 있습니다. "MySQL"을 연결 유형으로 선택하십시오. 호스트 이름/IP 주소, 포트, 사용자 이름 및 비밀번호를 입력하십시오. (선택 사항) 고급 옵션을 구성합니다. 연결을 저장하고 연결 이름을 입력하십시오.

Navicat에서 SQL을 수행하는 단계 : 데이터베이스에 연결하십시오. SQL 편집기 창을 만듭니다. SQL 쿼리 또는 스크립트를 작성하십시오. 실행 버튼을 클릭하여 쿼리 또는 스크립트를 실행하십시오. 결과를 봅니다 (쿼리가 실행 된 경우).
