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

safer SQL range in INSERT query

Browse source
This commit is contained in:
Christian Quest 2016-05-06 17:27:01 +02:00
parent f94740c1cf
commit 1bca268190
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
backend.py
View file

@ -98,9 +98,9 @@ WHERE events_id=%s;""", (id,))
else: else:
event_stop = j['properties']['stop'] event_stop = j['properties']['stop']
if event_start == event_stop: if event_start == event_stop:
when = "["+event_start+", "+event_stop+"]" bounds = '[]'
else: else:
when = "["+event_start+", "+event_stop+")" bounds = '[)'
# connect to db and insert # connect to db and insert
db = db_connect() db = db_connect()
cur = db.cursor() cur = db.cursor()
@ -113,7 +113,7 @@ WHERE events_id=%s;""", (id,))
if h is None: if h is None:
cur.execute("""SELECT md5(st_asewkt(st_geomfromgeojson( %s )));""",(geometry,)) cur.execute("""SELECT md5(st_asewkt(st_geomfromgeojson( %s )));""",(geometry,))
h = cur.fetchone() h = cur.fetchone()
cur.execute("""INSERT INTO events ( events_type, events_what, events_when, events_tags, events_geo) VALUES (%s, %s, %s, %s, %s) RETURNING events_id;""",(j['properties']['type'],j['properties']['what'],when,json.dumps(j['properties']),h[0])) cur.execute("""INSERT INTO events ( events_type, events_what, events_when, events_tags, events_geo) VALUES (%s, %s, tstzrange(%s,%s,%s) , %s, %s) RETURNING events_id;""",(j['properties']['type'],j['properties']['what'],event_start, event_stop, bounds, json.dumps(j['properties']),h[0]))
# get newly created event id # get newly created event id
e = cur.fetchone() e = cur.fetchone()
db.commit() db.commit()