|
|
|
สอบถามวิธี Insert into แบบ array ครับ เป็นกรณีศึกษาครับ คือผม งง |
|
|
|
|
|
|
|
เหมือนเคยเขียนถามไปแล้วนะครับ แต่คําผมที่ได้ ผมอาจจะยัง งง เลยอยากให้ทําตัวอย่างให้ดูทีครับจะได้ ต่อยอดได้
คือผมอยากทํา class แล้วประกอบไปด้วย Method Insert Update Delete เพื่อเขียน Class มาทีเดียวแล้วใช่ได้ตลอด
จากโค๊ดให้ดูที่ Method Insertครับ คือถ้าผมต้องการให้มันระบุ column เพื่อมันจะได้ลงถูก Column ยังไงครับ แล้วข้อมูลที่จะเอามาลงต้องเป็น แบบarray ครับ เช่น Multi Upload ครับ
Code (PHP)
public function connect()
{
if(!$this->con)
{
$myconn = @mysql_connect($this->db_host,$this->db_user,$this->db_pass);
if($myconn)
{
$seldb = @mysql_select_db($this->db_name,$myconn);
if($seldb)
{
$this->con = true;
return true;
}
else
{
return false;
}
}
else
{
return false;
}
}
else
{
return true;
}
}
/*
* Changes the new database, sets all current results
* to null
*/
public function setDatabase($name)
{
if($this->con)
{
if(@mysql_close())
{
$this->con = false;
$this->results = null;
$this->db_name = $name;
$this->connect();
}
}
}
/*
* Checks to see if the table exists when performing
* queries
*/
private function tableExists($table)
{
$tablesInDb = @mysql_query('SHOW TABLES FROM '.$this->db_name.' LIKE "'.$table.'"');
if($tablesInDb)
{
if(mysql_num_rows($tablesInDb)==1)
{
return true;
}
else
{
return false;
}
}
}
/*
* Selects information from the database.
* Required: table (the name of the table)
* Optional: rows (the columns requested, separated by commas)
* where (column = value as a string)
* order (column DIRECTION as a string)
*/
public function select($table, $rows = '*', $where = null, $order = null)
{
$q = 'SELECT '.$rows.' FROM '.$table;
if($where != null)
$q .= ' WHERE '.$where;
if($order != null)
$q .= ' ORDER BY '.$order;
$query = @mysql_query($q);
if($query)
{
$this->numResults = mysql_num_rows($query);
for($i = 0; $i < $this->numResults; $i++)
{
$r = mysql_fetch_array($query);
$key = array_keys($r);
for($x = 0; $x < count($key); $x++)
{
// Sanitizes keys so only alphavalues are allowed
if(!is_int($key[$x]))
{
if(mysql_num_rows($query) > 1)
$this->result[$i][$key[$x]] = $r[$key[$x]];
else if(mysql_num_rows($query) < 1)
$this->result = null;
else
$this->result[$key[$x]] = $r[$key[$x]];
}
}
}
return true;
}
else
{
return false;
}
}
/*
* Insert values into the table
* Required: table (the name of the table)
* values (the values to be inserted)
* Optional: rows (if values don't match the number of rows)
*/
public function insert($table,$values,$rows = null)
{
if($this->tableExists($table))
{
$insert = 'INSERT INTO '.$table;
if($rows != null)
{
$insert .= ' ('.$rows.')';
}
for($i = 0; $i < count($values); $i++)
{
if(is_string($values[$i]))
$values[$i] = '"'.$values[$i].'"';
}
$values = implode(',',$values);
$insert .= ' VALUES ('.$values.')';
$ins = @mysql_query($insert);
if($ins)
{
return true;
}
else
{
return false;
}
}
}
/*
* Deletes table or records where condition is true
* Required: table (the name of the table)
* Optional: where (condition [column = value])
*/
public function delete($table,$where = null)
{
if($this->tableExists($table))
{
if($where == null)
{
$delete = 'DELETE '.$table;
}
else
{
$delete = 'DELETE FROM '.$table.' WHERE '.$where;
}
$del = @mysql_query($delete);
if($del)
{
return true;
}
else
{
return false;
}
}
else
{
return false;
}
}
/*
* Updates the database with the values sent
* Required: table (the name of the table to be updated
* rows (the rows/values in a key/value array
* where (the row/condition in an array (row,condition) )
*/
public function update($table,$rows,$where)
{
if($this->tableExists($table))
{
// Parse the where values
// even values (including 0) contain the where rows
// odd values contain the clauses for the row
for($i = 0; $i < count($where); $i++)
{
if($i%2 != 0)
{
if(is_string($where[$i]))
{
if(($i+1) != null)
$where[$i] = '"'.$where[$i].'" AND ';
else
$where[$i] = '"'.$where[$i].'"';
}
}
}
$where = implode('',$where);
$update = 'UPDATE '.$table.' SET ';
$keys = array_keys($rows);
for($i = 0; $i < count($rows); $i++)
{
if(is_string($rows[$keys[$i]]))
{
$update .= $keys[$i].'="'.$rows[$keys[$i]].'"';
}
else
{
$update .= $keys[$i].'='.$rows[$keys[$i]];
}
// Parse to add commas
if($i != count($rows)-1)
{
$update .= ',';
}
}
$update .= ' WHERE '.$where;
$query = @mysql_query($update);
if($query)
{
return true;
}
else
{
return false;
}
}
else
{
return false;
}
}
/*
* Returns the result set
*/
public function getResult()
{
return $this->result;
}
}
?>
Tag : PHP
|
|
|
|
|
|
Date :
2013-04-04 21:30:30 |
By :
kenghockey |
View :
1184 |
Reply :
1 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
ตัวอย่าง ก็ต้องระวังพวก type ที่กำหนดในฐานข้อมูลด้วยครับไม่งานทำงานไม่ได้
Code (PHP)
public function insert($table, $params = array()) {
if (!self::tableExists($table)) {
return FALSE;
} else {
$sql = 'INSERT INTO ' . $table;
$this->sql = $sql;
var_dump($params);
if (!is_array($params))
return 'Required paramse(array) -> ' . $params;
foreach ($params as $key => $value) {
if($value){
$keys[] = $key;
$val[] = is_string($value) ? ('"' . $value . '"') : $value;
}
}
$sql .= ' (' . implode(',', $keys) . ') VALUES (' . implode(',', $val) . ')';
$this->sql = $sql;
$q = mysqli_query($this->conn, $sql);
if (!$q)
return FALSE;
else
return mysqli_insert_id($this->conn);
}
}
$table = 'mytable';
$insert = array(
'inumber' => 1234,
'txt' => strval(987654) // string
);
https://www.thaicreate.com/php/forum/093417.html
|
ประวัติการแก้ไข 2013-04-05 00:52:28 2013-04-05 04:33:47
|
|
|
|
Date :
2013-04-05 00:50:43 |
By :
t-monroe |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Load balance : Server 02
|