com.xxdb

Class DBConnection

java.lang.Object

com.xxdb.DBConnection

public class DBConnection
extends Object

Sets up a connection to DolphinDB server through TCP/IP protocol Executes DolphinDB scripts

Example:

import com.xxdb; DBConnection conn = new DBConnection(); boolean success = conn.connect("localhost", 8080); conn.run("sum(1..100)");

Constructor Summary

Constructors

Constructor and Description
DBConnection()
DBConnection(boolean asynchronousTask)
DBConnection(boolean asynchronousTask, boolean useSSL)
DBConnection(boolean asynchronousTask, boolean useSSL, boolean compress)
DBConnection(boolean asynchronousTask, boolean useSSL, boolean compress, boolean usePython)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	connect(String hostName, int port)
boolean	connect(String hostName, int port, boolean enableHighAvailability)
boolean	connect(String hostName, int port, int timeout)
boolean	connect(String hostName, int port, int timeout, boolean reconnect)
boolean	connect(String hostName, int port, String initialScript)
boolean	connect(String hostName, int port, String[] highAvailabilitySites)
boolean	connect(String hostName, int port, String initialScript, boolean enableHighAvailability)
boolean	connect(String hostName, int port, String userId, String password)
boolean	connect(String hostName, int port, String initialScript, String[] highAvailabilitySites)
boolean	connect(String hostName, int port, String userId, String password, boolean enableHighAvailability)
boolean	connect(String hostName, int port, String userId, String password, String initialScript)
boolean	connect(String hostName, int port, String userId, String password, String[] highAvailabilitySites)
boolean	connect(String hostName, int port, String userId, String password, String initialScript, boolean enableHighAvailability)
boolean	connect(String hostName, int port, String userId, String password, String initialScript, boolean enableHighAvailability, String[] highAvailabilitySites)
boolean	connect(String hostName, int port, String userId, String password, String initialScript, boolean enableHighAvailability, String[] highAvailabilitySites, boolean reconnect)
boolean	connect(String hostName, int port, String userId, String password, String initialScript, String[] highAvailabilitySites)
boolean	connected()
boolean	connectNode(com.xxdb.DBConnection.Node node)
String	getHostName()
InetAddress	getLocalAddress()
int	getPort()
boolean	getRemoteLittleEndian()
String	getSessionID()
boolean	isBusy()
boolean	isConnected()
void	login(String userID, String password, boolean enableEncryption)
com.xxdb.DBConnection.ExceptionType	parseException(String msg, com.xxdb.DBConnection.Node node)
void	parseIpPort(String ipport, com.xxdb.DBConnection.Node node)
Entity	run(String script)
Entity	run(String script, boolean clearSessionMemory)
Entity	run(String script, int priority)
Entity	run(String script, int priority, boolean clearSessionMemory)
Entity	run(String script, int priority, int parallelism)
Entity	run(String script, int priority, int parallelism, boolean clearSessionMemory)
Entity	run(String function, List<Entity> arguments)
Entity	run(String function, List<Entity> arguments, int priority)
Entity	run(String function, List<Entity> arguments, int priority, int parallelism)
Entity	run(String function, List<Entity> arguments, int priority, int parallelism, int fetchSize)
Entity	run(String script, ProgressListener listener)
Entity	run(String script, ProgressListener listener, boolean clearSessionMemory)
Entity	run(String script, ProgressListener listener, int priority, int parallelism)
Entity	run(String script, ProgressListener listener, int priority, int parallelism, boolean clearSessionMemory)
Entity	run(String script, ProgressListener listener, int priority, int parallelism, int fetchSize)
Entity	run(String script, ProgressListener listener, int priority, int parallelism, int fetchSize, boolean clearSessionMemory)
Entity	run(String script, ProgressListener listener, int priority, int parallelism, int fetchSize, boolean clearSessionMemory, String tableName)
Entity	run(String script, String tableName)
void	setLoadBalance(boolean loadBalance)
void	switchDataNode(com.xxdb.DBConnection.Node node)
Entity	tryRun(String script)
Entity	tryRun(String script, boolean clearSessionMemory)
Entity	tryRun(String script, int priority, int parallelism)
Entity	tryRun(String script, int priority, int parallelism, boolean clearSessionMemory)
Entity	tryRun(String script, int priority, int parallelism, int fetchSize, boolean clearSessionMemory)
Entity	tryRun(String function, List<Entity> arguments)
Entity	tryRun(String function, List<Entity> arguments, int priority, int parallelism)
Entity	tryRun(String function, List<Entity> arguments, int priority, int parallelism, int fetchSize)
void	tryUpload(Map<String,Entity> variableObjectMap)
void	upload(Map<String,Entity> variableObjectMap)

Methods inherited from class java.lang.Object

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

Constructor Detail

DBConnection

public DBConnection()

DBConnection

public DBConnection(boolean asynchronousTask)

DBConnection

public DBConnection(boolean asynchronousTask,
                    boolean useSSL)

DBConnection

public DBConnection(boolean asynchronousTask,
                    boolean useSSL,
                    boolean compress)

DBConnection

public DBConnection(boolean asynchronousTask,
                    boolean useSSL,
                    boolean compress,
                    boolean usePython)

Method Detail

isBusy

public boolean isBusy()

setLoadBalance

public void setLoadBalance(boolean loadBalance)

connect

public boolean connect(String hostName,
                       int port)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       int timeout)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       int timeout,
                       boolean reconnect)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       String initialScript)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       String initialScript,
                       boolean enableHighAvailability)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       boolean enableHighAvailability)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       String[] highAvailabilitySites)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       String initialScript,
                       String[] highAvailabilitySites)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       String userId,
                       String password)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       String userId,
                       String password,
                       boolean enableHighAvailability)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       String userId,
                       String password,
                       String[] highAvailabilitySites)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       String userId,
                       String password,
                       String initialScript)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       String userId,
                       String password,
                       String initialScript,
                       boolean enableHighAvailability)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       String userId,
                       String password,
                       String initialScript,
                       String[] highAvailabilitySites)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       String userId,
                       String password,
                       String initialScript,
                       boolean enableHighAvailability,
                       String[] highAvailabilitySites)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       String userId,
                       String password,
                       String initialScript,
                       boolean enableHighAvailability,
                       String[] highAvailabilitySites,
                       boolean reconnect)
                throws IOException

Throws:

IOException

switchDataNode

public void switchDataNode(com.xxdb.DBConnection.Node node)
                    throws IOException

Throws:

IOException

connectNode

public boolean connectNode(com.xxdb.DBConnection.Node node)
                    throws IOException

Throws:

IOException

parseException

public com.xxdb.DBConnection.ExceptionType parseException(String msg,
                                                          com.xxdb.DBConnection.Node node)

parseIpPort

public void parseIpPort(String ipport,
                        com.xxdb.DBConnection.Node node)

connected

public boolean connected()

login

public void login(String userID,
                  String password,
                  boolean enableEncryption)
           throws IOException

Throws:

IOException

getRemoteLittleEndian

public boolean getRemoteLittleEndian()

tryRun

public Entity tryRun(String script)
              throws IOException

Throws:

IOException

tryRun

public Entity tryRun(String script,
                     int priority,
                     int parallelism)
              throws IOException

Throws:

IOException

tryRun

public Entity tryRun(String script,
                     int priority,
                     int parallelism,
                     boolean clearSessionMemory)
              throws IOException

Throws:

IOException

tryRun

public Entity tryRun(String script,
                     int priority,
                     int parallelism,
                     int fetchSize,
                     boolean clearSessionMemory)
              throws IOException

Throws:

IOException

run

public Entity run(String script,
                  String tableName)
           throws IOException

Throws:

IOException

run

public Entity run(String script)
           throws IOException

Throws:

IOException

run

public Entity run(String script,
                  int priority)
           throws IOException

Throws:

IOException

run

public Entity run(String script,
                  int priority,
                  int parallelism)
           throws IOException

Throws:

IOException

run

public Entity run(String script,
                  ProgressListener listener)
           throws IOException

Throws:

IOException

run

public Entity run(String script,
                  ProgressListener listener,
                  boolean clearSessionMemory)
           throws IOException

Throws:

IOException

run

public Entity run(String script,
                  int priority,
                  boolean clearSessionMemory)
           throws IOException

Throws:

IOException

run

public Entity run(String script,
                  ProgressListener listener,
                  int priority,
                  int parallelism)
           throws IOException

Throws:

IOException

run

public Entity run(String script,
                  ProgressListener listener,
                  int priority,
                  int parallelism,
                  boolean clearSessionMemory)
           throws IOException

Throws:

IOException

run

public Entity run(String script,
                  int priority,
                  int parallelism,
                  boolean clearSessionMemory)
           throws IOException

Throws:

IOException

run

public Entity run(String script,
                  ProgressListener listener,
                  int priority,
                  int parallelism,
                  int fetchSize)
           throws IOException

Throws:

IOException

tryRun

public Entity tryRun(String script,
                     boolean clearSessionMemory)
              throws IOException

Throws:

IOException

run

public Entity run(String script,
                  boolean clearSessionMemory)
           throws IOException

Throws:

IOException

run

public Entity run(String script,
                  ProgressListener listener,
                  int priority,
                  int parallelism,
                  int fetchSize,
                  boolean clearSessionMemory)
           throws IOException

Throws:

IOException

run

public Entity run(String script,
                  ProgressListener listener,
                  int priority,
                  int parallelism,
                  int fetchSize,
                  boolean clearSessionMemory,
                  String tableName)
           throws IOException

Throws:

IOException

tryRun

public Entity tryRun(String function,
                     List<Entity> arguments)
              throws IOException

Throws:

IOException

tryRun

public Entity tryRun(String function,
                     List<Entity> arguments,
                     int priority,
                     int parallelism)
              throws IOException

Throws:

IOException

tryRun

public Entity tryRun(String function,
                     List<Entity> arguments,
                     int priority,
                     int parallelism,
                     int fetchSize)
              throws IOException

Throws:

IOException

run

public Entity run(String function,
                  List<Entity> arguments)
           throws IOException

Throws:

IOException

run

public Entity run(String function,
                  List<Entity> arguments,
                  int priority)
           throws IOException

Throws:

IOException

run

public Entity run(String function,
                  List<Entity> arguments,
                  int priority,
                  int parallelism)
           throws IOException

Throws:

IOException

run

public Entity run(String function,
                  List<Entity> arguments,
                  int priority,
                  int parallelism,
                  int fetchSize)
           throws IOException

Throws:

IOException

tryUpload

public void tryUpload(Map<String,Entity> variableObjectMap)
               throws IOException

Throws:

IOException

upload

public void upload(Map<String,Entity> variableObjectMap)
            throws IOException

Throws:

IOException

close

public void close()

getHostName

public String getHostName()

getPort

public int getPort()

getSessionID

public String getSessionID()

getLocalAddress

public InetAddress getLocalAddress()

isConnected

public boolean isConnected()