PHP는 PDO를 사용하여 데이터베이스 클래스를 운영합니다. (Mysql에 적용 가능)

/*** 작성자: Hu Rui * 날짜: 2012/07/21 * 이메일: hooray0905@foxmail.com */ class HRDB{ protected $ pdo; 보호된 $res; 보호된 $config;

/*构造函数*/ function __construct($config){ $this- >Config = $config; $this->connect(); }

/*数据库连接*/ 공용 함수 connect(){ $this->pdo = new PDO($this->Config['dsn'], $this->Config['name'], $this->Config['password']); $this->pdo->query('set names utf8;'); //把结果序列化成stdClass //$this->pdo->setAttribute(PDO: :ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ); //自己写代码捕获Exception $this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); } /*数据库关闭*/ 공용 함수 close(){ $this->pdo = null; }

&lt ;p>공용 함수 쿼리($sql){ $res = $this->pdo->query($sql); if($res){ $this->res = $res; } } 공용 함수 exec($sql){ $res = $this->pdo->exec($sql); if($ res){ $this->res = $res; } } 공용 함수 fetchAll(){ return $this->res->fetchAll(); } 공용 함수 fetch(){ return $this->res->fetch(); } 공용 함수 fetchColumn(){ return $this- >res->fetchColumn(); } 공용 함수 lastInsertId(){ return $this->res->lastInsertId(); }

/** * 매개변수 설명 * int $debug 디버깅 활성화 여부, 활성화하면 sql 문이 출력됩니다. * 0 비활성화 * 1 활성화 * 2 활성화 및 종료 프로그램 * int $ 모드 반환 유형 * 0 여러 레코드 반환 * 1 단일 레코드 반환 * 2 행 수 반환 * 문자열/배열 $table 데이터베이스 테이블, 2 값 전달 모드 * 일반 패턴: * 'tb_member, tb_money' * 배열 패턴: * array('tb_member', 'tb_money') * 문자열/배열 $fields 쿼리할 데이터베이스 필드, 비워둘 수 있음, 기본값은 모두 검색, 두 가지 값 전달 모드 * 일반 모드: * '사용자 이름, 비밀번호' * 배열 모드: * array('username', 'password') * string/array $sqlwhere 쿼리 조건, 비어 있음 허용, 두 가지 값 전달 모드 * 일반 모드: * 'and type = 1 및 사용자 이름 like " %os%"' * 배열 모드 : * array('type = 1', 'username like "%os%"') * string $orderby 정렬, 기본값은 id 역순입니다 */ 공개 함수 선택($debug, $mode, $table, $fields="*", $sqlwhere="", $orderby="tbid desc" ){ //参数处리 if(is_array($table)){ $table = implode(', ', $table); } if(is_array($fields) )){ $fields = implode(', ', $fields); } if(is_array($sqlwhere)){ $sqlwhere = ' 및 '.implode(' 및 ' , $sqlwhere); } //数据库操작 if($debug === 0){ if($mode === 2){ $this-> query("1=1 $sqlwhere에서 $table에서 개수(tbid) 선택"); $return = $this->fetchColumn(); }else if($mode === 1){ $this->query("select $fields from $table where 1=1 $sqlwhere order by $orderby"); $return = $this->fetch(); }else { $this->query("select $fields from $table where 1=1 $sqlwhere order by $orderby"); $return = $this->fetchAll(); } return $return; }else{ if($mode === 2){ echo "1=1인 $sqlwhere에서 $table에서 개수(tbid) 선택"; }else if($mode === 1){ echo "$table에서 $fields 선택, 여기서 1=1 $sqlwhere order by $orderby"; } else{ echo "select 1=1인 $table의 $필드 $sqlwhere order by $orderby"; } if($debug === 2){ exit; } } }

/** * 매개변수 설명 * int $debug 디버깅 활성화 여부, 활성화하면 sql 문이 출력됩니다. * 0 비활성화 * 1 활성화 * 2 활성화 및 종료 프로그램 * int $ 모드 반환 유형 * 0 반환 정보 없음 * 1 실행 항목 수를 반환 * 2 마지막으로 삽입된 레코드의 ID를 반환 * 문자열/배열 $ 테이블 데이터베이스 테이블, 두 가지 값 전달 모드 * 일반 모드: * 'tb_member, tb_money' * 어레이 모드: * array('tb_member', 'tb_money') * 문자열/배열 $set 필드를 삽입하고 콘텐츠, 두 가지 값 전달 모드 * 일반 모드: * 'username = "test", type = 1, dt = now()' * Array 모드: * array('username = "test"', 'type = 1', 'dt = now()') */ 공용 함수 삽입($debug, $mode, $table, $set){ //参数处理 if(is_array($table)){ $table = implode(', ', $table); } if(is_array($set)){ $set = implode( ', ', $set); } //数据库操작 if($debug === 0){ if($mode === 2){ $this->query("insert into $table set $ set"); $return = $this->lastInsertId(); }else if($mode === 1){ $this->exec("$table 세트에 삽입 $set"); $return = $this->res; }else{ $this->query("$table set $set에 삽입"); $return = NULL; } return $return; }else{ echo "$table set $set에 삽입"; if($debug === 2){ 종료; } } }

/** * 매개변수 설명 * int $debug 디버깅 활성화 여부, 활성화하면 sql 문이 출력됩니다. * 0 비활성화 * 1 활성화 * 2 활성화 및 종료 프로그램 * int $ 모드 반환 유형 * 0 반환 정보 없음 * 1 실행 항목 수 반환 * 문자열 $table 데이터베이스 테이블, 두 가지 값 전달 모드 * 일반 모드: * 'tb_member, tb_money' * 배열 모드: * array('tb_member', 'tb_money') * string/array $set 업데이트가 필요한 필드 및 내용, 값 2개 -통과 모드 * 일반 모드: * 'username = "test", type = 1, dt = now()' * 배열 모드: * array('username = "test" ', 'type = 1', 'dt = now()') * 문자열/배열 $sqlwhere 조건 수정, 비어 있음, 두 가지 값 전달 모드 허용 * 일반 모드: * 'and type = 1 및 사용자 이름 like "%os% "' * 배열 모드: * array('type = 1', 'username like "%os%"') */ 공개 함수 업데이트($debug, $mode, $table, $set, $sqlwhere=""){ //参数处理 if(is_array($table)){ $table = implode(', ', $table); } if(is_array($set)){ $set = implode(', ', $set); } if(is_array($sqlwhere)){ $sqlwhere = ' and '.implode(' and ', $sqlwhere); } //数据库操작 if($debug === 0){ if($mode === 1){ $this->exec("update $table set $set where 1=1 $sqlwhere"); $return = $this->res; }else{ $this ->query("update $table set $set where 1=1 $sqlwhere"); $return = NULL; } return $return; }else{ echo "update $table set $set where 1=1 $sqlwhere"; if($debug === 2){ exit; } } }

/** * 매개변수 설명 * int $debug 디버깅 활성화 여부, 활성화하면 sql 문이 출력됩니다. * 0 비활성화 * 1 활성화 * 2 활성화 및 종료 프로그램 * int $ 모드 반환 유형 * 0 반환 정보 없음 * 1 실행 항목 개수 반환 * 문자열 $table 데이터베이스 테이블 * 문자열/배열 $sqlwhere 삭제 조건, 비어 있음 허용, 두 가지 값 전달 모드 * 일반 모드: * 'and type = 1 및 사용자 이름은 "%os%"''와 같습니다 * 배열 모드: * array('type = 1' , '사용자 이름은 "%os %"와 같습니다') */ 공용 함수 delete($debug, $mode, $table, $sqlwhere=""){ //参数处理 if( is_array($sqlwhere)){ $sqlwhere = ' and '.implode(' and ', $sqlwhere); } //数据库操작 if($debug === 0) { if($mode === 1){ $this->exec("1=1 $sqlwhere인 $table에서 삭제"); $return = $this->res ; }else{ $this->query("1=1 $sqlwhere인 $table에서 삭제"); $return = NULL; } return $return; }else{ echo "1=1인 $sqlwhere에서 삭제"; if($debug === 2){ exit; } } } }

复代码 其实使用上 ， 와 之前的差不大，目的就是为了方便移植. 本次中写着 中处理了几个问题： ① insert语句太复杂, fields与values对应容易流现误差 看下最常见的一句sql插入语句

tb_member(사용자 이름, 유형, dt) 값('test', 1, now())에 삽입 复제代码 传统模式下，fieldsandvalues参数是分开传入的，但却要保证两者参数传入的顺序一致。这很容易导致顺序错乱或者漏传某个参数. 这次已经把问题修改了，采用了mysql独有的삽입법，同样是上面那功能，就可以换成这样的写法

insert into tb_member set username = "test", type = 1, lastlogindt = now() 复제代码 就imageupdate一样，一目了然。

② PART分参数可以用数组代替 SQL에 대한 정보:

1=1, tbid = 1, 사용자 이름 = "만세"인 tb_member에서 삭제 复主代码 여기에는 条件, 这样操작동성있는 成本很高,现在完全可以用这种式이 있습니다.

$where = array( 'tbid = 1', 'username = "만세"' ); $db->delete(1, 0, 'tb_member', $where); 코드 복사 아무리 많은 조건이 있어도 생각을 방해하지 않습니다. 마찬가지로 where 매개변수뿐만 아니라 업데이트의 세트도 이 형식일 수 있습니다(자세한 내용은 전체 소스 코드 참조).

$set = array('username = "123"', 'type = 1', 'lastlogindt = now() '); $where = array('tbid = 1'); $db->update(1, 0, 'tb_member', $set, $where); 코드 복사 ③ 사용자 정의 가능한 SQL 문 때로는 sql이 너무 복잡해서 클래스에서 제공하는 메소드를 사용하여 sql 문을 조립하는 것이 불가능할 때도 있는데, 이때 제가 조립한 sql 문을 직접 전달하여 실행하고 정보를 반환하는 함수가 필요합니다. 이제 이 기능도 사용할 수 있습니다.

$db->query('tb_member에서 사용자 이름, 비밀번호 선택'); $rs = $db ->fetchAll(); 코드 복사 pdo의 원래 작성 방법과 많이 비슷하죠?

④ 다중 데이터베이스 연결 생성 지원 원래 방법은 단순한 데이터베이스 조작 방법이기 때문에 다중 데이터베이스 연결을 지원하지 않습니다. 구현 시 두 개의 동일한 파일을 복사하고 일부 변수를 수정해야 하는데 이는 정말 복잡합니다. 이제 이 문제가 해결되었습니다.

$db_hoorayos_config = array( 'dsn'=>'mysql:host =localhost;dbname=hoorayos', 'name'=>'root', 'password'=>'만세' ); $db = new HRDB($db_hoorayos_config) ;

$db_hoorayos_config2 = array( 'dsn'=>'mysql:host=localhost;dbname=hoorayos2', 'name'=>'root ', 'password'=>'만세' ); $db2 = new HRDB($db_hoorayos_config2);

복사 코드 이렇게 하면 동시에 2개의 데이터베이스 연결을 생성할 수 있으므로 데이터베이스 간 상호 작용을 더 쉽게 처리할 수 있습니다.

테스트 코드(호출 예):

require_once('global.php'); require_once('inc/setting .inc.php');

$db = new HRDB($db_hoorayos_config);

echo ' '; echo '일반 모드, 문자열을 직접 전달 '; $rs = $db->select(1, 0, 'tb_member ', '사용자 이름, 비밀번호', '그리고 유형 = 1이고 사용자 이름은 "%os%"'와 같습니다'); echo ' 배열 모드에서는 배열로 전달할 수 있습니다 '; $fields = array('username', 'password'); $where = array('type = 1', 'username like "%os%"'); $rs = $db-&gt ; select(1, 0, 'tb_member', $fields, $where);

echo ' insert test ;' ; echo '일반 모드, 문자열을 직접 전달 '; $db->insert(1, 0, 'tb_member', 'username = "test", type = 1 , lastlogindt = now()'); echo ' 배열 모드에서는 배열을 전달할 수 있습니다 '; $set = array('username = "test"', 'type = 1' , 'lastlogindt = now()'); $db->insert(1, 0, 'tb_member', $set);

echo ' 업데이트 테스트 '; echo '일반 모드, 문자열을 직접 전달 '; $db->update(1, 0, 'tb_member ', 'username = "123", type = 1, lastlogindt = now()', 'and tbid = 7'); echo ' 배열 모드에서는 배열을 전달할 수 있습니다 ; $set = array('username = "123"', 'type = 1', 'lastlogindt = now()'); $where = array('tbid = 1') $db->update(1, 0, 'tb_member', $set, $where);

echo ' 삭제 테스트&lt ;/b> '; echo '일반 모드, 문자열을 직접 전달 '; $db->delete(1, 0, 'tb_member', 'and tbid = 1 및 사용자 이름 = "만세"'); echo ' 배열 모드에서는 배열을 전달할 수 있습니다 '; $where = array( 'tbid = 1', ' 사용자 이름 = "만세"' ); $db->delete(1, 0, 'tb_member', $where);

echo ' 사용자 정의 SQL '; $db->query('tb_member에서 사용자 이름, 비밀번호 선택'); $rs = $db ->fetchAll( ); var_dump($rs);

$db->close(); ?>

코드 복사