kangaroo-and-rabbit/karideo
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[DEV] perfect commit in bdd

Browse Source
This commit is contained in:
Edouard Dupin 2020-04-08 14:57:12 +00:00
parent f484c27b21
commit d06dc57bbb
1 changed files with 12 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
back/src/data_interface.py
View File

@ -131,10 +131,10 @@ class DataInterface():
try: try:
cursor.execute('SELECT * FROM ' + self.name_view + ' WHERE id=%s', req) cursor.execute('SELECT * FROM ' + self.name_view + ' WHERE id=%s', req)
except psycopg2.errors.UndefinedFunction: except psycopg2.errors.UndefinedFunction:
self.connection.commit()
raise ServerError("INTERNAL_ERROR fail request SQL ...", status_code=500) raise ServerError("INTERNAL_ERROR fail request SQL ...", status_code=500)
finally:
self.connection.commit()
results = cursor.fetchone() results = cursor.fetchone()
self.connection.commit()
#debug.info("get specific data = " + json.dumps(results)) #debug.info("get specific data = " + json.dumps(results))
return results; return results;
@ -145,10 +145,10 @@ class DataInterface():
try: try:
cursor.execute('SELECT * FROM ' + self.name_view + ' WHERE ' + _key + '=%s', req) cursor.execute('SELECT * FROM ' + self.name_view + ' WHERE ' + _key + '=%s', req)
except psycopg2.errors.UndefinedFunction: except psycopg2.errors.UndefinedFunction:
self.connection.commit()
raise ServerError("INTERNAL_ERROR fail request SQL ...", status_code=500) raise ServerError("INTERNAL_ERROR fail request SQL ...", status_code=500)
finally:
self.connection.commit()
results = cursor.fetchone() results = cursor.fetchone()
self.connection.commit()
#debug.info("get specific data = " + json.dumps(results)) #debug.info("get specific data = " + json.dumps(results))
return results; return results;
def find2(self, _key1, _value1, _key2, _value2): def find2(self, _key1, _value1, _key2, _value2):
@ -158,10 +158,10 @@ class DataInterface():
try: try:
cursor.execute('SELECT * FROM ' + self.name_view + ' WHERE ' + _key1 + '=%s AND ' + _key2 + '=%s', req) cursor.execute('SELECT * FROM ' + self.name_view + ' WHERE ' + _key1 + '=%s AND ' + _key2 + '=%s', req)
except psycopg2.errors.UndefinedFunction: except psycopg2.errors.UndefinedFunction:
self.connection.commit()
raise ServerError("INTERNAL_ERROR fail request SQL ...", status_code=500) raise ServerError("INTERNAL_ERROR fail request SQL ...", status_code=500)
finally:
self.connection.commit()
results = cursor.fetchone() results = cursor.fetchone()
self.connection.commit()
#debug.info("get specific data = " + json.dumps(results)) #debug.info("get specific data = " + json.dumps(results))
return results; return results;
@ -172,10 +172,10 @@ class DataInterface():
try: try:
cursor.execute('UPDATE ' + self.base_name + ' SET deleted=true WHERE id=%s' + self.where_expand, req) cursor.execute('UPDATE ' + self.base_name + ' SET deleted=true WHERE id=%s' + self.where_expand, req)
except psycopg2.errors.UndefinedFunction: except psycopg2.errors.UndefinedFunction:
self.connection.commit()
raise ServerError("INTERNAL_ERROR fail request SQL ...", status_code=500) raise ServerError("INTERNAL_ERROR fail request SQL ...", status_code=500)
finally:
self.connection.commit()
self.mark_to_store(); self.mark_to_store();
self.connection.commit()
return True return True
def is_value_modifiable_and_good_type(self, _key, _value, _check_with="modifiable"): def is_value_modifiable_and_good_type(self, _key, _value, _check_with="modifiable"):
@ -230,9 +230,9 @@ class DataInterface():
try: try:
cursor.execute(request, list_data) cursor.execute(request, list_data)
except psycopg2.errors.UndefinedFunction: except psycopg2.errors.UndefinedFunction:
self.connection.commit()
raise ServerError("INTERNAL_ERROR fail request SQL ...", status_code=500) raise ServerError("INTERNAL_ERROR fail request SQL ...", status_code=500)
finally:
self.connection.commit()
self.mark_to_store(); self.mark_to_store();
return self.get(_id); return self.get(_id);
@ -261,8 +261,9 @@ class DataInterface():
try: try:
cursor.execute(request, list_data) cursor.execute(request, list_data)
except psycopg2.errors.UndefinedFunction: except psycopg2.errors.UndefinedFunction:
self.connection.commit()
raise ServerError("INTERNAL_ERROR fail request SQL ...", status_code=500) raise ServerError("INTERNAL_ERROR fail request SQL ...", status_code=500)
finally:
self.connection.commit()
id_of_new_row = cursor.fetchone()[0] id_of_new_row = cursor.fetchone()[0]
self.mark_to_store(); self.mark_to_store();
return self.get(id_of_new_row); return self.get(id_of_new_row);