php mysqli 連接數據庫 CURD 增改查刪

<?php

function println($msg)
{
    echo "<br>";
    echo $msg;
}

$mysql_server_name = "localhost"; //改爲本身的mysql數據庫服務器
$mysql_username = "root"; //改爲本身的mysql數據庫用戶名
$mysql_password = ""; //改爲本身的mysql數據庫密碼
$mysql_database = ""; //改爲本身的mysql數據【庫】名
$mysql_table = ""; //改爲本身的mysql數據【表】名

/** 新建 鏈接 */
$mysqli = new mysqli($mysql_server_name, $mysql_username, $mysql_password);
/** 調試鏈接是否正常 */
//var_dump($mysqli);

/** check connection */
if ($mysqli->connect_errno) {
    printf("Connect failed: %s\n", $mysqli->connect_error);
    exit();
}

/** 刪除 數據庫 */
$sql_delete_db = "drop database $mysql_database";
if ($mysqli->query($sql_delete_db) === true) {
    printf("delete db4 ok");
} else {
    printf("delete db4 failed: %s\n", $mysqli->connect_error);
}

/**
 * 建立數據庫:db4
 */
$sql_create_db = "create database $mysql_database";
if ($mysqli->query($sql_create_db) === true) {
    println("create db4 ok");
} else {
    println("create db4 failed:" . $mysqli->error);
}

/**
 * 選擇數據庫;db4
 */
$mysqli->select_db($mysql_database);

/**
 * 建立數據表;person
 */
$sql_create_table = "create table $mysql_table(id int NOT NULL AUTO_INCREMENT,PRIMARY KEY(id),name varchar(15),age int)";
if ($mysqli->query($sql_create_table) === true) {
    println("create table ok");
} else {
    println("create table failed:" . $mysqli->error);
}

/**
 * 從表(person)中刪除數據;
 */
$sql_delete = "delete from $mysql_table where age = 200";
if ($mysqli->query($sql_delete) === true) {
    println("delete table data ok");
} else {
    println("delete table data failed:" . $mysqli->error);
}

/**
 * 在表(person)中插入新數據;
 */
$age = rand(12, 80);//隨機生成年齡
$sql_inset = "insert into $mysql_table (name,age) value ('flying_$age',$age)";
if ($mysqli->query($sql_inset) === true) {
    println("insert table ok");
} else {
    println("insert table failed:" . $mysqli->error);
}
/**
 * 從表(person)中查詢數據;
 */
$sql_select = "select * from  $mysql_table order by age";
if ($result = $mysqli->query($sql_select)) {
    printf("Select returned %d rows.\n", $result->num_rows);
    while ($row = $result->fetch_row()) {
        println("$row[0]  $row[1]  $row[2]");
    }
//    while ($row = $result->fetch_array()) {
//        println($row['id'] . "-" . $row['name'] . "-" . $row['age']);
//    }
    $result->close();
}


/**
 * 更新表(person)中數據;
 */
$sql_update = "update $mysql_table set age = 200 where age < 67";
if ($mysqli->query($sql_update) === true) {
    println("sql_update table ok");
} else {
    println("sql_update table failed:" . $mysqli->error);
}
/**
 * 關閉鏈接
 */
$mysqli->close();
相關文章
相關標籤/搜索