org.teiid.client

Interface DQP

public interface DQP

Method Summary

Modifier and Type	Method and Description
ResultsFuture<?>	begin()
boolean	cancelRequest(long requestID)
ResultsFuture<?>	closeLobChunkStream(int lobRequestId, long requestId, String streamId)
ResultsFuture<?>	closeRequest(long requestID)
ResultsFuture<?>	commit()
ResultsFuture<?>	commit(XidImpl xid, boolean onePhase)
ResultsFuture<?>	end(XidImpl xid, int flags)
ResultsFuture<ResultsMessage>	executeRequest(long reqID, RequestMessage message)
ResultsFuture<?>	forget(XidImpl xid)
MetadataResult	getMetadata(long requestID)
MetadataResult	getMetadata(long requestID, String preparedSql, boolean allowDoubleQuotedVariable)
ResultsFuture<Integer>	prepare(XidImpl xid)
ResultsFuture<ResultsMessage>	processCursorRequest(long reqID, int batchFirst, int fetchSize)
ResultsFuture<Xid[]>	recover(int flag)
ResultsFuture<LobChunk>	requestNextLobChunk(int lobRequestId, long requestId, String streamId)
ResultsFuture<?>	rollback()
ResultsFuture<?>	rollback(XidImpl xid)
ResultsFuture<?>	start(XidImpl xid, int flags, int timeout)

Method Detail

executeRequest

@Secure(optional=true)
ResultsFuture<ResultsMessage> executeRequest(long reqID,
                                                                    RequestMessage message)
                                                             throws org.teiid.core.TeiidProcessingException,
                                                                    org.teiid.core.TeiidComponentException

Throws:

org.teiid.core.TeiidProcessingException

org.teiid.core.TeiidComponentException

processCursorRequest

ResultsFuture<ResultsMessage> processCursorRequest(long reqID,
                                                   int batchFirst,
                                                   int fetchSize)
                                            throws org.teiid.core.TeiidProcessingException

Throws:

org.teiid.core.TeiidProcessingException

closeRequest

ResultsFuture<?> closeRequest(long requestID)
                       throws org.teiid.core.TeiidProcessingException,
                              org.teiid.core.TeiidComponentException

Throws:

org.teiid.core.TeiidProcessingException

org.teiid.core.TeiidComponentException

cancelRequest

boolean cancelRequest(long requestID)
               throws org.teiid.core.TeiidProcessingException,
                      org.teiid.core.TeiidComponentException

Throws:

org.teiid.core.TeiidProcessingException

org.teiid.core.TeiidComponentException

closeLobChunkStream

ResultsFuture<?> closeLobChunkStream(int lobRequestId,
                                     long requestId,
                                     String streamId)
                              throws org.teiid.core.TeiidProcessingException,
                                     org.teiid.core.TeiidComponentException

Throws:

org.teiid.core.TeiidProcessingException

org.teiid.core.TeiidComponentException

requestNextLobChunk

ResultsFuture<LobChunk> requestNextLobChunk(int lobRequestId,
                                            long requestId,
                                            String streamId)
                                     throws org.teiid.core.TeiidProcessingException,
                                            org.teiid.core.TeiidComponentException

Throws:

org.teiid.core.TeiidProcessingException

org.teiid.core.TeiidComponentException

getMetadata

MetadataResult getMetadata(long requestID)
                    throws org.teiid.core.TeiidComponentException,
                           org.teiid.core.TeiidProcessingException

Throws:

org.teiid.core.TeiidComponentException

org.teiid.core.TeiidProcessingException

getMetadata

MetadataResult getMetadata(long requestID,
                           String preparedSql,
                           boolean allowDoubleQuotedVariable)
                    throws org.teiid.core.TeiidComponentException,
                           org.teiid.core.TeiidProcessingException

Throws:

org.teiid.core.TeiidComponentException

org.teiid.core.TeiidProcessingException

begin

ResultsFuture<?> begin()
                throws XATransactionException

Throws:

XATransactionException

commit

ResultsFuture<?> commit()
                 throws XATransactionException

Throws:

XATransactionException

rollback

ResultsFuture<?> rollback()
                   throws XATransactionException

Throws:

XATransactionException

start

ResultsFuture<?> start(XidImpl xid,
                       int flags,
                       int timeout)
                throws XATransactionException

Throws:

XATransactionException

end

ResultsFuture<?> end(XidImpl xid,
                     int flags)
              throws XATransactionException

Throws:

XATransactionException

prepare

ResultsFuture<Integer> prepare(XidImpl xid)
                        throws XATransactionException

Throws:

XATransactionException

commit

ResultsFuture<?> commit(XidImpl xid,
                        boolean onePhase)
                 throws XATransactionException

Throws:

XATransactionException

rollback

ResultsFuture<?> rollback(XidImpl xid)
                   throws XATransactionException

Throws:

XATransactionException

forget

ResultsFuture<?> forget(XidImpl xid)
                 throws XATransactionException

Throws:

XATransactionException

recover

ResultsFuture<Xid[]> recover(int flag)
                      throws XATransactionException

Throws:

XATransactionException