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'); }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。