数据库查询、存储

数据库查询、存储

新老用户识别

......
case '你好':
//更换为你的数据库名
$dbname = 'SnXAHxsmUPuRqZkaWnjF';
$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($link));
}
//连接成功后立即调用mysql_select_db()选中需要连接的数据库
if(!mysql_select_db($dbname,$link)){
die("Select Database Failed: ".mysql_error($link));
}
//查询用户是否存在
$sql = "SELECT * FROM 'CRM' WHERE 'USER' = '{$fromUsername}' LIMIT 0, 30";
$query = mysql_query($sql);
$rs = mysql_fetch_array($query);
//读取用户
$name = $rs['USER'];
//判断用户是否相同
if($name == $fromUsername){
$contentStr = "欢迎老朋友！";
}else{
//插入用户数据
$sql = "INSERT INTO 'CRM'('ID','USER') VALUES (NULL,'{$fromUsername}')";
mysql_query($sql);
$contentStr = "欢迎新朋友！";
}
mysql_close($link);
$resultStr = sprintf($textTpl,$fromUsername,$toUsername,$time,$contentStr);
echo $resultStr;
break;
......

存储数据

......
$dbname = 'SnXAHxsmUPuRqZkaWnjF';
$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($link));
}
//连接成功后立即调用mysql_select_db()选中需要连接的数据库
if(!mysql_select_db($dbname,$link)){
die("Select Database Failed:".mysql_error($link));
}
//查询用户是否存在
$sql = "SELECT * FROM 'CRM' WHERE 'USER' = '{$fromUsername}' LIMIT 0,30";
$rs = mysql_fetch_array($query);
//读取用户
$name = $rs['USER'];
//读取已储存的内容
$content = $rs['COUNTENT'];
//判断用户是否存在
if($name==$fromUsername){
//原有信息加时间戳和本次信息
$content = $content.date("Y-m-d G:i ",mktime()).$keyword;
//更新用户数据
$sql = "UPDATE 'CRM' SET 'CONTENT'='{$content}' WHERE 'USER' = '{$fromUsername}' ";

mysql_query($sql);
$contentStr = "老朋友信息已存储！";
}else{
//加时间戳
$content = date("Y-m-d G:i ", mktime()).$keyword;
//创建新用户记录
$sql = "INSERT INTO 'CRM'('ID','USER','CONTENT') VALUES (NULL,'{$fromUsername}','{$content}')";
mysql_query($sql);
$contentStr = "新朋友信息已储存！";
mysql_close($link);
}
$resultStr = sprintf($textTpl,$fromUsername,$toUsername,$time,$contentStr);
echo $resultStr;
......