Skip to content
Snippets Groups Projects
Commit 8211ca8c authored by Alex Barth's avatar Alex Barth
Browse files

More DB query updates.

parent 88f92d3b
No related branches found
No related tags found
No related merge requests found
...@@ -226,7 +226,7 @@ class PuSHSubscription implements PuSHSubscriptionInterface { ...@@ -226,7 +226,7 @@ class PuSHSubscription implements PuSHSubscriptionInterface {
* Load a subscription. * Load a subscription.
*/ */
public static function load($domain, $subscriber_id) { public static function load($domain, $subscriber_id) {
if ($v = db_fetch_array(db_query("SELECT * FROM {feeds_push_subscriptions} WHERE domain = '%s' AND subscriber_id = %d", $domain, $subscriber_id))) { if ($v = db_query("SELECT * FROM {feeds_push_subscriptions} WHERE domain = :domain AND subscriber_id = :sid", array(':domain' => $domain, ':sid' => $subscriber_id))->fetchAssoc()) {
$v['post_fields'] = unserialize($v['post_fields']); $v['post_fields'] = unserialize($v['post_fields']);
return new PuSHSubscription($v['domain'], $v['subscriber_id'], $v['hub'], $v['topic'], $v['secret'], $v['status'], $v['post_fields'], $v['timestamp']); return new PuSHSubscription($v['domain'], $v['subscriber_id'], $v['hub'], $v['topic'], $v['secret'], $v['status'], $v['post_fields'], $v['timestamp']);
} }
......
...@@ -89,14 +89,18 @@ class FeedsTermProcessor extends FeedsProcessor { ...@@ -89,14 +89,18 @@ class FeedsTermProcessor extends FeedsProcessor {
public function clear(FeedsBatch $batch, FeedsSource $source) { public function clear(FeedsBatch $batch, FeedsSource $source) {
$deleted = 0; $deleted = 0;
$vocabulary = $this->vocabulary(); $vocabulary = $this->vocabulary();
$result = db_query("SELECT td.tid $terms = db_query("SELECT td.tid
FROM {term_data} td FROM {term_data} td
JOIN {feeds_term_item} ft ON td.tid = ft.tid JOIN {feeds_term_item} ft ON td.tid = ft.tid
WHERE td.vid = %d WHERE td.vid = :vid
AND ft.id = '%s' AND ft.id = :id
AND ft.feed_nid = %d", AND ft.feed_nid = :feed_nid",
$vocabulary->vid, $this->id, $source->feed_nid); array(
while ($term = db_fetch_object($result)) { ':vid' => $vocabulary->vid,
':id' => $this->id,
':feed_nid' => $source->feed_nid,
));
foreach ($terms as $term) {
if (taxonomy_del_term($term->tid) == SAVED_DELETED) { if (taxonomy_del_term($term->tid) == SAVED_DELETED) {
$deleted++; $deleted++;
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment