dedup/utils.py


1
2
3
4
5
6
7
8
9
10
11
12

from debian.debian_support import version_compare

def fetchiter(cursor):
    rows = cursor.fetchmany()
    while rows:
        for row in rows:
            yield row
        rows = cursor.fetchmany()

def sql_add_version_compare(db):
    db.create_collation("debian_version", version_compare)
    db.create_function("debian_version_compare", 2, version_compare)