php数据接口
统一的数据访问接口PDO
PDO(PHP Data Objects) 扩展为 PHP 访问数据库定义了一个轻量级的、一致性的接口,它提供了一个数据访问抽象层,这样,无论使用什么数据库,用户都可以通过统一的函数执行来查询和获取数据。注意,你并不能使用 PDO 扩展本身执行任何数据库操作,必须使用一个 database-specific PDO driver (针对特定数据库的 PDO 驱动)访问数据库服务器。
⑵ php中怎么把数据库连接写成一个接口
我自己封装的一个
<?php
class AppConfig{
public static $dbParam = array(
'dbHost' => 'localhost',
'dbUser' => 'root',
'dbPassword' =>'',
'dbName' => '数据库名',
'dbCharset' => 'utf8',
'dbPort' => 3306,
'dbPrefix' => 'test_',
'dbPconnect' => 0,
'dbDebug' => true,
);
}
class Model {
private $version = ''; //mysql版本
private $config = array(); //数据库配置数组
private $class; //当前类名
public $tablepre = 'ts_'; //表前缀
public $db = ''; //库名
public $table = ''; //表名
private static $link; //数据库链接句柄
private $data = array(); //中间数据容器
private $condition = ''; //查询条件
private $fields = array(); //字段信息
private $sql = array(); //sql集合,调试用
public $primaryKey = 'id'; //表主键
//构造函数初始化
public function __construct($dbParam = array()) {
$this->config = (is_array($dbParam) && !empty($dbParam)) ? $dbParam : AppConfig::$dbParam;
$this->connect();
$this->init();
}
//链接数据库
private function connect() {
if($this->config['dbPconnect']) {
self::$link = @mysql_pconnect($this->config['dbHost'], $this->config['dbUser'], $this->config['dbPassword']);
}else{
self::$link = @mysql_connect($this->config['dbHost'], $this->config['dbUser'], $this->config['dbPassword'], true);
}
mysql_errno(self::$link) != 0 && $this->errdie('Could not connect Mysql: ');
$this->db= !empty($this->db) ? $this->db : $this->config['dbName'];
$serverinfo = $this->version();
if ($serverinfo > '4.1' && $this->config['dbCharset']) {
mysql_query("SET character_set_connection=".$this->config['dbCharset'].",character_set_results=".$this->config['dbCharset'].",character_set_client=binary", self::$link);
}
if ($serverinfo > '5.0') {
mysql_query("SET sql_mode=''", self::$link);
}
@mysql_select_db($this->db, self::$link) or $this->errdie('Cannot use database');
return self::$link;
}
//表基本信息初始化
protected function init() {
$this->class = get_class($this);
$this->table = !empty($this->table) ? $this->table : strtolower($this->class);
$this->table = $this->tablepre . $this->table;
return $this;
}
//设置属性值
public function __set($name, $value) {
//exit($value);
$this->data['fields'][$name] = $value;
}
//获取属性值
public function __get($name) {
if(isset($this->data['fields'][$name])) {
return($this->data['fields'][$name]);
}else {
return NULL;
}
}
//字段信息处理
private function implodefields($data) {
if (!is_array($data)) {
$data = array();
}
$this->fields = !empty($this->data['fields']) ? array_merge($this->data['fields'], $data) : $data;
foreach($this->fields as $key => $value) {
$fieldsNameValueStr[] = "`$key`='$value'";
$fieldsNameStr[] = "`$key`";
$fieldsValueStr[] = "'$value'";
}
return array($fieldsNameValueStr, $fieldsNameStr, $fieldsValueStr);
}
//条件判断组装
private function condition($where = NULL) {
if (is_numeric($where)) {
$where = "WHERE `{$this->primaryKey}`='{$where}' LIMIT 1";
}elseif (is_array($where)){
$where = "WHERE `{$this->primaryKey}` in (".implode(',',$where).")";
}elseif(!empty($this->data['condition'])){
//'预留WHERE', 'order', 'group', 'limit' …………等条件关键词处理接口
$where = $where ? "WHERE {$where}" : "WHERE 1";
isset($this->data['condition']['where']) && $where .= ' AND '.$this->data['condition']['where'];
isset($this->data['condition']['group']) && $where .= ' GROUP BY '.$this->data['condition']['group'];
isset($this->data['condition']['order']) && $where .= ' ORDER BY '.$this->data['condition']['order'];
isset($this->data['condition']['limit']) && $where .= ' LIMIT '.$this->data['condition']['limit'];
}else{
$where = "WHERE {$where}";
}
$this->condition = $where;
return $this;
}
//插入数据
public function insert($data = array(), $replace = false) {
$fields = $this->implodefields($data);
$insert = $replace ? 'REPLACE' : 'INSERT';
$sql = "{$insert} INTO `{$this->db}`.`{$this->table}` (".implode(', ',$fields[1]).") values (".implode(', ',$fields[2]).")";
$this->query($sql);
return $this->getInsertId();
}
//更新数据
public function update($data = array() ,$where = '') {
$numargs = func_num_args();
if ($numargs == 1) {
$where = $data;
$data = array();
}
$fields = $this->implodefields($data);
$this->condition($where);
$sql = "UPDATE `{$this->db}`.`{$this->table}` SET ".implode(', ',$fields[0])." {$this->condition}";
$this->query($sql);
return $this->getAffectedRows();
}
//删除数据
public function delete($where = NULL) {
if(!is_array($where) && strtolower(substr(trim($where), 0, 6)) == 'delete'){
$sql = $where;
}else{
$this->condition($where);
$sql = "DELETE FROM `{$this->db}`.`{$this->table}` {$this->condition}";
}
$this->query($sql);
return $this->getAffectedRows();
}
//查询数据
public function select($where = NULL, $fields = '*') {
if(!is_array($where) && strtolower(substr(trim($where), 0, 6)) == 'select'){
$sql = $where;
}else{
$this->condition($where);
$sql = "SELECT {$fields} FROM `{$this->db}`.`{$this->table}` {$this->condition}";
}
return $this->fetch($this->query($sql));
}
//查询一条数据
public function getOne($where, $fields = '*') {
$data = $this->select($where, $fields = '*');
if($data) {
return $data[0];
}
return array();
}
//查询多条数据
public function getAll($where, $fields = '*') {
$data = $this->select($where, $fields = '*');
return $data;
}
//结果数量
public function getCount($where = '', $fields = '*') {
$this->condition($where);
$sql = "SELECT count({$fields}) as count FROM `{$this->db}`.`{$this->table}` {$this->condition}";
$data = $this->query($sql);
if($data){
return @mysql_result($data,0);
}
return 0;
}
//执行sql语句(flag为0返回mysql_query查询后的结果,为1返回lastid,其他返回影响行数,默认为2返回影响行数)
public function query($sql, $flag = '0', $type = '') {
if ($this->config['dbDebug']) {
$startime = $this->microtime_float();
}
//查询
if ($type == 'UNBUFFERED' && function_exists('mysql_unbuffered_query')) {
$result = @mysql_unbuffered_query($sql, self::$link);
} else {
//exit($sql);
$result = @mysql_query($sql, self::$link);
}
//重试
if (in_array(mysql_errno(self::$link), array(2006,2013)) && empty($result) && $this->config['dbPconnect']==0 && !defined('RETRY')) {
define('RETRY',true); @mysql_close(self::$link); sleep(2);
$this->connect();
$result = $this->query($sql);
}
if ($result === false) {
$this->errdie($sql);
}
if ($this->config['dbDebug']) {
$endtime = $this->microtime_float();
$this->sql[] = array($sql,$endtime-$startime);
}
//清空操作数据
$this->data = array();
return $flag == '0' ? $result : ($flag == '1' ? $this->getInsertId() : $this->getAffectedRows());
}
//返回结果$onlyone为true返回一条否则返回所有,$type有MYSQL_ASSOC,MYSQL_NUM,MYSQL_BOTH
public function fetch($result, $onlyone = false, $type = MYSQL_ASSOC) {
if($result){
if ($onlyone) {
$row = @mysql_fetch_array($result, $type);
return $row;
}else{
$rowsRs = array();
while($row=@mysql_fetch_array($result, $type)) {
$rowsRs[] = $row;
}
return $rowsRs;
}
}
return array();
}
//可以运行SELECT,SHOW,EXPLAIN 或 DESCRIBE 等返回一个资源标识符的语句得到返回结果数组
public function show($sql, $onlyone = false) {
return $this->fetch($this->query($sql), $onlyone);
}
// 使用call函数处理同类型函数
private function __call($name, $arguments) {
$callArr = array('on', 'where', 'order', 'between', 'group', 'limit');
if (in_array($name, $callArr)) {
$this->data['condition'][$name] = $arguments[0];
}else{
$this->errdie("function error: function {$name} is not in ($this->class) class exist");
}
return $this;
}
//返回最后一次插入ID
public function getInsertId() {
return @mysql_insert_id(self::$link);
}
//返回受影响行数
public function getAffectedRows() {
return @mysql_affected_rows(self::$link);
}
//获取错误信息
private function error() {
return ((self::$link) ? @mysql_error(self::$link) : @mysql_error());
}
//获取错误信息ID
private function errno() {
return ((self::$link) ? @mysql_errno(self::$link) : @mysql_errno());
}
//获取版本信息
function version() {
if(empty($this->version)) {
$this->version = mysql_get_server_info(self::$link);
}
return $this->version;
}
//打印错误信息
private function errdie($sql = '') {
if ($this->config['dbDebug']) {
die('</BR><B>MySQL ERROR</B></BR>
SQL:'.$sql.'</BR>
ERRNO:'.$this->errno().'</BR>
ERROR:'.$this->error().'</BR>');
}
die('DB ERROR!!!');
}
//获取时间微妙数
private function microtime_float()
{
list($usec, $sec) = explode(" ", microtime());
return ((float)$usec + (float)$sec);
}
//析构函数
public function __destruct() {
echo '<hr>';
$this->config['dbDebug'] && print_r($this->sql);
//unset($this->result);
//unset($this->condition);
//unset($this->data);
}
}
class user extends Model {
//public $db = 'qsf_mvc';
//public $table = 'user';
public $primaryKey = 'uid';
}
$userObj = new user();
//---------------------------------------插入数据方法一-----------------------------------------
//模拟ActiveRecord模式 插入数据
$userObj->username = 'hoho';
$userObj->passwd = '1478522';
$userObj->email = '[email protected]';
$userObj->sex = 1;
$userObj->desc = '清洁工';
$insetId = $userObj->insert();
if ($insetId > 0) {
echo "插入ID为:{$insetId}<BR>";
}
//---------------------------------------插入数据方法二-----------------------------------------
//直接数组做参数插入数据
$userArr = array(
'username' => 'hoho',
'passwd' => '1478522',
'email' => '[email protected]',
'sex' => '1',
'desc' => '厨师',
);
$insetId = $userObj->insert($userArr);
if ($insetId > 0) {
echo "插入ID为:{$insetId}<BR>";
}
//---------------------------------------更新数据方法一----------------------------------------
$userObj->username = 'h111oho';
$userObj->passwd = '1478511122';
$userObj->email = '[email protected]';
$userObj->sex = 1;
$userObj->desc = '清洁工';
$affectedRows1 = $userObj->update(89);
if ($affectedRows1 > 0) {
echo "影响行数为:{$affectedRows1}<BR>";
}
//---------------------------------------更新数据方法二----------------------------------------
//更新记录(传递参数的方式和insert操作一样)
$userArr = array(
'username' => 'hohoho',
'passwd' => '1474rr4448522',
'email' => '[email protected]',
'sex' => '0',
'desc' => '厨师qq',
);
$affectedRows = $userObj->update($userArr, $insetId);
if ($affectedRows > 0) {
echo "影响行数为:{$affectedRows}<BR>";
}
//----------------------------------------查询数据----------------------------------------------
$userRs0 = $userObj->select(8); //单个主键值
//print_r($userRs0);
$userRs1 = $userObj->select(array(1,5,8)); //多个主键值的数组
//print_r($userRs1);
$userRs2 = $userObj->select('select count(*) as count from user where uid > 20'); //直接完整sql语句
//print_r($userRs2);
$userRs3 = $userObj->select("`uid` > 0"); //where条件
//print_r($userRs3);
$userRs4 = $userObj->getOne("`uid` > 0"); //获取单条记录
//print_r($userRs4);
$usersRs5 = $userObj->getAll("`uid` > 0"); ////获取所有记录
//print_r($usersRs5);
$usersRs6 = $userObj->limit('0,10')->where('uid > 100')->order('uid DESC')->group('username')->select();
//print_r($usersRs6);
//----------------------------------------删除数据-----------------------------------------------
//删除操作传递参数的方式和select操作一样
$userObj->delete(60); //单个主键值
$userObj->delete(array(1,5,8)); //多个主键值的数组
$userObj->delete('delete from user where uid > 100'); //直接完整sql语句
$userObj->delete("`uid` > 100"); //where条件
$userObj->limit('5')->where('uid > 80')->delete();
//----------------------------------------特殊查询-----------------------------------------------
$userShowRs = $userObj->show('show create table user', true); //获取特殊查询的结果,第二个参数代表返回一条结果还是所有的结果
⑶ php怎么改变数据接口的真实路径
<?php
include("connection.php");
$perNumber=10; //每页显示的记录数
$page=$_GET['page']; //获得当前的页面值
$count=mysql_query("select count(*) from user"); //获得记录总数
$rs=mysql_fetch_array($count);
$totalNumber=$rs[0];
$totalPage=ceil($totalNumber/$perNumber); //计算出总页数
if (!isset($page)) {
$page=1;
} //如果没有值,则赋值1
$startCount=($page-1)*$perNumber; //分页开始,根据此方法计算出开始的记录
$result=mysql_query("select * from user limit $startCount,$perNumber"); //根据前面的计算出开始的记录和记录数
while ($row=mysql_fetch_array($result)) {
echo "user_id:".$row[0]."<br>";
echo "username:".$row[1]."<br>"; //显示数据库的内容
}
if ($page != 1) { //页数不等于1
?>
<a href="fenye.php?page=<?php echo $page - 1;?>">上一页</a> <!--显示上一页-->
<?php
}
for ($i=1;$i<=$totalPage;$i++) { //循环显示出页面
?>
<a href="fenye.php?page=<?php echo $i;?>"><?php echo $i ;?></a>
<?php
}
if ($page<$totalPage) { //如果page小于总页数,显示下一页链接
?>
⑷ PHP如何写一个给外人上传数据的接口
接口的流程.
建立控制器(访问地址)->审核访问者身份(token)->验证提交数据是否符合类型(validate
)->处理接收数据(逻辑流程)->返回结果(json字符串).
其中要注意是否存在跨域,如果跨域要做跨域处理,例如返回jsonp.
⑸ php中的API接口怎么写
api接口是具有的特定功能的程序代码块,作用是产生或者处理传输数据;
其存在的意义在于,不同语言之间的正常交流,包括iOS,java,PHP,C等,但是所有的程序语言都支持Json和Xml数据类型,所以接口产生数据基本都是json或者xml文件。
怎么写?
其实就是正常的功能类和方法,调用时产生需求功能对应的数据,仅此而已,在没有什么复杂的逻辑。
⑹ php怎么写api接口
api和WEB开发一样,首先是需要一些相关参数,这类参数,会有客户端传过来,也许是POST或GET,这需要制定统一规范或者开发团队约定好。而有了参数后,可根据应用需求,完成其数据处理。数据逻辑处理完后,返回客户端所需要用到的相关数据,例如:任务状态、内购结果、玩家信息等等数据怎么返给客户端?直接输出的形式,如:JSON、XML、TEXT 等等。
⑺ PHP 的API接口
使用PHP写api接口是经常做的,PHP写好接口后,前台就可以通过链接获取接口提供的数据,而返回的数据一般分为两种情况,xml和json,在这个过程中,服务器并不知道,请求的来源是什么,有可能是别人非法调用我们的接口,获取数据,因此就要使用安全验证
原理
从图中可以看得很清楚,前台想要调用接口,需要使用几个参数生成签名。
时间戳:当前时间
随机数:随机生成的随机数
口令:前后台开发时,一个双方都知道的标识,相当于暗号
算法规则:商定好的运算规则,上面三个参数可以利用算法规则生成一个签名。前台生成一个签名,当需要访问接口的时候,把时间戳,随机数,签名通过URL传递到后台。后台拿到时间戳,随机数后,通过一样的算法规则计算出签名,然后和传递过来的签名进行对比,一样的话,返回数据。
算法规则
在前后台交互中,算法规则是非常重要的,前后台都要通过算法规则计算出签名,至于规则怎么制定,看你怎么高兴怎么来。
我这个算法规则是
时间戳,随机数,口令按照首字母大小写顺序排序
然后拼接成字符串
进行sha1加密
再进行MD5加密
转换成大写。
⑻ php中如何调用接口以及编写接口代码详解
可以用curl获取借楼的信息。
所谓接口,就是提供一个url,只要你满足它要求的参数,就能得到你要的数据。比如你拿到一个接口,带上所需的参数,复制到地址栏同样能得到。不过最好用程序得到。file_get_contents也可以用,不过有局限性。所以我建议用curl。给你一个函数,挺好用的。
function request($url,$https=true,$method='GET',$data=null){
$ch = curl_init();//初始化,得到资源
curl_setopt($ch, CURLOPT_URL,$url); //请求数据的路径
curl_setopt($ch, CURLOPT_HEADER,false);//是否输出头
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); //不直接输出结果
//curl_setopt ($ch, CURLOPT_SAFE_UPLOAD, 0);//兼容php之后的版本
if($https){
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); //是否验证主机
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); //是否进行证书验证
}
if($method=='POST'){
curl_setopt($ch, CURLOPT_POST, true); //POST传输
curl_setopt($ch, CURLOPT_POSTFIELDS, $data); //传输数据
}
$content_json = curl_exec($ch);
if ($content_json === false) {
return "网络请求出错: " . curl_error($ch);
}
curl_close($ch);
return $content_json;
}
⑼ PHP怎么做接口
php做短信接口其实有2中
一种是直接post数据到对方的api
另外一种是通过soket来进行发送数据包
一般现在都是post形式进行发送数据了
socket的模式很少
⑽ 关于php 调用数据接口 实现网页逻辑的问题
当然是JSP啦。。。下面给你找了下资料 。 强势: 1、一处编写随处运行。这是一个程序员的梦想,也是从前的程序员的恶梦,为了在不同的平台间运行,使许多程序员一行行的重写代码。在这一点上java已经给了我最完美的答案它做的要比php更出色,除了系统之外,你的代码不用做一点更改的。 2、系统的多台平支持。我已经在差不多所有平台上见到了一致的java servlet/jsp的Web Server/Application Server……系统它可以让你在任意环境做开发,在任意环境进行系统部署,在任意环境扩展。相比asp/php的局限性是显面易见的。 3、强大的的可伸缩性。从只有一个小的jar文件就可以运行servlet/jsp到由多台服务器进行集群和负载均横,到多台Application进行事务处理、消息处理......一台服务器到无数以服务器,Java显示了一个巨人的生命力。 4、多样化和功能强大的开发工具支持。这一点与asp很像,java已经有了许多非常优秀的开发工具而且有许多可以免费得到,并且其中的许多已经可以顺利的运行于多种平台之下。如果你细心的使用它们会发现比自己第一面看到它们时的功能要强大的多。 弱势: 1、与ASP一样,Java的一些优势正是它致命的问题所在。正是由于为了跨平台的功能,为了极度的伸缩能力,所以极大的增加了产品的复杂性。这么说,它在扩展时需要的分成多少块,哪么java系统中就有多少种产品。所以你要以看到jre、jdk、jsdk、jswdk……,实际上它们只要有效的搭配在一起,就可以产生强大的效能,密不可分,但是对于一位初学者来说:“有没有搞错!难道让我运行一个jsp就要这么多乱七八糟的东西!” 2、从出现的第一天起就被对手痛骂的:“慢如老牛”。真的,我在第一次运行我的jsp时,我竟然以为我的机器机而将哪个进程给kill了!第一次编绎、运行对于使用者来说真是一场恶梦,在开发时我经常晚上做梦在看WinNT的任务管理器CPU格全绿时等着降下来的样子和感觉。 3、技巧还是技巧。一个短处就一定要付出代价的。Java的运行速度是用将class常驻内存来完成的,所以它在一些情况下所使用的内存比起用户数量来说却实是“最低性能价格比”了。另一方面来说,它还需要硬盘空间来存储一系列的.java文件和.class文件以及对应的版本文件。 4、缺少系统性的资料。这也许不该说,但是sun在国内做的却实很差劲,java的资烊在国内极少,到现在我还没有在书店里看到一本jsp的书,而对java体系的论述书更是少而又少,与java相关的书(中文版)到现在不过三位数。而再看看之中大量的具然还在讲Visual J++或是Java 1.1这样的阵年旧货。 总结: 适用人群:具有较强学习能力和耐心的开发人员。投入低但是希望拥有较大的伸缩能力的应用。 适用平台:……(太多而只不再一一列说)适用应用:Internet/Intranet高可靠性应用、Internet/Intranet与Client/Server结合的应用系统 学习方式:Java的Doc文档和java站点中的一系文档Internet的源代码资源(对不起大家,真的不能提出更好的建议了,再有的就是大家的能力和运气,以及Inetnet上网友的帮助了) 推荐开发工具:JBuilder/Visual Age for java(这个我没用过,但是有人强力推荐)/Sun Forte for JavaKAWA 推荐开发环境:Windows NT/Windows 2000开发系统JBuilder 3.5(它能成为Web Server,甚至不再需要其它的工具)Tomcat 3.1JDK 1.3(可以不安装)Access 2000/P II 266/128M RAM/9G HD 推荐应用环境(最少):RedHat Linux 6.2/MySQL 3.22/Apache 1.3.12/Tomcat 3.1/JDK 1.3Beta/PIII 500/512M RAM/9G HD 推荐应用环境(最佳):Solaris 8/Sybase 11/iPlanet Enterprise Web Server 4.1/JDK 1.3Beta/Sun Netra T1/1G RAM/18G HD