public DataSet(Sql sql,
    Class type) 
{
         
        super(sql);
        delegate = sql;
        String table = type.getName();
        int idx = table.lastIndexOf('.");
        if (idx  > 0) {
            table = table.substring(idx + 1);
        }
        this.table = table.toLowerCase();
}

 public DataSet(Sql sql,
    String table) 
{
        super(sql);
        delegate = sql;
        this.table = table;
}

 public  void add(Map map) throws SQLException 
{
        StringBuffer buffer = new StringBuffer("insert into ");
        buffer.append(table);
        buffer.append(" (");
        StringBuffer paramBuffer = new StringBuffer();
        boolean first = true;
        for (String column : map.keySet()) {
            if (first) {
                first = false;
                paramBuffer.append("?");
            } else {
                buffer.append(", ");
                paramBuffer.append(", ?");
            }
            buffer.append(column);
        }
        buffer.append(") values (");
        buffer.append(paramBuffer.toString());
        buffer.append(")");
        Connection connection = createConnection();
        PreparedStatement statement = null;
        try {
            statement = connection.prepareStatement(buffer.toString());
            int i = 1;
            for (Object value : map.values()) {
                setObject(statement, i++, value);
            }
            int answer = statement.executeUpdate();
            if (answer != 1) {
                log.log(Level.WARNING, "Should have updated 1 row not " + answer + " when trying to add: " + map);
            }
        }
        catch (SQLException e) {
            log.log(Level.WARNING, "Failed to add row for: " + map, e);
            throw e;
        }
        finally {
            closeResources(connection, statement);
        }
}

 public  void cacheConnection(Closure closure) throws SQLException 
{
        delegate.cacheConnection(closure);
}

 protected  void closeResources(Connection connection,
    Statement statement) 
{
        delegate.closeResources(connection, statement);
}

 protected  void closeResources(Connection connection,
    Statement statement,
    ResultSet results) 
{
        delegate.closeResources(connection, statement, results);
}

 public  void commit() throws SQLException 
{
        delegate.commit();
}

 protected Connection createConnection() throws SQLException 
{
        return delegate.createConnection();
}

 public DataSet createView(Closure criteria) 
{
        return new DataSet(this, criteria);
}

 public  void each(Closure closure) throws SQLException 
{
        eachRow(getSql(), getParameters(), closure);
}

 public DataSet findAll(Closure where) 
{
        return new DataSet(this, where);
}

 public Object firstRow() throws SQLException 
{
        List rows = rows();
        if (rows.isEmpty()) return null;
        return (rows.get(0));
}

Returns the first row from a DataSet's underlying table

 public List getParameters() 
{
        if (params == null) {
            params = new ArrayList();
            if (parent != null) {
                params.addAll(parent.getParameters());
            }
            params.addAll(getSqlWhereVisitor().getParameters());
        }
        return params;
}

 public String getSql() 
{
        if (sql == null) {
            sql = "select * from " + table;
            String whereClaus = getSqlWhere();
            if (whereClaus.length()  > 0) {
                sql += " where " + whereClaus;
            }
            String orerByClaus = getSqlOrderBy();
            if (orerByClaus.length()  > 0) {
                sql += " order by " + orerByClaus;
            }
        }
        return sql;
}

 protected SqlOrderByVisitor getSqlOrderByVisitor() 
{
        if (sortVisitor == null) {
            sortVisitor = new SqlOrderByVisitor();
            visit(sort, sortVisitor);
        }
        return sortVisitor;
}

 protected SqlWhereVisitor getSqlWhereVisitor() 
{
        if (visitor == null) {
            visitor = new SqlWhereVisitor();
            visit(where, visitor);
        }
        return visitor;
}

 public DataSet reverse() 
{
        if (sort == null) {
            throw new GroovyRuntimeException("reverse() only allowed immediately after a sort()");
        }
        return new DataSet(this);
}

 public  void rollback() throws SQLException 
{
        delegate.rollback();
}

 public List rows() throws SQLException 
{
        return rows(getSql(), getParameters());
}

Returns a List of all of the rows from the table a DataSet represents

 public DataSet sort(Closure sort) 
{
        return new DataSet(this, null, sort);
}

 public  void withTransaction(Closure closure) throws SQLException 
{
        delegate.withTransaction(closure);
}