Skip to content
Snippets Groups Projects
Commit 0133ce71 authored by Cornelia Michlits's avatar Cornelia Michlits
Browse files

104-onto error-handling

Former-commit-id: 1ed1f241
parent 649d4808
No related branches found
No related tags found
1 merge request!42Fixed the query service tests
...@@ -4,3 +4,4 @@ py-eureka-client==0.9.1 ...@@ -4,3 +4,4 @@ py-eureka-client==0.9.1
docker==5.0.0 docker==5.0.0
gevent==21.8.0 gevent==21.8.0
rdflib==6.0.2 rdflib==6.0.2
psycopg2-binary==2.8.6
from psycopg2 import connect from psycopg2 import connect
import psycopg2.extras import psycopg2.extras
import requests
import json import json
def insert_mdb_concepts(uri, c_name): def insert_mdb_concepts(uri, c_name):
...@@ -16,11 +15,7 @@ def insert_mdb_concepts(uri, c_name): ...@@ -16,11 +15,7 @@ def insert_mdb_concepts(uri, c_name):
cursor = conn.cursor() cursor = conn.cursor()
# Insert tblnames into table mdb_TABLES # Insert tblnames into table mdb_TABLES
cursor.execute("PREPARE stmt AS INSERT INTO mdb_concepts (URI,name,created) VALUES ($1,$2,current_timestamp) ON CONFLICT (URI) DO NOTHING") cursor.execute("INSERT INTO mdb_concepts (URI,name,created) VALUES (%s,%s,current_timestamp) ON CONFLICT (URI) DO NOTHING", (uri,c_name))
psycopg2.extras.execute_batch(cursor,
"""EXECUTE stmt (%s,%s)"""
, (uri,c_name))
cursor.execute("DEALLOCATE stmt")
r = cursor.statusmessage r = cursor.statusmessage
conn.commit() conn.commit()
conn.close() conn.close()
...@@ -41,11 +36,7 @@ def insert_mdb_columns_concepts(cdbid,tid, cid, uri): ...@@ -41,11 +36,7 @@ def insert_mdb_columns_concepts(cdbid,tid, cid, uri):
cursor = conn.cursor() cursor = conn.cursor()
# Insert tblnames into table mdb_TABLES # Insert tblnames into table mdb_TABLES
cursor.execute("PREPARE stmt AS INSERT INTO mdb_columns_concepts (cDBID,tID, cID,URI,created) VALUES ($1,$2,$3,$4,current_timestamp) ON CONFLICT (cDBID, tID, cID, URI) DO NOTHING") cursor.execute("INSERT INTO mdb_columns_concepts (cDBID,tID, cID,URI,created) VALUES (%s,%s,%s,%s,current_timestamp) ON CONFLICT (cDBID, tID, cID, URI) DO NOTHING", (cdbid,tid,cid,uri))
psycopg2.extras.execute_batch(cursor,
"""EXECUTE stmt (%s,%s,%s,%s)"""
, (cdbid,tid,cid,uri))
cursor.execute("DEALLOCATE stmt")
r = cursor.statusmessage r = cursor.statusmessage
conn.commit() conn.commit()
conn.close() conn.close()
......
...@@ -15,7 +15,7 @@ parameters: ...@@ -15,7 +15,7 @@ parameters:
uri: uri:
type: "string" type: "string"
example: "http://www.ontology-of-units-of-measure.org/resource/om-2/metre" example: "http://www.ontology-of-units-of-measure.org/resource/om-2/metre"
conceptname: name:
type: "string" type: "string"
example: "metre" example: "metre"
responses: responses:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment