当前位置：Gxlcms > PHP教程 > 使用单例模式实现mysql类

使用单例模式实现mysql类

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

  3. defined('ACC')||exit('Access Denied');
  4. // 封装mysql操作类,包括连接功能,及查询功能.
  5. class mysql extends absdb{
  6. protected static $ins = null;
  7. protected $host; // 主机名
  8. protected $user; // 用户名
  9. protected $passwd; // 密码
  10. protected $db; // 数据库名
  11. protected $port; // 端口
  12. protected $conn = null;
  13. // 在内部操作,获得一个对象
  14. public static function getIns() {
  15. if(self::$ins === null) {
  16. self::$ins = new self();
  17. }
  18. $conf = conf::getIns();
  19. self::$ins->host = $conf->host;
  20. self::$ins->user = $conf->user;
  21. self::$ins->passwd = $conf->pwd;
  22. self::$ins->db = $conf->db;
  23. self::$ins->port = $conf->port;
  24. self::$ins->connect();
  25. self::$ins->select_db();
  26. self::$ins->setChar();
  27. return self::$ins;
  28. }
  29. // 不让外部做new操作,
  30. protected function __construct() {
  32. }
  33. // 连接数据库
  34. public function connect() {
  35. $this->conn = @mysql_connect($this->host,$this->user,$this->passwd,$this->port);
  36. if(!$this->conn) {
  37. $error = new Exception('数据库连不上',9);
  38. throw $error;
  39. }
  40. }
  41. // 发送sql查询
  42. public function query($sql) {
  43. $rs = mysql_query($sql,$this->conn);
  44. if(!$rs) {
  45. log::write($sql);
  46. }
  47. return $rs;
  48. }
  49. // 封装一个getAll方法
  50. // 参数:$sql
  51. // 返回: array,false
  52. public function getAll($sql) {
  53. $rs = $this->query($sql);
  54. if(!$rs) {
  55. return false;
  56. }
  57. $list = array();
  58. while($row = mysql_fetch_assoc($rs)) {
  59. $list[] = $row;
  60. }
  61. return $list;
  63. }
  64. // 封装一个getRow方法
  65. // 参数:$sql
  66. // 返回: array,false
  67. public function getRow($sql) {
  68. $rs = $this->query($sql);
  69. if(!$rs) {
  70. return false;
  71. }
  72. return mysql_fetch_assoc($rs);
  73. }
  74. // 封装一个getOne方法,
  75. // 参数: $sql
  76. // 返回: int,str(单一的值)
  77. public function getOne($sql) {
  78. $rs = $this->query($sql);
  79. if(!$rs) {
  80. return false;
  81. }
  82. $tmp = mysql_fetch_row($rs);
  83. return $tmp[0];
  84. }
  85. // 封装一个afftect_rows()方法
  86. // 参数:无
  87. // 返回 int 受影响行数
  88. public function affected_rows() {
  89. return mysql_affected_rows($this->conn);
  90. }
  91. // 返回最新生成的auto_increment列的值
  92. public function last_id() {
  93. return mysql_insert_id($this->conn);
  94. }
  95. // 选库函数
  96. public function select_db() {
  97. $sql = 'use ' . $this->db;
  98. return $this->query($sql);
  99. }
  100. // 设置字符集的函数
  101. public function setChar() {
  102. $sql = 'set names utf8';
  103. return $this->query($sql);
  104. }
  105. // 自动生成insert语句,update语句并执行
  106. public function autoExecute($data,$table,$act='insert',$where='') {
  108. if($act == 'insert') {
  109. $sql = 'insert into ' . $table . ' (';
  110. $sql .= implode(',',(array_keys($data)));
  111. $sql .= ') values (\'';
  112. $sql .= implode("','",array_values($data));
  113. $sql .= "')";
  114. } else if($act == 'update') {
  115. if(!trim($where)) {
  116. return false;
  117. }
  119. $sql = 'update ' . $table . ' set ';
  120. foreach($data as $k=>$v) {
  121. $sql .= $k;
  122. $sql .= '=';
  123. $sql .= "'".$v."',";
  124. }
  126. $sql = substr($sql,0,-1);
  127. $sql .= ' where ';
  128. $sql .= $where;
  129. } else {
  130. return false;
  131. }
  132. //return $sql;
  133. return $this->query($sql);
  135. }
  136. }

mysql

人气教程排行

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