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

Bases: swat.cas.datamsghandlers.PandasDataFrame

Create an SQLQuery data message handler

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().

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.


__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