diff --git a/plugins/FeedsHTTPFetcher.inc b/plugins/FeedsHTTPFetcher.inc
index f17aaff707e10a16abb9a21180c946cfca935d1f..698d5c63955ae29a0d8974f4bc61459920d3e954 100644
--- a/plugins/FeedsHTTPFetcher.inc
+++ b/plugins/FeedsHTTPFetcher.inc
@@ -226,7 +226,7 @@ class PuSHSubscription implements PuSHSubscriptionInterface {
    * Load a subscription.
    */
   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']);
       return new PuSHSubscription($v['domain'], $v['subscriber_id'], $v['hub'], $v['topic'], $v['secret'], $v['status'], $v['post_fields'], $v['timestamp']);
     }
diff --git a/plugins/FeedsTermProcessor.inc b/plugins/FeedsTermProcessor.inc
index 7fa48b3d648b99c4c86ef4b87bd1dcf5fa8e460d..5b26c492d0a9d99b6d31c4776ef88b39809e57f7 100644
--- a/plugins/FeedsTermProcessor.inc
+++ b/plugins/FeedsTermProcessor.inc
@@ -89,14 +89,18 @@ class FeedsTermProcessor extends FeedsProcessor {
   public function clear(FeedsBatch $batch, FeedsSource $source) {
     $deleted = 0;
     $vocabulary = $this->vocabulary();
-    $result = db_query("SELECT td.tid
+    $terms = db_query("SELECT td.tid
                         FROM {term_data} td
                         JOIN {feeds_term_item} ft ON td.tid = ft.tid
-                        WHERE td.vid = %d
-                        AND ft.id = '%s'
-                        AND ft.feed_nid = %d",
-                        $vocabulary->vid, $this->id, $source->feed_nid);
-    while ($term = db_fetch_object($result)) {
+                        WHERE td.vid = :vid
+                        AND ft.id = :id
+                        AND ft.feed_nid = :feed_nid",
+                        array(
+                          ':vid' => $vocabulary->vid,
+                          ':id' => $this->id,
+                          ':feed_nid' => $source->feed_nid,
+                        ));
+    foreach ($terms as $term) {
       if (taxonomy_del_term($term->tid) == SAVED_DELETED) {
         $deleted++;
       }