截止目前已经改造了5个类:
这个模型类支持以下功能：
>连贯操作，js叫链式操作，连贯操作的函数可以打乱顺序，最后一个函数必须是执行语句的那个函数，如select, delete, update, add等
如 $db->table( ‘user‘ )->where( ‘id=1‘ )->select()
等等
->支持扩展各种子类模型，命名如: UserModel, 也可以用其他方式的，跟表名称不同的Model命名，如MyUserModel等
1 <?php
2
3 class Model {
4 protected $dbHost; //主机
5 protected $dbUser; //用户名
6 protected $dbPwd; //密码
7 protected $dbName; //数据库名
8
9 protected $prefix; //表前缀
10 protected $tbName; //表名称
11 protected $charset; //字符集
12 protected $link; //数据库连接资源
13 protected $sql; //拼接的sql语句
14 protected $options; //sql查询条件
15
16
17 public function __construct( $config ){
18 $this->dbHost = $config[‘db_host‘];
19 $this->dbUser = $config[‘db_user‘];
20 $this->dbPwd = $config[‘db_pwd‘];
21 $this->dbName = $config[‘db_name‘];
22 $this->prefix = $config[‘prefix‘];
23 $this->charset = $config[‘charset‘];
24
25 $this->link = $this->connect();
26
27 $this->tbName = $this->getTableName();
28
29 $this->initOptions();
30 }
31
32 protected function initOptions(){
33 $sqlKey = [ ‘where‘, ‘group‘, ‘having‘, ‘limit‘, ‘order‘, ‘field‘, ‘table‘ ];
34 foreach ( $sqlKey as $key => $value ) {
35 $this->options[$value] = ‘‘;
36 if( $value == ‘table‘ ) {
37 $this->options[$value] = $this->tbName;
38 }
39 }
40 }
41
42 public function table( $tbName ) {
43 if( !empty( $tbName ) ) {
44 $this->options[‘table‘] = $tbName;
45 }
46 return $this;
47 }
48
49 public function limit( $limit ){
50 if( !empty( $limit ) ) {
51 if( is_string( $limit ) ) {
52 $this->options[‘limit‘] = ‘limit ‘ . $limit;
53 }else if ( is_array( $limit ) ) {
54 $this->options[‘limit‘] = ‘limit ‘ . join( ‘,‘, $limit );
55 }
56 }
57 return $this;
58 }
59
60 public function order( $order ){
61 if( !empty( $order ) ) {
62 $this->options[‘order‘] = ‘order by ‘ . $order;
63 }
64 return $this;
65 }
66
67 public function having( $having ){
68 if( !empty( $group ) ) {
69 $this->options[‘having‘] = ‘having ‘ . $having;
70 }
71 return $this;
72 }
73
74 public function group( $group ){
75 if( !empty( $group ) ) {
76 $this->options[‘group‘] = ‘group by ‘ . $group;
77 }
78 return $this;
79 }
80
81 public function where( $where ){
82 if( !empty( $where ) ) {
83 $this->options[‘where‘] = ‘where ‘ . $where;
84 }
85 return $this;
86 }
87
88 public function field( $fields ){
89 if( !empty( $fields ) ) {
90 if( is_string( $fields ) ) {
91 $this->options[‘field‘] = $fields;
92 }else if( is_array( $fields ) ){
93 $this->options[‘field‘] = join( ‘,‘, $fields );
94 }
95 }
96 return $this;
97 }
98
99 public function getTableName(){
100 if( !empty( $this->tbName ) ) {
101 return $this->prefix . $this->tbName;
102 }
103 $className = get_class( $this );
104 //UserModel GoodsModel, 获取Model前面的字符串(就是表名称)
105 $tbName = strtolower( substr( $className, 0, -5 ) );
106 return $this->prefix . $this->tbName;
107 }
108
109 protected function connect(){
110 $link = mysql_connect( $this->dbHost, $this->dbUser, $this->dbPwd );
111 if( !$link ){
112 die( "mysql数据库连接失败:" . mysql_error() );
113 }
114 mysql_select_db( $this->dbName, $link );
115 mysql_query( $this->charset );
116 return $link;
117 }
118
119 public function select(){
120 $sql = ‘SELECT %FIELD% FROM %TABLE% %WHERE% %GROUP% %HAVING% %ORDER% %LIMIT%‘;
121 $sql = str_replace(
122 [‘%FIELD%‘, ‘%TABLE%‘, ‘%WHERE%‘, ‘%GROUP%‘, ‘%HAVING%‘, ‘%ORDER%‘, ‘%LIMIT%‘],
123 [ $this->options[‘field‘], $this->options[‘table‘], $this->options[‘where‘], $this->options[‘group‘], $this->options[‘having‘], $this->options[‘order‘], $this->options[‘limit‘] ],
124 $sql
125 );
126 $this->sql = $sql;
127 return $this->query( $sql );
128 }
129
130 public function __get( $key ){
131 if( $key == ‘sql‘ ) {
132 return $this->sql;
133 }else if( $key == ‘prefix‘ ) {
134 return $this->prefix;
135 }
136 return false;
137 }
138
139 public function query( $sql ){
140 //执行语句之前，清空原来的options保存的sql语句临时拼接数据
141 $this->initOptions();
142 $res = mysql_query( $sql );
143 $data = array();
144 if( $res && mysql_num_rows( $res ) ) {
145 while( $row = mysql_fetch_assoc( $res ) ){
146 $data[] = $row;
147 }
148 }
149 return $data;
150 }
151
152 public function add( $data ){
153 $data = $this->parse( $data );
154 $keys = array_keys( $data );
155 $values = array_values( $data );
156 $sql = ‘INSERT INTO %TABLE%(%FIELD%) values(%VALUES%)‘;
157 $sql = str_replace(
158 [ ‘%TABLE%‘, ‘%FIELD%‘, ‘%VALUES%‘ ],
159 [ $this->options[‘table‘], join( ‘,‘, $keys ), join( ‘,‘, $values ) ],
160 $sql
161 );
162 $this->sql = $sql;
163 return $this->exec( $sql, true );
164 }
165
166 public function delete(){
167 $sql = ‘DELETE FROM %TABLE% %WHERE%‘;
168 $sql = str_replace(
169 [ ‘%TABLE%‘, ‘%WHERE%‘ ],
170 [ $this->options[‘table‘], $this->options[‘where‘] ],
171 $sql
172 );
173 $this->sql = $sql;
174 return $this->exec( $sql );
175 }
176
177 public function exec( $sql, $isInsert = false ){
178 $this->initOptions();
179 $res = mysql_query( $sql );
180 if( $res !== false ) {
181 if( $isInsert ) {
182 return mysql_insert_id();
183 }else {
184 return mysql_affected_rows();
185 }
186 }
187 return false;
188 }
189
190 public function parse( $data ) {
191 $res = [];
192 foreach( $data as $k => $v ){
193 if( is_string( $v ) ) {
194 $res[$k] = ‘"‘ . $v . ‘"‘;
195 }
196 }
197 return $res;
198 }
199
200 public function update( $data ) {
201 $data = $this->parse( $data );
202 $fieldValue = $this->format( $data );
203 $sql = ‘UPDATE %TABLE% SET %FIELD% %WHERE%‘;
204 $sql = str_replace(
205 [ ‘%TABLE%‘, ‘%FIELD%‘, ‘%WHERE%‘ ],
206 [ $this->options[‘table‘], $fieldValue, $this->options[‘where‘] ],
207 $sql
208 );
209 $this->sql = $sql;
210 return $this->exec( $sql );
211 }
212
213 //update ghostwu_user set field = value, where ....
214 protected function format( $data ){
215 $res = [];
216 foreach( $data as $k => $v ) {
217 $res[] = $k . ‘=‘ . $v;
218 }
219 return join( ‘,‘, $res );
220 }
221
222 public function __destruct(){
223 mysql_close( $this->link );
224 }
225
226 public function __call( $funcName, $args ) {
227 $str = substr( $funcName, 0, 5 );
228 $field = substr( $funcName, 5 );
229 if( $str == ‘getBy‘ ) {
230 echo $args[0];
231 return $this->where( $field . ‘="‘ . $args[0] . ‘"‘ )->select();
232 }
233 return false;
234 }
235 }
236 $config = [
237 ‘db_host‘ => ‘localhost‘,
238 ‘db_user‘ => ‘root‘,
239 ‘db_pwd‘ => ‘‘,
240 ‘prefix‘ => ‘ghostwu_‘,
241 ‘db_name‘ => ‘blog‘,
242 ‘charset‘ => ‘utf8‘,
243 ];
244 $db = new Model( $config );
245 print_r( $db->field( ‘*‘ )->table( $db->prefix . ‘users‘ )->getByName( ‘zhangsan‘ ) );
246 echo $db->sql . PHP_EOL;
247 //$db->table( $db->prefix . ‘users‘ )->where( ‘id=1‘ )->update( [ ‘name‘ => ‘david‘, ‘email‘ => ‘[email protected]‘ ] );
248 //echo $db->sql . PHP_EOL;
249 //$db->table( $db->prefix . ‘users‘ )->where( ‘id in( 4, 5, 6, 7 )‘ )->delete();
250 //echo $db->sql . PHP_EOL;
251 //$db->table( $db->prefix . ‘users‘ )->add( [‘name‘ => ‘zhangsan‘, ‘email‘ => ‘[email protected]‘] );
252 /*
253 $list = $db->table( $db->prefix . ‘users‘ )->field( [ ‘name‘, ‘email‘ ] )->where( ‘id >= 1‘ )->order( ‘id desc‘ )->limit( [0, 5] )->select();
254 echo $db->sql . PHP_EOL;
255 print_r( $list );
256 */
257 ?>
原文地址：https://www.cnblogs.com/ghostwu/p/8502878.html
时间： 2024-10-12 13:36:31