| java.lang.Object
 com.ziclix.python.sql.pipe.db.BaseDB
com.ziclix.python.sql.pipe.db.DBSource
| DBSource | | public class DBSource extends BaseDB implements Source(Code) | | A database source. Given a PyConnection and information about the query, produce the data.
author:
brian zimmer
version:
$Revision: 2414 $ |
| Method Summary | |
| protected String | createSql(String where)
Create the sql string given the where clause. | | public void | end()
Close the cursor. | | public PyObject | next()
Return the next row in the result set. | | public void | start()
|
| paramsinclude | | protected PyObject paramsinclude(Code) | | Field params, include
|
| sentHeader | | protected boolean sentHeader(Code) | | Field sentHeader
|
| DBSource | | public DBSource(PyConnection connection, Class dataHandler, String tableName, String where, PyObject include, PyObject params)(Code) | | Constructor for handling the generation of data.
Parameters:
connection - the database connection
Parameters:
dataHandler - a custom DataHandler for the cursor, can be None
Parameters:
tableName - the table in question on the source database
Parameters:
where - an optional where clause, defaults to '(1=1)' if null
Parameters:
include - the columns to be queried from the source, '*' if None
Parameters:
params - optional params to substituted in the where clause |
| createSql | | protected String createSql(String where)(Code) | | Create the sql string given the where clause.
|
| end | | public void end()(Code) | | Close the cursor.
|
| next | | public PyObject next()(Code) | | Return the next row in the result set. The first row returned will be column information.
|
| start | | public void start()(Code) | | Method start
|
|
|