tykayn/oedb-backend
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

limit parameter

Browse source
This commit is contained in:
cquest 2016-06-19 14:15:05 +02:00
parent 81c0b2f4b2
commit 639347de8f
1 changed files with 7 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

9
backend.py
View file

@ -192,6 +192,11 @@ class EventResource(BaseEvent):
else: else:
event_type = "" event_type = ""
if 'limit' in req.params:
limit = cur.mogrify("LIMIT %s", (req.params['limit'],)).decode("utf-8")
else:
limit = "LIMIT 200"
event_geom = "geom_center" event_geom = "geom_center"
if 'geom' in req.params: if 'geom' in req.params:
if req.params['geom'] == 'full': if req.params['geom'] == 'full':
@ -200,11 +205,11 @@ class EventResource(BaseEvent):
event_geom = cur.mogrify("ST_SnapToGrid(geom,%s)",(req.params['geom'],)).decode("utf-8") event_geom = cur.mogrify("ST_SnapToGrid(geom,%s)",(req.params['geom'],)).decode("utf-8")
# Search recent active events. # Search recent active events.
sql = """SELECT events_id, events_tags, createdate, lastupdate, {event_dist} st_asgeojson({event_geom}) as geometry FROM events JOIN geo ON (hash=events_geo) {event_bbox} WHERE events_when && {event_when} {event_what} {event_type} ORDER BY createdate DESC LIMIT 200""" sql = """SELECT events_id, events_tags, createdate, lastupdate, {event_dist} st_asgeojson({event_geom}) as geometry FROM events JOIN geo ON (hash=events_geo) {event_bbox} WHERE events_when && {event_when} {event_what} {event_type} ORDER BY createdate DESC {limit}"""
# No user generated content here, so format is safe. # No user generated content here, so format is safe.
sql = sql.format(event_dist=event_dist, event_geom=event_geom, sql = sql.format(event_dist=event_dist, event_geom=event_geom,
event_bbox=event_bbox, event_what=event_what, event_bbox=event_bbox, event_what=event_what,
event_when=event_when, event_type=event_type) event_when=event_when, event_type=event_type, limit=limit)
cur.execute(sql) cur.execute(sql)
resp.body = dumps(self.rows_to_collection(cur.fetchall())) resp.body = dumps(self.rows_to_collection(cur.fetchall()))
resp.status = falcon.HTTP_200 resp.status = falcon.HTTP_200