公众平台开发九数据库操作

一、简API完成的，没有对数据库进行操作。在接下来的高MySQL数据库的操作做一下二、思路分MySQL数据库进行操作演示，实现与数据库的交互。在BAEdbname。可使用标准的PHPMysql或PHPMysqli扩展数据库，BAE的PHP中已提供这两个 三、创建BAEMySQL数据登陆开发者中心->->选择应用->云环境->服务管理->MySQL(云数据库)->创建数据库注意每个应用有且只有一个数据库享受1G免费其余数据库均不享受免费。只有将已使用免费的数据库删除，才能再次使用此项。点击“phpMyadmin”数据库。“执行”AUTO_INCREMENT（UNIQUECREATETABLEIFNOTEXISTS`test_mysql`CREATETABLEIFNOTEXISTS`test_mysql``id`int(11)NOTNULL`from_user`varchar(40)DEFAULT`account`varchar(40)DEFAULT`password`varchar(40)DEFAULT`update_time`datetimeDEFAULTNULL,PRIMARYKEY(`id`),UNIQUEKEY`from_user`phpMyAdmin四、示例（PHP*MySQLBAEMySQL/*替换为你自己的数据库名（可 查看到*MySQLBAEMySQL/*替换为你自己的数据库名（可 查看到$dbname=/*从环境变量里取出数据库连接需要的参数$host=$port=$user=$pwd=/*mysql_connect()连接服务器$link=@mysql_connect("{$host}:{$port}",$user,$pwd,true);if(!$link){die("ConnectServerFailed:".}/*mysql_select_db()选中需要连接的数据库*/if(!mysql_select_db($dbname,$link)){die("SelectDatabaseFailed:".}/*至此连接已完全建立，就可对当前数据库进行相应的操作了/*需要再连接其它数据库，请再使用mysql_connect+mysql_select_db启 *phpmysql$sql="createtableifnotexiststest_mysql(idintprimarykeyauto_increment,nonamevarchar(1024),keyidx_no(no))";$ret=mysql_query($sql,$link);if($ret===false){die("CreateTableFailed:".}elseecho"CreateTableSucceed<br} $sql="insertintotest_mysql(no,name)values(2007,'thisisatest(2008,'thisisanothertestmessage'),$ret=mysql_query($sql,$link);if($ret===false){die("InsertFailed:".}elseecho"InsertSucceed<br}$sql="deletefromtest_mysqlwhereno=$ret=mysql_query($sql,$link);if($ret===false){die("DeleteFailed:".}else}elseecho Succeed<br}$sql="updatetest_mysqlsetname='yyyyyy'whereno=$ret=mysql_query($sql,$link);if($ret===false){die("UpdateFailed:".}elseecho"UpdateSucceed<br}$sql="selectid,no,namefrom$ret=mysql_query($sql,$link);if($ret===false){die("SelectFailed:".}elseecho"SelectSucceed<brwhile($row=mysql_fetch_assoc($ret))echo"{$row['id']}{$row['no']}{$row['name']}<br}}$sql="droptableifexists$ret=mysql_query($sql,$link);if($ret===false){die("DropTableFailed:".}elseecho"DropTableSucceed<br}configure.php/***配置数据库名称define("MYSQLNAME",五、修改成可调用的函数形式（PHP5.1functionmysql_query($sql)ordie('创建表失败，错误信息：'.mysql_error());return"创建表成功";}5.2数functionreturnreturnreturn}}}function_delete_data($sql){return returnreturn}}}function_update_data($sql){return returnreturn}}}function$ret=mysql_query($sql)ordie('SQLreturn$ret;}functionmysql_query($sql)ordie('删除表失败，错误信息：'.mysql_error());return"删除表成功";}}六、测试MySQL函数使新建文件dev_mysql.php在同 下并引入mysql_bae.func.php文require_oncerequire_oncephpMyAdmintest_mysql$create_sql="CREATETABLEIFNOTEXISTS`test_mysql``id`int(11)NOTNULL`from_user`varchar(40)DEFAULT`account`varchar(40)DEFAULT`password`varchar(40)DEFAULT`update_time`datetimeDEFAULTNULL,PRIMARYKEY(`id`),UNIQUEKEY`from_user`echo$insert_sql="insertintotest_mysql(from_user,account,update_time)$insert_sql="insertintotest_mysql(from_user,account,update_time)values('David','860510','abcabc','2013-09-29$res=_insert_data($insert_sql);if($res==1){echoechoecho}：$update_sql$update_sql="updatetest_mysqlsetaccount=860512whereaccount=$res=_update_data($update_sql);if($res==1){echo}elseif($res==0){echo}elseif($res==echo}：$delete_sql$delete_sql="deletefromtest_mysqlwhereaccount=$res=_delete_data($delete_sql);if($res==1){echo}elseif($res==0){echo}elseif($res==echo}： $select_sql="select*from$result=while($rows=echo"<br}：$drop_sql$drop_sql="droptableifexistsecho：MySQL七、实现 的交互（Mysql扩展如：绑 3.保证数据库中存在test_msyql表，这里测试 对MySQL数据库的增删改查操作，不考如：绑 3.如：修改如：修改4.删除mysql_bae.func.phprequire_once$keywords=$keywords=$nowtime=date("Y-m-d$select_sql="SELECTidfromtest_mysqlWHERE$rows=mysql_fetch_array($res,MYSQL_ASSOC);if($rows[id]<>''){}if(trim($keywords[0]if($user_flag<>'y'){$insert_sql="INSERTINTOtest_mysql(from_user,account,password,update_time)$resif(trim($keywords[0]if($user_flag<>'y'){$insert_sql="INSERTINTOtest_mysql(from_user,account,password,update_time)$res=_insert_data($insert_sql);if($res==1){$contentStr}elseif($res==$contentStr$contentStr}$contentStr}}：if(trim($keywords[0]if(trim($keywords[0]$select_sql="SELECT*FROMtest_mysqlWHEREif($rows[id]<>''){$contentStr="账户 $rows[password]\n"."From_user：$rows[from_user]\n"."$contentStr="}}：if(trim($keywords[0]if(trim($keywords[0]$select_password_sql="SELECT*FROMtest_mysqlWHEREif($old_password==$update_sql="UPDATEtest_mysqlSETpassword='$new_password'WHEREfrom_user='$fromUsername'";$res=_update_data($update_sql);if($res==1){$contentStr}elseif($res==$contentStr}$contentStr=" 有误，请确认后重试}}：if(trim($keywords[0]if(trim($keywords[0]$delete_sql="DELETEFROMtest_mysqlWHERE$res=_delete_data($delete_sql);if($res==1){$contentStr}elseif($res==$contentStr}}： 八、PHPMysqli扩展，封装成Mysqlirequire_once'includes/configure.php';classMySQLi_BAE{private$mysqli;private$host;private$user;private$password;private$port;privatefunction}}functionset($property_name,$this-}function/*从平台获取查询要连接的数据库名称$this->database=/*从环境变量里取出数据库连接需要的参数$this->host=$this->user=$this->password=$this->port=$this->mysqli=newmysqli($this->host,$this-$this->password,$this->database,$this-if($this->mysqli-die("ConnectServerdie("ConnectServerFailed:".$this->mysqli-}$this->mysqli->query("setnames}//dqlfunction$res$this->mysqli->query($query)ordie("操作失败return//$this->mysqli-}//dmlfunction$res$this->mysqli->query($query)ordie("操作失败return0;//if($this->mysqli->affected_rows0){return1;//执行成功return2;//}}//$this->mysqli-}}九、测试类的使require_onceDMLrequire_once$mysqli_BAE=new$mysqli_BAE=new$sql="insertintotest_mysql(from_user,account,password,update_time)values('David','860510','abcabc','2013-09-2717:14:28')";//$sql="updatetest_mysqlsetaccount=860512whereaccount=//$sql="deletefromtest_mysqlwhereaccount=echoechoecho}：require_once$mysqli_BAE=newrequire_once$mysqli_BAE=new$sql="select*fromforeach($rowforeach($rowas$key=>$val){echo"$val--";}echo}$res-：十、实现 的交互（Mysqli