cartodb4/crankshaft
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

restructure to accom list of time columns

Browse Source
This commit is contained in:
Andy Eschbacher 2016-03-31 09:27:37 -04:00
parent 7695102500
commit 6165d5e61e
1 changed files with 44 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
src/py/crankshaft/crankshaft/pysal_utils/pysal_utils.py
View File

@ -41,32 +41,62 @@ def query_attr_select(params):
table name, etc.) table name, etc.)
""" """
attrs = [k for k in params
if k not in ('id_col', 'geom_col', 'subquery', 'num_ngbrs')]
template = "i.\"{%(col)s}\"::numeric As attr%(alias_num)s, "
attr_string = "" attr_string = ""
template = "i.\"%(col)s\"::numeric As attr%(alias_num)s, "
for idx, val in enumerate(sorted(attrs)): if 'time_cols' in params:
attr_string += template % {"col": val, "alias_num": idx + 1} ## if markov analysis
attrs = params['time_cols']
for idx, val in enumerate(attrs):
attr_string += template % {"col": val, "alias_num": idx + 1}
else:
## if moran's analysis
attrs = [k for k in params
if k not in ('id_col', 'geom_col', 'subquery', 'num_ngbrs', 'subquery')]
for idx, val in enumerate(sorted(attrs)):
attr_string += template % {"col": params[val], "alias_num": idx + 1}
return attr_string return attr_string
def query_attr_where(params): def query_attr_where(params):
""" """
Construct where conditions when building neighbors query
Create portion of WHERE clauses for weeding out NULL-valued geometries Create portion of WHERE clauses for weeding out NULL-valued geometries
Input: dict of params:
{'subquery': ...,
'numerator': 'data1',
'denominator': 'data2',
'': ...}
Output: 'idx_replace."data1" IS NOT NULL AND idx_replace."data2" IS NOT NULL'
Input:
{'subquery': ...,
'time_cols': ['time1', 'time2', 'time3'],
'etc': ...}
Output: 'idx_replace."time1" IS NOT NULL AND idx_replace."time2" IS NOT NULL AND idx_replace."time3" IS NOT NULL'
""" """
attrs = sorted([k for k in params
if k not in ('id_col', 'geom_col', 'subquery', 'num_ngbrs')])
attr_string = [] attr_string = []
template = "idx_replace.\"%s\" IS NOT NULL"
for attr in attrs: if 'time_cols' in params:
attr_string.append("idx_replace.\"{%s}\" IS NOT NULL" % attr) ## markov where clauses
attrs = params['time_cols']
# add values to template
for attr in attrs:
attr_string.append(template % attr)
else:
## moran where clauses
if len(attrs) == 2: # get keys
attr_string.append("idx_replace.\"{%s}\" <> 0" % attrs[1]) attrs = sorted([k for k in params
if k not in ('id_col', 'geom_col', 'subquery', 'num_ngbrs', 'subquery')])
# add values to template
for attr in attrs:
attr_string.append(template % params[attr])
if len(attrs) == 2:
attr_string.append("idx_replace.\"%s\" <> 0" % params[attrs[1]])
out = " AND ".join(attr_string) out = " AND ".join(attr_string)