diff --git a/trac/db/mysql_backend.py b/trac/db/mysql_backend.py
|
a
|
b
|
|
| 214 | 214 | return 'concat(%s)' % ', '.join(args) |
| 215 | 215 | |
| 216 | 216 | def like(self): |
| | 217 | """Return a case-insensitive LIKE clause.""" |
| 217 | 218 | return "LIKE %s COLLATE utf8_general_ci ESCAPE '/'" |
| 218 | 219 | |
| 219 | 220 | def like_escape(self, text): |
diff --git a/trac/db/postgres_backend.py b/trac/db/postgres_backend.py
|
a
|
b
|
|
| 197 | 197 | return '||'.join(args) |
| 198 | 198 | |
| 199 | 199 | def like(self): |
| 200 | | # Temporary hack needed for the case-insensitive string matching in the |
| 201 | | # search module |
| | 200 | """Return a case-insensitive LIKE clause.""" |
| 202 | 201 | return "ILIKE %s ESCAPE '/'" |
| 203 | 202 | |
| 204 | 203 | def like_escape(self, text): |
diff --git a/trac/db/sqlite_backend.py b/trac/db/sqlite_backend.py
|
a
|
b
|
|
| 253 | 253 | return '||'.join(args) |
| 254 | 254 | |
| 255 | 255 | def like(self): |
| | 256 | """Return a case-insensitive LIKE clause.""" |
| 256 | 257 | if sqlite_version >= 30100: |
| 257 | 258 | return "LIKE %s ESCAPE '/'" |
| 258 | 259 | else: |
diff --git a/trac/ticket/model.py b/trac/ticket/model.py
|
a
|
b
|
|
| 382 | 382 | cursor.execute("SELECT time,author FROM ticket_change " |
| 383 | 383 | "WHERE ticket=%%s AND field='comment' " |
| 384 | 384 | " AND (oldvalue=%%s OR oldvalue %s)" % db.like(), |
| 385 | | (self.id, scnum, '%.' + db.like_escape(scnum))) |
| | 385 | (self.id, scnum, '%' + db.like_escape('.' + scnum))) |
| 386 | 386 | for ts, author in cursor: |
| 387 | 387 | cursor.execute("SELECT field,author,oldvalue,newvalue " |
| 388 | 388 | "FROM ticket_change " |
| … |
… |
|
| 403 | 403 | when_ts = to_timestamp(when) |
| 404 | 404 | |
| 405 | 405 | db, handle_ta = self._get_db_for_write(db) |
| 406 | | like = db.like() |
| 407 | 406 | cursor = db.cursor() |
| 408 | 407 | cursor.execute("SELECT time,newvalue FROM ticket_change " |
| 409 | 408 | "WHERE ticket=%%s AND field='comment' " |
| 410 | | " AND (oldvalue=%%s OR oldvalue %s)" % like, |
| 411 | | (self.id, scnum, '%.' + db.like_escape(scnum))) |
| | 409 | " AND (oldvalue=%%s OR oldvalue %s)" % db.like(), |
| | 410 | (self.id, scnum, '%' + db.like_escape('.' + scnum))) |
| 412 | 411 | for (ts, old_comment) in cursor: |
| 413 | 412 | if comment == old_comment: |
| 414 | 413 | return |
| 415 | 414 | cursor.execute("SELECT COUNT(ticket) FROM ticket_change " |
| 416 | | "WHERE ticket=%%s AND time=%%s AND field %s" % like, |
| 417 | | (self.id, ts, db.like_escape('_comment') + '%')) |
| | 415 | "WHERE ticket=%s AND time=%s " |
| | 416 | " AND field>='_comment0' and field<'_comment:'", |
| | 417 | (self.id, ts)) |
| 418 | 418 | rev = cursor.fetchone()[0] |
| 419 | 419 | cursor.execute("INSERT INTO ticket_change " |
| 420 | 420 | "(ticket,time,author,field,oldvalue,newvalue) " |
| … |
… |
|
| 431 | 431 | def get_comment_history(self, cnum, db=None): |
| 432 | 432 | scnum = str(cnum) |
| 433 | 433 | db = self._get_db(db) |
| 434 | | like = db.like() |
| 435 | 434 | history = [] |
| 436 | 435 | cursor = db.cursor() |
| 437 | 436 | cursor.execute("SELECT time,author,newvalue FROM ticket_change " |
| 438 | 437 | "WHERE ticket=%%s AND field='comment' " |
| 439 | | " AND (oldvalue=%%s OR oldvalue %s)" % like, |
| 440 | | (self.id, scnum, '%.' + db.like_escape(scnum))) |
| | 438 | " AND (oldvalue=%%s OR oldvalue %s)" % db.like(), |
| | 439 | (self.id, scnum, '%' + db.like_escape('.' + scnum))) |
| 441 | 440 | for (ts0, author0, last_comment) in cursor: |
| 442 | 441 | cursor.execute("SELECT field,author,oldvalue,newvalue " |
| 443 | 442 | "FROM ticket_change " |
| 444 | | "WHERE ticket=%%s AND time=%%s AND field %s" % like, |
| 445 | | (self.id, ts0, db.like_escape('_comment') + '%')) |
| | 443 | "WHERE ticket=%s AND time=%s " |
| | 444 | " AND field>='_comment0' and field<'_comment:'", |
| | 445 | (self.id, ts0)) |
| 446 | 446 | for field, author, comment, ts in cursor: |
| 447 | 447 | rev = int(field[8:]) |
| 448 | 448 | history.append((rev, datetime.fromtimestamp(int(ts0), utc), |
diff --git a/trac/ticket/tests/query.py b/trac/ticket/tests/query.py
|
a
|
b
|
|
| 210 | 210 | FROM ticket AS t |
| 211 | 211 | LEFT OUTER JOIN enum AS priority ON (priority.type='priority' AND priority.name=priority) |
| 212 | 212 | WHERE ((COALESCE(t.owner,'') %(like)s)) |
| 213 | | ORDER BY COALESCE(t.id,0)=0,t.id""" % {'like': self.env.get_db_cnx().like()}) |
| | 213 | ORDER BY COALESCE(t.id,0)=0,t.id""" % {'like': self.env.get_db_cnx().like()}) |
| 214 | 214 | self.assertEqual(['%someone%'], args) |
| 215 | 215 | tickets = query.execute(self.req) |
| 216 | 216 | |
| … |
… |
|
| 222 | 222 | FROM ticket AS t |
| 223 | 223 | LEFT OUTER JOIN enum AS priority ON (priority.type='priority' AND priority.name=priority) |
| 224 | 224 | WHERE ((COALESCE(t.owner,'') NOT %(like)s)) |
| 225 | | ORDER BY COALESCE(t.id,0)=0,t.id""" % {'like': self.env.get_db_cnx().like()}) |
| | 225 | ORDER BY COALESCE(t.id,0)=0,t.id""" % {'like': self.env.get_db_cnx().like()}) |
| 226 | 226 | self.assertEqual(['%someone%'], args) |
| 227 | 227 | tickets = query.execute(self.req) |
| 228 | 228 | |
| … |
… |
|
| 234 | 234 | FROM ticket AS t |
| 235 | 235 | LEFT OUTER JOIN enum AS priority ON (priority.type='priority' AND priority.name=priority) |
| 236 | 236 | WHERE ((COALESCE(t.owner,'') %(like)s)) |
| 237 | | ORDER BY COALESCE(t.id,0)=0,t.id""" % {'like': self.env.get_db_cnx().like()}) |
| | 237 | ORDER BY COALESCE(t.id,0)=0,t.id""" % {'like': self.env.get_db_cnx().like()}) |
| 238 | 238 | self.assertEqual(['someone%'], args) |
| 239 | 239 | tickets = query.execute(self.req) |
| 240 | 240 | |
| … |
… |
|
| 246 | 246 | FROM ticket AS t |
| 247 | 247 | LEFT OUTER JOIN enum AS priority ON (priority.type='priority' AND priority.name=priority) |
| 248 | 248 | WHERE ((COALESCE(t.owner,'') %(like)s)) |
| 249 | | ORDER BY COALESCE(t.id,0)=0,t.id""" % {'like': self.env.get_db_cnx().like()}) |
| | 249 | ORDER BY COALESCE(t.id,0)=0,t.id""" % {'like': self.env.get_db_cnx().like()}) |
| 250 | 250 | self.assertEqual(['%someone'], args) |
| 251 | 251 | tickets = query.execute(self.req) |
| 252 | 252 | |
| … |
… |
|
| 423 | 423 | FROM ticket AS t |
| 424 | 424 | LEFT OUTER JOIN enum AS priority ON (priority.type='priority' AND priority.name=priority) |
| 425 | 425 | WHERE (((COALESCE(t.keywords,'') %(like)s AND COALESCE(t.keywords,'') NOT %(like)s AND COALESCE(t.keywords,'') %(like)s))) |
| 426 | | ORDER BY COALESCE(t.id,0)=0,t.id""" % {'like': self.env.get_db_cnx().like()}) |
| | 426 | ORDER BY COALESCE(t.id,0)=0,t.id""" % {'like': self.env.get_db_cnx().like()}) |
| 427 | 427 | self.assertEqual(['%foo%', '%bar%', '%baz%'], args) |
| 428 | 428 | tickets = query.execute(self.req) |
| 429 | 429 | |
diff --git a/trac/versioncontrol/cache.py b/trac/versioncontrol/cache.py
|
a
|
b
|
|
| 245 | 245 | rev_as_int = db.cast('rev', 'int') |
| 246 | 246 | if first is None: |
| 247 | 247 | cursor.execute("SELECT rev FROM node_change " |
| 248 | | "WHERE path = %%s " |
| | 248 | "WHERE %s <= %%s " |
| | 249 | " AND path = %%s " |
| 249 | 250 | " AND change_type IN ('A', 'C', 'M') " |
| 250 | | " AND %s <= %%s " |
| 251 | 251 | "ORDER BY %s DESC " |
| 252 | 252 | "LIMIT 1" % ((rev_as_int,) * 2), |
| 253 | 253 | (path, last)) |
| … |
… |
|
| 255 | 255 | for row in cursor: |
| 256 | 256 | first = int(row[0]) |
| 257 | 257 | cursor.execute("SELECT DISTINCT rev FROM node_change " |
| 258 | | "WHERE (path = %%s OR path %s) " |
| 259 | | " AND %s >= %%s AND %s <= %%s" % |
| 260 | | (db.like(), rev_as_int, rev_as_int), |
| 261 | | (path, db.like_escape(path + '/') + '%', first, last)) |
| | 258 | "WHERE %s >= %%s AND %s <= %%s " |
| | 259 | " AND (path = %%s OR (path >= %%s AND path < %%s))" % |
| | 260 | (rev_as_int, rev_as_int), |
| | 261 | (first, last, path, path + '/', path + '0')) |
| 262 | 262 | return [int(row[0]) for row in cursor] |
| 263 | 263 | |
| 264 | 264 | def has_node(self, path, rev=None): |
| … |
… |
|
| 293 | 293 | |
| 294 | 294 | if path: |
| 295 | 295 | path = path.lstrip('/') |
| 296 | | sql += " AND (" |
| 297 | | # changes on path itself |
| 298 | | sql += "path=%s " |
| 299 | | args.append(path) |
| 300 | | sql += " OR " |
| 301 | | # changes on path children |
| 302 | | sql += "path "+db.like() |
| 303 | | args.append(db.like_escape(path+'/') + '%') |
| 304 | | sql += " OR " |
| | 296 | # changes on path itself or its children |
| | 297 | sql += " AND (path = %s OR (path >= %s AND path < %s)" |
| | 298 | args.extend((path, path + '/', path + '0')) |
| 305 | 299 | # deletion of path ancestors |
| 306 | 300 | components = path.lstrip('/').split('/') |
| 307 | | for i in range(1, len(components)+1): |
| | 301 | parents = ','.join(('%s',) * len(components)) |
| | 302 | sql += " OR (path IN (" + parents + ") AND change_type = 'D'))" |
| | 303 | for i in range(1, len(components) + 1): |
| 308 | 304 | args.append('/'.join(components[:i])) |
| 309 | | parent_insert = ','.join(('%s',) * len(components)) |
| 310 | | sql += " (path in (" + parent_insert + ") and change_type='D')" |
| 311 | | sql += ")" |
| 312 | 305 | |
| 313 | 306 | sql += " ORDER BY " + db.cast('rev', 'int') + \ |
| 314 | 307 | (direction == '<' and " DESC" or "") + " LIMIT 1" |