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