<?php
class PD
{
//造对象
public $dsn = "mysql:dbname=test2;host=localhost"; //数据库类型，数据库名和服务器地址
public $uid="root"; //用户名
public $pwd="123"; //密码 /**
*给一个sql语句，返回执行的结果
*@param string $sql 用户指定的sql语句
*@param array $attr 用户指定的数组，默认为空
*@param int $type 用户给的语句类型，0代表增删改，1代表查询
*@return 返回查询的结果，如果是查询返回二维数组,如果是增删改返回true或false
*/ function EXEC($sql,$attr=array(),$type=1)
{
//造连接对象
$pdo = new PDO($this->dsn,$this->uid,$this->pwd); //执行sql语句
$st = $pdo->prepare($sql); //判断增、删、改、查
if($type==0)
{
return $st->execute($attr);
}
else if($type==1) //从结果集对象里面取数据
{
if(!empty($attr) && count($attr)>0) //判断是否有传过来进行查询的数组
{
$st->execute($attr);
return $st->fetchAll(PDO::FETCH_ASSOC);
}
else
{
$st->execute();
return $st->fetchAll(PDO::FETCH_ASSOC);
}
}
else
{
return false;
} } function StrEXEC($sql,$attr=array(),$type=1)
{
//造连接对象
$pdo = new PDO($this->dsn,$this->uid,$this->pwd); //执行sql语句
$st = $pdo->prepare($sql); //判断增、删、改、查
if($type==0)
{
return $st->execute($attr);
}
else if($type==1) //从结果集对象里面取数据
{
if(!empty($attr) && count($attr)>0) //判断是否有传过来进行查询的数组
{
$st->execute($attr);
$data = $st->fetchAll(PDO::FETCH_ASSOC);
$str="";
foreach($data as $v) //进行字符串的拼接
{
$str .= implode("^",$v);
$str .="|";
}
return substr($str,0,strlen($str)-1);
}
else
{
$st->execute();
$data = $st->fetchAll(PDO::FETCH_ASSOC);
$str="";
foreach($data as $v)
{
$str .= implode("^",$v);
$str .="|";
}
return substr($str,0,strlen($str)-1);
}
}
else
{
return false;
} } }