在PHP的面向過程中，我們可以通過封裝函數(shù)來實(shí)現(xiàn)對(duì)數(shù)據(jù)庫的操作，那么在面向過程中，我們同樣可以通過類來實(shí)現(xiàn)對(duì)數(shù)據(jù)庫的操作，整個(gè)過程和面向過程的思路大體差不多，但是代碼量更多了一些，實(shí)現(xiàn)起來稍微困難。一共實(shí)現(xiàn)了十個(gè)功能。先定義成員屬性，然后定義成員方法。一共分為連接數(shù)據(jù)庫的config文件、具體實(shí)現(xiàn)對(duì)數(shù)據(jù)庫操作的類文件、測(cè)試代碼。所有的代碼均是通過了測(cè)試，具體的測(cè)試結(jié)果由于篇幅問題沒有附圖。

成都創(chuàng)新互聯(lián)服務(wù)項(xiàng)目包括阿里地區(qū)網(wǎng)站建設(shè)、阿里地區(qū)網(wǎng)站制作、阿里地區(qū)網(wǎng)頁制作以及阿里地區(qū)網(wǎng)絡(luò)營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，阿里地區(qū)網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到阿里地區(qū)省份的部分城市，未來相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！

具體實(shí)現(xiàn)功能：

1、連接數(shù)據(jù)庫；

2、插入數(shù)據(jù)；

3、更新數(shù)據(jù)；

4、刪除數(shù)據(jù)；

5、修改數(shù)據(jù)；

6、求最大值；

7、求最小值；

8、求平均數(shù)；

9、求和；

10、指定查詢；

具體代碼分為三個(gè)部分：

一、config文件：主要用于連接數(shù)據(jù)庫

 '127.0.0.1',   //主機(jī)
	'DB_USER' => 'root',		//用戶名	
	'DB_PWD' => '123456',		//密碼
	'DB_NAME' => 'blog',		//數(shù)據(jù)庫名
	'DB_CHARSET' => 'utf8',		//字符集
	'DB_PREFIX' => 'bbs_',		//前綴

);

二、數(shù)據(jù)庫操作類：

host = $config['DB_HOST'];
		$this->user = $config['DB_USER'];
		$this->pwd = $config['DB_PWD'];
		$this->dbName = $config['DB_NAME'];
		$this->charset = $config['DB_CHARSET'];
		$this->prefix = $config['DB_PREFIX'];
		//連接
		$this->link = $this->connect();
		//判斷連接成功與否  失敗處理
		if (!$this->link) {
			exit('數(shù)據(jù)庫連接或者選擇數(shù)據(jù)庫失敗。');
		}

		//表名  需要處理
		$this->table = $this->getTable();

		//字段 	需要處理
		$this->fields = $this->getFields();



	}

	//連接數(shù)據(jù)庫成員方法
	protected function connect()
	{
		$conn = MySQLi_connect($this->host,$this->user,$this->pwd);

		//連接數(shù)據(jù)庫失敗處理
		if (!$conn) {

			return flase;
		}

		//選擇數(shù)據(jù)失敗處理
		if (!mysqli_select_db($conn,$this->dbName)) {

			return false ;
		}
		//設(shè)置字符集
		mysqli_set_charset($conn,$this->charset);

		//返回處理結(jié)果
		return $conn;

	}
	//初始化表 【暫時(shí)出現(xiàn)報(bào)錯(cuò)，后面用命名空間解決】
	protected function getTable()
	{
		//判斷用戶時(shí)候設(shè)置過？
		if (isset($this->table)) {

			//設(shè)置過就以用戶的為準(zhǔn)，先把用戶前綴棄掉，然后拼接前綴，保證統(tǒng)一性
			return $this->prefix . ltrim($this->table,$this->prefix);
		} else {

			//沒有設(shè)置過就用 類名拼接前綴，組成一個(gè)全新的的表名
			//get_class() 獲取類名 等同于 __CLASS__
			//獲取類名后進(jìn)行字串提取[substr( string,start,length )],并且全部轉(zhuǎn)換為小寫[strtolower()]
			return $this->prefix . strtolower(substr(get_class($this),0,-5));
		}
	}
	//初始化字段 需要把字段緩存到一個(gè)文件里面去
	protected function getFields()
	{
		//如果有字段的文件說明以前緩存過這個(gè)文件，直接包含即可，但是需要知道文件路徑的規(guī)則
		//定義文件路徑
		$filePath = './caceh/' . $this->table . '.php';

		//判斷時(shí)候有緩存文件
		if (file_exists($filePath)) {

			//存在緩存文件直接包含即可
			return include $filePath;
		} else {

			//沒有的話就需要生成一個(gè)緩存文件
			//首先需要查詢字段
			$fields = $this->queryFields();

			//var_export() 輸出或返回一個(gè)變量的字符串  true表示不打印  將其保存下來
			$str = "';
			//寫入到緩存文件file_put_contents(文件保存路徑，需要寫進(jìn)去的內(nèi)容)
			file_put_contents($filePath, $str);

		}
		return $fields;


	}

	//查詢字段處理
	protected function queryFields()
	{
		//打印字段的sql語句
		$sql = 'desc ' . $this->table;
		//var_dump($sql);
		//執(zhí)行sql語句  需要定義成員方法query
		$data = $this->query($sql);

		$fields = [];
		//想要獲取字段，需要對(duì)返回的數(shù)據(jù)進(jìn)行遍歷
		foreach ($data as $key => $value) {
			$fields[] = $value['Field'];
			if ($value['Key'] == 'PRI') {
				$fields['_pk'] = $value['Field'];
			}
		}
		return $fields;


	}

	//系統(tǒng)級(jí)查詢(定義為 public ),在外部調(diào)用的時(shí)候，想自定義SQL語句可以只是調(diào)用該成員方法
	//查詢相應(yīng)的結(jié)果，這個(gè)僅供讀取使用查詢相應(yīng)的結(jié)果
	public function query($sql)
	{
		//執(zhí)行一條SQL語句
		$result = mysqli_query($this->link,$sql);

		if ($result) {
			$data = [];
			//獲取每行數(shù)據(jù)
			while ($row = mysqli_fetch_assoc($result)) {
				$data[] = $row;
			}
			return $data;

		} else {
			return false;
		}


	}

	//查詢成員方法
	//準(zhǔn)備好無需換的SQL語句
	//用戶調(diào)用詢的時(shí)候，將call里面保存進(jìn)去的參數(shù)，一一替換sql語句
	//發(fā)送SQL語句
	//返回查詢的結(jié)果
	public function select()
	{
		//拼接sql語句
		$sql = "select %FIELDS% from %TABLE% %WHERE% %GROUP% %HAVING% %ORDER% %LIMIT%";

		//將sql語句中的相應(yīng)部分替換
		$newsql = str_replace(
					array(
						'%FIELDS%',
						'%TABLE%',
						'%WHERE%',
						'%GROUP%',
						'%HAVING%',
						'%ORDER%',
						'%LIMIT%',
					),
					array(
						$this->parseFields(),
						$this->parseTable(),
						$this->parseWhere(),
						$this->parseGroup(),
						$this->parseHaving(),
						$this->parseOrder(),
						$this->parseLimit(),
					),
					$sql
				);
		echo $newsql;
		$this->sql = $newsql;
		return $this->query($newsql);
	}
	//字段處理
	protected function parseFields()
	{
		//因?yàn)槲覀儗?duì)比字段的時(shí)不需要對(duì)比主鍵是誰，所以需要unset()
		//將當(dāng)前的字段賦值給一個(gè)變量
		$fields = $this->fields;

		unset($fields['_pk']);

		//判斷字段是什么形式（字符串、數(shù)組）
		if (is_array($this->options['fields'][0])) {

			//遍歷取出鍵值
			foreach ($this->options['fields'][0] as $key => $value) {
				//判斷傳入的字段時(shí)候合法（屬于表結(jié)構(gòu)中的字段）
				if (!in_array($value, $fields)) {
					//如果不屬于合法的字段就unset()
					unset($this->options['fields'][0][$key]);
				}
			}
			return join(',',$this->options['fields'][0]);

		} else if (is_string($this->options['fields'][0])){
			//如果是字符串就先變?yōu)閿?shù)組進(jìn)行處理
			$this->options['fields'][0] = explode(',', $this->options['fields'][0]);
			//遍歷
			foreach ($this->options['fields'][0]  as $key => $value) {
				//判斷字段是否合法
				if (!in_array($value,$fields)) {

					unset($this->options['fields'][0][$key]);
				}
				return join(',',$this->options['fields'][0]);
			}

		} else {
			return join(',',$fields);
		}

	}

	//判斷用戶有沒有手動(dòng)指定過查詢哪個(gè)用
	//如果指定過，則以用戶設(shè)定的options里面的表為準(zhǔn)
	//如果沒有設(shè)定過，則以默認(rèn)的為準(zhǔn)
	protected function parseTable()
	{
		if (isset($this->options['table'][0])) {
			return $this->options['table'][0];
		} else {
			return $this->table;
		}

	}


	//判斷用戶設(shè)置過where 如果設(shè)置過就以用戶設(shè)置為準(zhǔn)，沒有設(shè)置就為空

	protected function parseWhere()
	{
		if (isset($this->options['where'][0])) {
			return 'WHERE ' .$this->options['where'][0];
		} else {
			return '';
		}
	}


	//判斷用戶設(shè)置過group 如果設(shè)置過就以用戶設(shè)置為準(zhǔn)，沒有設(shè)置就為空

	protected function parseGroup()
	{
		if (isset($this->options['where'][0])) {
			return 'GROUP BY ' .$this->options['group'][0];
		} else {
			return '';
		}
	}

	//判斷用戶設(shè)置過having如果設(shè)置過就以用戶設(shè)置為準(zhǔn)，沒有設(shè)置就為空

	protected function parseHaving()
	{
		if (isset($this->options['having'][0])) {
			return 'HAVING ' .$this->options['having'][0];
		} else {
			return '';
		}
	}

	//判斷用戶設(shè)置過order如果設(shè)置過就以用戶設(shè)置為準(zhǔn)，沒有設(shè)置就為空
	protected function parseOrder()
	{
		if (isset($this->options['order'][0])) {
			return 'ORDER BY ' .$this->options['order'][0];
		} else {
			return '';
		}
	}

	//limit可以有以下幾種傳法


	protected function parseLimit()
	{
		if (isset($this->options['limit'][0])) {

			if (is_int($this->options['limit'][0])) {

				//用戶傳進(jìn)來的是一個(gè)整 數(shù)，就是查詢指定的條數(shù)
				return 'LIMIT ' . $this->options['limit'][0];

			} else if (is_array($this->options['limit'][0])){

				//用戶傳進(jìn)來的是一個(gè)數(shù)組，則數(shù)組中的第一個(gè)元素為$offset,第二個(gè)元素為$num
				return 'LIMIT ' . join(',',$this->options['limit'][0]);
			} else {

				//如果戶傳進(jìn)來的是一個(gè)字符串，則以用戶傳的為準(zhǔn)
				return 'LIMIT ' . $this->options['limit'][0];
			}
		} else {

			return '';
		}
	}

	//插入的成員方法
	public function insert($data)
	{
		//SQL語句
		$sql = "insert into %TABLE%(%FIELDS%) values(%VALUES%) ";
		//替換
		$newsql = str_replace(
						array(
							'%TABLE%',
							'%FIELDS%',
							'%VALUES%'
						),
						array(
							$this->parseTable(),
							$this->parseInsertFieldes($data),
							join (',',$this->parseValue($data)),
						),
						$sql
					);
		//重新賦值
		$this->sql = $newsql;
		echo $this->sql;
		//調(diào)用exec并執(zhí)行
		return $this->exec($newsql,true);

	}
	//處理插入時(shí)候的字段
	protected function parseInsertFieldes(&$data)
	{
		foreach ($data as $key => $value) {
			if (!in_array($key,$this->fields)) {
				unset($data[$key]);
			}
		}
		return join(',',array_keys($data));
	}

	//處理插入時(shí)候的值
	//分為字符串  數(shù)組 空的情況處理
	protected function parseValue($data)
	{

		if (is_string($data)) {
			$data = '\'' . $data . '\'';
		} else if (is_array($data)){
			$data = array_map(array($this, 'parseValue'),$data);
		} else if (is_null($data)){
			$data = 'null';
		}

		return $data;
	}
	//
	public function exec($sql,$isInsertId = false)
	{
		$result = mysqli_query($this->link,$sql);

		if ($result) {

			if ($isInsertId) {
				//insertfan返回自動(dòng)增長的id
				return mysqli_insert_id($this->link);
			} else {
				//update delete 返回受影響的行數(shù)

				return mysqli_affected_rows($this->link);
			}
		} else {
			return false;
		}
	}

	//更新方法
	public function update($data)
	{
		$sql = "update %TABLE% set %SETS% %WHERE% %ORDER% %LIMIT%";

		$newsql = str_replace(
					array(
						'%TABLE%',
						'%SETS%',
						'%WHERE%',
						'%ORDER%',
						'%LIMIT%'
					),
					array(
						$this->parseTable(),
						$this->parseSets($data),
						$this->parseWhere(),
						$this->parseOrder(),
						$this->parseLimit(),
					),
					$sql
				);
		$this->sql = $newsql;
		//echo $newsql;
		return $this->exec($newsql);

	}

	//更新內(nèi)容設(shè)置
	protected function parseSets($data)
	{
		$sets = [];
		foreach ($data as $key => $value) {
			 if (in_array($key,$this->fields)) {
			 	$sets[] = $key . '=' . $this->parseValue($value);
			 }
		}
		return join(',',$sets);
	}


	//刪除方法
	public function delete()
	{
		$sql = "delete from %TABLE% %WHERE% %ORDER% %LIMIT%";

		$newsql = str_replace(
					array(
						'%TABLE%',
						'%WHERE%',
						'%ORDER%',
						'%LIMIT%'
					),
					array(
						$this->parseTable(),
						$this->parseWhere(),
						$this->parseOrder(),
						$this->parseLimit(),
					),
					$sql
				);

		$this->sql = $newsql;

		return $this->exec($newsql);
	}

	//求總數(shù)
	public function sum($field = null )
	{
		if (is_null($field)) {
			$field = $this->fields['_pk'];
		}

		$sql = "select count($field) as sum from %TABLE% %WHERE% ";

		$newsql = str_replace(
						array(
							'%TABLE%',
							'%WHERE%',
						),
						array(
							$this->parseTable(),
							$this->parseWhere(),
							),
						$sql
				);
		$this->sql = $newsql;
		$data = $this->query($newsql);
		return $data[0]['sum'];
	}
	//求最大數(shù)
	public function max($field = null )
	{
		if (is_null($field)) {
			$field = $this->fields['_pk'];
		}

		$sql = "select max($field) as max from %TABLE% %WHERE% ";

		$newsql = str_replace(
					array(
						'%TABLE%',
						'%WHERE%',
					),
					array(
						$this->parseTable(),
						$this->parseWhere(),
					),
					$sql
				);
		$this->sql = $newsql;
		$data = $this->query($newsql);
		return $data[0]['max'];
	}
	//求最小數(shù)
	public function min($field = null )
	{
		if (is_null($field)) {
			$field = $this->fields['_pk'];
		}

		$sql = "select min($field) as min from %TABLE% %WHERE% ";

		$newsql = str_replace(
					array(
						'%TABLE%',
						'%WHERE%',
					),
					array(
						$this->parseTable(),
						$this->parseWhere(),
					),
					$sql
				);
		$this->sql = $newsql;
		$data = $this->query($newsql);
		return $data[0]['min'];
	}
	//求平均數(shù)
	public function avg($field = null )
	{
		if (is_null($field)) {
			$field = $this->fields['_pk'];
		}

		$sql = "select avg($field) as avg from %TABLE% %WHERE% ";

		$newsql = str_replace(
					array(
						'%TABLE%',
						'%WHERE%',
					),
					array(
						$this->parseTable(),
						$this->parseWhere(),
					),
					$sql
				);
		$this->sql = $newsql;
		$data = $this->query($newsql);
		return $data[0]['avg'];
	}


	//自動(dòng)的一個(gè)按照字段來查詢的智能化查詢方法
	protected function getBy($field,$value)
	{
		$sql = "select %FIELDS% from %TABLE% %WHERE%";

		$newsql = str_replace(
					array(
						'%FIELDS%',
						'%TABLE%',
						'%WHERE%'
					),
					array(
						$this->parseFields(),
						$this->parseTable(),
						' WHERE '.$field . "='$value'",
					),
					$sql
				);
		$this->sql = $newsql;
		echo $newsql;
		return $this->query($newsql);
	}

	//__call方法，針對(duì)用戶請(qǐng)求limit(), order(),group()等將其保存到options中， 判斷其方法合法性;
	//并且return $this 讓其能夠連貫操作，
	public function __call($func,$args)
	{
		//合法的
		$allow = ['where','table','fields','order','limit','group','having'];
		//把傳入的統(tǒng)一轉(zhuǎn)化為小寫
		$func = strtolower($func);
		if (in_array($func,$allow)) {
			$this->options[$func] = $args;
			return $this;
		} else if(substr($func,0,5) == 'getby'){
			$field = substr($func,5);

			if (in_array($field,$this->fields)) {
				return $this->getBy($field,$args[0]);
			}
		} else {
			exit ('方法不合法！');
		}

	}

	//析構(gòu)方法 關(guān)閉頁面/對(duì)象消費(fèi)時(shí)候調(diào)用
	public function __destruct()
	{
		mysqli_close($this->link);
	}
}

三、測(cè)試（驗(yàn)證）代碼：

//包含文件
$config = include 'config.php';

$blog = new UserModel($config);
//測(cè)試查詢

$data = $blog->fields('uid,uesrname,password')->table('bbs_user')->limit([1,2])->order('uid desc ')->group('username')->select();

var_dump($data);

//插入測(cè)試
$_POST['uesrname'] = 'chen';
$_POST['password'] = 123456;
$_POST['creatime'] = 123423;

$_POST['senlin'] = '不存在的字段處理';

echo $blog->insert($_POST);

//更新測(cè)試

$_POST['uesrname'] = '1kkkkk12';
$_POST['password'] = 123456;
$_POST['createtime'] = 234567;
$_POST['haiyan'] = '你可長點(diǎn)心眼吧';
echo $blog->where('uid>0')->limit('1')->update($_POST);

//刪除測(cè)試
echo $blog->where('uid>0 and uid<2')->delete();

//測(cè)試求和
echo $blog->sum('uid');

//測(cè)試求最大數(shù)
echo $blog->max('uid');

//測(cè)試求最小數(shù)
echo $blog->min();

//測(cè)試求平均數(shù)
echo $blog->avg();

//測(cè)試自動(dòng)的一個(gè)按照字段來查詢
$data = $blog->getByPassword('123456');
var_dump($data);