2. /** 
3. * 数据库配置类 
4. */ 
5. class DBConfig 
6. { 
7. public static $HOST = 'localhost'; 
8. public static $USERNAME = 'root'; 
9. public static $PASSWORD = 'root'; 
10. public static $DATABASE = 'shopping'; 
11. public static $CHARSET = 'utf8'; 
12. } 
13. ?> 

2. /** 
3.  
4. * 数据库操作类 
5.  
6. */ 
7. class DataBase{ 
8. private $connection; 
9. /** 
10. * 构造方法 
11.  
12. * @access public 
13.  
14. */ 
15. public function __construct(){ 
16.  
17. $CONFIG = require(dirname(__FILE__).'/DBConfig.class.php'); 
18.  
19. $this>connection = mysql_connect(DBConfig::$HOST,DBConfig::$USERNAME,DBConfig::$PASSWORD); 
20.  
21. mysql_select_db(DBConfig::$DATABASE); 
22.  
23. mysql_query("SET NAMES '".DBConfig::$CHARSET."'"); 
24.  
25. } 
26. /** 
27.  
28. * 析构方法 
29.  
30. * @access public 
31.  
32. */ 
33. public function __destruct(){ 
34. mysql_close($this>connection); 
35. } 
36.  
37. /** 
38. * 执行SQL查询语句 
39.  
40. * @access private 
41.  
42. * @param string $p_sql 查询命令 
43.  
44. * @return array 记录集,无记录返回空数组 
45.  
46. */ 
47.  
48. private function query($p_sql){ 
49.  
50. $dataTemp = mysql_query($p_sql,$this>connection); 
51.  
52. $data = array(); 
53.  
54. $dataItem = 0; 
55.  
56. while ($rows = mysql_fetch_assoc($dataTemp)) { 
57.  
58. $data[$dataItem] = $rows; 
59.  
60. $dataItem++; 
61. } 
62. return $data; 
63. } 
64. /** 
65. * 执行SQL语句 
66. * @access public 
67. * @param string $p_sql 需要执行的SQL,可以为INSERT,SELECT,UPDATE或DELETE 
68. * @return 如果SQL是SELECT,返回记录集,如果SQL是INSERT,返回新记录ID,如果SQL是UPDATE或DELETE,返回所影响的行数 
69. */ 
70. public function execute($p_sql){ 
71. $controlr = strtoupper(substr($p_sql,0,6)); 
72. switch ($controlr) { 
73. case 'INSERT': 
74. mysql_query($p_sql,$this>connection); 
75. $result = mysql_insert_id($this>connection); 
76. break; 
77. case 'SELECT': 
78. $result = $this>query($p_sql,$this>connection); 
79. break; 
80. default: 
81. mysql_query($p_sql,$this>connection); 
82. $result = mysql_affected_rows($this>connection); 
83. break; 
84. } 
85. return $result; 
86. } 
87. } 
88. ?> 

调用很简单:

1. $sql = '.....'; // 可以是任何增删改查的语句 
2. $db = new DataBase(); 
3. $rs = $db>execute($sql); 
4. $db = null;