PDO数据库初始化连接数据库文件代码（附源码下载）

PDO数据库初始化文件代码（附源码下载）

1. <?php
   
2. class MyPDO{
   
3.     private $type;      //数据库类别
   
4.     private $host;      //主机地址
   
5.     private $port;      //端口号
   
6.     private $dbname;    //数据库名
   
7.     private $charset;   //字符集
   
8.     private $user;      //用户名
   
9.     private $pwd;       //密码
   
10.     private $pdo;       //保存PDO对象
    
11.     private static $instance;
    
12.     private function __construct($param) {
    
13.         $this->initParam($param);
    
14.         $this->initPDO();
    
15.         $this->initException();
    
16.     }
    
17.     private function __clone() {
    
18.     }
    
19.     public static function getInstance($param=array()){
    
20.         if(!self::$instance instanceof self)
    
21.             self::$instance=new self($param);
    
22.         return self::$instance;
    
23.     }
    
24.     //初始化参数
    
25.     private function initParam($param){
    
26.         $this->type=$param['type']??'mysql';
    
27.         $this->host=$param['host']??'127.0.0.1';
    
28.         $this->port=$param['port']??'3306';
    
29.         $this->dbname=$param['dbname']??'data';
    
30.         $this->charset=$param['charset']??'utf8';
    
31.         $this->user=$param['user']??'root';
    
32.         $this->pwd=$param['pwd']??'root';
    
33.     }
    
34.     //初始化PDO
    
35.     private function initPDO(){
    
36.         try{
    
37.             $dsn="{$this->type}:host={$this->host};port={$this->port};dbname={$this->dbname};charset={$this->charset}";
    
38.             $this->pdo=new PDO($dsn, $this->user, $this->pwd);
    
39.         } catch (PDOException $ex) {
    
40.             $this->showException($ex);
    
41.             exit;
    
42.         }
    
43.     }
    
44.    
    
45.     //显示异常
    
46.     private function showException($ex,$sql=''){
    
47.         if($sql!=''){
    
48.             echo 'SQL语句执行失败<br>';
    
49.             echo '错误的SQL语句是：'.$sql,'<br>';
    
50.         }
    
51.         echo '错误编号：'.$ex->getCode(),'<br>';
    
52.         echo '错误行号：'.$ex->getLine(),'<br>';
    
53.         echo '错误文件：'.$ex->getFile(),'<br>';
    
54.         echo '错误信息：'.$ex->getMessage(),'<br>';
    
55.     }
    
56.     //设置异常模式
    
57.     private function initException(){
    
58.         $this->pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
    
59.     }
    
60. 
    
61.     //执行增、删、改操作
    
62.     public function exec($sql){
    
63.         try{
    
64.             return $this->pdo->exec($sql);
    
65.         } catch (PDOException $ex) {
    
66.             $this->showException($ex, $sql);
    
67.             exit;
    
68.         }
    
69.     }
    
70.     //获取自动增长的编号
    
71.     public function lastInsertId(){
    
72.         return $this->pdo->lastInsertId();
    
73.     }
    
74.    
    
75.     //判断匹配的类型
    
76.     private function fetchType($type){
    
77.         switch ($type){
    
78.             case 'num':
    
79.                 return PDO::FETCH_NUM;
    
80.             case 'both':
    
81.                 return PDO::FETCH_BOTH;
    
82.             case 'obj':
    
83.                 return PDO::FETCH_OBJ;
    
84.             default:
    
85.                  return PDO::FETCH_ASSOC;
    
86.         }
    
87.     }
    
88.     //获取所有数据 ，返回二维数组
    
89.     public function fetchAll($sql,$type='assoc'){
    
90.         try{
    
91.             $stmt=$this->pdo->query($sql);  //获取PDOStatement对象
    
92.             $type= $this->fetchType($type); //获取匹配方法
    
93.             return $stmt->fetchAll($type);
    
94.         } catch (Exception $ex) {
    
95.             $this->showException($ex, $sql);
    
96.         }
    
97.     }
    
98.     //获取一维数组
    
99.     public function fetchRow($sql,$type='assoc'){
    
100.         try{
     
101.             $stmt=$this->pdo->query($sql);  //获取PDOStatement对象
     
102.             $type= $this->fetchType($type); //获取匹配方法
     
103.             return $stmt->fetch($type);
     
104.         } catch (Exception $ex) {
     
105.             $this->showException($ex, $sql);
     
106.             exit;
     
107.         }
     
108.     }
     
109.     //返回一行一列
     
110.     public function fetchColumn($sql){
     
111.         try{
     
112.              $stmt=$this->pdo->query($sql);
     
113.             return $stmt->fetchColumn();
     
114.         } catch (Exception $ex) {
     
115.             $this->showException($ex, $sql);
     
116.             exit;
     
117.         }
     
118.         
     
119.     }
     
120.    
     
121. }
     
122. 
     

复制代码

源码下载：
MyPDO.class.zip (1.35 KB, 下载次数: 568)

2020-11-16 16:08 上传

点击文件名下载附件
PDO数据库初始化文件代码（附源码下载）