Removed views from queries. (01a20be4) · Commits · VOSpace INAF / vospace-transfer-service

transfer_service/db_connector.py

+7 −10

Original line number	Diff line number	Diff line
		@@ -80,7 +80,7 @@ class DbConnector(object):
		try:
		conn = self.getConnection()
		cursor = conn.cursor(cursor_factory = RealDictCursor)
		cursor.execute("SELECT * FROM node_vos_path WHERE vos_path = %s;", (vospacePath,))
		cursor.execute("SELECT id_from_vos_path(%s);", (vospacePath,))
		result = cursor.fetchall()
		cursor.close()
		except Exception:
		@@ -102,9 +102,8 @@ class DbConnector(object):
		cursor = conn.cursor(cursor_factory = RealDictCursor)
		cursor.execute("""
		SELECT creator_id
		FROM node_vos_path nvp
		JOIN node n ON nvp.node_id = n.node_id
		WHERE vos_path = %s;
		FROM node
		WHERE node_id = id_from_vos_path(%s);
		""",
		(vospacePath,))
		result = cursor.fetchall()
		@@ -125,9 +124,8 @@ class DbConnector(object):
		cursor = conn.cursor(cursor_factory = RealDictCursor)
		cursor.execute("""
		SELECT unnest(group_read) as group_read
		FROM node_vos_path nvp
		JOIN node n ON nvp.node_id = n.node_id
		WHERE vos_path = %s;
		FROM node
		WHERE node_id = id_from_vos_path(%s);
		""",
		(vospacePath,))
		result = cursor.fetchall()
		@@ -150,9 +148,8 @@ class DbConnector(object):
		cursor = conn.cursor(cursor_factory = RealDictCursor)
		cursor.execute("""
		SELECT unnest(group_write) as group_write
		FROM node_vos_path nvp
		JOIN node n ON nvp.node_id = n.node_id
		WHERE vos_path = %s;
		FROM node
		WHERE node_id = id_from_vos_path(%s);
		""",
		(vospacePath,))
		result = cursor.fetchall()