blob: fd30378d0b0a95606c9cb2bdfeec25e2d588ace0 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
from debian.debian_support import version_compare
import sqlalchemy.event
def fetchiter(cursor):
rows = cursor.fetchmany(1024)
while rows:
for row in rows:
yield row
rows = cursor.fetchmany(1024)
def enable_sqlite_foreign_keys(engine):
@sqlalchemy.event.listens_for(engine, "connect")
def pragma_foreign_keys(connection, _):
connection.execute("PRAGMA foreign_keys=ON;")
def sqlite_add_version_compare(engine):
@sqlalchemy.event.listens_for(engine, "connect")
def add_version_compare(connection, _):
connection.create_collation("debian_version", version_compare)
connection.create_function("debian_version_compare", 2, version_compare)
|
