Overview  Package   Class  Deprecated  Index  Help 
Groovy 1.8.4
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

groovy.sql
[Java] Class DataSet

java.lang.Object
  groovy.sql.Sql
      groovy.sql.DataSet

public class DataSet
extends Sql

An enhancement of Groovy's Sql class providing support for accessing and querying databases using POGO fields and operators rather than JDBC-level API calls and RDBMS column names. So, instead of a query like: 

 def db = // an instance of groovy.sql.Sql
 def sql = '''select * from Person
     where (purchaseCount > ? and birthMonth = ?)
     and (lastName < ? or lastName > ?)
     and age < ? and age > ? and firstName != ?
     order by firstName DESC, age'''
 def params = [10, "January", "Zulu", "Alpha", 99, 5, "Bert"]
 def sortedPeopleOfInterest = db.rows(sql, params)
You can write code like this: 
 def person = new DataSet(db, 'Person') // or db.dataSet('Person'), or db.dataSet(Person)
 def janFrequentBuyers = person.findAll { it.purchaseCount > 10 && it.lastName == "January" }
 def sortedPeopleOfInterest = janFrequentBuyers.
     findAll{ it.lastName < 'Zulu' || it.lastName > 'Alpha' }.
     findAll{ it.age < 99 }.
     findAll{ it.age > 5 }.
     sort{ it.firstName }.reverse().
     findAll{ it.firstName != 'Bert' }.
     sort{ it.age }
Currently, the Groovy source code for any accessed POGO must be on the classpath at runtime.
Authors:
Chris Stevenson
Paul King
James Strachan
Version:
\$Revision\$

Field Summary
 
Fields inherited from class Sql
ARRAY, BIGINT, BINARY, BIT, BLOB, BOOLEAN, CHAR, CLOB, DATALINK, DATE, DECIMAL, DISTINCT, DOUBLE, FLOAT, INTEGER, JAVA_OBJECT, LOG, LONGVARBINARY, LONGVARCHAR, NULL, NUMERIC, OTHER, REAL, REF, SMALLINT, STRUCT, TIME, TIMESTAMP, TINYINT, VARBINARY, VARCHAR
 
Constructor Summary
DataSet(Sql sql, Class type)

DataSet(Sql sql, String table)

 
Method Summary
void add(Map map)

void cacheConnection(Closure closure)

protected void closeResources(Connection connection, Statement statement, ResultSet results)

protected void closeResources(Connection connection, Statement statement)

void commit()

protected Connection createConnection()

DataSet createView(Closure criteria)

void each(Closure closure)

DataSet findAll(Closure where)

Object firstRow()

Returns the first row from a DataSet's underlying table
List getParameters()

String getSql()

protected SqlOrderByVisitor getSqlOrderByVisitor()

protected SqlWhereVisitor getSqlWhereVisitor()

DataSet reverse()

void rollback()

List rows()

Returns a List of all of the rows from the table a DataSet represents
DataSet sort(Closure sort)

void withTransaction(Closure closure)

 
Methods inherited from class Sql
ARRAY, BIGINT, BINARY, BIT, BLOB, BOOLEAN, CHAR, CLOB, DATALINK, DATE, DECIMAL, DISTINCT, DOUBLE, FLOAT, INTEGER, JAVA_OBJECT, LONGVARBINARY, LONGVARCHAR, NULL, NUMERIC, OTHER, REAL, REF, SMALLINT, STRUCT, TIME, TIMESTAMP, TINYINT, VARBINARY, VARCHAR, asList, asList, asList, asSql, cacheConnection, cacheStatements, call, call, call, call, call, call, checkForNamedParams, close, closeResources, closeResources, closeResources, commit, configure, createConnection, createPreparedQueryCommand, createQueryCommand, dataSet, dataSet, eachRow, eachRow, eachRow, eachRow, eachRow, eachRow, eachRow, eachRow, eachRow, eachRow, eachRow, eachRow, execute, execute, execute, execute, executeInsert, executeInsert, executeInsert, executeInsert, executePreparedQuery, executeQuery, executeUpdate, executeUpdate, executeUpdate, executeUpdate, expand, findWhereKeyword, firstRow, firstRow, firstRow, firstRow, getConnection, getDataSource, getParameters, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getUpdateCount, getUpdatedParams, in, inout, isCacheNamedQueries, isCacheStatements, isEnableNamedQueries, isWithinBatch, loadDriver, newInstance, newInstance, newInstance, newInstance, newInstance, newInstance, newInstance, nullify, out, preCheckForNamedParams, query, query, query, resultSet, rollback, rows, rows, rows, rows, rows, rows, rows, rows, rows, rows, rows, rows, rows, rows, setCacheNamedQueries, setCacheStatements, setEnableNamedQueries, setInternalConnection, setObject, setParameters, setResultSetConcurrency, setResultSetHoldability, setResultSetType, withBatch, withBatch, withBatch, withBatch, withStatement, withTransaction
 
Methods inherited from class Object
wait, wait, wait, equals, toString, hashCode, getClass, notify, notifyAll
 

Constructor Detail

DataSet

public DataSet(Sql sql, Class type)

DataSet

public DataSet(Sql sql, String table)

 
Method Detail

add

public void add(Map map)

cacheConnection

@Override
public void cacheConnection(Closure closure)

closeResources

@Override
protected void closeResources(Connection connection, Statement statement, ResultSet results)

closeResources

@Override
protected void closeResources(Connection connection, Statement statement)

commit

@Override
public void commit()

createConnection

@Override
protected Connection createConnection()

createView

public DataSet createView(Closure criteria)

each

public void each(Closure closure)

findAll

public DataSet findAll(Closure where)

firstRow

public Object firstRow()
Returns the first row from a DataSet's underlying table
throws:
SQLException if a database error occurs
Returns:
Returns the first GroovyRowResult object from the dataset

getParameters

public List getParameters()

getSql

public String getSql()

getSqlOrderByVisitor

protected SqlOrderByVisitor getSqlOrderByVisitor()

getSqlWhereVisitor

protected SqlWhereVisitor getSqlWhereVisitor()

reverse

public DataSet reverse()

rollback

@Override
public void rollback()

rows

public List rows()
Returns a List of all of the rows from the table a DataSet represents
throws:
SQLException if a database error occurs
Returns:
Returns a list of GroovyRowResult objects from the dataset

sort

public DataSet sort(Closure sort)

withTransaction

@Override
public void withTransaction(Closure closure)

 

Copyright © 2003-2011 The Codehaus. All rights reserved.