WebSVN – php-qbpwcf – Diff – /trunk/usr/lib64/qbpwcf/db.php

 	#$result["queryString"],mysql查詢的語言.
 	#必填參數：
 	#$conf["fileArgu"],字串,變數__FILE__的內容.
 	$conf["fileArgu"]=__FILE__;
 	#$conf["dbSql"],字串,要執行sql語法
 	$conf["dbSql"]="";
-	#$conf["dbAddress"],字串,爲mysql-Server的位置。
-	$conf["dbAddress"]=$dbAddress;
 	#$conf["dbAccount"],字串,爲用於連入mysql-Server時要使用的帳號。
 	$conf["dbAccount"]=$dbAccount;
 	#可省略參數:
+	#$conf["dbAddress"],字串,爲mysql-Server的位置,若設置為"localhost",則會忽略,預設為不指定,會嘗試透過unix domain socket來存取資料庫.
+	#$conf["dbAddress"]=$dbAddress;
 	#$conf["pre"],陣列,要在本指令前執行的每個指令與參數.$conf["pre"][$i]["cmd"],字串,要在本指令前執行的第$i+1個指令.$conf["pre"][$i]["param"],陣列字串,要在本指令前執行的第$i+1個指令的參數.
 	#$conf["pre"]=array();
 	#$conf["dbPassword"],字串,爲連線到mysql-Server時要使用的密碼，可省略，若省略則代表不使用密碼。
 	#$conf["dbPassword"]=$dbPassword;
 	#$conf["dbName"],字串,爲要連的資料庫名稱
 		#$conf["variableCheck::checkArguments"]["skipableVariableName"],爲可省略參數的變數名稱陣列，形態爲陣列變數，例如: $conf["skipableVariableName"] = array("id","account","password");
 		$conf["variableCheck::checkArguments"]["skipableVariableName"]=array("pre","dbAddress","dbPassword","dbName","dbPort");
 		#$conf["variableCheck::checkArguments"]["skipableVariableType"],爲可省略參數的變數名稱陣列，形態爲陣列變數，例如: $conf["skipableVariableType"] = array("string",integer,"double");
 		$conf["variableCheck::checkArguments"]["skipableVariableType"]=array("array","string","string","string","string");
 		#$conf["variableCheck::checkArguments"]["skipableVarDefaultValue"],字串陣列,每個不存在的可省略變數要初始化為什麼,null與代表不指定,若預設值是必填參數之一，請將$conf["mustBeFilledVar"]改成"\$conf["\mustBeFilledVar\"]".
-		$conf["variableCheck::checkArguments"]["skipableVarDefaultValue"]=array(null,"localhost",null,null,"3306");
+		$conf["variableCheck::checkArguments"]["skipableVarDefaultValue"]=array(null,null,null,null,"3306");
 		#$conf["arrayCountEqualCheck"],字串陣列,為檢查哪些陣列參數的元素數量要一樣,$conf["arrayCountEqualCheck"][$i]=array()為第$i組key為哪些的變數其元素數量要相等.
 		#$conf["arrayCountEqualCheck"][]=array();
 		#參考資料:
 		#array_keys=>http://php.net/manual/en/function.array-keys.php
 		$checkResult=variableCheck::checkArguments($conf["variableCheck::checkArguments"]);
 			#回傳解果
 			return $result;
 			}#if end
-		#shell不接受「`」
-		#函式說明:
-		#處理字串避免網頁出錯
-		#回傳結果:：
-		#$result["status"],執行是否正常,"true"代表正常,"false"代表不正常.
-		#$result["function"],當前執行的函數.
-		#$result["content"],爲處理好的字串.
-		#$result["error"],錯誤訊息陣列.
-		#$result["argu"],使用的參數.
-		#必填參數:
-		$conf["stringProcess::correctCharacter"]["stringIn"]=$conf["dbSql"];#爲要處理的字串
-		#可省略參數:
-		$conf["stringProcess::correctCharacter"]["selectedCharacter"]=array("`");#爲被選擇要處理的字串/字元，須爲陣列值。
-			#若不設定則預設爲要將這些字串作替換 ("<",">","=","//","'","$","%","&","|","/*","*","#","\"").
-			#特殊字元，「\n」代表換行，「\t」代表tab鍵的間隔
-		$conf["stringProcess::correctCharacter"]["changeTo"]=array("");#爲被選擇的字元要換成什麼字串/字元，須爲陣列值。若不設定，則預設爲更換成""(空字串).
-		#備註:
-		#無.
-		$correctCharacter=stringProcess::correctCharacter($conf["stringProcess::correctCharacter"]);
-		unset($conf["stringProcess::correctCharacter"]);
-		#如果檢查失敗
-		if($correctCharacter["status"]=="false"){
-			#設置錯誤識別
-			$result["status"]="false";
-			#設置錯誤訊息
-			$result["error"]=$correctCharacter;
-			#回傳解果
-			return $result;
-			}#if end
-		#取得處理後的 sql
-		$sql=$correctCharacter["content"];
 		#避免亂碼
-		$sql="SET NAMES UTF8;"."SET CHARACTER_SET_CLIENT=utf8;"."SET CHARACTER_SET_RESULTS=utf8;".$sql;
+		$sql="SET NAMES UTF8;"."SET CHARACTER_SET_CLIENT=utf8;"."SET CHARACTER_SET_RESULTS=utf8;".$conf["dbSql"];
 		#初始化參數
 		$argu=array();
 		#精簡的參數
 		$argu[]=$sql;
 		$argu[]="|";
 		$argu[]="mysql";
 		$argu[]="-u";
 		$argu[]=$conf["dbAccount"];
 		#如果有設置 $conf["dbPassword"]
 		if(isset($conf["dbPassword"])){
 			#加上密碼參數
 			$argu[]="-p".$conf["dbPassword"];
 			}#if end
+		#如果有指定 dbAddress
+		if(isset($conf["dbAddress"])){
+			#如果不為 localhost
+			if($conf["dbAddress"]!=="localhost"){
-		#加上 位置參數
+				#加上 位置參數
-		$argu[]="-h".$conf["dbAddress"];
+				$argu[]="-h".$conf["dbAddress"];
+				}#if end
+			}#if end
 		#如果有設置 $conf["dbName"]
 		if(isset($conf["dbName"])){
 			#加上資料庫名稱參數
 			$argu[]=$conf["dbName"];
 			}#if end
-		#建立暫存的檔案
-		#將指令寫入暫存的檔案裡面
 		#函式說明:
 		#呼叫shell執行系統命令,並取得回傳的內容.
 		#回傳結果:
 		#$result["status"],執行是否正常,"true"代表正常,"false"代表不正常.
 		#$result["error"],錯誤訊息陣列.
 		#$result["statusCode"],執行結束後的代碼.
 		#必填的參數
 		#$conf["command"],字串,要執行的指令與.
 		$conf["external::callShell"]["command"]="echo";
 		#$conf["fileArgu"],字串,變數__FILE__的內容.
 		$conf["external::callShell"]["fileArgu"]=$conf["fileArgu"];
 		#可省略參數:
 		#$conf["argu"],陣列字串,指令搭配的參數,預設為空陣列.
 		$conf["external::callShell"]["argu"]=$argu;
 		#$conf["arguIsAddr"],陣列字串,指令搭配的哪些參數為路徑,為路徑的參數會進行轉換以便符合呼叫當前函數的位置,預設不指定,若有3個參數,其中第3個參數為路徑,則表示為array("false","false","true").
 		#$conf["arguIsAddr"]=array();
 		#如果有參數
 		if(count($argu)>0){
 			#$conf["thereIsShellVar"],陣列字串,指令搭配的參數"argu",若含有「\'」,則取代為「"」.每個argu參數都要有對應的元素."true"代表要置換.
 			$conf["external::callShell"]["thereIsShellVar"]=array();
 			#針對每個參數
 			for($i=0;$i<count($argu);$i++){
 				#第一個參數
 				if($i===0){
 		#escapeshellarg=>http://php.net/manual/en/function.escapeshellarg.php
 		$callShell=external::callShell($conf["external::callShell"]);
 		unset($conf["external::callShell"]);
 		#debug
-		#var_dump($callShell);
+		#var_dump(__LINE__,$callShell);
-		#exit;
 		#如果檢查參數作業出錯
 		if($callShell["status"]=="false"){
-			/* debug
-			$fsock=fopen("/var/www/html/log/log.txt","a");
-			fwrite($fsock,"func:".__CLASS__." line:".__LINE__.":".print_r($callShell,true).PHP_EOL.PHP_EOL);
-			fclose($fsock);
-			*/
 			#設置執行錯誤識別
 			$result["status"]="false";
 			#設置錯誤訊息
 			$result["error"]=$callShell;
 			return $result;
 			}#if end
 		#用新的id再傳送一次要求給 qbpwcf_usock_path
 		$paramsOfUnixDomainSockClient["id"]=$jsonRes->id;
 		$unixDomainSockClient=sock::unixDomainSockClient($paramsOfUnixDomainSockClient);
 		unset($paramsOfUnixDomainSockClient);
 		#var_dump($unixDomainSockClient);
 			#回傳結果
 			return $result;
 			}#if end
 		#var_dump($con);
 		#取得mysqli物件
 		$mysqli=$con["connectInformation"];
 		#輸入資料到 資料表 board 的語法
 		$count=count($conf["columnName"]);
 		#跑 $count-1 次,插入第一筆到最倒數第二筆
 		for($i=0;$i<=($count-2);$i++){
 			#放入欲插入的項目名稱
 			$str1=$str1."`".$conf["columnName"][$i]."`".",";
 			}#for end
 		#插入最後一筆項目名稱
 	#$conf["dbPort"],字串,爲連線到mysql-Server時要使用的port，可省略，若省略則代表使用預設的port 3306.
 	#$conf["dbPort"]=$dbPort;
 	#參考資料:
 	#無.
 	#備註:
-	#無.
+	#建議修改 whereValue 參數為多維陣列,每個元素為有兩個元素的陣列,其元素的key為operator者代表運算子,其value可以為"=","<>",">","<",預設為"=";key為value者代表運算元,亦即用來比較的數字、字串等.
 	*/
 	public static function updateDataTableContent($conf){
 		#初始化要回傳的內容
 		$result=array();
 					}#if end
 				#定義 shell script 變數
 				$shellVarDefined[]=array("cmd"=>"x".$i."=","param"=>array($conf["updateDataValue"][$i]));
-				#定義變數
+				#定義sql變數
-				#$varDefined[]="select @x".$i." := '\${x".$i."}';";
+				$varDefined[]="select @x".$i." := '\${x".$i."}';";
-				$varDefined[]="select @x".$i." := \${x".$i."};";
 				#將要更新的內容字串串接，結尾無逗號
 				$chooseColumnSql = $chooseColumnSql."`".$conf["tableColumnName"][$i]."`= @x".$i." ";
 				}#判斷式結束
 			#如果不是最後一項要更新的資料
 			if($i!=($counts-1)){
 				#定義 shell script 變數
 				$shellVarDefined[]=array("cmd"=>"x".$i."=","param"=>array($conf["updateDataValue"][$i]));
-				#sql定義變數
+				#定義sql變數
-				#$varDefined[]="select @x".$i." := '\${x".$i."}';";
+				$varDefined[]="select @x".$i." := '\${x".$i."}';";
-				$varDefined[]="select @x".$i." := \${x".$i."};";
 				#將要更新的內容字串串接，結尾有逗號
 				$chooseColumnSql = $chooseColumnSql."`".$conf["tableColumnName"][$i]."`= @x".$i." ,";
 				}#判斷式結束
 			}#回圈結束
 		#取得條件有幾項
 		$conditionArrayCounts=count($conf["whereColumn"]);
 		#構成條件式
 		for($i=0;$i<$conditionArrayCounts;$i++){
 			#如果是第一筆
-			if($i==0){
+			if($i===0){
 				#尋找的條件式
 				$condition="WHERE `".$conf["whereColumn"][$i]."` = '".$conf["whereValue"][$i]."'";
 				#測試有無抓到第一個條件
 				#var_dump($condition);
 				}#判斷式結束
 			#如果不是第一筆
-			if($i!=0){
+			if($i!==0){
 				#其它條件
 				$condition=$condition." AND `".$conf["whereColumn"][$i]."` = '".$conf["whereValue"][$i]."'";
 				#測試有無抓到其它條件
 		#針對每個要使用的數值
 		foreach($varDefined as $index=>$var){
 			#累加定義變數的sql
 			$varDefineStr=$varDefineStr.$var;
 			}#foreach end
 		#合併所有的語法成一句完整的語法
 		$sqlString = $varDefineStr.$selectUpdateTableSql.$chooseColumnSql.$condition;
+		#debug
+		#var_dump(__LINE__,$sqlString);
 		#設置取得執行的sql語法
 		$result["sql"]=$sqlString;
 		#函式說明:
 		#用shell執行mysql指令.
 			}#if end
 		$shell=db::shell($conf["db::shell"]);
 		unset($conf["db::shell"]);
-		/* debug
-		$fsock=fopen("/var/www/html/log/log.txt","a");
-		fwrite($fsock,"func:".__CLASS__." line:".__LINE__.":".print_r($shell,true).PHP_EOL.PHP_EOL);
-		fclose($fsock);
-		*/
 		#如果執行sql失敗
 		if($shell["status"]==="false"){
 			#設置執行不正常
 			$result["status"]="false";
 			#設置錯誤訊息
 			$result["error"]=$shell;
 			#回傳結果

Subversion Repositories php-qbpwcf

(root)/trunk/usr/lib64/qbpwcf/db.php – Rev 177 → 183