PHP--数据库操作

获取表单数据

GET[′′]获取get方式传递的数据，而GET[″]获取get方式传递的数据，而_POST[”]获取POST提交的数据，而REQUEST不管是get还是post。通过REQUEST不管是get还是post。通过_REQUEST获取一个类似于map的键值对数据结构。

执行插入数据

/**
*
*
* @param unknown $sql
*/
function insert($sql) {
$connInfo = getConnection ();

if ($connInfo ['code'] != 1) {
echo json_encode ( $connInfo );
return;
}
$conn = $connInfo ['data'] ['conn'];

//避免数据库乱码
$q=" set names utf8";
$conn->query($q);
// 执行插入
$result=$conn->multi_query($sql);
if ($result === TRUE) {
$data = array (
'id' => $conn->insert_id  // 返回的ID
);
$returnMessage = array (
'code' => 1,
'message' => "添加成功",
'data' => $data
);
} else {
$returnMessage = array (
'code' => - 2,
'message' => '添加失败'
);
}
$conn->close ();
echo json_encode ( $returnMessage );
}

删除

/**
* 删除
*
* @param unknown $delete_sql
*/
function delete($delete_sql) {
$connInfo = getConnection ();
// 检测连接
if ($connInfo ['code'] != 1) {
echo json_encode ( $connInfo );
return;
}
$conn = $connInfo ['data'] ['conn'];
mysqli_query ( $conn, $delete_sql );
mysqli_close ( $conn );
}

更新

/**
*
*
* @param unknown $updata_sql
*/
function update($updata_sql) {
$connInfo = getConnection ();
if ($connInfo ['code'] != 1) {
echo json_encode ( $connInfo );
return;
}
$conn = $connInfo ['data'] ['conn'];
//避免中文乱码
$q=" set names utf8";
$conn->query($q);
mysqli_query ( $conn, $updata_sql );
mysqli_close ( $conn );
}

分页查询数据

/**
*
* @param unknown $select_sql
* @param unknown $from_tab
* @param unknown $where
* @param unknown $order
* @param unknown $limit
* @return multitype:number multitype:unknown
*/
function select_page($select, $from_tab, $where, $order, $limit) {
$data=array();
// 查询总数
$select_total_sql = " SELECT count(*) as total " . $from_tab . $where;
$count=select_count ( $select_total_sql )['data']['total'];
$data['total']=$count;

//分页查数据
$sql=$select.$from_tab.$where.$order.$limit;
$rows=select_rows($sql);

$data['rows']=$rows;

$returnMessage=array('code'=>1,'data'=>$data);
return $returnMessage;
}

获取当前页数据

/**
*
*
* @param unknown $select_sql
* @return multitype:number string
*/
function select_rows($select_sql) {
// 获取数据连接
$connInfo = getConnection ();
if ($connInfo ['code'] != 1) {
$returnMessage = array (
'code' => - 1,
'message' => '数据库连接失败'
);
return $returnMessage;
}

$conn = $connInfo ['data'] ['conn'];
$result = $conn->query ( $select_sql ); // 执行查询

$data = array ();
if ($result->num_rows > 0) {
$rows = array ();
while ( $row = $result->fetch_assoc () ) {
array_push ( $rows, $row );
}
$data ['rows'] = $rows;
}
$conn->close ();

$returnMessage = array (
'code' => 1,
'data' => $data
);
return $returnMessage;
}

获取行数

/**
* 获取行数
*
* @param unknown $select_count
*          select count(*) as total
* @return multitype:number string |unknown
*/
function select_count($select_count) {
// 获取数据连接
$connInfo = getConnection ();
if ($connInfo ['code'] != 1) {
$returnMessage = array (
'code' => - 1,
'message' => '数据库连接失败'
);
return $returnMessage;
}
$conn = $connInfo ['data'] ['conn'];
// 获取总数
$result = $conn->query ( $select_count );
$rows_total = $result->fetch_assoc ()["total"];

$data = array (
'total' => $rows_total
);
$returnMessage = array (
'code' == 1,
'data' => $data
);
return $returnMessage;
}

数据库连接

/**
*
* @param unknown $url
* @param unknown $username
* @param unknown $password
* @param unknown $dbname
* @return Ambigous <multitype:number string , multitype:number string multitype:mysqli >
*/
function getConnection() {
获取require 'Config.php';中的数据库连接信息
// 创建连接
global $url;
global $username;
global $password;
global $db_name;
$conn = new mysqli ( $url, $username, $password, $db_name );

// 检测连接
if ($conn->connect_error) {
$returnMessage = array (
'code' => - 1,
'message' => "连接数据库失败,原因：" . $conn->connect_error
);
} else {
$data = array (
'conn' => $conn
);
$returnMessage = array (
'code' => 1,
'message' => "连接数据库成功: ",
'data' => $data
);
}
return $returnMessage;
}

测试：

/* 添加数据 */
/* $sql=' INSERT INTO user(name,password) VALUES("张三","123123")';
echo json_encode(insert($sql)); */

/* 删除数据 */
/* $delete_sql=" DELETE FROM user WHERE id=19";
elete($delete_sql); */

//修改数据
/* $update_sql=" UPDATE user set name='张三' WHERE id=17 ";
update($update_sql); */

//分页查询数据
$select_sql=" SELECT * ";
$from_tab=" FROM user ";
$where=" WHERE name='张三' ";
$order=" ";
$limit=" ";
echo json_encode(select_page($select_sql, $from_tab, $where, $order, $limit));

参考：

查询结果输出为json格式：https://www.cnblogs.com/yiven/p/6491019.html

批量获取数据并存入数据：http://bbs.blueidea.com/thread-3056406-1-1.html