com.buabook.kdb.query

Class KdbAsyncQuery

java.lang.Object

com.buabook.kdb.query.KdbQuery

com.buabook.kdb.query.KdbAsyncQuery

All Implemented Interfaces:

AutoCloseable

public class KdbAsyncQuery
extends KdbQuery

KDB Query Class - Asynchronous Implementation

Based on KdbQuery provides an asynchronous (send query and wait locally for a response from process) means of communicating with a KDB process.

(c) 2014 - 2015 Sport Trades Ltd

Since:

21 Jul 2014

Version:

1.0.1

Author:

Jas Rajasansir

See Also:

KdbQuery

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	log

Fields inherited from class com.buabook.kdb.query.KdbQuery

connection

Constructor Summary

Constructors

Constructor and Description
KdbAsyncQuery(KdbConnection existingConnection)
KdbAsyncQuery(KdbProcess target)

Method Summary

Modifier and Type	Method and Description
Object	query(String query) Method to query a kdb process with a string argument only.
Object	query(String query, KdbDict arguments) NOTE: This function does not perform any re-send of the query in case the connection fails (due to IOException).

Methods inherited from class com.buabook.kdb.query.KdbQuery

close

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final org.slf4j.Logger log

Constructor Detail

KdbAsyncQuery

public KdbAsyncQuery(KdbProcess target)
              throws KdbTargetProcessUnavailableException

Throws:

KdbTargetProcessUnavailableException

KdbAsyncQuery

public KdbAsyncQuery(KdbConnection existingConnection)
              throws KdbTargetProcessUnavailableException

Throws:

KdbTargetProcessUnavailableException

Method Detail

query

public Object query(String query)
             throws QueryExecutionFailedException

Description copied from class: KdbQuery

Method to query a kdb process with a string argument only. Example: "aFunction[]" or "aFunctionWithArgs[1;`symbol].

Specified by:

query in class KdbQuery

Parameters:

query - The string query to execute

Returns:

The query result

Throws:

QueryExecutionFailedException - If the query fails for any reason

query

public Object query(String query,
                    KdbDict arguments)
             throws QueryExecutionFailedException

NOTE: This function does not perform any re-send of the query in case the connection fails (due to IOException). The calling function needs to ensure they re-send the query if they want to.

Specified by:

query in class KdbQuery

Parameters:

query - The function to execute

arguments - The dictionary of arguments

Returns:

The query result

Throws:

QueryExecutionFailedException - If the query fails for any reason