← Back to branch summary

~eday/burrow/doc-updates

« back to all changes in this revision

Viewing changes to burrow/backend/sqlite.py

  • Committer: Tarmac
  • Author(s): Eric Day
  • Date: 2011-06-29 20:51:02 UTC
  • mfrom: (20.1.1 lp803237)
  • Revision ID: tarmac-20110629205102-f2kh0r0nyinn3xj3
Fixed bug #803237. More query string cleanup to do, will do full review later.

Show diffs side-by-side

added added

removed removed

Lines of Context:
burrow/backend/sqlite.py
97
97
            yield message
98
98
        if len(ids) == 0:
99
99
            return
100
 
        query = 'DELETE FROM messages WHERE queue=%d AND name IN (%s)'
101
 
        self.db.execute(query % (rowid, ','.join(ids)))
 
100
        values = (rowid,) + tuple(ids)
 
101
        query = 'DELETE FROM messages WHERE queue=? AND name IN (%s)'
 
102
        self.db.execute(query % ','.join('?' * len(ids)), values)
102
103
        query = 'SELECT rowid FROM messages WHERE queue=? LIMIT 1'
103
104
        if len(self.db.execute(query, (rowid,)).fetchall()) == 0:
104
105
            query = 'DELETE FROM queues WHERE rowid=?'
142
143
        if comma == '':
143
144
            return
144
145
        values += (rowid,)
 
146
        values += tuple(ids)
145
147
        query += ' WHERE queue=? AND name IN (%s)'
146
 
        self.db.execute(query % ','.join(ids), values)
 
148
        self.db.execute(query % ','.join('?' * len(ids)), values)
147
149
        self.notify(account, queue)
148
150
 
149
151
    def create_message(self, account, queue, message, body, attributes):