Homec4science
Diffusion blackdynamite (features/zeo) Browse

R3127/BlackDynamite/selector.py
99bf0335d48efeatures/zeo

Last Change
Raw File

selector.py
View Options

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# -*- py-which-shell: "python"; -*-
################################################################
import copy
import constraints as BDcons
################################################################
class Selector(object):
def __init__(self, base):
self.base = base
def buildList(self, curs, sqlobj):
if isinstance(sqlobj, type):
sqlobj = sqlobj(self.base)
col_info = self.base.getColumnProperties(sqlobj)
list_objects = []
for entries in curs:
obj = copy.deepcopy(sqlobj)
for i in range(0, len(col_info)):
col_name = col_info[i][0]
obj[col_name] = entries[i]
list_objects.append(obj)
# print len(list_objects)
return list_objects
def select(self, _types, constraints=None, sort_by=None):
const = BDcons.BDconstraints(self.base, constraints)
condition, params = const.getMatchingCondition()
################################################################
#review
#if not isinstance(sort_by, list) and sort_by is not None):
# sort_by = [sort_by]
#
# order_condition = ""
# if (sort_by is not None):
# order_condition = " ORDER BY ("
# for cond in sort_by:
# order_condition += cond + ","
# order_condition = order_condition[:len(order_condition)-1] + ")"
################################################################
if not isinstance(_types, list):
_types = [_types]
selected_tables = ['{0}.{1}'.format(self.base.schema, t.table_name)
for t in _types]
selected_tables = ','.join(selected_tables)
request = "SELECT * FROM {0}".format(selected_tables)
if condition:
request += " WHERE " + condition
if sort_by:
request += " ORDER BY " + sort_by
# print(request)
# print(params)
curs = self.base.performRequest(request, params)
obj_list = self.buildList(curs, _types[0])
return obj_list
c4science · Help