hazza/Phraseanet
1
0
Fork 0
mirror of https://github.com/alchemy-fr/Phraseanet.git synced 2025-10-14 21:43:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix update sphinx

Browse Source
This commit is contained in:
Romain Neutron
2012-03-07 11:46:01 +01:00
parent 76c0ece4ee
commit d02b04ece6
1 changed files with 10 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
lib/classes/sphinxrt.class.php
View File

@@ -81,7 +81,7 @@ class sphinxrt
if ($rt_id) if ($rt_id)
{ {
$this->connection->beginTransaction(); $this->connection->beginTransaction();
$sql = "DELETE FROM " . $rt_id . " WHERE id = " . (int) $id . ""; $sql = "DELETE FROM " . $rt_id . " WHERE id = " . (int) $id . "";
$stmt = $this->connection->prepare($sql); $stmt = $this->connection->prepare($sql);
$stmt->execute(); $stmt->execute();
$stmt->closeCursor(); $stmt->closeCursor();
@@ -99,14 +99,13 @@ class sphinxrt
$cl = new SphinxClient(); $cl = new SphinxClient();
if ($cl->Status() === false) if ($cl->Status() === false)
return $this; return $this;
$cl->SetServer($registry->get('GV_sphinx_host'), (int) $registry->get('GV_sphinx_port')); $cl->SetServer($registry->get('GV_sphinx_host'), (int) $registry->get('GV_sphinx_port'));
$cl->SetConnectTimeout(1); $cl->SetConnectTimeout(1);
$status = strrev($status); $status = strrev($status);
$new_stat = array(); $new_stat = array();
for ($i = 4; $i < strlen($status); $i++) for ($i = 4; $i < strlen($status); $i++)
{ {
@@ -122,20 +121,18 @@ class sphinxrt
return $this; return $this;
} }
public function replace_in_metas($rt_id, $meta_id, $tag_id, $record_id, $sbas_id, $coll_id, $grouping, $type, Array $content, DateTime $created) public function replace_in_metas($rt_id, $meta_id, $tag_id, $record_id, $sbas_id, $coll_id, $grouping, $type, $content, DateTime $created)
{ {
$crc_sbas_tag = crc32($sbas_id . '_' . $tag_id); $crc_sbas_tag = crc32($sbas_id . '_' . $tag_id);
$crc_sbas_coll = crc32($sbas_id . '_' . $coll_id); $crc_sbas_coll = crc32($sbas_id . '_' . $coll_id);
$crc_sbas_record = crc32($sbas_id . '_' . $record_id); $crc_sbas_record = crc32($sbas_id . '_' . $record_id);
$crc_type = crc32($type); $crc_type = crc32($type);
$this->connection->beginTransaction(); $this->connection->beginTransaction();
// foreach ($content as $value) $sql = "REPLACE INTO " . $rt_id . " VALUES (
// {
$sql = "REPLACE INTO " . $rt_id . " VALUES (
'" . (int) $meta_id . "' '" . (int) $meta_id . "'
,'" . str_replace("'", "\'", implode(' ', $content)) . "' ,'" . str_replace("'", "\'", $content) . "'
,'" . (int) $tag_id . "' ,'" . (int) $tag_id . "'
," . (int) $record_id . " ," . (int) $record_id . "
," . (int) $sbas_id . " ," . (int) $sbas_id . "
@@ -149,7 +146,6 @@ class sphinxrt
," . (int) $created->format('U') . " )"; ," . (int) $created->format('U') . " )";
$stmt = $this->connection->prepare($sql); $stmt = $this->connection->prepare($sql);
$stmt->execute(); $stmt->execute();
// }
$stmt->closeCursor(); $stmt->closeCursor();
@@ -160,9 +156,9 @@ class sphinxrt
public function replace_in_documents($rt_id, $record_id, $value, $sbas_id, $coll_id, $grouping, $type, DateTime $created) public function replace_in_documents($rt_id, $record_id, $value, $sbas_id, $coll_id, $grouping, $type, DateTime $created)
{ {
$crc_sbas_coll = crc32($sbas_id . '_' . $coll_id); $crc_sbas_coll = crc32($sbas_id . '_' . $coll_id);
$crc_sbas_record = crc32($sbas_id . '_' . $record_id); $crc_sbas_record = crc32($sbas_id . '_' . $record_id);
$crc_type = crc32($type); $crc_type = crc32($type);
$this->connection->beginTransaction(); $this->connection->beginTransaction();