Package org.teiid.olingo.service

Class LocalClient

java.lang.Object

org.teiid.olingo.service.LocalClient

All Implemented Interfaces:

Client

public class LocalClient
extends Object
implements Client

Field Summary

Fields

Modifier and Type	Field	Description
protected ConnectionImpl	connection

Fields inherited from interface org.teiid.odata.api.Client

BATCH_SIZE, CHARSET, INVALID_CHARACTER_REPLACEMENT, SKIPTOKEN_TIME

Constructor Summary

Constructors

Constructor	Description
LocalClient(String vdbName, String vdbVersion, Properties properties, Map<Object,Future<Boolean>> loading)

Method Summary

Modifier and Type	Method	Description
static ConnectionImpl	buildConnection(TeiidDriver driver, String vdbName, String version, Properties props)
void	close()
void	commit(String txnId)
void	executeCall(String sql, List<SQLParameter> parameters, ProcedureReturnType returnType, OperationResponse response)
CountResponse	executeCount(Query query, List<SQLParameter> parameters)
void	executeSQL(Query query, List<SQLParameter> parameters, boolean calculateTotalSize, Integer skipOption, Integer topOption, String nextOption, int pageSize, QueryResponse response)
UpdateResponse	executeUpdate(Command query, List<SQLParameter> parameters)
ConnectionImpl	getConnection()
MetadataStore	getMetadataStore()
String	getProperty(String key)
VDBMetaData	getVDB()
Connection	open()
void	rollback(String txnId)
String	startTransaction()

Methods inherited from class java.lang.Object

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

Field Detail

connection

protected ConnectionImpl connection

Constructor Detail

LocalClient

public LocalClient(String vdbName,
                   String vdbVersion,
                   Properties properties,
                   Map<Object,Future<Boolean>> loading)

Method Detail

open

public Connection open()
                throws SQLException,
                       TeiidProcessingException

Specified by:

open in interface Client

Throws:

SQLException

TeiidProcessingException

close

public void close()
           throws SQLException

Specified by:

close in interface Client

Throws:

SQLException

getConnection

public ConnectionImpl getConnection()

buildConnection

public static ConnectionImpl buildConnection(TeiidDriver driver,
                                             String vdbName,
                                             String version,
                                             Properties props)
                                      throws SQLException

Throws:

SQLException

getVDB

public VDBMetaData getVDB()

Specified by:

getVDB in interface Client

executeCall

public void executeCall(String sql,
                        List<SQLParameter> parameters,
                        ProcedureReturnType returnType,
                        OperationResponse response)
                 throws SQLException

Specified by:

executeCall in interface Client

Throws:

SQLException

getMetadataStore

public MetadataStore getMetadataStore()

Specified by:

getMetadataStore in interface Client

executeSQL

public void executeSQL(Query query,
                       List<SQLParameter> parameters,
                       boolean calculateTotalSize,
                       Integer skipOption,
                       Integer topOption,
                       String nextOption,
                       int pageSize,
                       QueryResponse response)
                throws SQLException

Specified by:

executeSQL in interface Client

Throws:

SQLException

executeCount

public CountResponse executeCount(Query query,
                                  List<SQLParameter> parameters)
                           throws SQLException

Specified by:

executeCount in interface Client

Throws:

SQLException

executeUpdate

public UpdateResponse executeUpdate(Command query,
                                    List<SQLParameter> parameters)
                             throws SQLException

Specified by:

executeUpdate in interface Client

Throws:

SQLException

getProperty

public String getProperty(String key)

Specified by:

getProperty in interface Client

startTransaction

public String startTransaction()
                        throws SQLException

Specified by:

startTransaction in interface Client

Throws:

SQLException

commit

public void commit(String txnId)
            throws SQLException

Specified by:

commit in interface Client

Throws:

SQLException

rollback

public void rollback(String txnId)
              throws SQLException

Specified by:

rollback in interface Client

Throws:

SQLException