swat.cas.datamsghandlers.SQLQuery¶

class swat.cas.datamsghandlers.SQLQuery(query, engine, nrecs=1000, transformers=None, **kwargs)¶

Create an SQLQuery data message handler

Parameters:	query : string SQL query. engine : sqlalchemy engine sqlalchemy engine. nrecs : int or long, optional Number of records to send at a time. kwargs : any, optional Arguments sent to pandas.io.sql.read_sql_query()**.
Returns:	SQLQuery data message handler object

See also

pandas.io.sql.read_sql_query(), PandasDataFrame

__init__(query, engine, nrecs=1000, transformers=None, **kwargs)¶: Initialize self. See help(type(self)) for accurate signature.

Methods

__init__(query, engine[, nrecs, transformers])	Initialize self.
create_engine(args, *kwargs)	Return engine from sqlalchemy.create_engine()
finish(connection)	Finish the data sending operation
getone(connection, **kwargs)	Get a single response from the server
getrow(row)	Get a row of values from the data source
send(connection, nrecs)	Send the records to the connection
write(row, values)	Write the value to the row and column specified in the buffer