Project

General

Profile

1 2211 aaronmk
# SQL code generation
2
3 2276 aaronmk
import operator
4
5 2360 aaronmk
import objects
6 2222 aaronmk
import strings
7 2227 aaronmk
import util
8 2211 aaronmk
9 2499 aaronmk
##### Escaping
10
11
def esc_name(name, quote='"'):
12
    return quote + name.replace(quote, quote+quote) + quote
13
        # doubling an embedded quote escapes it in both PostgreSQL and MySQL
14
15 2513 aaronmk
def clean_name(name): return name.replace('"', '').replace('`', '')
16
17 2219 aaronmk
##### SQL code objects
18
19 2349 aaronmk
class MockDb:
20 2503 aaronmk
    def esc_value(self, value): return strings.repr_no_u(value)
21 2349 aaronmk
22 2499 aaronmk
    def esc_name(self, name): return esc_name(name)
23 2349 aaronmk
mockDb = MockDb()
24
25 2514 aaronmk
class BasicObject(objects.BasicObject):
26
    def __init__(self, value): self.value = value
27
28
    def __str__(self): return clean_name(strings.repr_no_u(self))
29
30
class Code(BasicObject):
31 2211 aaronmk
    def to_str(self, db): raise NotImplemented()
32 2349 aaronmk
33 2514 aaronmk
    def __repr__(self): return self.to_str(mockDb)
34 2211 aaronmk
35 2269 aaronmk
class CustomCode(Code):
36 2256 aaronmk
    def __init__(self, str_): self.str_ = str_
37
38
    def to_str(self, db): return self.str_
39
40 2540 aaronmk
class Expr(Code):
41
    def __init__(self, expr): self.expr = expr
42
43
    def to_str(self, db): return '('+self.expr.to_str(db)+')'
44
45 2335 aaronmk
##### Literal values
46
47 2216 aaronmk
class Literal(Code):
48 2211 aaronmk
    def __init__(self, value): self.value = value
49 2213 aaronmk
50
    def to_str(self, db): return db.esc_value(self.value)
51 2211 aaronmk
52 2400 aaronmk
def as_Value(value):
53
    if isinstance(value, Code): return value
54
    else: return Literal(value)
55
56 2216 aaronmk
def is_null(value): return isinstance(value, Literal) and value.value == None
57
58 2335 aaronmk
##### Tables
59
60 2211 aaronmk
class Table(Code):
61
    def __init__(self, name, schema=None):
62
        '''
63
        @param schema str|None (for no schema)
64
        '''
65
        self.name = name
66
        self.schema = schema
67
68 2348 aaronmk
    def to_str(self, db):
69
        str_ = ''
70
        if self.schema != None: str_ += db.esc_name(self.schema)+'.'
71
        str_ += db.esc_name(self.name)
72
        return str_
73 2336 aaronmk
74
    def to_Table(self): return self
75 2211 aaronmk
76 2219 aaronmk
def as_Table(table):
77 2270 aaronmk
    if table == None or isinstance(table, Code): return table
78 2219 aaronmk
    else: return Table(table)
79
80 2336 aaronmk
class NamedTable(Table):
81
    def __init__(self, name, code, cols=None):
82
        Table.__init__(self, name)
83
84
        if not isinstance(code, Code): code = Table(code)
85
86
        self.code = code
87
        self.cols = cols
88
89
    def to_str(self, db):
90 2467 aaronmk
        str_ = self.code.to_str(db)+'\nAS '+Table.to_str(self, db)
91 2336 aaronmk
        if self.cols != None: str_ += ' ('+(', '.join(self.cols))+')'
92
        return str_
93
94
    def to_Table(self): return Table(self.name)
95
96 2335 aaronmk
##### Columns
97
98 2211 aaronmk
class Col(Code):
99
    def __init__(self, name, table=None):
100
        '''
101
        @param table Table|None (for no table)
102
        '''
103 2241 aaronmk
        if util.is_str(table): table = Table(table)
104 2211 aaronmk
        assert table == None or isinstance(table, Table)
105
106
        self.name = name
107
        self.table = table
108
109
    def to_str(self, db):
110
        str_ = ''
111
        if self.table != None: str_ += self.table.to_str(db)+'.'
112 2348 aaronmk
        str_ += db.esc_name(self.name)
113 2211 aaronmk
        return str_
114 2314 aaronmk
115
    def to_Col(self): return self
116 2211 aaronmk
117 2393 aaronmk
def is_table_col(col): return col.table != None
118
119 2260 aaronmk
def as_Col(col, table=None):
120 2333 aaronmk
    assert col != None
121
122
    if isinstance(col, Code): return col
123 2260 aaronmk
    else: return Col(col, table)
124
125 2401 aaronmk
def to_name_only_col(col, check_table=None):
126
    col = as_Col(col)
127
128
    if check_table != None:
129
        table = col.table
130
        assert table == None or table == check_table
131
    return Col(col.name)
132
133 2323 aaronmk
class NamedCol(Col):
134 2229 aaronmk
    def __init__(self, name, code):
135 2310 aaronmk
        Col.__init__(self, name)
136
137 2229 aaronmk
        if not isinstance(code, Code): code = Literal(code)
138
139
        self.code = code
140
141
    def to_str(self, db):
142 2310 aaronmk
        return self.code.to_str(db)+' AS '+Col.to_str(self, db)
143 2314 aaronmk
144
    def to_Col(self): return Col(self.name)
145 2229 aaronmk
146 2462 aaronmk
def remove_col_rename(col):
147
    if isinstance(col, NamedCol): col = col.code
148
    return col
149
150 2524 aaronmk
##### Functions
151
152
class Function(Table): pass
153
154
class FunctionCall(Code):
155
    def __init__(self, function, *args):
156
        '''
157
        @param args [Code...] The function's arguments
158
        '''
159
        if not isinstance(function, Code): function = Function(function)
160 2532 aaronmk
        args = map(remove_col_rename, args)
161 2524 aaronmk
162
        self.function = function
163
        self.args = args
164
165
    def to_str(self, db):
166
        args_str = ', '.join((v.to_str(db) for v in self.args))
167
        return self.function.to_str(db)+'('+args_str+')'
168
169 2533 aaronmk
def wrap_in_func(function, value):
170
    '''Wraps a value inside a function call.
171
    Propagates any column renaming to the returned value.
172
    '''
173
    name = None
174
    if isinstance(value, NamedCol): name = value.name
175
    value = FunctionCall(function, value)
176
    if name != None: value = NamedCol(name, value)
177
    return value
178
179 2335 aaronmk
##### Conditions
180 2259 aaronmk
181 2398 aaronmk
class ColValueCond(Code):
182
    def __init__(self, col, value):
183
        value = as_ValueCond(value)
184
185
        self.col = col
186
        self.value = value
187
188
    def to_str(self, db): return self.value.to_str(db, self.col)
189
190
##### Condition column comparisons
191
192 2514 aaronmk
class ValueCond(BasicObject):
193 2213 aaronmk
    def __init__(self, value):
194 2225 aaronmk
        if not isinstance(value, Code): value = Literal(value)
195 2462 aaronmk
        value = remove_col_rename(value)
196 2213 aaronmk
197
        self.value = value
198 2214 aaronmk
199 2216 aaronmk
    def to_str(self, db, left_value):
200 2214 aaronmk
        '''
201 2216 aaronmk
        @param left_value The Code object that the condition is being applied on
202 2214 aaronmk
        '''
203
        raise NotImplemented()
204 2228 aaronmk
205 2514 aaronmk
    def __repr__(self): return self.to_str(mockDb, '<left_value>')
206 2211 aaronmk
207
class CompareCond(ValueCond):
208
    def __init__(self, value, operator='='):
209 2222 aaronmk
        '''
210
        @param operator By default, compares NULL values literally. Use '~=' or
211
            '~!=' to pass NULLs through.
212
        '''
213 2211 aaronmk
        ValueCond.__init__(self, value)
214
        self.operator = operator
215
216 2216 aaronmk
    def to_str(self, db, left_value):
217
        if not isinstance(left_value, Code): left_value = Col(left_value)
218 2462 aaronmk
        left_value = remove_col_rename(left_value)
219 2216 aaronmk
220 2222 aaronmk
        right_value = self.value
221
        left = left_value.to_str(db)
222
        right = right_value.to_str(db)
223
224
        # Parse operator
225 2216 aaronmk
        operator = self.operator
226 2222 aaronmk
        passthru_null_ref = [False]
227
        operator = strings.remove_prefix('~', operator, passthru_null_ref)
228
        neg_ref = [False]
229
        operator = strings.remove_prefix('!', operator, neg_ref)
230
        equals = operator.endswith('=')
231
        if equals and is_null(self.value): operator = 'IS'
232
233
        # Create str
234
        str_ = left+' '+operator+' '+right
235
        if equals and not passthru_null_ref[0] and isinstance(right_value, Col):
236
            str_ += ' OR ('+left+' IS NULL AND '+right+' IS NULL)'
237
        if neg_ref[0]: str_ = 'NOT ('+str_+')'
238
        return str_
239 2216 aaronmk
240 2260 aaronmk
# Tells as_ValueCond() to assume a non-ValueCond is a literal value
241
assume_literal = object()
242
243
def as_ValueCond(value, default_table=assume_literal):
244
    if not isinstance(value, ValueCond):
245
        if default_table is not assume_literal:
246
            value = as_Col(value, default_table)
247
        return CompareCond(value)
248 2216 aaronmk
    else: return value
249 2219 aaronmk
250 2335 aaronmk
##### Joins
251
252 2352 aaronmk
join_same = object() # tells Join the left and right columns have the same name
253 2260 aaronmk
254 2353 aaronmk
# Tells Join the left and right columns have the same name and are never NULL
255
join_same_not_null = object()
256
257 2260 aaronmk
filter_out = object() # tells Join to filter out rows that match the join
258
259 2514 aaronmk
class Join(BasicObject):
260 2260 aaronmk
    def __init__(self, table, mapping, type_=None):
261
        '''
262
        @param mapping dict(right_table_col=left_table_col, ...)
263 2352 aaronmk
            * if left_table_col is join_same: left_table_col = right_table_col
264 2353 aaronmk
              * Note that right_table_col must be a string
265
            * if left_table_col is join_same_not_null:
266
              left_table_col = right_table_col and both have NOT NULL constraint
267
              * Note that right_table_col must be a string
268 2260 aaronmk
        @param type_ None (for plain join)|str (e.g. 'LEFT')|filter_out
269
            * filter_out: equivalent to 'LEFT' with the query filtered by
270
              `table_pkey IS NULL` (indicating no match)
271
        '''
272
        if util.is_str(table): table = Table(table)
273
        assert type_ == None or util.is_str(type_) or type_ is filter_out
274
275
        self.table = table
276
        self.mapping = mapping
277
        self.type_ = type_
278
279
    def to_str(self, db, left_table):
280 2353 aaronmk
        # Switch order (left_table is on the right in the comparison)
281
        right_table = left_table
282
        left_table = self.table # note left_table is reassigned
283
284 2260 aaronmk
        def join(entry):
285
            '''Parses non-USING joins'''
286
            right_table_col, left_table_col = entry
287
288 2353 aaronmk
            # Switch order (right_table_col is on the left in the comparison)
289
            left = right_table_col
290
            right = left_table_col
291
292 2260 aaronmk
            # Parse special values
293 2353 aaronmk
            if right is join_same: right = left
294
            elif right is join_same_not_null:
295
                right = CompareCond(as_Col(left, right_table), '~=')
296 2260 aaronmk
297 2353 aaronmk
            right = as_ValueCond(right, right_table)
298 2410 aaronmk
            return '('+right.to_str(db, as_Col(left, left_table))+')'
299 2260 aaronmk
300 2265 aaronmk
        # Create join condition
301
        type_ = self.type_
302 2276 aaronmk
        joins = self.mapping
303 2265 aaronmk
        if type_ is not filter_out and reduce(operator.and_,
304 2460 aaronmk
            (v is join_same_not_null for v in joins.itervalues())):
305 2260 aaronmk
            # all cols w/ USING, so can use simpler USING syntax
306 2298 aaronmk
            cols = (as_Col(v).to_str(db) for v in joins.iterkeys())
307
            join_cond = 'USING ('+(', '.join(cols))+')'
308 2467 aaronmk
        else: join_cond = 'ON\n'+('\nAND\n'.join(map(join, joins.iteritems())))
309 2260 aaronmk
310
        # Create join
311
        if type_ is filter_out: type_ = 'LEFT'
312 2266 aaronmk
        str_ = ''
313
        if type_ != None: str_ += type_+' '
314 2353 aaronmk
        str_ += 'JOIN '+left_table.to_str(db)+' '+join_cond
315 2266 aaronmk
        return str_
316 2349 aaronmk
317 2514 aaronmk
    def __repr__(self): return self.to_str(mockDb, '<left_table>')
318 2424 aaronmk
319
##### Value exprs
320
321
row_count = CustomCode('count(*)')