php使用pdo连接并查询sql数据库的方法

$login = "root"; 
$passwd = "mysql"; 
try{ 
  $db=new pdo('mysql:host=localhost;dbname=mysql',$login,$passwd); 
  foreach($db->query('select * from test') as $row){ 
  print_r($row); 
  } 
  $db=null; 
}catch(pdoexception $e){ 
  echo $e->getmessage(); 
}

$dbms='mysql'; //数据库类型 oracle 用odi,对于开发者来说，使用不同的数据库，只要改这个，不用记住那么多的函数了 
$host='localhost'; //数据库主机名 
$dbname='test'; //使用的数据库 
$user='root'; //数据库连接用户名 
$pass=''; //对应的密码 
$dsn="$dbms:host=$host;dbname=$dbname";  
class db extends pdo {    
 public function __construct(){         
 try {              
 parent::__construct("$globals[dsn]", $globals['user'], $globals['pass']);          
 } catch (pdoexception $e) {          
  die("error: " . $e->__tostring() . "<br/>");        
  }     
  }         
 public final function query($sql){         
 try {            
  return parent::query($this->setstring($sql));         
  }catch (pdoexception $e){             
  die("error: " . $e->__tostring() . "<br/>");        
   }
   }         
   private final function setstring($sql){         
   echo "我要处理一下$sql";         
   return $sql;    }} 
   $db=new db(); 
   $db->setattribute(pdo::attr_case, pdo::case_upper); 
   foreach ($db->query('select * from xxxx_menu') as $row) {     
   print_r($row); 
   } 
$db->exec('delete from `xxxx_menu` where mid=43');