org.apache.hadoop.hbase.hbql.impl
Class HStatementImpl

java.lang.Object
  org.apache.hadoop.hbase.hbql.impl.HStatementImpl

All Implemented Interfaces:

HStatement

Direct Known Subclasses:

HPreparedStatementImpl

public class HStatementImpl
extends Object
implements HStatement

Constructor Summary

HStatementImpl(HConnectionImpl conn)

Method Summary

void	close()
protected ExecutionResults	execute(HBqlStatement statement)
ExecutionResults	execute(String sql)
protected <T> HResultSet<T>	executeQuery(HBqlStatement statement, Class clazz, QueryListener<T>... listeners)
<T> HResultSet<T>	executeQuery(String sql, Class clazz, QueryListener<T>... listeners)
HResultSet<HRecord>	executeQuery(String sql, QueryListener<HRecord>... listeners)
protected <T> List<T>	executeQueryAndFetch(HBqlStatement statement, Class clazz, QueryListener<T>... listeners)
<T> List<T>	executeQueryAndFetch(String sql, Class clazz, QueryListener<T>... listeners)
List<HRecord>	executeQueryAndFetch(String sql, QueryListener<HRecord>... listeners)
protected <T> QueryFuture	executeQueryAsync(HBqlStatement statement, Class clazz, QueryListener<T>... listeners)
<T> QueryFuture	executeQueryAsync(String sql, Class clazz, QueryListener<T>... listeners)
QueryFuture	executeQueryAsync(String sql, QueryListener<HRecord>... listeners)
ExecutionResults	executeUpdate(HBqlStatement statement)
ExecutionResults	executeUpdate(String sql)
protected HConnectionImpl	getHConnectionImpl()
boolean	getIgnoreQueryExecutor()
<T> HResultSet<T>	getResultSet()
boolean	isClosed()
void	setIgnoreQueryExecutor(boolean ignoreQueryExecutor)

Methods inherited from class java.lang.Object

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

Constructor Detail

HStatementImpl

public HStatementImpl(HConnectionImpl conn)

Method Detail

getHConnectionImpl

protected HConnectionImpl getHConnectionImpl()

getResultSet

public <T> HResultSet<T> getResultSet()

Specified by:

getResultSet in interface HStatement

getIgnoreQueryExecutor

public boolean getIgnoreQueryExecutor()

setIgnoreQueryExecutor

public void setIgnoreQueryExecutor(boolean ignoreQueryExecutor)

executeUpdate

public ExecutionResults executeUpdate(HBqlStatement statement)
                               throws HBqlException

Throws:

HBqlException

executeQuery

protected <T> HResultSet<T> executeQuery(HBqlStatement statement,
                                         Class clazz,
                                         QueryListener<T>... listeners)
                              throws HBqlException

Throws:

HBqlException

executeQueryAsync

protected <T> QueryFuture executeQueryAsync(HBqlStatement statement,
                                            Class clazz,
                                            QueryListener<T>... listeners)
                                 throws HBqlException

Throws:

HBqlException

executeQueryAndFetch

protected <T> List<T> executeQueryAndFetch(HBqlStatement statement,
                                           Class clazz,
                                           QueryListener<T>... listeners)
                                throws HBqlException

Throws:

HBqlException

execute

protected ExecutionResults execute(HBqlStatement statement)
                            throws HBqlException

Throws:

HBqlException

execute

public ExecutionResults execute(String sql)
                         throws HBqlException

Specified by:

execute in interface HStatement

Throws:

HBqlException

executeQuery

public HResultSet<HRecord> executeQuery(String sql,
                                        QueryListener<HRecord>... listeners)
                                 throws HBqlException

Specified by:

executeQuery in interface HStatement

Throws:

HBqlException

executeQueryAsync

public QueryFuture executeQueryAsync(String sql,
                                     QueryListener<HRecord>... listeners)
                              throws HBqlException

Specified by:

executeQueryAsync in interface HStatement

Throws:

HBqlException

executeQuery

public <T> HResultSet<T> executeQuery(String sql,
                                      Class clazz,
                                      QueryListener<T>... listeners)
                           throws HBqlException

Specified by:

executeQuery in interface HStatement

Throws:

HBqlException

executeQueryAsync

public <T> QueryFuture executeQueryAsync(String sql,
                                         Class clazz,
                                         QueryListener<T>... listeners)
                              throws HBqlException

Specified by:

executeQueryAsync in interface HStatement

Throws:

HBqlException

executeQueryAndFetch

public List<HRecord> executeQueryAndFetch(String sql,
                                          QueryListener<HRecord>... listeners)
                                   throws HBqlException

Specified by:

executeQueryAndFetch in interface HStatement

Throws:

HBqlException

executeQueryAndFetch

public <T> List<T> executeQueryAndFetch(String sql,
                                        Class clazz,
                                        QueryListener<T>... listeners)
                             throws HBqlException

Specified by:

executeQueryAndFetch in interface HStatement

Throws:

HBqlException

executeUpdate

public ExecutionResults executeUpdate(String sql)
                               throws HBqlException

Specified by:

executeUpdate in interface HStatement

Throws:

HBqlException

isClosed

public boolean isClosed()

Specified by:

isClosed in interface HStatement

close

public void close()
           throws HBqlException

Specified by:

close in interface HStatement

Throws:

HBqlException