-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathpdo.php
More file actions
89 lines (82 loc) · 2.1 KB
/
pdo.php
File metadata and controls
89 lines (82 loc) · 2.1 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
<?php
/* (C)2006-2021 FoundPHP Framework.
* name: Database Object
* weburl: http://www.FoundPHP.com
* mail: master@FoundPHP.com
* author: 孟大川
* version: v3.201212
* start: 2013-05-24
* update: 2021-02-23
* payment: Free 免费
* This is not a freeware, use is subject to license terms.
* 此软件为授权使用软件,请参考软件协议。
* http://www.foundphp.com/?m=agreement
*/
Class Dirver_pdo{
var $Lists = '';
var $nums = 0;
//连接数据库
function DBLink($dba=''){
try {
$this->LinkID = @new PDO($dba['type'].':dbname='.$dba['dbname'].' host='.$dba['dbhost'].($dba['dbport']!=''?':'.$dba['dbport']:''), $dba['dbuser'], $dba['dbpass']);
$this->charset = $dba['charset'];
$this->LinkID->exec($this->charset); //设置编码
$this->set_names= 0;
return $this->LinkID;
ignore_user_abort();
}catch (PDOException $e){
return 2;
}
}
//查询语句
function query($query,$limit='') {
//检测如果有限制数据集则处理
if($limit>0){
$query = $query.' LIMIT '.$limit;
}
//时间处理
if (@stristr($query, "now()") !== FALSE){
$query = preg_replace("/(.*)\'now\(\)\'(.*)/is","\\1now()\\2",$query);
}
return array('query'=>mysqli_query($this->LinkID,$query),'sql'=>$query);
}
//返回数组资料
function fetch_array($query) {
if ($query){
return $query->fetch_array(MYSQLI_ASSOC);
}
return false;
}
//取得返回列的数目
function num_rows($query){
if ($query){
return mysqli_num_rows($query);
}
return false;
}
//返回最后一次使用 INSERT 指令的 ID
function insert_id(){
return mysqli_insert_id($this->LinkID);
}
//创建数据库
function create_db($dbname){
mysqli_query($this->LinkID,"CREATE DATABASE ".$dbname);
}
//列出数据库
function show_db(){
$query = mysqli_query($this->LinkID,"SHOW DATABASES ");
while($r = $this->fetch_array($query)){
$result[] = $r['Database'];
}
return $result;
}
//关闭当前数据库连接
function close(){
return @mysqli_close($this->LinkID);
}
//检测mysql版本
function version(){
return @mysqli_get_server_info($this->LinkID);
}
}
?>