php/yii2
1
0
Fork 0
mirror of https://github.com/yiisoft/yii2.git synced 2025-11-09 01:27:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

Sphinx Active Record saving via 'replace' converted into fallback

Browse Source
This commit is contained in:
Paul Klimov
2013-11-18 15:36:06 +02:00
parent cd3950aaa7
commit bd79e1c1be
2 changed files with 23 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
extensions/sphinx/ActiveRecord.php
View File

@ -851,7 +851,20 @@ class ActiveRecord extends Model
return 0; return 0;
} }
// Replace is supported only by runtime indexes and necessary only for field update
$useReplace = false;
$indexSchema = $this->getIndexSchema();
if ($this->getIndexSchema()->isRuntime) { if ($this->getIndexSchema()->isRuntime) {
foreach ($values as $name => $value) {
$columnSchema = $indexSchema->getColumn($name);
if ($columnSchema->isField) {
$useReplace = true;
break;
}
}
}
if ($useReplace) {
$values = array_merge($values, $this->getOldPrimaryKey(true)); $values = array_merge($values, $this->getOldPrimaryKey(true));
$command = static::getDb()->createCommand(); $command = static::getDb()->createCommand();
$command->replace(static::indexName(), $values); $command->replace(static::indexName(), $values);

10
tests/unit/extensions/sphinx/ActiveRecordTest.php
View File

@ -161,6 +161,16 @@ class ActiveRecordTest extends SphinxTestCase
$record2 = RuntimeIndex::find(['id' => 2]); $record2 = RuntimeIndex::find(['id' => 2]);
$this->assertEquals(9, $record2->type_id); $this->assertEquals(9, $record2->type_id);
// replace
$query = 'replace';
$rows = RuntimeIndex::find($query);
$this->assertEmpty($rows);
$record = RuntimeIndex::find(['id' => 2]);
$record->content = 'Test content with ' . $query;
$record->save();
$rows = RuntimeIndex::find($query);
$this->assertNotEmpty($rows);
// updateAll // updateAll
$pk = ['id' => 2]; $pk = ['id' => 2];
$ret = RuntimeIndex::updateAll(['type_id' => 55], $pk); $ret = RuntimeIndex::updateAll(['type_id' => 55], $pk);