最近练习写Class，这次是MySQL.class.php，请指点

深空

贴了几处，想得到一些指导，请指点，没有多少写Class的经验，也没多少编码经验，呵呵，多多提点意见和建议，深表感谢

1. <?php
   
2. /*
   
3. +-------------------------------------------------------------------+
   
4. | OpenPHP.cn Version 1.0 Beta                                       |
   
5. +-------------------------------------------------------------------+
   
6. | Copyright (c) 2003-2004 The OpenPHP.cn Web Team                   |
   
7. +-------------------------------------------------------------------+
   
8. | WebSite   : http://www.openphp.cn                                 |
   
9. | Time      : Sat, Apr 17 2004 05:36:04 GMT                         |
   
10. | Support   : support@openphp.cn                                    |
    
11. | Contect   : webmaster@openphp.cn                                  |
    
12. | Licence   : http://www.openphp.cn/?license                        |
    
13. +-------------------------------------------------------------------+
    
14. | Filename  : MySQL.class.php                                       |
    
15. | Function  : DB class                                              |
    
16. +-------------------------------------------------------------------+
    
17. | Authors       : ShenKong <shenkong@openphp.cn>;                    |
    
18. | Maintainer    : ShenKong <shenkong@openphp.cn>;                    |
    
19. | Create Time   : Sat, Apr 17 2004 05:36:04 GMT                     |
    
20. | Last Modify   : Sat, Apr 17 2004 05:36:04 GMT                     |
    
21. +-------------------------------------------------------------------+
    
22. */
    
23. 
    
24.     define("DB_FETCH_ROW", MYSQL_NUM);
    
25.     define("DB_FETCH_ASSOC", MYSQL_ASSOC);
    
26.     define("DB_FETCH_ARRAY", MYSQL_BOTH);
    
27. 
    
28.     class DB
    
29.     {
    
30.         var $dbHost = null;
    
31.         var $dbName = null;
    
32.         var $dbUser = null;
    
33.         var $dbPswd = null;
    
34.         var $conn   = null;
    
35.         var $query  = null;
    
36.         var $result = null;
    
37.         var $errStr = null;
    
38.         var $quick  = false;        
    
39.         var $sqlStr = array();
    
40.         var $sQueries = 0;
    
41.         var $uQueries = 0;
    
42. 
    
43.         function DB($dsn, $fetchMode = DB_FETCH_ASSOC, $pConn = false)
    
44.         {
    
45.             $this->;dbHost = $dsn["dbHost"];
    
46.             $this->;dbName = $dsn["dbName"];
    
47.             $this->;dbUser = $dsn["dbUser"];
    
48.             $this->;dbPswd = $dsn["dbPswd"];
    
49.             $this->;connect($pConn);
    
50.             $this->;selectDB();
    
51.             $this->;setFetchMode($fetchMode);
    
52.         }
    
53. 
    
54.         function connect($pConn = false)
    
55.         {
    
56.             $pConn ? $connFunc = "mysql_pconnect" : $connFunc = "mysql_connect";
    
57.             $this->;conn = @ $connFunc($this->;dbHost, $this->;dbUser, $this->;dbPswd);
    
58.             if (!$this->;conn)
    
59.             {
    
60.                 $this->;errStr = "DataBase Connect False : ($this->;dbHost, $this->;dbUser, ******) !";
    
61.                 $this->;dbError();
    
62.             }
    
63.         }
    
64. 
    
65.         function selectDB()
    
66.         {
    
67.             if ($this->;dbName != null)
    
68.             {
    
69.                 if(! @ mysql_select_db($this->;dbName, $this->;conn))
    
70.                 {
    
71.                     $this->;errStr = "DataBase -[$this->;dbName]- does not exist !";
    
72.                     $this->;dbError();
    
73.                 }
    
74.             }
    
75.             return false;
    
76.         }
    
77. 
    
78.         function setFetchMode($fetchMode)
    
79.         {
    
80.             if(!defined("DB_FETCH_MODE"))
    
81.             {
    
82.                 define("DB_FETCH_MODE", $fetchMode);
    
83.             }
    
84.         }
    
85. 
    
86.         function query($query, $quick = false)
    
87.         {
    
88.             $this->;quick = $quick;
    
89.             $this->;query = $query;
    
90.             $this->;sqlStr[] = $this->;query;
    
91.             $this->;quick ? $queryFunc = "mysql_unbuffered_query" : $queryFunc = "mysql_query";
    
92.             $this->;result = @ $queryFunc($this->;query, $this->;conn);
    
93.             $this->;sQueries++;
    
94.             if (!$this->;result)
    
95.             {
    
96.                 $this->;dbError();
    
97.             }
    
98.             return $this->;result;
    
99.         }
    
100. 
     
101.         function simpleQuery($query, $from = 0, $limit = 0)
     
102.         {
     
103.             if($from)
     
104.             {
     
105.                 $from = $from . ',';
     
106.             }
     
107.             if($limit)
     
108.             {
     
109.                 $query .= ' Limit ' . $from. $limit;
     
110.             }
     
111.             $this->;query($query);
     
112.         }
     
113. 
     
114.         function getOne($query)
     
115.         {
     
116.             //$this->;query = preg_replace("!(select .+ from [^ ]+)(.*)!i", "\\1", $query);
     
117.             if (!stristr($query, "limit"))
     
118.             {
     
119.                 $query .= " Limit 1";
     
120.             }
     
121.             $this->;query($query, true);
     
122.             $row = $this->;fetchRow(DB_FETCH_ROW);
     
123.             $this->;free();
     
124.             return $row[0];
     
125.         }
     
126. 
     
127.         function getRow($query, $fetchMode = DB_FETCH_MODE)
     
128.         {
     
129.             if (!stristr($query, "limit"))
     
130.             {
     
131.                 $query .= " Limit 1";
     
132.             }
     
133.             $this->;query($query, true);
     
134.             $row = $this->;fetchRow($fetchMode);
     
135.             $this->;free();
     
136.             return $row;
     
137.         }
     
138. 
     
139.         function getAll($query, $fetchMode = DB_FETCH_MODE)
     
140.         {
     
141.             $this->;query($query, true);
     
142.             while($rows = @ $this->;fetchRow($fetchMode))
     
143.             {
     
144.                 $allRows[] = $rows;
     
145.             }
     
146.             $this->;free();
     
147.             return $allRows;
     
148.         }
     
149. 
     
150.         function update($query)
     
151.         {
     
152.             $this->;query = $query;
     
153.             $this->;sqlStr[] = $this->;query;
     
154.             $this->;result = mysql_unbuffered_query($query);
     
155.             if (!$this->;result)
     
156.             {
     
157.                 $this->;errStr = "Update data Error !";
     
158.                 $this->;dbError();
     
159.             }
     
160.             $this->;uQueries++;
     
161.             $this->;free();
     
162.             return true;
     
163.         }
     
164. 
     
165.         function getTables()
     
166.         {
     
167.             $this->;result = @ mysql_list_tables($this->;dbName);
     
168.             if (!$this->;result)
     
169.             {
     
170.                 $this->;errStr = "List database's tables Error !";
     
171.                 $this->;dbError();
     
172.             }
     
173.             $tablesNum = @ mysql_num_rows($this->;result);
     
174.             for ($i = 0; $i < $tablesNum; $i++)
     
175.             {
     
176.                 $tables[] = mysql_tablename($this->;result, $i);
     
177.             }
     
178.             return $tables;
     
179.         }
     
180. 
     
181.         function optimize()
     
182.         {
     
183.             $tables = $this->;getTables();
     
184.             print_r($tables);
     
185.             $tablesNum = count($tables);
     
186.             for($i=0; $i < $tablesNum; $i++)
     
187.             {
     
188.                 $this->;update("Optimize Table " . $tables[$i]);
     
189.                 echo "Optimeze Table " . $tables[$i] . "\n";
     
190.             }
     
191.         }
     
192. 
     
193.         function fetchRow($fetchMode = DB_FETCH_MODE)
     
194.         {
     
195.             $rows = @ mysql_fetch_array($this->;result, $fetchMode);
     
196.             return $rows;
     
197.         }
     
198. 
     
199.         function seek()
     
200.         {
     
201.         }
     
202. 
     
203.         function rows()
     
204.         {
     
205.             return @ mysql_num_rows($this->;result);
     
206.         }
     
207. 
     
208.         function fields()
     
209.         {
     
210.             return @ mysql_num_fields($this->;result);
     
211.         }
     
212. 
     
213.         function lastID()
     
214.         {
     
215.             return @ mysql_insert_id($this->;conn);
     
216.         }
     
217. 
     
218.         function free()
     
219.         {
     
220.             @ mysql_free_result($this->;result);
     
221.             $this->;result = null;
     
222.         }
     
223. 
     
224.         function close()
     
225.         {
     
226.             @ mysql_close($this->;conn);
     
227.         }
     
228. 
     
229.         function dbError()
     
230.         {
     
231.             //ob_end_clean();
     
232.             $errStr = "Error No : " . mysql_errno() . "\n";
     
233.             $errStr .= "Time : " . date("Y-m-d H:i:s") . "\n";
     
234.             if (isset($this->;errStr))
     
235.             {
     
236.                 $errStr .= $this->;errStr . "\n";
     
237.             }
     
238.             if(isset($this->;query))
     
239.             {
     
240.                 $errStr .= "Query : " . $this->;query . "\n";
     
241.             }
     
242.             $errStr .= "Error MSG : " . mysql_error();
     
243.             echo nl2br($errStr);
     
244.             exit;
     
245.         }
     
246.     }
     
247. 
     
248. ?>;

复制代码

rainren

很不错, 比我想的好多了! 我用MYSQL写留言簿, 正想将数据库中的操作分离出来!

rainren

我贴一下我写的留言簿, 然后学学你写类的手法可以简化一下我的页面!

1. 
   
2. <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
   
3. "http://www.w3.org/TR/xhtml1/DTD/transitional.dtd">;
   
4. 
   
5. <?php
   
6. function flag_error ($fieldname, $errstr)
   
7.   {
   
8.     global $field_with_errors, $errors;
   
9.     $field_with_errors[$fieldname] = 1;
   
10.     $errors[] = $errstr;
    
11.     }
    
12. 
    
13. function has_error ($fieldname)
    
14.   {
    
15.     global $field_with_errors;
    
16.     if (isset ($field_with_errors[$fieldname]) )
    
17.         return true;
    
18.     return false;
    
19.    }
    
20. 
    
21. $p = & $_POST;
    
22. $errors = array();
    
23. 
    
24. if (count ($p) >; 0 )
    
25.   {
    
26.     //error checking
    
27.     if ( trim($p['name']) =='')
    
28.        flag_error ('name', '请输入您的姓名');
    
29. 
    
30.     if ( trim($p['email']) =='')
    
31.        flag_error ('email', '请输入您的E-mail');
    
32. 
    
33.     if ( trim($p['title']) =='')
    
34.        flag_error ('title', '请输入您的留言主题');
    
35. 
    
36.     if ( empty($p['content']))
    
37.        flag_error ('content', '请输入您的留言内容');
    
38. 
    
39.     if ( count ($errors) == 0 )
    
40.       {
    
41.          $hostname="localhost";
    
42.          $user="";
    
43.          $passwd="";
    
44.          $database="house";
    
45.          $dbc=mysql_pconnect($hostname, $user, $passwd) or die ("Sorry, connect database error");
    
46. 
    
47.          mysql_select_db($database, $dbc) or die ("Sorry, select database ".$database." error");
    
48. 
    
49.          $data=date("Y-m-j h:i:s");
    
50.          $name = $p['name'];
    
51.          $url = $p['url'];
    
52.          $email = $p['email'];
    
53.          $title = $p['title'];
    
54.          $content = $p['content'];
    
55. 
    
56.          $query = sprintf( "insert into guestbook(name, url, email, title, content, data) values('%s','%s','%s','%s','%s','%s')",
    
57.          addslashes ( $p['name'] ),
    
58.          addslashes ( $p['url'] ),
    
59.          addslashes ( $p['email'] ),
    
60.          addslashes ( $p['title'] ),
    
61.          addslashes ( $p['content'] ), $data);
    
62. 
    
63.          mysql_query($query) or die(mysql_error());
    
64. 
    
65.          mysql_close($dbc);
    
66.          }
    
67. 
    
68.     if ( count ($errors) == 0 )
    
69.        {
    
70.          //success
    
71.           print ('<html>;<head>;');
    
72.          
    
73.             $cssstyle="
    
74.                 <style type=\"text/css\">;
    
75.                    body { font-family:\"Verdana\", \"Arial\", \"Helvetiva\", \"sans-serif\";
    
76.                           font-size:15px; color:#008000; margin-top:20px; margin-right:20px;
    
77.                             margin-left:20px; margin-bottom:10px; background-color:#000000; line-height:180%; }
    
78.                     p { line-height:180%; }
    
79.                     th,td { font-size:15px; }
    
80.                     a:link { text-decoration:none; color:#008000; font-size:15px;}
    
81.                     a:visited { text-decoration:none; color:#008000; font-size:15px; }
    
82.                     a:hover { text-decoration:none; color:#FFFFFF; text-decoration:blink; background-color:#008000; font-size:15px; }
    
83.                     a:active { text-decoration:none; color:#008000; font-size:15px; }
    
84.                  </style>; ";
    
85.           print $cssstyle;
    
86. 
    
87.           print ('</head>;<body>;');
    
88.           echo "<h3 align=\"center\">;感谢您的留言！本站会根据您的留言提供更个性化的服务。<a href=\"view.php\">;<b>;查看所有留言</b>;<a>;</h3>;";
    
89.           echo "<table border=\"1\" width=\"80%\" align=\"center\" cellspacing=\"10\" cellpadding=\"10\">;";
    
90.           echo "<tr>;";
    
91.           echo "<td width=\"50%\">;<img border=\"0\" src=\"yast_sysadmin.gif\" width=\"48\" height=\"48\" />;您的姓名是：".$name."</td>;";
    
92.           echo "<td width=\"50%\">;<img border=\"0\" src=\"time.gif\" width=\"48\" height=\"48\" />;留言日期：".$data."</td>;";
    
93.           echo "</tr>;";
    
94.           echo "<tr>;";
    
95.           echo "<td>;<img border=\"0\" src=\"xfmail.gif\" width=\"48\" height=\"48\" />;E-mail: ".$email."</td>;";
    
96.           echo "<td>;<img border=\"0\" src=\"mozillacrystal.gif\" width=\"48\" height=\"48\" />;您的主页：<a href=\"".$p['url']."\" target=_blank>;".$p['url']."</a>;</td>;";
    
97.           echo "</tr>;";
    
98.           echo "<tr>;";
    
99.           echo "<td colspan=\"2\">;";
    
100.             echo "<h3 align=\"center\">;<img border=\"0\" src=\"kate.gif\" width=\"48\" height=\"48\" />;".$title."</h3>;<br />;";
     
101.           echo "<pre>;".$content."</pre>;";
     
102.           echo "</td>;</tr>;</table>;";
     
103.           print ('</body>;</html>;');
     
104.           exit;
     
105.           }
     
106.     }
     
107. ?>;
     
108. <html>;
     
109. <head>;
     
110. <title>;留言</title>;
     
111. <meta http-equiv="Content-Type" content="text/html; charset=gb2312">;
     
112. <?php
     
113. $cssstyle="
     
114. <style type=\"text/css\">;
     
115.     body { font-family:\"Verdana\", \"Arial\", \"Helvetiva\", \"sans-serif\";
     
116.            font-size:15px; color:#008000; margin-top:20px; margin-right:20px;
     
117.            margin-left:20px; margin-bottom:10px; background-color:#000000; line-height:180%; }
     
118.     p { line-height:180%; }
     
119.     th,td { font-size:15px; }
     
120.     a:link { text-decoration:none; color:#008000; font-size:15px;}
     
121.     a:visited { text-decoration:none; color:#008000; font-size:15px; }
     
122.     a:hover { text-decoration:none; color:#FFFFFF; text-decoration:blink; background-color:#008000; font-size:15px; }
     
123.     a:active { text-decoration:none; color:#008000; font-size:15px; }
     
124. </style>; ";
     
125. print $cssstyle;
     
126. ?>;
     
127. </head>;
     
128. 
     
129. <body>;
     
130. <h1 align="center">;留言簿</h1>;
     
131. <h3 align="right">;<a href="view.php">;<b>;查看所有留言</b>;<a>;</h3>;
     
132. 
     
133.   <?php
     
134.     if ( count($errors) >; 0)
     
135.      {
     
136.         ?>;
     
137.         <p class="error">; 您的留言有一些错误, 请对照错误信息重新填写:</p>;
     
138.         <ul>;
     
139.         <?php
     
140.              $n = count ($errors);
     
141.              for ( $i=0; $i < $n; $i ++ )
     
142.                  print ( "<li class=\"error\">;".$errors[$i]."</li>;<br />;");
     
143.          ?>;
     
144.         </ur>;
     
145.    <?php
     
146.        }
     
147.     ?>;
     
148. 
     
149. <table align="center" width="80%" cellspacing="15">;
     
150. <tr>;
     
151. <td>;
     
152.   <form method="post" action="<?php print( $PHP_SELF); ?>;" class="form">;
     
153.   <img border="0" src="yast_sysadmin.gif" width="48" height="48">;姓&&&&名     
     
154.     <input type="text" name="name" value="<?php
     
155.                                             if (isset ($p['name']))
     
156.                                                 print ($p['name']); ?>;" />;
     
157.   
     
158.   </td>;
     
159.   <td>;
     
160.   <img border="0" src="xfmail.gif" width="48" height="48">;电子邮件  
     
161.      <input type="text" name="email" value="<?php
     
162.                                               if (isset ($p['email']))
     
163.                                                   print ($p['email']);
     
164.                                               ?>;" />;
     
165.   
     
166.   </td>;
     
167.   </tr>;
     
168.   <tr>;
     
169.    <td>;
     
170.    <img border="0" src="kpaint.gif" width="48" height="48">;留言主题
     
171.      <input type="text" name="title" value="<?php
     
172.                                               if (isset ($p['title']))
     
173.                                                   print ($p['title']);
     
174.                                                   ?>;" />;
     
175.   
     
176.   </td>;
     
177.   <td>;
     
178.   <img border="0" src="mozillacrystal.gif" width="48" height="48">;个人主页
     
179.      <input type="text" name="url" value="http://">;
     
180.    
     
181.    </td>;
     
182.    </tr>;
     
183.   <tr>;
     
184.   <td colspan="2">;
     
185.   <table width="80%" cellspacing="20">;
     
186.     <tr>;
     
187.       <td width="100" align="center">;
     
188.         <img border="0" src="kate.gif" width="48" height="48">;<br />;
     
189.          留<br />;
     
190.          言<br />;
     
191.          内<br />;
     
192.          容<br />;
     
193.       </td>;
     
194.       <td >;
     
195.          <textarea name="content" rows="10" cols="70" value="<?php
     
196.                                                                if (isset ($p['content']))
     
197.                                                                    print ($p['content']);
     
198.                                                                ?>;">;</textarea>;
     
199.       </td>;        
     
200.      </tr>;
     
201.   </table>;
     
202.   </td>;
     
203.   </tr>;
     
204.   <tr>;
     
205.   <td align="center" colspan="2">;
     
206.     <br />;
     
207.       <input type="submit" name="确定" value="确定">;
     
208.      </form>;
     
209.   </td>;
     
210.   </tr>;
     
211. </table>;
     
212. </body>;
     
213. </html>;
     

复制代码

      

深空

嘿嘿，我以前也写过一个留言本，比较复杂：）
简单说一下我的类的调用方法：
    $DSN = array(
                    "dbHost" =>; "localhost",
                    "dbName" =>; "openphp",
                    "dbUser" =>; "root",
                    "dbPswd" =>; "",
                );
    $DB = new DB($DSN);
    $row = $DB->;getAll("Select * From open_topics", DB_FETCH_ARRAY);

初始化的时候有三个参数
全局 $fetchMode = DB_FETCH_ASSOC 设定后将不能再调用setFetchMode方法。第三个参数是持久连接

get*方法第一个参数是SQL语句，getOne和getRow方法可能不需要Limit，get*方法直接返回结果集
如果你想自己循环结果集,可以这样:
    $DB->;query($query);
    while ($rows = $DB->;fetchRow())
    {
        $row[] = $rows;
    }

tonera

呵呵，跟我写的第一个类差不多啊。超强！什么都能干！什么都干！
是不是通病？？

rainren

那应该怎么写类呢?