A source that uses a database query for the source of the rows it feeds through the pipeline. This source can actually be re-used for different database queries. For example:
database( sql ) .query("select * from People where age >= ${age}") .into() .go()
Constructor and description |
---|
JdbcSource
(groovy.sql.Sql db) |
JdbcSource
(java.lang.String url, java.lang.String username, java.lang.String password) |
Type Params | Return Type | Name and description |
---|---|---|
|
static JdbcSource |
database(groovy.sql.Sql sql) |
|
static JdbcSource |
database(java.lang.String url, java.lang.String username, java.lang.String password) |
|
void |
doStart(Pipeline pipeline) |
|
JdbcSource |
query(groovy.lang.GString query) |
Groovy Documentation