recherche

Maison >développement back-end >tutoriel php >一个数据库操作PHP类

一个数据库操作PHP类

WBOY
WBOYoriginal
2016-07-25 08:44:271046parcourir
  1. /*
  2. * Author 墨龙
  3. * Time 2010年12月2日 15:50:35
  4. */
  6. $db = new mysql($db_host,$db_user,$db_password,$db_table,$db_conn,$pre,$coding);
  8. class mysql{
  10. private $db_host;
  11. private $db_user;
  12. private $db_password;
  13. private $db_table;
  14. private $db_conn; //数据库连接标识;
  15. private $result; //执行query命令的结果资源标识
  16. private $sql; //sql执行语句
  17. private $pre; //数据库表前缀
  18. private $coding; //数据库编码，GBK,UTF8,gb2312
  20. function __construct($db_host,$db_user,$db_password,$db_table,$db_conn,$pre,$coding){
  22. $this->db_host = $db_host;
  23. $this->db_user = $db_user;
  24. $this->db_password = $db_password;
  25. $this->db_table = $db_table;
  26. $this->db_conn = $db_conn;
  27. $this->pre = $pre;
  28. $this->coding = $coding;
  29. $this->connect();
  31. }
  33. function connect(){
  35. $this->db_conn = @mysql_connect($this->db_host,$this->db_user,$this->db_password) or die($this->show_error("数据库链接错误,请检查数据库链接配置！"));
  36. if(!mysql_select_db($this->db_table,$this->db_conn)){
  38. echo "没有找到数据表：".$this->db_table;
  39. }
  40. mysql_select_db($this->db_table,$this->db_conn);
  41. $this->query("SET NAMES $this->coding");
  42. }
  44. /*执行SQL语句的函数*/
  45. function query($sql){
  47. if(emptyempty($sql)){
  48. $this->show_error("你的sql语句不能为空！");
  49. }else{
  50. $this->sql = $sql;
  51. }
  52. $result = mysql_query($this->sql,$this->db_conn);
  54. return $this->result = $result;
  55. }
  57. /*创建添加新的数据库*/
  58. public function create_database($database_name){
  59. $database=$database_name;
  60. $sqlDatabase = 'create database '.$database;
  61. return $this->query($sqlDatabase);
  62. }
  64. // 根据select查询结果计算结果集条数
  65. public function db_num_rows(){
  66. if($this->result==null){
  67. if($this->show_error){
  68. $this->show_error("sql语句错误!");
  69. }
  70. }else{
  71. return mysql_num_rows($this->result);
  72. }
  73. }
  75. /*查询服务器所有数据库*/
  76. //将系统数据库与用户数据库分开，更直观的显示？
  77. public function show_databases(){
  78. $this->query("show databases");
  79. echo "现有数据库：".$amount =$this->db_num_rows($rs);
  80. echo "
    ";
  81. $i=1;
  82. while($row = $this->fetch_array($rs)){
  83. echo "$i $row[Database]";
  84. echo "
    ";
  85. $i++;
  86. }
  87. }
  89. //以数组形式返回主机中所有数据库名
  90. public function databases()
  91. {
  92. $rsPtr=mysql_list_dbs($this->db_conn);
  93. $i=0;
  94. $cnt=mysql_num_rows($rsPtr);
  95. while($i {
  96. $rs[]=mysql_db_name($rsPtr,$i);
  97. $i++;
  98. }
  99. return print_r($rs);
  100. }
  102. /*查询数据库下所有的表*/
  103. function show_tables($database_name){
  104. $this->query("show tables");
  105. echo "现有数据库：".$amount = $this->db_num_rows($rs);
  106. echo "
    ";
  107. $i=1;
  108. while($row = $this->fetch_array($rs)){
  109. $columnName="Tables_in_".$database_name;
  110. echo "$i $row[$columnName]";
  111. echo "
    ";
  112. $i++;
  113. }
  114. }
  116. /*
  117. mysql_fetch_row() array $row[0],$row[1],$row[2]
  118. mysql_fetch_array() array $row[0] 或 $row[id]
  119. mysql_fetch_assoc() array 用$row->content 字段大小写敏感
  120. mysql_fetch_object() object 用$row[id],$row[content] 字段大小写敏感
  121. */
  122. /*取得记录集,获取数组-索引和关联,使用$row['content'] */
  123. public function fetch_array()
  124. {
  125. return @mysql_fetch_array($this->result);
  126. }
  128. //获取关联数组,使用$row['字段名']
  129. public function fetch_ass()
  130. {
  131. return @mysql_fetch_assoc($this->result);
  132. }
  134. //获取数字索引数组,使用$row[0],$row[1],$row[2]
  135. public function fetch_row()
  136. {
  137. return @mysql_fetch_row($this->result);
  138. }
  140. //获取对象数组,使用$row->content
  141. public function fetch_Object()
  142. {
  143. return @mysql_fetch_object($this->result);
  144. }
  146. //简化查询select
  147. public function findall($table){
  148. $table = $this->fulltablename($table);
  149. $this->query("select * from $table");
  150. }
  152. public function select($table,$columnName,$condition){
  153. $table = $this->fulltablename($table);
  154. if(emptyempty($columnName)){
  155. $columnName = "*";
  156. }
  157. $this->query("SELECT $columnName FROM $table $condition");
  158. }
  160. //简化的insert
  161. function insert($table,$arr){
  162. $table = $this->fulltablename($table);
  163. $sql = "INSERT INTO $table ";
  164. if(!is_array($arr)){
  165. $this->show_error("请输入参数数组！");
  166. }else{
  167. $k = "";
  168. $v = "";
  169. foreach($arr as $key => $value){
  170. $k .= "`$key`,";
  171. $v .= "'".$value."',";
  172. }
  173. }
  174. $sql = $sql." (".substr($k,0,-1).") VALUES (".substr($v,0,-1).")";
  175. $this->query($sql);
  176. }
  177. //简化的update
  178. function update($table,$arr,$where){
  179. $table = $this->fulltablename($table);
  180. $sql = "UPDATE $table SET ";
  181. if(!is_array($arr)){
  182. $this->show_error("请输入参数数组！");
  183. }else{
  184. foreach($arr as $key => $value){
  185. $sql .= " `".$key."` = '".$value."' ,";
  186. }
  187. }
  188. $sql = substr($sql,0,-1)." where ".$where;
  189. return $this->query($sql);
  190. }
  191. //简化的delete
  192. function delete($table,$where = ""){
  193. $table = $this->fulltablename($table);
  194. if(emptyempty($where)){
  195. $this->show_error("条件不能为空!");
  196. }else{
  197. $where = " where ".$where;
  198. }
  199. $sql = "DELETE FROM $table ".$where;
  200. //echo $sql;
  201. return $this->query($sql);
  202. }
  204. //取得上一步 INSERT 操作产生的 ID
  205. public function insert_id(){
  206. return mysql_insert_id();
  207. }
  209. //加上前缀的数据表
  210. public function fulltablename($table){
  211. return $table = $this->pre.$table;
  212. }
  214. //查询字段数量
  215. public function num_fields($table){
  216. $table = $this->fulltablename($table);
  217. $this->query("select * from $table");
  218. echo "
    ";
  219. echo "字段数：".$total = mysql_num_fields($this->result);
  220. echo "
    ";
  221. for ($i=0; $i print_r(mysql_fetch_field($this->result,$i) );
  222. }
  223. echo "";
  224. echo "
    ";
  225. }
  227. //取得 MySQL 服务器信息
  228. public function mysql_server($num=''){
  229. switch ($num){
  230. case 1 :
  231. return mysql_get_server_info(); //MySQL 服务器信息
  232. break;
  234. case 2 :
  235. return mysql_get_host_info(); //取得 MySQL 主机信息
  236. break;
  238. case 3 :
  239. return mysql_get_client_info(); //取得 MySQL 客户端信息
  240. break;
  242. case 4 :
  243. return mysql_get_proto_info(); //取得 MySQL 协议信息
  244. break;
  246. default:
  247. return mysql_get_client_info(); //默认取得mysql版本信息
  248. }
  249. }
  251. //析构函数，自动关闭数据库,垃圾回收机制
  252. /*public function __destruct()
  253. {
  254. if(!empty($this->result)){
  255. $this->free();
  256. }
  257. mysql_close($this->$db_conn);
  258. }*/
  260. /*获得客户端真实的IP地址*/
  261. function getip(){
  262. if(getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown"))
  263. {
  264. $ip = getenv("HTTP_CLIENT_IP");
  265. }
  266. else if (getenv("HTTP_X_FORWARDED_FOR") && strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown")){
  267. $ip = getenv("HTTP_X_FORWARDED_FOR");
  268. }
  269. else if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown"))
  270. {
  271. $ip = getenv("REMOTE_ADDR");
  272. }
  273. else if (isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], "unknown")){
  274. $ip = $_SERVER['REMOTE_ADDR'];
  275. }
  276. else{
  277. $ip = "unknown";
  278. }
  279. return($ip);
  280. }
  282. function show_error($str){
  283. echo "";
  284. }
  286. }
  287. ?>
复制代码

PHP


Déclaration：
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn
Article précédent：PHP操作Cookie的类 Article suivant：PHP把全角数字转为半角数字

Articles Liés

Voir plus