用PHP将数组插入MySQL数据库
我有我想要存储在我的数据库中的以下数组…
$insData = array( 'uid' => $fbme['id'], 'first_name' => $fbme['first_name'], 'last_name' => $fbme['last_name'], 'email' => isset($fbme['email']) ? $fbme['email'] : '', 'link' => $fbme['link'], 'affiliations' => $networks, 'birthday' => $info[0]['birthday_date'], 'current_location' => isset($fbme['location']['name']) ? $fbme['location']['name'] : '', 'education_history' => $education, 'work' => $workInfo, 'hometown_location' => isset($fbme['hometown']['name']) ? $fbme['hometown']['name'] : '', 'interests' => $info[0]['interests'], 'locale' => $info[0]['locale'], 'movies' => $movies, 'music' => $music, 'political' => $info[0]['political'], 'relationship_status' => $info[0]['relationship_status'], 'sex' => isset($fbme['gender']) ? $fbme['gender'] : '', 'tv' => $television, 'status' => '0', 'created' => $now, 'updated' => $now, ); 我试图search谷歌如何做到这一点，所有我可以find的信息，说明我的数组需要拆分之前，插入到表中。 它是否正确？ 对不起，对于PHP来说很新颖。
你不能直接插入数组作为MySQL ，因为MySQL不理解PHP数据types。 Mysql只理解SQL 。 所以要插入一个数组到MySQL数据库，你必须将其转换为一个SQL语句。 这可以手动完成或通过库。 输出应该是一个INSERT语句。
这是一个标准的mysql插入语句。
INSERT INTO TABLE1(COLUMN1, COLUMN2, ....) VALUES (VALUE1, VALUE2..)
如果你有一个名字为fbdata的表格，而你的数组键中有列，你可以插入这个小代码片段。 这里是你的数组如何转换为这个语句。
$columns = implode(", ",array_keys($insData)); $escaped_values = array_map('mysql_real_escape_string', array_values($insData)); $values = implode(", ", $escaped_values); $sql = "INSERT INTO `fbdata`($columns) VALUES ($values)";
更新PHP7
由于PHP 5.5 mysql_real_escape_string已被弃用，从PHP7开始，它已被删除。 请参阅： 关于新程序的Php.net文档。
有许多不同的方法…我会给你一个使用准备好的语句的例子：
$prep = array(); foreach($insData as $k => $v ) { $prep[':'.$k] = $v; } $sth = $db->prepare("INSERT INTO table ( " . implode(', ',array_keys($insData)) . ") VALUES (" . implode(', ',array_keys($prep)) . ")"); $res = $sth->execute($prep);
我在这里作弊，并假设你的第一个数组中的键是SQL表中的列名。 我也假设你有PDO可用。 更多可以在http://php.net/manual/en/book.pdo.phpfind
这是基于公认的答案我的完整解决scheme。
用法示例：
include("./assets/php/db.php"); $data = array('field1' => 'data1', 'field2'=> 'data2'); insertArr("databaseName.tableName", $data);
db.php中
<?PHP /** * Class to initiate a new MySQL connection based on $dbInfo settings found in dbSettings.php * * @example * $db = new database(); // Initiate a new database connection * mysql_close($db->get_link()); */ class database{ protected $databaseLink; function __construct(){ include "dbSettings.php"; $this->database = $dbInfo['host']; $this->mysql_user = $dbInfo['user']; $this->mysql_pass = $dbInfo['pass']; $this->openConnection(); return $this->get_link(); } function openConnection(){ $this->databaseLink = mysql_connect($this->database, $this->mysql_user, $this->mysql_pass); } function get_link(){ return $this->databaseLink; } } /** * Insert an associative array into a MySQL database * * @example * $data = array('field1' => 'data1', 'field2'=> 'data2'); * insertArr("databaseName.tableName", $data); */ function insertArr($tableName, $insData){ $db = new database(); $columns = implode(", ",array_keys($insData)); $escaped_values = array_map('mysql_real_escape_string', array_values($insData)); foreach ($escaped_values as $idx=>$data) $escaped_values[$idx] = "'".$data."'"; $values = implode(", ", $escaped_values); $query = "INSERT INTO $tableName ($columns) VALUES ($values)"; mysql_query($query) or die(mysql_error()); mysql_close($db->get_link()); } ?>
dbSettings.php
<?PHP $dbInfo = array( 'host' => "localhost", 'user' => "root", 'pass' => "password" ); ?>
对数组进行序列化 ，并在数据库列上有一个文本，这将解决问题。
我这样做，例如保存对象，这样我可以轻松地检索它们。
就我个人而言，我会json_encode数组（考虑到任何逃逸等需要），并把整个整个地段进入适当大小的文本/ blob字段。
这使得非常容易地存储“非结构化”数据，而是一个真正的PITA来search/索引任何宽限期。
一个简单的json_decode会将数据“爆炸”回你的数组中。
插入数组数据到MySQL的PHP
我有arrays数据..我想在数据库中发布数据
1：这是我的数组数据：
stdClass Object ( [questions] => Array ( [0] => stdClass Object ( [question_id] => 54 [question] => Which%20of%20the%20following%20is%20a%20rational%20number%20(s)%3F%3Cbr%20%2F%3E%0D%0A%3Cbr%20%2F%3E [option_1] => %3Cimg%20align%3D%22middle%22%20%20%20src%3D%22formula%2F54%2F010779c34ce28fee25778247e127b82d.png%22%20alt%3D%22%22%20%2F%3E%3Cspan%20class%3D%22Apple-tab-span%22%20style%3D%22white-space%3A%20pre%3B%20%22%3E%09%3C%2Fspan%3E [option_2] => %26nbsp%3B%3Cimg%20align%3D%22middle%22%20%20%20src%3D%22formula%2F54%2F3af35a16c371ffaaf9ea6891fb732478.png%22%20alt%3D%22%22%20%2F%3E [option_3] => %26nbsp%3B%3Cimg%20align%3D%22middle%22%20%20%20src%3D%22formula%2F54%2F4a57d5766a79f0ddf659d63c7443982b.png%22%20alt%3D%22%22%20%2F%3E [option_4] => %26nbsp%3BAll%20the%20above%26nbsp%3B [iscorrect] => yes [answerGiven] => D [marksobtain] => 2 [timetaken] => 3 [difficulty_levelval] => 2 ) [1] => stdClass Object ( [question_id] => 58 [question] => %3Cdiv%3EIf%20A%20%26nbsp%3B%3A%20Every%20whole%20number%20is%20a%20natural%20number%20and%3C%2Fdiv%3E%0D%0A%3Cdiv%3E%26nbsp%3B%20%26nbsp%3BR%20%3A%200%20is%20not%20a%20natural%20number%2C%3C%2Fdiv%3E%0D%0A%3Cdiv%3EThen%20which%20of%20the%20following%20statement%20is%20true%3F%3C%2Fdiv%3E [option_1] => %26nbsp%3BA%20is%20False%20and%20R%20is%20true. [option_2] => A%20is%20True%20and%20R%20is%20the%20correct%20explanation%20of%20A [option_3] => %26nbsp%3BA%20is%20True%20and%20R%20is%20false [option_4] => %26nbsp%3BBoth%20A%20and%20R%20are%20True [iscorrect] => no [answerGiven] => D [marksobtain] => 0 [timetaken] => 2 [difficulty_levelval] => 2 ) ) )
我用来插入数据的代码：
代码::
<?php //require_once("config_new2012.php"); require("codelibrary/fb/facebook.php"); include("codelibrary/inc/variables.php"); include_once(INC."functions.php"); include_once(CLASSES."frontuser_class.php"); include_once(CLASSES."testdetails_class.php"); $data = file_get_contents('php://input'); $arr_data = explode("=",$data); $final_data = urldecode($arr_data[1]); $final_data2 = json_decode($final_data); //print_r ($final_data2); if(is_array($final_data2)){ echo 'i am in array '; $sql = "INSERT INTO p_user_test_details(question_id, question, option_1, option_2, option_3, option_4,iscorrect,answerGiven,marksobtain,timetaken,difficulty_levelval) values "; $valuesArr = array(); foreach($final_data2 as $row){ $question_id = (int) $row['question_id']; $question = mysql_real_escape_string( $row['question'] ); $option_1 = mysql_real_escape_string( $row['option_1'] ); $option_2 = mysql_real_escape_string( $row['option_2'] ); $option_3 = mysql_real_escape_string( $row['option_3'] ); $option_4 = mysql_real_escape_string( $row['option_4'] ); $iscorrect = mysql_real_escape_string( $row['iscorrect'] ); $answerGiven = mysql_real_escape_string( $row['answerGiven'] ); $marksobtain = mysql_real_escape_string( $row['marksobtain'] ); $timetaken = mysql_real_escape_string( $row['timetaken'] ); $difficulty_levelval = mysql_real_escape_string( $row['difficulty_levelval'] ); $valuesArr[] = "('$question_id', '$question', '$option_1','$option_2','$option_3','$option_4','$iscorrect','$answerGiven','$marksobtain','$timetaken','$difficulty_levelval')"; } $sql .= implode(',', $valuesArr); mysql_query($sql) or exit(mysql_error()); } else{ echo 'no one is there '; }
我search了同样的问题，但我想将数组存储在一个不添加数组作为元组的字段中，所以您可能需要函数serialize（）和unserialize（）。
看到这个http://www.wpfasthelp.com/insert-php-array-into-mysql-database-table-row-field.htm
也许这将是复杂的这个queston，但它肯定会为你做的工作。 我创build了两个类来处理不仅数组插入，而且还要查询数据库，更新和删除文件。 “MySqliConnection”类用于创build只有一个数据库连接的实例（以防止重复的新对象）。
<?php /** * * MySQLi database connection: only one connection is allowed */ class MySqliConnection{ public static $_instance; public $_connection; public function __construct($host, $user, $password, $database){ $this->_connection = new MySQLi($host, $user, $password, $database); if (isset($mysqli->connect_error)) { echo "Failed to connect to MySQL: (" . $mysqli->connect_errno . ") " . $mysqli->connect_error; echo $mysqli->host_info . "\n"; } } /* * Gets instance of connection to database * @return (MySqliConnection) Object */ public static function getInstance($host, $user, $password, $database){ if(!self::$_instance){ self::$_instance = new self($host, $user, $password, $database); //if no instance were created - new one will be initialize } return self::$_instance; //return already exsiting instance of the database connection } /* * Prevent database connection from bing copied while assignig the object to new wariable * @return (MySqliConnection) Object */ public function getConnection(){ return $this->_connection; } /* * Prevent database connection from bing copied/duplicated while assignig the object to new wariable * @return nothing */ function __clone(){ } } /*// CLASS USE EXAMPLE $db = MySqliConnection::getInstance('localhost', 'root', '', 'sandbox'); $mysqli = $db->getConnection(); $sql_query = 'SELECT * FROM users; $this->lastQuery = $sql_query; $result = $mysqli->query($sql_query); while($row = $result->fetch_array(MYSQLI_ASSOC)){ echo $row['ID']; } */
secound“TableManager”类稍微复杂一些。 它也使用我上面发布的MySqliConnection类。 所以你必须在你的项目中包含他们两个。 TableManager将允许您轻松更新和删除insetrion。 类有sepparate占位符读写。
<?php /* * DEPENDENCIES: * include 'class.MySqliConnection.inc'; //custom class * */ class TableManager{ private $lastQuery; private $lastInsertId; private $tableName; private $tableIdName; private $columnNames = array(); private $lastResult = array(); private $curentRow = array(); private $newPost = array(); /* * Class constructor * [1] (string) $tableName // name of the table which you want to work with * [2] (string) $tableIdName // name of the ID field which will be used to delete and update records * @return void */ function __construct($tableName, $tableIdName){ $this->tableIdName = $tableIdName; $this->tableName = $tableName; $this->getColumnNames(); $this->curentRow = $this->columnNames; } public function getColumnNames(){ $sql_query = 'SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE table_name = "'.$this->tableName.'"'; $mysqli = $this->connection(); $this->lastQuery = $sql_query; $result = $mysqli->query($sql_query); if (!$result) { throw new Exception("Database Error [{$this->database->errno}] {$this->database->error}"); } while($row = $result->fetch_array(MYSQLI_ASSOC)){ $this->columnNames[$row['COLUMN_NAME']] = null; } } /* * Used by a Constructor to set native parameters or virtual array curentRow of the class * [1] (array) $v * @return void */ function setRowValues($v){ if(!is_array($v)){ $this->curentRow = $v; return true; } foreach ($v as $a => $b) { $method = 'set'.ucfirst($a); if(is_callable(array($this, $method))){ //if method is callable use setSomeFunction($k, $v) to filter the value $this->$method($b); }else{ $this->curentRow[$a] = $b; } } } /* * Used by a constructor to set native parameters or virtual array curentRow of the class * [0] * @return void */ function __toString(){ var_dump($this); } /* * Query Database for information - Select column in table where column = somevalue * [1] (string) $column_name // name od a column * [2] (string) $quote_pos // searched value in a specified column * @return void */ public function getRow($column_name = false, $quote_post = false){ $mysqli = $this->connection(); $quote_post = $mysqli->real_escape_string($quote_post); $this->tableName = $mysqli->real_escape_string($this->tableName); $column_name = $mysqli->real_escape_string($column_name); if($this->tableName && $column_name && $quote_post){ $sql_query = 'SELECT * FROM '.$this->tableName.' WHERE '.$column_name.' = "'.$quote_post.'"'; $this->lastQuery = $sql_query; $result = $mysqli->query($sql_query); if (!$result) { throw new Exception("Database Error [{$this->database->errno}] {$this->database->error}"); } while($row = $result->fetch_array(MYSQLI_ASSOC)){ $this->lastResult[$row['ID']] = $row; $this->setRowValues($row); } } if($this->tableName && $column_name && !$quote_post){ $sql_query = 'SELECT '.$column_name.' FROM '.$this->tableName.''; $this->lastQuery = $sql_query; $result = $mysqli->query($sql_query); if (!$result) { throw new Exception("Database Error [{$this->database->errno}] {$this->database->error}"); } while($row = $result->fetch_array(MYSQLI_ASSOC)){ $this->lastResult[] = $row; $this->setRowValues($row); } } if($this->tableName && !$column_name && !$quote_post){ $sql_query = 'SELECT * FROM '.$this->tableName.''; $this->lastQuery = $sql_query; $result = $mysqli->query($sql_query); if (!$result) { throw new Exception("Database Error [{$this->database->errno}] {$this->database->error}"); } while($row = $result->fetch_array(MYSQLI_ASSOC)){ $this->lastResult[$row['ID']] = $row; $this->setRowValues($row); } } } /* * Connection class gets instance of db connection or if not exsist creats one * [0] * @return $mysqli */ private function connection(){ $this->lastResult = ""; $db = MySqliConnection::getInstance('localhost', 'root', '', 'sandbox'); $mysqli = $db->getConnection(); return $mysqli; } /* * ... * [1] (string) $getMe * @return void */ function __get($getMe){ if(isset($this->curentRow[$getMe])){ return $this->curentRow[$getMe]; }else{ throw new Exception("Error Processing Request - No such a property in (array) $this->curentRow", 1); } } /* * ... * [2] (string) $setMe, (string) $value * @return void */ function __set($setMe, $value){ $temp = array($setMe=>$value); $this->setRowValues($temp); } /* * Dumps the object * [0] * @return void */ function dump(){ echo "<hr>"; var_dump($this); echo "<hr>"; } /* * Sets Values for $this->newPost array which will be than inserted by insertNewPost() function * [1] (array) $newPost //array of avlue that will be inserted to $this->newPost * @return bolean */ public function setNewRow($arr){ if(!is_array($arr)){ $this->newPost = $arr; return false; } foreach ($arr as $k => $v) { if(array_key_exists($k, $this->columnNames)){ $method = 'set'.ucfirst($k); if(is_callable(array($this, $method))){ if($this->$method($v) == false){ //if something go wrong $this->newPost = array(); //empty the newPost array and return flase throw new Exception("There was a problem in setting up New Post parameters. [Cleaning array]", 1); } }else{ $this->newPost[$k] = $v; } }else{ $this->newPost = array(); //empty the newPost array and return flase throw new Exception("The column does not exsist in this table. [Cleaning array]", 1); } } } /* * Inserts new post held in $this->newPost * [0] * @return bolean */ public function insertNewRow(){ // check if is set, is array and is not null if(isset($this->newPost) && !is_null($this->newPost) && is_array($this->newPost)){ $mysqli = $this->connection(); $count_lenght_of_array = count($this->newPost); // preper insert query $sql_query = 'INSERT INTO '.$this->tableName.' ('; $i = 1; foreach ($this->newPost as $key => $value) { $sql_query .=$key; if ($i < $count_lenght_of_array) { $sql_query .=', '; } $i++; } $i = 1; $sql_query .=') VALUES ('; foreach ($this->newPost as $key => $value) { $sql_query .='"'.$value.'"'; if ($i < $count_lenght_of_array) { $sql_query .=', '; } $i++; } $sql_query .=')'; var_dump($sql_query); if($mysqli->query($sql_query)){ $this->lastInsertId = $mysqli->insert_id; $this->lastQuery = $sql_query; } $this->getInsertedPost($this->lastInsertId); } } /* * getInsertedPost function query the last inserted id and assigned it to the object. * [1] (integer) $id // last inserted id from insertNewRow fucntion * @return void */ private function getInsertedPost($id){ $mysqli = $this->connection(); $sql_query = 'SELECT * FROM '.$this->tableName.' WHERE '.$this->tableIdName.' = "'.$id.'"'; $result = $mysqli->query($sql_query); while($row = $result->fetch_array(MYSQLI_ASSOC)){ $this->lastResult[$row['ID']] = $row; $this->setRowValues($row); } } /* * getInsertedPost function query the last inserted id and assigned it to the object. * [0] * @return bolean // if deletion was successful return true */ public function deleteLastInsertedPost(){ $mysqli = $this->connection(); $sql_query = 'DELETE FROM '.$this->tableName.' WHERE '.$this->tableIdName.' = '.$this->lastInsertId.''; $result = $mysqli->query($sql_query); if($result){ $this->lastResult[$this->lastInsertId] = "deleted"; return true; }else{ throw new Exception("We could not delete last inserted row by ID [{$mysqli->errno}] {$mysqli->error}"); } var_dump($sql_query); } /* * deleteRow function delete the row with from a table based on a passed id * [1] (integer) $id // id of the table row to be delated * @return bolean // if deletion was successful return true */ public function deleteRow($id){ $mysqli = $this->connection(); $sql_query = 'DELETE FROM '.$this->tableName.' WHERE '.$this->tableIdName.' = '.$id.''; $result = $mysqli->query($sql_query); if($result){ $this->lastResult[$this->lastInsertId] = "deleted"; return true; }else{ return false; } var_dump($sql_query); } /* * deleteAllRows function deletes all rows from a table * [0] * @return bolean // if deletion was successful return true */ public function deleteAllRows(){ $mysqli = $this->connection(); $sql_query = 'DELETE FROM '.$this->tableName.''; $result = $mysqli->query($sql_query); if($result){ return true; }else{ return false; } } /* * updateRow function updates all values to object values in a row with id * [1] (integer) $id * @return bolean // if deletion was successful return true */ public function updateRow($update_where = false){ $id = $this->curentRow[$this->tableIdName]; $mysqli = $this->connection(); $updateMe = $this->curentRow; unset($updateMe[$this->tableIdName]); $count_lenght_of_array = count($updateMe); // preper insert query $sql_query = 'UPDATE '.$this->tableName.' SET '; $i = 1; foreach ($updateMe as $k => $v) { $sql_query .= $k.' = "'.$v.'"'; if ($i < $count_lenght_of_array) { $sql_query .=', '; } $i++; } if($update_where == false){ //update row only for this object id $sql_query .=' WHERE '.$this->tableIdName.' = '.$this->curentRow[$this->tableIdName].''; }else{ //add your custom update where query $sql_query .=' WHERE '.$update_where.''; } var_dump($sql_query); if($mysqli->query($sql_query)){ $this->lastQuery = $sql_query; } $result = $mysqli->query($sql_query); if($result){ return true; }else{ return false; } } } /*TO DO 1 insertPost(X, X) write function to isert data and in to database; 2 get better query system and display data from database; 3 write function that displays data of a object not databsae; object should be precise and alocate only one instance of the post at a time. // Updating the Posts to curent object $this->curentRow values ->updatePost(); // Deleting the curent post by ID // Add new row to database */ /* USE EXAMPLE $Post = new TableManager("post_table", "ID"); // New Object // Getting posts from the database based on pased in paramerters $Post->getRow('post_name', 'SOME POST TITLE WHICH IS IN DATABASE' ); $Post->getRow('post_name'); $Post->getRow(); MAGIC GET will read current object $this->curentRow parameter values by refering to its key as in a varible name echo $Post->ID. echo $Post->post_name; echo $Post->post_description; echo $Post->post_author; $Task = new TableManager("table_name", "table_ID_name"); // creating new TableManager object $addTask = array( //just an array [colum_name] => [values] 'task_name' => 'New Post', 'description' => 'New Description Post', 'person' => 'New Author', ); $Task->setNewRow($addTask); //preper new values for insertion to table $Task->getRow('ID', '12'); //load value from table to object $Task->insertNewRow(); //inserts new row $Task->dump(); //diplays object properities $Task->person = "John"; //magic __set() method will look for setPerson(x,y) method firs if non found will assign value as it is. $Task->description = "John Doe is a funny guy"; //magic __set() again $Task->task_name = "John chellange"; //magic __set() again $test = ($Task->updateRow("ID = 5")) ? "WORKS FINE" : "ERROR"; //update cutom row with object values echo $test; $test = ($Task->updateRow()) ? "WORKS FINE" : "ERROR"; //update curent data loaded in object echo $test; */
<?php function mysqli_insert_array($table, $data, $exclude = array()) { $con= mysqli_connect("localhost", "root","","test"); $fields = $values = array(); if( !is_array($exclude) ) $exclude = array($exclude); foreach( array_keys($data) as $key ) { if( !in_array($key, $exclude) ) { $fields[] = "`$key`"; $values[] = "'" . mysql_real_escape_string($data[$key]) . "'"; } } $fields = implode(",", $fields); $values = implode(",", $values); if( mysqli_query($con,"INSERT INTO `$table` ($fields) VALUES ($values)") ) { return array( "mysql_error" => false, "mysql_insert_id" => mysqli_insert_id($con), "mysql_affected_rows" => mysqli_affected_rows($con), "mysql_info" => mysqli_info($con) ); } else { return array( "mysql_error" => mysqli_error($con) ); } } $a['firstname']="abc"; $a['last name']="xyz"; $a['birthdate']="1993-09-12"; $a['profilepic']="img.jpg"; $a['gender']="male"; $a['email']="abc@hightecit.com"; $a['likechoclate']="Dm"; $a['status']="1"; $result=mysqli_insert_array('registration',$a,'abc'); if( $result['mysql_error'] ) { echo "Query Failed: " . $result['mysql_error']; } else { echo "Query Succeeded! <br />"; echo "<pre>"; print_r($result); echo "</pre>"; } ?>
你有两种方法来做到这一点：
- 您可以创build一个表格（或多个表格链接在一起），并为每个数组的键值添加一个字段，并在每个字段中插入数组的相应值。 这是最常见的方式
- 你可以有一个字段的表，并把你的数组序列化在这里。 我不build议你这样做，但是如果你不想要一个复杂的数据库模式，这是有用的。
让我们不要忘记从这样的问题中学习最重要的东西： SQL注入 。
使用PDO并准备好语句 。
点击这里查看PDO教程。
最近，我正在学习Wordpress，它提供了一个WP_QUERY类来操作数据库。 您可以将数组或对象插入到数据库中。我觉得这很棒，所以我去看看如何实现它。也许有一些想法可以从中获得。主要function是： apply_filters 。
apply_filters( $tag, $value, $key);
你可以忽略第一个参数，把第二个参数当作数组来处理，函数做的是把数组清理成string。
插入数据库后，你可以看到这个：
key s:12:"focal_length";s:3:"190";s:3:"iso";s:3:"400";s:13:"shutter_speed";s:6:"0.0004";s:5:"title";s:0:"";}}
