heavydb._parsers Namespace Reference

Functions
def	_format_result_timestamp
def	_format_result_date
def	_format_result_time
def	_extract_col_vals
def	_extract_description
def	_extract_column_details
def	_bind_parameters

Variables
tuple	Description
tuple	ColumnDetails
dictionary	_typeattr
	_thrift_types_to_values = T.TDatumType._NAMES_TO_VALUES
	_thrift_values_to_types = T.TDatumType._VALUES_TO_NAMES
	_thrift_encodings_to_values = T.TEncodingType._NAMES_TO_VALUES
	_thrift_values_to_encodings = T.TEncodingType._VALUES_TO_NAMES

Detailed Description

Utility methods for parsing data returned from HeavyDB

Function Documentation

def heavydb._parsers._bind_parameters (   operation,   parameters  )

private

Definition at line 160 of file _parsers.py.

Referenced by tests.test_cursor.TestCursor.test_escape_basic(), and tests.test_cursor.TestCursor.test_escape_malicious().

def _bind_parameters(operation, parameters):
    return (
        text(operation)
        .bindparams(**parameters)
        .compile(compile_kwargs={"literal_binds": True})
    )

Here is the caller graph for this function:

def heavydb._parsers._extract_col_vals (   desc,   val  )

private

Definition at line 87 of file _parsers.py.

References heavydb._parsers._format_result_date(), heavydb._parsers._format_result_time(), and heavydb._parsers._format_result_timestamp().

def _extract_col_vals(desc, val):

    typename = T.TDatumType._VALUES_TO_NAMES[desc.col_type.type]
    nulls = val.nulls

    # arr_col has multiple levels to parse, not accounted for in original code
    # https://github.com/omnisci/pymapd/issues/68
    if hasattr(val.data, 'arr_col') and val.data.arr_col:
        vals = [
            None if null else getattr(v.data, _typeattr[typename] + '_col')
            for null, v in zip(nulls, val.data.arr_col)
        ]

        if typename == 'TIMESTAMP':
            vals = [_format_result_timestamp(desc, v) for v in vals]
        elif typename == 'DATE':
            vals = [_format_result_date(v) for v in vals]
        elif typename == 'TIME':
            vals = [_format_result_time(v) for v in vals]

    # else clause original code path
    else:
        vals = getattr(val.data, _typeattr[typename] + '_col')
        vals = [None if null else v for null, v in zip(nulls, vals)]

        if typename == 'TIMESTAMP':
            vals = _format_result_timestamp(desc, vals)
        elif typename == 'DATE':
            vals = _format_result_date(vals)
        elif typename == 'TIME':
            vals = _format_result_time(vals)

    return vals

Here is the call graph for this function: