// ++++++++++++++++++++++++++++++++++++++++++++++++++++
// + PROJECT NAME : PHP OOP CONNECT MYSQL
// + URL DESTINAMTION : http://freecode.siamfocus.com/php_oop_db_connect
// + CREATED BY : SiAMFOCUS.COM
// + CONTACT : ADMIN@SIAMFOCUS.COM
// + CREATED DATE : 26-19-2011
// + TECHNOLOGY : PHP,MYSQL
// +++++++++++++++++++++++++++++++++++++++++++++++++++++
โดยตัวอย่างนี้ผม ทำตัวอย่างให้ดู ทั้ง INSERT,UPDATE,DELETE, และการใช้งานแบบ ARRAY รับรอง แจ่มจริง ไรจริง
Class connectDB
{
private $_host = "localhost";
private $_user = "root";
private $_pass = "db_pass";
private $_db = "oop_test_db";
// Will need a new class Error to handle all errors
private function openDB()
{
$charset = "set names utf8";
$link = mysql_pconnect($this->_host, $this->_user, $this->_pass);
if (!$link) {
die('Could not connect to the server: ' . mysql_error());
}
$db_selected = mysql_select_db($this->_db, $link);
if (!$db_selected) {
die ('Could not connect to the database"' . $this->_db ." get error: " . mysql_error());
}
mysql_query($charset) or die('Invalid query: ' . mysql_error());
}
private function closeDB()
{
mysql_close($link);
}
public function return_sql($sql)
{
self::openDB();
$result = mysql_query($sql);
if ($result){
$arrData = array();
while ($rows = mysql_fetch_array($result)) {$arrData[] = $rows;}
}else{
$message = 'ชุดคำสั่งของ : ' . mysql_error() . " ไม่ถูกต้อง
";
// $message .= 'Whole query: ' . $query;
$message = mysql_error();
die($message);
}
//return the result to a function that will build the right table.
return $arrData;
self::closeDB();
}
public function exe($sql)
{
self::openDB();
$result = mysql_query($sql);
if (!$result) {
$message = 'ชุดคำสั่งของ : ' . mysql_error() . " ไม่ถูกต้อง
";
die($message);
}
}
}
$conn = new connectDB;
$sSql = "DELETE FROM tbl_oop_test";
$arrData = $conn->exe($sSql);
$conn = new connectDB;
$sSql = "INSERT INTO tbl_oop_test (test_name,test_surname) VALUES('ทดสอบ','นามสกุล')";
$arrData = $conn->exe($sSql);
$conn = new connectDB;
$sSql = "UPDATE tbl_oop_test SET test_name = 'ชื่อเสียงเรียงนาม'";
$arrData = $conn->exe($sSql);
$conn = new connectDB;
$sSql = "SELECT count(*) FROM tbl_oop_test";
$arrData = $conn->return_sql($sSql);
print "Recordcount = " . $arrData[0][0] . "
";
$conn = new connectDB;
$sSql = "SELECT * FROM tbl_oop_test";
$arrData = $conn->return_sql($sSql);
print "Name = " . $arrData[0][1] . "
";
print "Surname = " . $arrData[0][2] . "
";