当前位置：Gxlcms > PHP教程 > php操作mysql的类

php操作mysql的类

时间：2021-07-01 10:21:17 帮助过：7人阅读

[PHP]代码

  1. class mysql {
  2. private $db_host; //数据库主机
  3. private $db_user; //数据库用户名
  4. private $db_pwd; //数据库用户名密码
  5. private $db_database; //数据库名
  6. private $conn; //数据库连接标识;
  7. private $result; //执行query命令的结果资源标识
  8. private $sql; //sql执行语句
  9. private $row; //返回的条目数
  10. private $coding; //数据库编码，GBK,UTF8,gb2312
  11. private $bulletin = true; //是否开启错误记录
  12. private $show_error = false; //测试阶段，显示所有错误,具有安全隐患,默认关闭
  13. private $is_error = false; //发现错误是否立即终止,默认true,建议不启用，因为当有问题时用户什么也看不到是很苦恼的
  15. /*构造函数*/
  16. public function __construct($db_host, $db_user, $db_pwd, $db_database, $conn, $coding) {
  17. $this->db_host = $db_host;
  18. $this->db_user = $db_user;
  19. $this->db_pwd = $db_pwd;
  20. $this->db_database = $db_database;
  21. $this->conn = $conn;
  22. $this->coding = $coding;
  23. $this->connect();
  24. }
  26. /*数据库连接*/
  27. public function connect() {
  28. if ($this->conn == "pconn") {
  29. //永久链接
  30. $this->conn = mysql_pconnect($this->db_host, $this->db_user, $this->db_pwd);
  31. } else {
  32. //即使链接
  33. $this->conn = mysql_connect($this->db_host, $this->db_user, $this->db_pwd);
  34. }
  36. if (!mysql_select_db($this->db_database, $this->conn)) {
  37. if ($this->show_error) {
  38. $this->show_error("数据库不可用：", $this->db_database);
  39. }
  40. }
  41. mysql_query("SET NAMES $this->coding");
  42. }
  44. /*数据库执行语句，可执行查询添加修改删除等任何sql语句*/
  45. public function query($sql) {
  46. if ($sql == "") {
  47. $this->show_error("SQL语句错误：", "SQL查询语句为空");
  48. }
  49. $this->sql = $sql;
  51. $result = mysql_query($this->sql, $this->conn);
  53. if (!$result) {
  54. //调试中使用，sql语句出错时会自动打印出来
  55. if ($this->show_error) {
  56. $this->show_error("错误SQL语句：", $this->sql);
  57. }
  58. } else {
  59. $this->result = $result;
  60. }
  61. return $this->result;
  62. }
  64. /*创建添加新的数据库*/
  65. public function create_database($database_name) {
  66. $database = $database_name;
  67. $sqlDatabase = 'create database ' . $database;
  68. $this->query($sqlDatabase);
  69. }
  71. /*查询服务器所有数据库*/
  72. //将系统数据库与用户数据库分开，更直观的显示？
  73. public function show_databases() {
  74. $this->query("show databases");
  75. echo "现有数据库：" . $amount = $this->db_num_rows($rs);
  76. echo "
    ";
  77. $i = 1;
  78. while ($row = $this->fetch_array($rs)) {
  79. echo "$i $row[Database]";
  80. echo "
    ";
  81. $i++;
  82. }
  83. }
  85. //以数组形式返回主机中所有数据库名
  86. public function databases() {
  87. $rsPtr = mysql_list_dbs($this->conn);
  88. $i = 0;
  89. $cnt = mysql_num_rows($rsPtr);
  90. while ($i < $cnt) {
  91. $rs[] = mysql_db_name($rsPtr, $i);
  92. $i++;
  93. }
  94. return $rs;
  95. }
  97. /*查询数据库下所有的表*/
  98. public function show_tables($database_name) {
  99. $this->query("show tables");
  100. echo "现有数据库：" . $amount = $this->db_num_rows($rs);
  101. echo "
    ";
  102. $i = 1;
  103. while ($row = $this->fetch_array($rs)) {
  104. $columnName = "Tables_in_" . $database_name;
  105. echo "$i $row[$columnName]";
  106. echo "
    ";
  107. $i++;
  108. }
  109. }
  111. /*
  112. mysql_fetch_row() array $row[0],$row[1],$row[2]
  113. mysql_fetch_array() array $row[0] 或 $row[id]
  114. mysql_fetch_assoc() array 用$row->content 字段大小写敏感
  115. mysql_fetch_object() object 用$row[id],$row[content] 字段大小写敏感
  116. */
  118. /*取得结果数据*/
  119. public function mysql_result_li() {
  120. return mysql_result($str);
  121. }
  123. /*取得记录集,获取数组-索引和关联,使用$row['content'] */
  124. public function fetch_array($resultt="") {
  125. if($resultt<>""){
  126. return mysql_fetch_array($resultt);
  127. }else{
  128. return mysql_fetch_array($this->result);
  129. }
  130. }
  132. //获取关联数组,使用$row['字段名']
  133. public function fetch_assoc() {
  134. return mysql_fetch_assoc($this->result);
  135. }
  137. //获取数字索引数组,使用$row[0],$row[1],$row[2]
  138. public function fetch_row() {
  139. return mysql_fetch_row($this->result);
  140. }
  142. //获取对象数组,使用$row->content
  143. public function fetch_Object() {
  144. return mysql_fetch_object($this->result);
  145. }
  147. //简化查询select
  148. public function findall($table) {
  149. $this->query("SELECT * FROM $table");
  150. }
  152. //简化查询select
  153. public function select($table, $columnName = "*", $condition = '', $debug = '') {
  154. $condition = $condition ? ' Where ' . $condition : NULL;
  155. if ($debug) {
  156. echo "SELECT $columnName FROM $table $condition";
  157. } else {
  158. $this->query("SELECT $columnName FROM $table $condition");
  159. }
  160. }
  162. //简化删除del
  163. public function delete($table, $condition, $url = '') {
  164. if ($this->query("DELETE FROM $table WHERE $condition")) {
  165. if (!empty ($url))
  166. $this->Get_admin_msg($url, '删除成功！');
  167. }
  168. }
  170. //简化插入insert
  171. public function insert($table, $columnName, $value, $url = '') {
  172. if ($this->query("INSERT INTO $table ($columnName) VALUES ($value)")) {
  173. if (!empty ($url))
  174. $this->Get_admin_msg($url, '添加成功！');
  175. }
  176. }
  178. //简化修改update
  179. public function update($table, $mod_content, $condition, $url = '') {
  180. //echo "UPDATE $table SET $mod_content WHERE $condition"; exit();
  181. if ($this->query("UPDATE $table SET $mod_content WHERE $condition")) {
  182. if (!empty ($url))
  183. $this->Get_admin_msg($url);
  184. }
  185. }
  187. /*取得上一步 INSERT 操作产生的 ID*/
  188. public function insert_id() {
  189. return mysql_insert_id();
  190. }
  192. //指向确定的一条数据记录
  193. public function db_data_seek($id) {
  194. if ($id > 0) {
  195. $id = $id -1;
  196. }
  197. if (!@ mysql_data_seek($this->result, $id)) {
  198. $this->show_error("SQL语句有误：", "指定的数据为空");
  199. }
  200. return $this->result;
  201. }
  203. // 根据select查询结果计算结果集条数
  204. public function db_num_rows() {
  205. if ($this->result == null) {
  206. if ($this->show_error) {
  207. $this->show_error("SQL语句错误", "暂时为空，没有任何内容！");
  208. }
  209. } else {
  210. return mysql_num_rows($this->result);
  211. }
  212. }
  214. // 根据insert,update,delete执行结果取得影响行数
  215. public function db_affected_rows() {
  216. return mysql_affected_rows();
  217. }
  219. //输出显示sql语句
  220. public function show_error($message = "", $sql = "") {
  221. if (!$sql) {
  222. echo "" . $message . "";
  223. echo "
    ";
  224. } else {
  225. echo "
    ";
  226. echo "错误信息提示:
    ";
  227. echo "";
  228. echo "";
  229. echo "错误号：12142";
  230. echo "
    ";
  231. echo "错误原因：" . mysql_error() . "

    ";
  232. echo "";
  233. echo "" . $message . "";
  234. echo "";
  235. echo "
    " . $sql . "
    ";
  236. $ip = $this->getip();
  237. if ($this->bulletin) {
  238. $time = date("Y-m-d H:i:s");
  239. $message = $message . "\r\n$this->sql" . "\r\n客户IP:$ip" . "\r\n时间 :$time" . "\r\n\r\n";
  241. $server_date = date("Y-m-d");
  242. $filename = $server_date . ".txt";
  243. $file_path = "error/" . $filename;
  244. $error_content = $message;
  245. //$error_content="错误的数据库，不可以链接";
  246. $file = "error"; //设置文件保存目录
  248. //建立文件夹
  249. if (!file_exists($file)) {
  250. if (!mkdir($file, 0777)) {
  251. //默认的 mode 是 0777，意味着最大可能的访问权
  252. die("upload files directory does not exist and creation failed");
  253. }
  254. }
  256. //建立txt日期文件
  257. if (!file_exists($file_path)) {
  259. //echo "建立日期文件";
  260. fopen($file_path, "w+");
  262. //首先要确定文件存在并且可写
  263. if (is_writable($file_path)) {
  264. //使用添加模式打开$filename，文件指针将会在文件的开头
  265. if (!$handle = fopen($file_path, 'a')) {
  266. echo "不能打开文件 $filename";
  267. exit;
  268. }
  270. //将$somecontent写入到我们打开的文件中。
  271. if (!fwrite($handle, $error_content)) {
  272. echo "不能写入到文件 $filename";
  273. exit;
  274. }
  276. //echo "文件 $filename 写入成功";
  278. echo "——错误记录被保存!";
  280. //关闭文件
  281. fclose($handle);
  282. } else {
  283. echo "文件 $filename 不可写";
  284. }
  286. } else {
  287. //首先要确定文件存在并且可写
  288. if (is_writable($file_path)) {
  289. //使用添加模式打开$filename，文件指针将会在文件的开头
  290. if (!$handle = fopen($file_path, 'a')) {
  291. echo "不能打开文件 $filename";
  292. exit;
  293. }
  295. //将$somecontent写入到我们打开的文件中。
  296. if (!fwrite($handle, $error_content)) {
  297. echo "不能写入到文件 $filename";
  298. exit;
  299. }
  301. //echo "文件 $filename 写入成功";
  302. echo "——错误记录被保存!";
  304. //关闭文件
  305. fclose($handle);
  306. } else {
  307. echo "文件 $filename 不可写";
  308. }
  309. }
  311. }
  312. echo "
    ";
  313. if ($this->is_error) {
  314. exit;
  315. }
  316. }
  317. echo "";
  318. echo "
    319. ";
  320. echo "
    ";
  321. }
  323. //释放结果集
  324. public function free() {
  325. @ mysql_free_result($this->result);
  326. }
  328. //数据库选择
  329. public function select_db($db_database) {
  330. return mysql_select_db($db_database);
  331. }
  333. //查询字段数量
  334. public function num_fields($table_name) {
  335. //return mysql_num_fields($this->result);
  336. $this->query("select * from $table_name");
  337. echo "
    ";
  338. echo "字段数：" . $total = mysql_num_fields($this->result);
  339. echo "
    ";
  340.         for ($i = 0; $i < $total; $i++) {
  341.             print_r(mysql_fetch_field($this->result, $i));
  342.         }
  343.         echo "
    344. ";
  344. echo "
    ";
  345. }
  347. //取得 MySQL 服务器信息
  348. public function mysql_server($num = '') {
  349. switch ($num) {
  350. case 1 :
  351. return mysql_get_server_info(); //MySQL 服务器信息
  352. break;
  354. case 2 :
  355. return mysql_get_host_info(); //取得 MySQL 主机信息
  356. break;
  358. case 3 :
  359. return mysql_get_client_info(); //取得 MySQL 客户端信息
  360. break;
  362. case 4 :
  363. return mysql_get_proto_info(); //取得 MySQL 协议信息
  364. break;
  366. default :
  367. return mysql_get_client_info(); //默认取得mysql版本信息
  368. }
  369. }
  371. //析构函数，自动关闭数据库,垃圾回收机制
  372. public function __destruct() {
  373. if (!empty ($this->result)) {
  374. $this->free();
  375. }
  376. mysql_close($this->conn);
  377. } //function __destruct();
  379. /*获得客户端真实的IP地址*/
  380. function getip() {
  381. if (getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown")) {
  382. $ip = getenv("HTTP_CLIENT_IP");
  383. } else
  384. if (getenv("HTTP_X_FORWARDED_FOR") &&strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown")) {
  385. $ip = getenv("HTTP_X_FORWARDED_FOR");
  386. } else
  387. if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown")) {
  388. $ip = getenv("REMOTE_ADDR");
  389. } else
  390. if (isset ($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] &&strcasecmp($_SERVER['REMOTE_ADDR'], "unknown")) {
  391. $ip = $_SERVER['REMOTE_ADDR'];
  392. } else {
  393. $ip = "unknown";
  394. }
  395. return ($ip);
  396. }
  397. function inject_check($sql_str) { //防止注入
  398. $check =eregi('select|insert|update|delete|\'|\/\*|\*|\.\.\/|\.\/|union|into|load_file|outfile',$sql_str);
  399. if ($check) {
  400. echo "输入非法注入内容！";
  401. exit ();
  402. } else {
  403. return $sql_str;
  404. }
  405. }
  406. function checkurl() { //检查来路
  407. if (preg_replace("/https?:\/\/([^\:\/]+).*/i", "\\1", $_SERVER['HTTP_REFERER']) !== preg_replace("/([^\:]+).*/", "\\1", $_SERVER['HTTP_HOST'])) {
  408. header("Location: http://www.dareng.com");
  409. exit();
  410. }
  411. }
  413. }
  414. ?>
php, mysql

人气教程排行

本站所有资源全部来源于网络，若本站发布的内容侵害到您的隐私或者利益，请联系我们删除！