com.ziclix.python.sql.pipe.db

Class DBSource

java.lang.Object

com.ziclix.python.sql.pipe.db.BaseDB

com.ziclix.python.sql.pipe.db.DBSource

All Implemented Interfaces:

Source

public class DBSource
extends BaseDB
implements Source

A database source. Given a PyConnection and information about the query, produce the data.

Constructor Summary

Constructors

Constructor and Description
DBSource(PyConnection connection, java.lang.Class dataHandler, java.lang.String tableName, java.lang.String where, PyObject include, PyObject params) Constructor for handling the generation of data.

Method Summary

Modifier and Type	Method and Description
void	end() Close the cursor.
PyObject	next() Return the next row in the result set.
void	start() Method start

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DBSource

public DBSource(PyConnection connection,
                java.lang.Class dataHandler,
                java.lang.String tableName,
                java.lang.String where,
                PyObject include,
                PyObject params)

Constructor for handling the generation of data.

Parameters:

connection - the database connection

dataHandler - a custom DataHandler for the cursor, can be None

tableName - the table in question on the source database

where - an optional where clause, defaults to '(1=1)' if null

include - the columns to be queried from the source, '*' if None

params - optional params to substituted in the where clause

Method Detail

next

public PyObject next()

Return the next row in the result set. The first row returned will be column information.

Specified by:

next in interface Source

start

public void start()

Method start

Specified by:

start in interface Source

end

public void end()

Close the cursor.

Specified by:

end in interface Source