微信公众平台开发 数据库操作

一、简介

前面讲解的功能开发都是简单的调用API 完成的,没有对数据库进行操作。在接下来的高级功能开发中,需要使用到数据库,所以在这一篇中,将对MySQL 数据库的操作做一下简单的介绍,以供读者参考。

二、思路分析

百度开发者中心提供了强大的云数据库(包括MySQL, MongoDB, Redis),在这一节教程中,我们将对大家比较熟悉的MySQL 数据库进行操作演示,实现微信与数据库的交互。

在BAE应用中使用云数据库十分简单,数据库列表中的名称即是连接数据库时的dbname。用户名、密码、连接地址和端口在应用中通过环境变量取出。

可使用标准的PHP Mysql 或PHP Mysqli 扩展访问数据库,BAE的PHP中已提供这两个扩展,应用可直接使用。

三、创建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('HTTP_BAE_ENV_ADDR_SQL_IP');
  $port = getenv('HTTP_BAE_ENV_ADDR_SQL_PORT');
  $user = getenv('HTTP_BAE_ENV_AK');
  $pwd = getenv('HTTP_BAE_ENV_SK');

  /*接着调用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
";
  }

  //删除数据
  $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
";
  }

  //修改数据
  $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
";
  }

  //检索数据
  $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
";
    while ($row = mysql_fetch_assoc($ret)) {
      echo "{$row['id']} {$row['no']} {$row['name']}
";
    }
  }

  //删除表
  $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
";
  }

?>

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 "
";

}

测试结果:

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 'includes/configure.php';

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('David','860510', 'abcabc', '2013-09-27 17:14:28')";

//$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 '
';
}

$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);

测试结果:

与微信交互测试成功。

十一、完整代码获取

请访问 乐思乐享 官方论坛

URL:http://pan.baidu.com/s/1c0s3Jby

十二、关注

请关注 卓锦苏州 微信公众帐号,卓锦苏州 基于BAE 平台开发,针对于主流的微信功能进行开发测试。

您可以关注 卓锦苏州 公众帐号进行功能测试,以及获取新的应用开发。

1. 登录微信客户端,通讯录 -> 添加朋友 -> 查找公众号 -> zhuojinsz,查找并关注。

2. 扫描二维码:

卓锦苏州 功能列表:

感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!

(0)

相关推荐

  • .NET微信公众号获取OpenID和用户信息

    本文实例为大家分享了微信公众平台实现获取用户OpenID的方法,供大家参考,具体内容如下 Index.aspx.cs代码: public partial class Index : System.Web.UI.Page { //用户id public string openid = ""; //公众号信息部分 public string appid = ConfigurationManager.AppSettings["AppId"]; public string

  • 图文介绍报表与企业微信公众号集成方案

    下面通过图文并茂的方式把具体操作步骤介绍如下: 概述: 有时候我们希望把想查询的数据和微信企业号平台集成,或者我们希望能在微信端,将微信中的账户与对应数据集中的字段关联,并通过访问报表获取要查询的字段信息,就好比各个营业厅查询个人当前[套餐余量].又或者,我们希望能够更加方便的编辑自动回复.如果将报表与公众号集成这些需求都可以实现.下面我就来介绍一下该如何集成. 准备工作:微信公众号 (这里申请的是一个月的企业号体验版) 个人微信 报表工具:Finereport 步骤: 1. 配置微信公众号 通

  • php微信公众平台交互与接口详解

    本文分为三大部分为大家进行介绍,具体内容如下 1.微信用户.微信服务器和后台服务器的交互 例:微信用户向公众号发送一条文本消息,这条消息会首先传给微信服务器,微信服务器处理这条信息并将其以xml数据格式传递给后台服务器,后台服务器接受到数据后会对数据进行处理,再响应数据以xml数据格式传递给微信服务器,微信服务器再响应到用户微信界面. 微信用户与微信后台服务器之间的交互过程就是数据传递过程,只不过需要需要通过微信服务器这个中转站. 那么微信服务器这个中转站到底有什么用? 对xml数据进行加工包装

  • 微信公众号开发客服接口实例代码

    最近,开发微信公众号,负责开发客服功能,这里简单记录下: Kf_account.cs代码: public partial class Kf_account : Form { private readonly DataTable adt_user = new DataTable(); private readonly string as_INIFile = Application.StartupPath + "\\user.ini"; public Kf_account() { Bind

  • php微信公众号开发模式详解

    学习步骤:分四章来讲述这部分内容,下面是每章的大致内容. 1.了解开发模式与编辑模式,开发前的一些准备. 2.开发模式用户.微信服务器.个人服务器是如何交互的.什么是接口. 3.各种接口功能的调用与实现. 4.js-SDK的调用 微信公众号开发两种模式:编辑模式和开发模式.编辑模式比较简单,你不需要操作任何的代码,只需要借助微信提供的功能来管理自己的微信公众号.这种方式开发的页面比较简单,主要用来实现文章的推送等功能.开发者模式则能通过自己的后台服务器与微信关注用户实现更多的交互作用,调用微信的

  • 微信公众号 摇一摇周边功能开发

    ①申请开通摇一摇功能 申请开通摇一摇周边功能.成功提交申请请求后,工作人员会在三个工作日内完成审核.若审核不通过,可以重新提交申请请求.若是审核中,请耐心等待工作人员审核,在审核中状态不能再提交申请请求. 接口代码如下: http请求方式: POST(请使用https协议)https://api.weixin.qq.com/shakearound/account/register?access_token=ACCESS_TOKENPOST数据格式:json POST数据例子: { "name&q

  • php版微信公众号接口实现发红包的方法

    本文实例讲述了php版微信公众号接口实现发红包的方法.分享给大家供大家参考,具体如下: 最近接到一个任务,需要用微信来给用户自动发红包.要完成这个任务需要这么已经一些物料 微信商户号,已申请微信支付 微信商户号主体下面的微信公众号 先看一下效果图 只需要完成后面几步就可以了. 在微信公众号服务器上面调用红包代码 /* **微信红包功能 */ public function sendredpack(){ $re_openid = $this->_pg('re_openid'); $inputObj

  • 微信公众帐号开发教程之图文消息全攻略

    引言及内容概要 已经有几位读者抱怨"柳峰只用到文本消息作为示例,从来不提图文消息,都不知道图文消息该如何使用",好吧,我错了,原本以为把基础API封装完.框架搭建好,再给出一个文本消息的使用示例,大家就能够照猫画虎的,或许是因为我的绘画功底太差,画出的那只猫本来就不像猫吧-- 本篇主要介绍微信公众帐号开发中图文消息的使用,以及图文消息的几种表现形式.标题取名为"图文消息全攻略",这绝对不是标题党,是想借此机会把大家对图文消息相关的问题.疑虑.障碍全部清除掉. 图文消

  • 微信公众号 客服接口的开发实例详解

    微信平台更新之后,发现客服接口不错.研究了下 和大家分享下. 按照官方文档,是向客服接口发送规定的JSon 就可以了. 首先先封装下 JSon 的类: package com.lwz.wx.bean.kf; // 这个是最外层的 也可以说是基类吧. public class Basebean { private String touser; private String msgtype; public String getTouser() { return touser; } public vo

  • 微信公众号开发 自定义菜单跳转页面并获取用户信息实例详解

    微信公众号开发 自定义菜单 请先读完本文再进行配置开发 请先前往微信平台开发者文档阅读"网页授权获取用户基本信息"的接口说明 在微信公众账号开发中,往往有定义一个菜单,然后用户点击该菜单就进入用户个人中心的功能,通常应用于各个公众账号中的会员服务. 如何在微信自定义菜单中将用户导航到个人中心页面呢? 首选需要通过用户点击获取用户openid,而通过用户的点击跳转获取用户openid就必须在菜单中动态绑定用户的openid,或者在菜单的跳转URL中填写微信提供的链接,官方给了两个链接类型

  • java微信公众号开发案例

    微信公众号开发一般是针对企业和组织的,个人一般只能申请订阅号,并且调用的接口有限,下面我们就来简单的描述下接入公众号的步骤: 1.首先你需要一个邮箱在微信公众号平台进行注册:      注册的方式有订阅号.公众号.小程序和企业号,个人我们这里只能选择订阅号 2.注册完后,我们登录到公众号平台--->开发--->基本配置,这里需要填写URL和token,URL就是我们使用服务器的接口: 3.Java Web服务器程序编译好且在服务器上部署可以运行的话,可在微信公众号进行在线接口调试: 1).选择

  • php微信公众号js-sdk开发应用

    测试js的接口功能,我用的是BAE服务器不是SAE服务器.SAE服务器不能写入文件,测试会出问题. 什么叫js-sdk,我先演示js-sdk接口的具体作用. 我在微信随便打开一片推送文章如下图: 点开第一篇文章 上面就是我们的连接文章,如果我们把这篇文章发送给朋友,显示效果如下图: 分享到朋友圈我们再来看看效果: 为什么同样是文章连接,在公众号.发送给朋友.发送到朋友圈显示的界面效果不一样.公众号的显示效果是因为微信公众帐号在推送的时候调用了微信的消息接口,而后两者是因为页面调用js-sdk相关

随机推荐