1 dbConnect>>>链接数据库
---------------配置文件databanse.ini.php----------------------------------------
if(!defined('IN_XIAOCMS'))exit();
return array(
'host'=>'localhost',
'username'=>'root',
'password'=>'123456',
'dbname'=>'tougu',
'prefix'=>'xiao_',
'port'=>'3306',
'charset'=>'utf8',
);
---------------链接部分----------------------------------------
classdbConnect
{
private$pdo;
/**
* dbConnect constructor.
*/
public function__construct()
{
$params= xiaocms::load_config('database');
if(!is_array($params))exit('数据库配置文件不存在');
foreach($paramsas$key=>$value) {
$params[$key] =trim($value);
}
$dsn_array=array();
$dsn_array['host'] =$params['host'];
$dsn_array['port'] =$params['port'];
$dsn_array['dbname'] =$params['dbname'];
$dsn_array['charset'] =$params['charset'];
$params['dsn'] =sprintf('%s:%s','mysql',http_build_query($dsn_array,'',';'));
$options=array(PDO::MYSQL_ATTR_INIT_COMMAND=>"SET NAMES 'utf8';", PDO::ATTR_ERRMODE=> PDO::ERRMODE_EXCEPTION,PDO::ATTR_PERSISTENT=>true);
$this->pdo=newPDO($params['dsn'],$params['username'],$params['password'],$options);
}
public functionexecute($sql)
{
return$this->pdo->query($sql)->fetchAll(PDO::FETCH_ASSOC);
}
}
----------------定义存储过程-------------------------------------------------------------------------------------
public functionqueryTopicAndNewsBySubscriberId($type,$offset,$pageSize,$userId)
{
return$this->procedure
->setProcedureName('queryTopicAndNewsBySubscriberId')
->setArgument($type.','.$offset.','.$pageSize.','.$userId)
->getResult();
}
-----------------调用--------------------------------------------------------------------------------
$content=newcontentDb();
//查询所有的直播
$result=$content->querylive($this->type,$limit,20,$this->getIdentity()->getUserName());
