equal
deleted
inserted
replaced
325 |
325 |
326 def init_sqlite_connexion(cnx): |
326 def init_sqlite_connexion(cnx): |
327 |
327 |
328 class group_concat(object): |
328 class group_concat(object): |
329 def __init__(self): |
329 def __init__(self): |
330 self.values = [] |
330 self.values = set() |
331 def step(self, value): |
331 def step(self, value): |
332 if value is not None: |
332 if value is not None: |
333 self.values.append(value) |
333 self.values.add(value) |
334 def finalize(self): |
334 def finalize(self): |
335 return ', '.join(unicode(v) for v in self.values) |
335 return ', '.join(unicode(v) for v in self.values) |
336 |
336 |
337 cnx.create_aggregate("GROUP_CONCAT", 1, group_concat) |
337 cnx.create_aggregate("GROUP_CONCAT", 1, group_concat) |
338 |
338 |