Yii2实现跨mysql数据库关联查询排序功能代码
背景：在一个mysql服务器上（注意：两个数据库必须在同一个mysql服务器上）有两个数据库：
memory(存储常规数据表)中有一个user表(记录用户信息)
memory_stat(存储统计数据表)中有一个user_stat(记录用户统计数据)
现在在user表生成的GridView列表中展示user_stat中的统计数据
只需要在User的model类中添加关联
publicfunctiongetStat()
{
return$this->hasOne(UserStat::className(),['user_id'=>'id']);
}
在GridView就可以这样使用来展示统计数据
<?=GridView::widget([
'dataProvider'=>$dataProvider,
'columns'=>[
//其他列
[
'label'=>'统计数据',
'value'=>function($model){
returnisset($model->stat->data)?$model->stat->data:null;
}
],
//其他列
],
]);?>
现在增加了一个需求，需要在userGridView列表中对统计数据进行排序和筛选
若user和user_stat表在同一个数据库下我们可以这样做：
UserSearch:
public$data;
publicfunctionrules()
{/*{{{*/
return[
['data'],'integer'],
//其他列
];
}/*}}}*/
publicfunctionsearch($params,$onlyActiveUsers=false)
{
$query=User::find();
$query->joinWith(['stat']);
$dataProvider=newActiveDataProvider([
'query'=>$query,
'sort'=>[
'attributes'=>[
//其他列
'data'=>[
'asc'=>[UserStat::tableName().'.data'=>SORT_ASC],
'desc'=>[UserStat::tableName().'.data'=>SORT_DESC],
],
//其他列
],
'defaultOrder'=>[
'id'=>SORT_DESC,
],
],
'pagination'=>[
'pageSize'=>50,
],
]);
$this->load($params);
if(!$this->validate()){
$query->where('0=1');
return$dataProvider;
}
$query->filterWhere([
//其他列
UserStat::tableName().'.data'=>$this->data
]);
return$dataProvider;
}
在GridView就可以这样使用来展示统计数据,就可以排序了
<?=GridView::widget([
'dataProvider'=>$dataProvider,
'columns'=>[
//其他列
[
'label'=>'统计数据',
'attribute'=>'data',
'value'=>function($model){
returnisset($model->stat->data)?$model->stat->data:null;
}
],
//其他列
],
]);?>
search表单中添加以下列就可以筛选了
<?php$form=ActiveForm::begin();?>
//其他列
<?=$form->field($model,'data')?>
//其他列
<divclass="form-group">
<?=Html::submitButton('Search',['class'=>'btnbtn-primary'])?>
</div>
<?phpActiveForm::end();?>
然而现实是残酷的，user和user_stat表并在同一个数据库下。
于是就会报出这样一个错误：
SQLSTATE[42S02]:Basetableorviewnotfound:1146Table'memory.user_stat'doesn'texist
TheSQLbeingexecutedwas:...
要在两个数据库（同一台服务器）上进行关联数据查询，纯SQL语句如下：
selecta.*,b.*frommemory.userasa,memory_stat.user_statasbwherea.id=b.user_id;
Yii2转化成SQL语句时默认不会在表明前添加数据库名，于是mysql在执行sql语句时就会默认此表在memory数据库下。
selecta.*,b.*frommemory.userasa,memory.user_statasbwherea.id=b.user_id;
于是就出现了以上报错信息。
那么，如何来解决这个问题呢？
其实很简单，只需要重写user_stat的model类下的tableName()方法就可以了。
//默认是这样的
publicstaticfunctiontableName()
{
return'user_stat';
}
publicstaticfunctiongetDb()
{
returnYii::$app->get('dbStat');
}
//只需要在表明前添加数据库名
publicstaticfunctiontableName()
{
return'memory_stat.user_stat';
}
publicstaticfunctiongetDb()
{
returnYii::$app->get('dbStat');
}
//为了提高代码稳定性，可以这样写
publicstaticfunctiontableName()
{
preg_match("/dbname=([^;]+)/i",static::getDb()->dsn,$matches);
return$matches[1].'.user_stat';
}
publicstaticfunctiongetDb()
{
returnYii::$app->get('dbStat');
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。