经常使用php操作mysql时，大量输入mysql语句是比较麻烦的
所以可以使用封装的api进行操作mysql，能够提高效率，避免出错
MySqlHelper类
|
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 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 |
<?php define('DB_HOST', 'localhost'); define('DB_USER', 'root'); define('DB_PWD', ''); define('DB_CHARSET', 'UTF8'); define('DB_DBNAME', 'incircle'); class MySqlHelper{ /** * 连接MYSQL函数 * 连接MYSQL函数,通过常量的形式来连接数据库 * 自定义配置文件，配置文件中自定义常量，包含需要使用的信息 * @return resource */ function connect (){ //连接mysql $link=@mysql_connect(DB_HOST,DB_USER,DB_PWD) or die ('数据库连接失败<br/>ERROR '.mysql_errno().':'.mysql_error()); //设置字符集 mysql_set_charset(DB_CHARSET); //打开指定的数据库 mysql_select_db(DB_DBNAME) or die('指定的数据库打开失败'); return $link; } /** * 插入记录的操作 * @param array $array * @param string $table * @return boolean */ function insert($array,$table){ $keys=join(',',array_keys($array)); $values="'".join("','", array_values($array))."'"; $sql="insert {$table}({$keys}) VALUES ({$values})"; $res=mysql_query($sql); if($res){ return mysql_insert_id(); }else{ return false; } } /** * MYSQL更新操作 * @param array $array * @param string $table * @param string $where * @return number|boolean */ function update($array,$table,$where=null){ foreach ($array as $key=>$val){ $sets=$key."='".$val."',"; } $sets=rtrim($sets,','); //去掉SQL里的最后一个逗号 $where=$where==null?'':' WHERE '.$where; $sql="UPDATE {$table} SET {$sets} {$where}"; $res=mysql_query($sql); if ($res){ return mysql_affected_rows(); }else { return false; } } /** * 删除记录的操作 * @param string $table * @param string $where * @return number|boolean */ function delete($table,$where=null){ $where=$where==null?'':' WHERE '.$where; $sql="DELETE FROM {$table}{$where}"; $res=mysql_query($sql); if ($res){ return mysql_affected_rows(); }else { return false; } } /** * 查询一条记录 * @param string $sql * @param string $result_type * @return boolean */ function fetchOne($sql,$result_type=MYSQL_ASSOC){ $result=mysql_query($sql); if ($result && mysql_num_rows($result)>0){ return mysql_fetch_array($result,$result_type); }else { return false; } } /** * 得到表中的所有记录 * @param string $sql * @param string $result_type * @return boolean */ function fetchAll($sql,$result_type=MYSQL_ASSOC){ $result=mysql_query($sql); if ($result && mysql_num_rows($result)>0){ while ($row=mysql_fetch_array($result,$result_type)){ $rows[]=$row; } return $rows; }else { return false; } } /**取得结果集中的记录的条数 * @param string $sql * @return number|boolean */ function getTotalRows($sql){ $result=mysql_query($sql); if($result){ return mysql_num_rows($result); }else { return false; } } /**释放结果集 * @param resource $result * @return boolean */ function freeResult($result){ return mysql_free_result($result); } /**断开MYSQL * @param resource $link * @return boolean */ function close($link=null){ return mysql_close($link); } /**得到客户端的信息 * @return string */ function getClientInfo(){ return mysql_get_client_info(); } /**得到MYSQL服务器端的信息 * @return string */ function getServerInfo($link=null){ return mysql_get_server_info($link); } /**得到主机的信息 * @return string */ function getHostInfo($link=null){ return mysql_get_host_info($link); } /**得到协议信息 * @return string */ function getProtoInfo($link=null){ return mysql_get_proto_info($link); } } ?> |
操作测试脚本：
|
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 |
<?php require_once 'MySqlHelper.php'; $db = new MySqlHelper(); // 连接数据库 $link = $db->connect(); // 表名称 $table = "rank"; // 删除所有数据 $db->delete($table); // 插入数据 $array1 = array( "name"=>"wangchong1", "score"=>100 ); $db->insert($array1, $table); // 插入数据 $array2 = array( "name"=>"wangchong2", "score"=>200 ); $db->insert($array2, $table); // 插入数据 $array3 = array( "name"=>"wangchong3", "score"=>300 ); $db->insert($array3, $table); // 删除指定数据 $db->delete($table, "score=200"); // 查找并根据score倒序排序所有数据 $sql="SELECT * FROM {$table} ORDER BY score DESC"; $rows = $db->fetchAll($sql); print_r($rows); // 关闭数据库连接 $db->close($link); ?> |
- 本文固定链接: http://www.u3d8.com/?p=1606
- 转载请注明: 网虫虫 在 u3d8.com 发表过
