swat.cas.datamsghandlers.SQLTable

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

Bases: swat.cas.datamsghandlers.PandasDataFrame

Create an SQLTable data message handler

Parameters:

table : string

Name of table in database to fetch.

engine : sqlalchemy engine

sqlalchemy engine.

nrecs : int, optional

Number of records to send at a time.

**kwargs : keyword arguments, optional

Arguments sent to pandas.io.read_sql_table.

Returns:

SQLTable data message handler object

PandasDataFrame

__init__(table, engine, nrecs=1000, transformers=None, **kwargs)

Initialize self. See help(type(self)) for accurate signature.

Methods

__init__(table, 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