Did I find the right examples for you? yes no

All Samples(10)  |  Call(8)  |  Derive(0)  |  Import(2)

src/b/u/bubbles-0.1/bubbles/backends/sql/ops.py   bubbles(Download)
from ...objects import IterableDataSource
from ...errors import *
from .utils import prepare_key, zip_condition, join_on_clause
 
try:
    if len(filter_cols) == 1:
        value = (value, )
    condition = zip_condition(filter_cols, value)
    statement = sql.expression.select(cols, from_obj=statement,
                                        whereclause=condition)
    diff_cols = [diff_stmt.c[f] for f in key]
 
    cond = zip_condition(src_cols, diff_cols)
 
    join = sql.expression.join(src_stmt, diff_stmt, onclause=cond)
    def iterator():
        for row in src.rows():
            row_key = field_filter(row)
 
            cond = zip_condition(target_cols, row_key)
    # TODO: this might be a separate operation
 
    join_cond = zip_condition(dim.columns(prepare_key(dim_key)),
                              source.columns(prepare_key(source_key)))
    join = sql.expression.join(src_stmt, dim_stmt, onclause=join_cond)

src/b/u/bubbles-HEAD/bubbles/backends/sql/ops.py   bubbles(Download)
from ...objects import IterableDataSource
from ...errors import *
from .utils import prepare_key, zip_condition, join_on_clause
 
try:
    if len(filter_cols) == 1:
        value = (value, )
    condition = zip_condition(filter_cols, value)
    statement = sql.expression.select(cols, from_obj=statement,
                                        whereclause=condition)
    diff_cols = [diff_stmt.c[f] for f in key]
 
    cond = zip_condition(src_cols, diff_cols)
 
    join = sql.expression.join(src_stmt, diff_stmt, onclause=cond)
    def iterator():
        for row in src.rows():
            row_key = field_filter(row)
 
            cond = zip_condition(target_cols, row_key)
    # TODO: this might be a separate operation
 
    join_cond = zip_condition(dim.columns(prepare_key(dim_key)),
                              source.columns(prepare_key(source_key)))
    join = sql.expression.join(src_stmt, dim_stmt, onclause=join_cond)