分类存档: php - 第5页

用PDO同时向MySQL插入多条数据

①、先看控制器层的业务逻辑

if($_POST){
		
	foreach($_FILES['fileinfo'] as $key=>$value){// $key value:name,type,tmp_name,error,size
		foreach($value as $ke=>$val){     // $ke value:1 2 3 4
			$arr[$ke][$key] = $val;
		}
	}
		
	$files_type=array("audio","video","image"); 
	
	foreach($arr as $k=>$v){
		if(!in_array(substr($v['type'],0,5),$files_type) || $v['size'] >= 8*1024*1024){
			echo "不支持".$v['name']."文件类型上传或文件尺寸大于8M";
			unset($arr[$k]);
		}else{
			$arr[$k]['utime'] =  time();	
			$arr[$k]['uid'] = $_SESSION['userid'];
		}	
	}
	
	
	if(!insert_multi($dbh,'media',$arr))
	{
		die("上传失败!");
	}
		
	view($html="list",array('data'=>$data),'admin/',$dir);	
}

②、模型层的业务逻辑

//通用多条插入
//insert into $table(param1,parm2,param3) values(value1,value2,value3),(value1,value2,value3);  
function insert_multi($dbh,$table,$data=array()){//$data['post']=$_POST;$data['files']=$arr;		
	//print_r($data);	
	foreach($data as $key=>$value){
		foreach($value as $ke=>$val){			
			//$data[$key]['id'] = null;			
			if($ke=='type'){
				$data[$key]['types']= $val;
				unset($data[$key][$ke]);
			}
			if($ke=='tmp_name'){
				$data[$key]['bin']= mysql_real_escape_string(file_get_contents($val));
				unset($data[$key][$ke]);
			}
			if($ke=='error'){
				unset($data[$key][$ke]);
			}		
		}
	}
	//print_r($data);	
	$keystr="";$valstr="";		
	for($i=0;$i<count($data);$i++){	
		//print_r($data[$i]);
 		foreach($data[$i] as $k=>$v){
			if($i==0){
				$keystr .= $k.",";				
			}
			$valstr .= "'".$v."',";	
		}
 		$valstr = substr($valstr,0,-1)."),(";  
	}
	
	$sql = "insert into $table(".substr($keystr,0,-1).") values(".substr($valstr,0,-2); 		
	//print_r($sql);
	return $dbh->query($sql);
}

PDO使用初探

PDO一是PHP数据对象(PHP Data Object)的缩写。

连接是通过创建 PDO 基类的实例而建立的。不管使用哪种驱动程序,都是用 PDO 类名。

<?php
$dbh = new PDO('mysql:host=localhost;dbname=test', $user, $pass);?>

注意:如果有任何连接错误,将抛出一个 PDOException 异常对象。

处理链接错误

<?phptry {
    $dbh = new PDO('mysql:host=localhost;dbname=test', $user, $pass);
    foreach($dbh->query('SELECT * from FOO') as $row) {
        print_r($row);
    }
    $dbh = null;} catch (PDOException $e) {
    print "Error!: " . $e->getMessage() . "<br/>";
    die();}
?>

连接数据成功后,返回一个 PDO 类的实例给脚本,此连接在 PDO 对象的生存周期中保持活动。

要想关闭连接,需要销毁对象以确保所有剩余到它的引用都被删除,可以赋一个 NULL 值给对象变量。

如果不这么做,PHP 在脚本结束时会自动关闭连接。

关闭一个链接

<?php
$dbh = new PDO('mysql:host=localhost;dbname=test', $user, $pass);// 在此使用连接


// 现在运行完成,在此关闭连接
$dbh = null;?>

很多 web 应用程序通过使用到数据库服务的持久连接获得好处。

持久连接在脚本结束后不会被关闭,且被缓存,当另一个使用相同凭证的脚本连接请求时被重用。

持久连接缓存可以避免每次脚本需要与数据库回话时建立一个新连接的开销,从而让 web 应用程序更快。

持久化链接

<?php
$dbh = new PDO('mysql:host=localhost;dbname=test', $user, $pass, array(
    PDO::ATTR_PERSISTENT => true));?>

注意如果想使用持久连接,必须在传递给 PDO 构造函数的驱动选项数组中设置 PDO::ATTR_PERSISTENT 。如果是在对象初始化之后用 PDO::setAttribute() 设置此属性,则驱动程序将不会使用持久连接。

和mysql_connect()对比

<?php                   
define("dbt","mysql");
define("host","localhost");
define("port","3306");
define("user","root");
define("pwd","123456");
define('dbname','cms');
define("dsn",dbt.":host=".host.";dbname=".dbname);
//function conn_db(){//version 5.5 and older for this : mysql_connect()
//      $conn = mysql_connect(url,user,pwd);
//      if($conn){
//              $db_rs = mysql_select_db(dbname,$conn);
//              if(!$db_rs){die("no connection".mysql_error());}
//      }else{
//              die("no connection".mysql_error());
//      }
//      mysql_query("set names UTF8");  
//}
//conn_db();
try{
        $dbh=new PDO(dsn,user,pwd);
        echo print_r($dbh)."</br>connection success!</br>";
        
        //close
        $dbh=null;
}catch(PDOException $e){
        die("Error!:".$e->getMessage()."</br>");
}
//print_r(dsn);
?>


参考: PDO参考手册


手工切换ubuntu16.04不同版本PHP

如果需要更新源:

#vim  /etc/apt/sources.list

在末尾加入

# deb cdrom:[Ubuntu 16.04 LTS _Xenial Xerus_ - Release amd64 (20160420.1)]/ xenial main restricted
deb-src http://archive.ubuntu.com/ubuntu xenial main restricted #Added by software-properties
deb http://mirrors.aliyun.com/ubuntu/ xenial main restricted
deb-src http://mirrors.aliyun.com/ubuntu/ xenial main restricted multiverse universe #Added by software-properties
deb http://mirrors.aliyun.com/ubuntu/ xenial-updates main restricted
deb-src http://mirrors.aliyun.com/ubuntu/ xenial-updates main restricted multiverse universe #Added by software-properties
deb http://mirrors.aliyun.com/ubuntu/ xenial universe
deb http://mirrors.aliyun.com/ubuntu/ xenial-updates universe
deb http://mirrors.aliyun.com/ubuntu/ xenial multiverse
deb http://mirrors.aliyun.com/ubuntu/ xenial-updates multiverse
deb http://mirrors.aliyun.com/ubuntu/ xenial-backports main restricted universe multiverse
deb-src http://mirrors.aliyun.com/ubuntu/ xenial-backports main restricted universe multiverse #Added by software-properties
deb http://archive.canonical.com/ubuntu xenial partner
deb-src http://archive.canonical.com/ubuntu xenial partner
deb http://mirrors.aliyun.com/ubuntu/ xenial-security main restricted
deb-src http://mirrors.aliyun.com/ubuntu/ xenial-security main restricted multiverse universe #Added by software-properties
deb http://mirrors.aliyun.com/ubuntu/ xenial-security universe
deb http://mirrors.aliyun.com/ubuntu/ xenial-security multiverse

#apt-get update

#apt-get upgrade

#apt-get install php5

如果需要安装依赖

# apt-get install php5-fpm php5-gli php5-cgi libapache2-mod-php5filter libapache2-mod-php5

#apt-get install php5

停用原来版本

#a2dismod php7 

启用刚安装的版本

#a2enmod php5

#service apache2 restart

最后用phpinfo()检查

求全国当前不同地区的日出与日落时间

        一、准备全国经纬度数据文件

        二、看代码

fwrite(STDOUT,"请输入城市名:");
$city = trim(fgets(STDIN)); 
format_long_la($city);

function format_long_la($city){
    $arrtemp = get_long_la($city=$city); 
    if(count($arrtemp)==1){
        $newarr = explode(" ",$arrtemp[0]);$length = count($newarr);
        $long = explode(":",$newarr[$length-1]);//经度数组
        $la   = explode(":",$newarr[$length-2]);//纬度数组
        $arr  = array_merge($la,$long);$len = count($arr);
        for($i=0;$i<$len;$i++){//删除不能转换为数字类型的值
            if(!is_numeric($arr[$i])){
                unset($arr[$i]);
            }     
        }
        print_r($arr);
        
        echo date("Y M d D")."\n北纬".$arr[3]."\n东经".$arr[1]."\n".$city."的\n日出时间是:"
            .date_sunrise(time(),SUNFUNCS_RET_STRING,$arr[3],$arr[1],90,8)."\n";
        echo "日落时间是:".date_sunset(time(),SUNFUNCS_RET_STRING,$arr[3],$arr[1],90,8)."\n";
        
        fwrite(STDOUT,"请输入城市名:");
        $city = trim(fgets(STDIN)); 
        format_long_la($city);

    }else if(empty($arrtemp)){
        fwrite(STDOUT,"\n地址不存在,请输入详细地址:");
        $city = trim(fgets(STDIN)); 
        format_long_la($city);      
    }else{
        echo print_r(get_long_la($city=$city));
        fwrite(STDOUT,"\n包含".$city."的结果太多,请输入城市名:");
        $city = trim(fgets(STDIN)); 
        format_long_la($city);      
    }   
}
function get_rise_time(){}
function get_set_time(){}

function get_long_la($city="北京"){
    $arr = array(); 
    $file = 'thelongitudeandlatitude.html';
    if(file_get_contents($file)){
        $str = file_get_contents($file);
    }else{
        echo "文件不存在!";
    }
    $str = trim($str);
    $arr = explode("【",$str);$length = count($arr);//取'【'进行切割
    $strtemp = array();$ij= ""; 
    for($i = 1;$i < $length;$i++){
        if(!empty($arr[$i])&&$arr[$i]!=""){
            $arr[$i] = explode(";",$arr[$i]);//取';'进行切割
            $len = count($arr[$i]);
        }       
        for($j = 0;$j<$len;$j++){
            if(!empty($arr[$i][$j])&&$arr[$i][$j]!=""){
                $ij = $arr[$i][$j];
            }
            //echo "arr$i-$j:".$ij."</br>";
            if(strpos($ij,$city)){
                $strtemp[] = $ij;//break 2;//跳出双重循环,执行下边的语句
            }
        }
    }   
    return $strtemp;
}

        将代码与全国经纬度数据放在同一目录下,在php CLI环境下执行该文件就可。

        三、其他:全球78707个地址经纬度数据

$_SERVER预定义服务器变量

$_SERVER[‘PHP_SELF’] #当前正在执行脚本的文件名,与 document root相关。
$_SERVER[‘argv’] #传递给该脚本的参数。
$_SERVER[‘argc’] #包含传递给程序的命令行参数的个数(如果运行在命令行模式)。
$_SERVER[‘GATEWAY_INTERFACE’] #服务器使用的 CGI 规范的版本。例如,“CGI/1.1”。
$_SERVER[‘SERVER_NAME’] #当前运行脚本所在服务器主机的名称。

继续阅读 »