php封装MySQL的数据操作的功能查询结果

admin

php封装MySQL的数据操作的功能查询结果

代码如下：

1. <?php
   
2. //封装MySQL单例
   
3. class MySQLDB {
   
4.         private $host;                //主机地址
   
5.         private $port;                //端口号
   
6.         private $user;                //用户名
   
7.         private $pwd;                //密码
   
8.         private $dbname;        //数据接名
   
9.         private $charset;        //字符集
   
10.         private $link;                //连接对象
    
11.         private static $instance;
    
12.         private function __construct($param) {
    
13.                 $this->initParam($param);
    
14.                 $this->initConnect();
    
15.         }
    
16.         private function __clone() {
    
17.                
    
18.         }
    
19.         //获取单例
    
20.         public static function getInstance($param=array()) {
    
21.                 if(!self::$instance instanceof self)
    
22.                         self::$instance=new self($param);
    
23.                 return self::$instance;
    
24.         }
    
25.         //初始化参数
    
26.         private function initParam($param) {
    
27.                 $this->host=$param['host']??'127.0.0.1';
    
28.                 $this->port=$param['port']??'3306';
    
29.                 $this->user=$param['user']??'';
    
30.                 $this->pwd=$param['pwd']??'';
    
31.                 $this->dbname=$param['dbname']??'';
    
32.                 $this->charset=$param['charset']??'utf8';
    
33.         }
    
34.         //连接数据库
    
35.         private function initConnect() {
    
36.                 $this->link=@mysqli_connect($this->host,$this->user,$this->pwd,$this->dbname);
    
37.                 if(mysqli_connect_error()){
    
38.                         echo '数据库连接失败<br>';
    
39.                         echo '错误信息：'.mysqli_connect_error(),'<br>';
    
40.                         echo '错误码：'.mysqli_connect_errno(),'<br>';
    
41.                         exit;
    
42.                 }
    
43.                 mysqli_set_charset($this->link,$this->charset);
    
44.         }
    
45.         //执行数据库的增、删、改、查
    
46.         private function execute($sql) {
    
47.                 if(!$rs=mysqli_query($this->link,$sql)){
    
48.                         echo 'SQL语句执行失败<br>';
    
49.                         echo '错误信息：'.mysqli_error($this->link),'<br>';
    
50.                         echo '错误码：'.mysqli_errno($this->link),'<br>';
    
51.                         echo '错误的SQL语句：'.$sql,'<br>';
    
52.                         exit;
    
53.                 }
    
54.                 return $rs;
    
55.         }
    
56.         /**
    
57.         *执行增、删、改
    
58.         *@return bool 成功返回true,失败返回false
    
59.         */
    
60.         public function exec($sql) {
    
61.                 $key=substr($sql,0,6);
    
62.                 if(in_array($key,array('insert','update','delete')))
    
63.                         return $this->execute($sql);
    
64.                 else{
    
65.                         echo '非法访问<br>';
    
66.                         exit;
    
67.                 }
    
68. 
    
69.         }
    
70.         //获取自动增长的编号
    
71.         public function getLastInsertId() {
    
72.                 return mysqli_insert_id($this->link);
    
73.         }
    
74. 
    
75.         //执行查询语句
    
76.         private function query($sql) {
    
77.                 if(substr($sql,0,6)=='select' || substr($sql,0,4)=='show' || substr($sql,0,4)=='desc'){
    
78.                         return $this->execute($sql);
    
79.                 }else{
    
80.                         echo '非法访问<br>';
    
81.                         exit;
    
82.                 }
    
83.         }
    
84.         /**
    
85.         *执行查询语句，返回二维数组
    
86.         *@$sql string 查询sql语句
    
87.         *@type string assoc|num|both
    
88.         */
    
89.         public function fetchAll($sql,$type='assoc') {
    
90.                 $rs=$this->query($sql);
    
91.                 $type=$this->getType($type);
    
92.                 return mysqli_fetch_all($rs,$type);
    
93.         }
    
94.         //匹配一维数组
    
95.         public function fetchRow($sql,$type='assoc') {
    
96.                 $list=$this->fetchAll($sql,$type);
    
97.                 if(!empty($list))
    
98.                         return $list[0];
    
99.                 return array();
    
100.         }
     
101.         //匹配一行一列
     
102.         public function fetchColumn($sql) {
     
103.                 $list=$this->fetchRow($sql,'num');
     
104.                 if(!empty($list))
     
105.                         return $list[0];
     
106.                 return null;
     
107.         }
     
108. 
     
109.         //获取匹配类型
     
110.         private function getType($type) {
     
111.                 switch($type){
     
112.                         case 'num':
     
113.                                 return  MYSQLI_NUM;
     
114.                         case 'both':
     
115.                                 return  MYSQLI_BOTH;
     
116.                         default:
     
117.                                 return  MYSQLI_ASSOC;
     
118.                 }
     
119.         }
     
120. }
     
121. 
     
122. //测试
     
123. //配置参数
     
124. $param=array(
     
125.         'user'                =>        'root',
     
126.         'pwd'                =>        'root',
     
127.         'dbname'        =>        'data'
     
128. );
     
129. //获取单例
     
130. $db=MySQLDB::getInstance($param);
     
131. //更新
     
132. //$db->exec("update news set title='青草' where id=2");
     
133. //插入
     
134. /*
     
135. if($db->exec("insert into news values (null,'aa','bb',unix_timestamp())"))
     
136.         echo '编号是：'.$db->getLastInsertId();
     
137. */
     
138. 
     
139. //查询
     
140. //$list=$db->fetchAll('select * from news','aa');
     
141. //$list=$db->fetchRow('select * from news where id=1','aa');
     
142. 
     
143. $list=$db->fetchColumn('select count(*) from news');
     
144. 
     
145. echo '<pre>';
     
146. var_dump($list);

复制代码