微信公眾平台開發資料庫操作-微信開發-PHP中文網

首頁

微信小程式

微信開發

微信公眾平台開發資料庫操作

高洛峰

Mar 06, 2017 am 09:51 AM

微信開發

一、簡介

前面講解的功能開發都是簡單的呼叫API 完成的，沒有對資料庫進行操作。在接下來的進階功能開發中，需要使用到資料庫，所以在這篇中，將對MySQL 資料庫的操作做一下簡單的介紹，以供讀者參考。

二、思路分析

百度開發者中心提供了強大的雲端資料庫（包括MySQL, MongoDB, Redis），在這一節教學中，我們將對大家比較熟悉的MySQL資料庫進行操作演示，實現微信與資料庫的交互。

在BAE應用程式中使用雲端資料庫十分簡單，資料庫清單中的名稱就是連接資料庫時的dbname。使用者名稱、密碼、連接位址和連接埠在應用程式中透過環境變數取出。

可使用標準的PHP Mysql 或PHP Mysqli 擴充存取資料庫，BAE的PHP中已提供這兩個擴展，應用可直接使用。

官方文檔，請參考：ttp://developer.baidu.com/wiki/index.php?title=docs/cplat/rt/mysql

三、建立BAE MySQL資料庫

3.1 登陸百度開發者中心-> 管理中心-> 選擇應用程式-> 雲端環境-> 服務管理-> MySQL(雲端資料庫) -> 建立資料庫

微信公眾平台開發資料庫操作

#3.2 建立資料庫

微信公眾平台開發資料庫操作

注意：每個應用程式有且只有一個資料庫享受1G免費配額，其餘資料庫皆不享有免費配額優惠。只有將已使用免費配額的資料庫刪除，才能再次使用此優惠。

3.3 建立成功

在這裡可以看到資料庫的名稱，也就是dbname，後面會被使用到。

點選 “phpMyadmin” 存取資料庫。

微信公眾平台開發資料庫操作

3.4 phpMyadmin介面

新資料表，輸入表名及欄位數，點選「執行」建立表格。

微信公眾平台開發資料庫操作

3.5 建立表格

輸入欄位名稱及欄位類型，輸入完畢後，點選下方的「儲存」，完成表格的建立。

微信公眾平台開發資料庫操作

3.6 建立完成

修改id 欄位為主鍵並新增AUTO_INCREMENT；修改from_user 欄位為唯一（UNIQUE），完成表格的修改。

微信公眾平台開發資料庫操作

建表作業也可以使用下列SQL語句完成：

CREATE TABLE IF NOT EXISTS `test_mysql` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `from_user` varchar(40) DEFAULT NULL,
  `account` varchar(40) DEFAULT NULL,
  `password` varchar(40) DEFAULT NULL,
  `update_time` datetime DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `from_user` (`from_user`)
);

phpMyAdmin 動作

微信公眾平台開發資料庫操作

#資料庫及資料表的建立到此結束，以下將編寫程式碼對資料庫及資料表的使用做詳細講解。

四、官方範例（PHP MySQL）

BAE 官方提供的demo（PHP MySQL）範例如下：

mysql/basic.php 檔案內容

<?php /**
 * MySQL示例，通过该示例可熟悉BAE平台MySQL的使用（CRUD）
 */
require_once("../configure.php");
    /*替换为你自己的数据库名（可从管理中心查看到）*/
    $dbname = MYSQLNAME;
     
    /*从环境变量里取出数据库连接需要的参数*/
    $host = getenv(&#39;HTTP_BAE_ENV_ADDR_SQL_IP&#39;);
    $port = getenv(&#39;HTTP_BAE_ENV_ADDR_SQL_PORT&#39;);
    $user = getenv(&#39;HTTP_BAE_ENV_AK&#39;);
    $pwd = getenv(&#39;HTTP_BAE_ENV_SK&#39;);
    
    /*接着调用mysql_connect()连接服务器*/
    $link = @mysql_connect("{$host}:{$port}",$user,$pwd,true);
    if(!$link) {
      die("Connect Server Failed: " . mysql_error());
    }
    /*连接成功后立即调用mysql_select_db()选中需要连接的数据库*/
    if(!mysql_select_db($dbname,$link)) {
      die("Select Database Failed: " . mysql_error($link));
    }
    /*至此连接已完全建立，就可对当前数据库进行相应的操作了*/
    /*！！！注意，无法再通过本次连接调用mysql_select_db来切换到其它数据库了！！！*/
    /* 需要再连接其它数据库，请再使用mysql_connect+mysql_select_db启动另一个连接*/
     
    /**
    * 接下来就可以使用其它标准php mysql函数操作进行数据库操作
    */
    
    //创建一个数据库表
    $sql = "create table if not exists test_mysql(
            id int primary key auto_increment,
            no int, 
            name varchar(1024),
            key idx_no(no))";
    $ret = mysql_query($sql, $link);
    if ($ret === false) {
        die("Create Table Failed: " . mysql_error($link));
    } else {
        echo "Create Table Succeed<br />";
    }
    
    //插入数据
    $sql = "insert into test_mysql(no, name) values(2007,'this is a test message'),
            (2008,'this is another test message'),
            (2009,'xxxxxxxxxxxxxx')";
    $ret = mysql_query($sql, $link);
    if ($ret === false) {
        die("Insert Failed: " . mysql_error($link));
    } else {
        echo "Insert Succeed<br>";
    }
    
    //删除数据
    $sql = "delete from test_mysql where no = 2008";
    $ret = mysql_query($sql, $link);
    if ($ret === false) {
        die("Delete Failed: " . mysql_error($link));
    } else {
        echo "Delete  Succeed<br>";
    }
    
    //修改数据
    $sql = "update test_mysql set name = 'yyyyyy' where no = 2009";
    $ret = mysql_query($sql, $link);
    if ($ret === false) {
        die("Update Failed: " . mysql_error($link));
    } else {
        echo "Update Succeed<br>";
    }
    
    
    //检索数据
    $sql = "select id,no,name from test_mysql";
    $ret = mysql_query($sql, $link);
    if ($ret === false) {
        die("Select Failed: " . mysql_error($link));
    } else {
        echo "Select Succeed<br>";
        while ($row = mysql_fetch_assoc($ret)) {
            echo "{$row['id']} {$row['no']} {$row['name']}<br>";
        }
    }
    
    //删除表
    $sql = "drop table if exists test_mysql";
    $ret = mysql_query($sql, $link);
    if ($ret === false) {
        die("Drop Table Failed: " . mysql_error($link));
    } else {
        echo "Drop Table Succeed<br>";
    }


?>

configure.php 檔案內容

<?php     /***配置数据库名称***/
    define("MYSQLNAME", "qzMlSkByflhScPCOFtax");

?>

測試使用：

微信公眾平台開發資料庫操作

##執行成功。

五、修改成可呼叫的函數形式（PHP MySQL）

5.1 建立資料表

//创建一个数据库表
function _create_table($sql){
    mysql_query($sql) or die('创建表失败，错误信息：'.mysql_error());
    return "创建表成功";
}

5.2 插入資料

//插入数据
function _insert_data($sql){
      if(!mysql_query($sql)){
        return 0;    //插入数据失败
    }else{
          if(mysql_affected_rows()>0){
              return 1;    //插入成功
          }else{
              return 2;    //没有行受到影响
          }
    }
}

5.3 刪除資料

//删除数据
function _delete_data($sql){
      if(!mysql_query($sql)){
        return 0;    //删除失败
      }else{
          if(mysql_affected_rows()>0){
              return 1;    //删除成功
          }else{
              return 2;    //没有行受到影响
          }
    }
}

5.4 修改資料

//修改数据
function _update_data($sql){
      if(!mysql_query($sql)){
        return 0;    //更新数据失败
    }else{
          if(mysql_affected_rows()>0){
              return 1;    //更新成功;
          }else{
              return 2;    //没有行受到影响
          }
    }
}

5.5 檢索資料

//检索数据
function _select_data($sql){
    $ret = mysql_query($sql) or die('SQL语句有错误，错误信息：'.mysql_error());
    return $ret;
}

5.6 刪除資料表

//删除表
function _drop_table($sql){
    mysql_query($sql) or die('删除表失败，错误信息：'.mysql_error());
    return "删除表成功";
}

將上述函數和連接資料庫的程式碼結合起來，產生mysql_bae.func.php 文件，供下面測試使用。

六、測試MySQL 函數使用######6.1 新檔案dev_mysql.php 在同一目錄下並引入mysql_bae.func.php 檔案##########

require_once './mysql_bae.func.php';

#### #####6.2 測試建立表格######將上述使用phpMyAdmin 建立的test_mysql 表刪除，測試語句如下：#########

//创建表
$create_sql = "CREATE TABLE IF NOT EXISTS `test_mysql` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `from_user` varchar(40) DEFAULT NULL,
  `account` varchar(40) DEFAULT NULL,
  `password` varchar(40) DEFAULT NULL,
  `update_time` datetime DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `from_user` (`from_user`)
)";

echo _create_table($create_sql);

#######

测试正确结果：

微信公眾平台開發資料庫操作

到phpMyAdmin中查看

微信公眾平台開發資料庫操作

故意将SQL语句写错

微信公眾平台開發資料庫操作

测试错误结果：

微信公眾平台開發資料庫操作

6.3 测试插入数据

测试语句如下：

//插入数据
$insert_sql = "insert into test_mysql(from_user, account, password, update_time) values('David','860510', 'abcabc', '2013-09-29 17:14:28')";

$res = _insert_data($insert_sql);
if($res == 1){
    echo "插入成功";
}else{
    echo "插入失败";
}

测试结果：

微信公眾平台開發資料庫操作

6.4 测试更新数据

测试语句如下：

//更新数据
$update_sql = "update test_mysql set account = 860512 where account = 860510";

$res = _update_data($update_sql);
if($res == 1){
    echo "更新成功";
}elseif($res == 0){
    echo "更新失败";
}elseif($res == 2){
    echo "没有行受到影响";
}

测试结果：

微信公眾平台開發資料庫操作

再次更新：

微信公眾平台開發資料庫操作

6.5 测试删除数据

测试语句如下：

//删除数据
$delete_sql = "delete from test_mysql where account = 860512";

$res = _delete_data($delete_sql);
if($res == 1){
    echo "删除成功";
}elseif($res == 0){
    echo "删除失败";
}elseif($res == 2){
    echo "没有该条记录";
}

测试结果：

微信公眾平台開發資料庫操作

再次删除：

微信公眾平台開發資料庫操作

6.6 测试检索数据

再次执行上面的插入操作做检索测试，测试语句如下：

//检索数据
$select_sql = "select * from test_mysql";

$result = _select_data($select_sql);

while($rows = mysql_fetch_array($result,MYSQL_ASSOC)){

    echo $rows[id]."--".$rows[from_user]."--".$rows[account]."--".$rows[password]."--".$rows[update_time];
    echo "<br>";

}

测试结果：

微信公眾平台開發資料庫操作

6.7 测试删除表

测试语句如下：

//删除表$drop_sql = "drop table if exists test_mysql";echo _drop_table($drop_sql);

测试结果：

微信公眾平台開發資料庫操作

MySQL 函数测试全部成功。

七、实现与微信的交互（Mysql 扩展）

保证数据库中存在test_msyql表，这里测试微信对MySQL数据库的增删改查操作，不考虑特殊情况，只按照下面的方法测试：

1. 绑定+账户+密码
如：绑定+860512+abc123

2. 查询
如：查询

3. 修改+旧密码+新密码
如：修改+abc123+123456

4. 删除
如：删除

7.1 引入mysql_bae.func.php 文件

//引入数据库函数文件require_once 'mysql_bae.func.php';

7.2 前置操作

A. 将输入的语句拆分成数组，以“+”号分隔

$keywords = explode("+",$keyword);

B. 获取当前时间

//获取当前时间$nowtime=date("Y-m-d G:i:s");

C. 判断用户是否已经绑定

//判断是否已经绑定
$select_sql="SELECT id from test_mysql WHERE from_user='$fromUsername'";
$res=_select_data($select_sql);
$rows=mysql_fetch_array($res, MYSQL_ASSOC);
if($rows[id]  ''){
        $user_flag='y';          
}

7.3 测试插入操作

测试代码：

if(trim($keywords[0] == '绑定')){
    if($user_flag  'y'){
        $insert_sql="INSERT INTO test_mysql(from_user, account, password, update_time) VALUES('$fromUsername','$keywords[1]','$keywords[2]','$nowtime')";
        $res = _insert_data($insert_sql);
        if($res == 1){
            $contentStr = "绑定成功";
        }elseif($res == 0){
            $contentStr = "绑定失败";
        }
    }else{
        $contentStr = "该账户已绑定";
    }
}

测试结果：

微信公眾平台開發資料庫操作

7.4 测试查询操作

测试代码：

if(trim($keywords[0] == '查询')){
    $select_sql="SELECT * FROM test_mysql WHERE from_user='$fromUsername'";
    $select_res=_select_data($select_sql);
    $rows=mysql_fetch_assoc($select_res);
    if($rows[id]  ''){
    $contentStr="账户:$rows[account]\n"."密码：$rows[password]\n"."From_user：$rows[from_user]\n"."更新时间：$rows[update_time]";
    }else{
    $contentStr="您还未绑定账户，查询不到相关信息，请先绑定，谢谢！";
    }
}

测试结果：

微信公眾平台開發資料庫操作

7.5 测试更新操作

测试代码：

if(trim($keywords[0] == "修改")){
    $old_password=$keywords[1];
    $new_password=$keywords[2];
    $select_password_sql="SELECT * FROM test_mysql WHERE from_user='$fromUsername'";
    $select_res=_select_data($select_password_sql);
    $rows=mysql_fetch_assoc($select_res);
    if($old_password == $rows[password]){
        $update_sql="UPDATE test_mysql SET password='$new_password' WHERE from_user='$fromUsername'";
        $res = _update_data($update_sql);
        if($res == 1){
            $contentStr = "修改成功";
        }elseif($res == 0){
            $contentStr = "修改失败";
        }
    }else{
        $contentStr = "原密码有误，请确认后重试";
    }
}

测试结果：

微信公眾平台開發資料庫操作

7.6 测试删除操作

测试代码：

if(trim($keywords[0] == "删除")){
    $delete_sql="DELETE FROM test_mysql WHERE from_user='$fromUsername'";
    $res = _delete_data($delete_sql);
    if($res == 1){
        $contentStr = "删除成功";
    }elseif($res == 0){
        $contentStr = "删除失败";
    }
}

测试结果：

微信公眾平台開發資料庫操作

与微信的交互测试成功。

八、PHP Mysqli 扩展，封装成类

将Mysqli 扩展封装成类使用，代码如下：

<?php require_once &#39;includes/configure.php&#39;;

class MySQLi_BAE{

    private $mysqli;
    private $host;
    private $user;
    private $password;
    private $port;
    private $database;

    //在类之外访问私有变量时使用
    function __get($property_name){
        if(isset($this->$property_name)){
            return($this->$property_name);
        }else{
            return(NULL);
        }    
    }

    function __set($property_name, $value){
        $this->$property_name=$value;
    }

    function __construct(){

        /*从平台获取查询要连接的数据库名称*/
        $this->database = MYSQLNAME;

        /*从环境变量里取出数据库连接需要的参数*/
        $this->host = getenv('HTTP_BAE_ENV_ADDR_SQL_IP');
        $this->user = getenv('HTTP_BAE_ENV_AK');
        $this->password = getenv('HTTP_BAE_ENV_SK');
        $this->port = getenv('HTTP_BAE_ENV_ADDR_SQL_PORT');

        $this->mysqli = new mysqli($this->host, $this->user, $this->password, $this->database, $this->port);
        if($this->mysqli->connect_error){
            die("Connect Server Failed:".$this->mysqli->error);
        }
        
        $this->mysqli->query("set names utf8");
    }

    //dql statement
    function execute_dql($query){
        
        $res = $this->mysqli->query($query) or die("操作失败".$this->mysqli->error);
        return $res;
        
        //$this->mysqli->close();
    }

    //dml statement
    function execute_dml($query){
        
        $res = $this->mysqli->query($query) or die("操作失败".$this->mysqli->error);
        
        if(!$res){
            return 0;//失败
        }else{
            if($this->mysqli->affected_rows > 0){
                return 1;//执行成功
            }else{
                return 2;//没有行受影响
            }
        }
    
        //$this->mysqli->close();
    }
}
?>

九、测试类的使用

9.1 测试DML操作

测试代码：

<?php require_once "MySQLi_BAE.class.php";

$mysqli_BAE=new MySQLi_BAE();


//**************dml*******************
$sql="insert into test_mysql (from_user, account, password, update_time) values(&#39;David&#39;,&#39;860510&#39;, &#39;abcabc&#39;, &#39;2013-09-27 17:14:28&#39;)";

//$sql="update test_mysql set account = 860512 where account = 860510";

//$sql="delete from test_mysql where account = 860512";

$res=$mysqli_BAE->execute_dml($sql);

if($res==0){
    echo "执行失败";
}elseif($res==1){
    echo "执行成功";
}else{
    echo "没有行数影响";
}
?>

测试结果：

微信公眾平台開發資料庫操作

9.2 测试DQL操作

测试代码：

<?php require_once "MySQLi_BAE.class.php";

$mysqli_BAE=new MySQLi_BAE();

//**************dql******************
$sql="select * from test_mysql";

$res=$mysqli_BAE->execute_dql($sql);

while($row=$res->fetch_row()){
    
    foreach($row as $key=>$val){
        echo "$val--";
    }
    echo '<br>';
}

$res->free();
?>

测试结果：

微信公眾平台開發資料庫操作

十、实现与微信的交互（Mysqli 扩展）

10.1 前置操作

A. 引入MySQLi_BAE.class.php 文件

//引入数据库函数文件require_once "MySQLi_BAE.class.php";

B. 实例化对象

public function __construct()
{    $this->mysqli_BAE=new MySQLi_BAE();
}

10.2 测试插入操作

测试代码：

$insert_sql="INSERT INTO test_mysql(from_user, account, password, update_time) VALUES('$fromUsername','$keywords[1]','$keywords[2]','$nowtime')";
$res = $this->mysqli_BAE->execute_dml($insert_sql);

测试结果：

微信公眾平台開發資料庫操作

10.3 测试查询操作

测试代码：

$select_sql="SELECT * FROM test_mysql WHERE from_user='$fromUsername'";
$select_res=$this->mysqli_BAE->execute_dql($select_sql);
$rows=$select_res->fetch_array(MYSQLI_ASSOC);

测试结果：

微信公眾平台開發資料庫操作

10.4 测试更新操作

测试代码：

$update_sql="UPDATE test_mysql SET password='$new_password' WHERE from_user='$fromUsername'"; 
$res = $this->mysqli_BAE->execute_dml($update_sql);

测试结果：

微信公眾平台開發資料庫操作

10.5 测试删除操作

测试代码：

$delete_sql="DELETE FROM test_mysql WHERE from_user='$fromUsername'";
$res = $this->mysqli_BAE->execute_dml($delete_sql);

测试结果：

微信公眾平台開發資料庫操作

与微信交互测试成功。

更多微信公眾平台開發資料庫操作相关文章请关注PHP中文网！

陳述

本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

人工智慧驅動的應用程序，用於創建逼真的裸體照片

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

免費脫衣圖片

Clothoff.io

AI脫衣器

Video Face Swap

使用我們完全免費的人工智慧換臉工具，輕鬆在任何影片中換臉！

熱工具

記事本++7.3.1

好用且免費的程式碼編輯器

ZendStudio 13.5.1 Mac

強大的PHP整合開發環境

SublimeText3漢化版

中文版，非常好用

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

SublimeText3 Linux新版

SublimeText3 Linux最新版

微信公眾平台開發資料庫操作

熱AI工具

Undresser.AI Undress

AI Clothes Remover

Undress AI Tool

Clothoff.io

Video Face Swap

熱門文章

熱工具

記事本++7.3.1

ZendStudio 13.5.1 Mac

SublimeText3漢化版

SublimeText3 Mac版

SublimeText3 Linux新版

熱門話題