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)");

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DBConnection.ConnectConfig

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)
DBConnection(boolean asynchronousTask, boolean useSSL, boolean compress, boolean usePython, boolean isUrgent)
DBConnection(boolean asynchronousTask, boolean useSSL, boolean compress, boolean usePython, boolean isUrgent, SqlStdEnum sqlStd)
DBConnection(boolean asynchronousTask, boolean useSSL, boolean compress, boolean usePython, boolean isUrgent, SqlStdEnum sqlStd, boolean enableSCRAM)
DBConnection(boolean asynchronousTask, boolean useSSL, boolean compress, boolean usePython, boolean isUrgent, SqlStdEnum sqlStd, boolean enableSCRAM, boolean useKdb)
DBConnection(boolean asynchronousTask, boolean useSSL, boolean compress, boolean usePython, SqlStdEnum sqlStd)
DBConnection(SqlStdEnum sqlStd)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	connect(DBConnection.ConnectConfig connectConfig)
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, int timeout, boolean reconnect, int tryReconnectNums)
boolean	connect(String hostName, int port, int connectTimeout, int readTimeout)
boolean	connect(String hostName, int port, int connectTimeout, int readTimeout, boolean reconnect)
boolean	connect(String hostName, int port, int connectTimeout, int readTimeout, boolean reconnect, int tryReconnectNums)
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, boolean enableHighAvailability, String[] highAvailabilitySites, boolean reconnect, boolean enableLoadBalance)
boolean	connect(String hostName, int port, String userId, String password, String initialScript, boolean enableHighAvailability, String[] highAvailabilitySites, boolean reconnect, boolean enableLoadBalance, int tryReconnectNums)
boolean	connect(String hostName, int port, String userId, String password, String initialScript, boolean enableHighAvailability, String[] highAvailabilitySites, boolean reconnect, int tryReconnectNums)
boolean	connect(String hostName, int port, String userId, String password, String initialScript, String[] highAvailabilitySites)
boolean	connected()
boolean	connectNode(com.xxdb.DBConnection.Node node)
ExtendedDataInput	getDataInputStream()
String	getHostName()
InetAddress	getLocalAddress()
int	getPort()
String	getPwd()
boolean	getRemoteLittleEndian()
String	getSessionID()
Socket	getSocket()
String	getUserId()
static DBConnection	internalCreateEnableReverseStreamingDBConnection(boolean asynchronousTask, boolean useSSL, boolean compress, boolean usePython, boolean isUrgent, SqlStdEnum sqlStd)
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 function, List<Entity> arguments, int priority, int parallelism, int fetchSize, boolean enableSeqNo)
Entity	run(String function, List<Entity> arguments, int priority, int parallelism, int fetchSize, boolean enableSeqNo, ProgressListener listener)
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, ProgressListener listener, int priority, int parallelism, int fetchSize, boolean clearSessionMemory, String tableName, boolean enableSeqNo)
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(SqlStdEnum sqlStd)

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)

DBConnection

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

DBConnection

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

DBConnection

public DBConnection(boolean asynchronousTask,
                    boolean useSSL,
                    boolean compress,
                    boolean usePython,
                    boolean isUrgent,
                    SqlStdEnum sqlStd)

DBConnection

public DBConnection(boolean asynchronousTask,
                    boolean useSSL,
                    boolean compress,
                    boolean usePython,
                    boolean isUrgent,
                    SqlStdEnum sqlStd,
                    boolean enableSCRAM)

DBConnection

public DBConnection(boolean asynchronousTask,
                    boolean useSSL,
                    boolean compress,
                    boolean usePython,
                    boolean isUrgent,
                    SqlStdEnum sqlStd,
                    boolean enableSCRAM,
                    boolean useKdb)

Method Detail

internalCreateEnableReverseStreamingDBConnection

public static DBConnection internalCreateEnableReverseStreamingDBConnection(boolean asynchronousTask,
                                                                            boolean useSSL,
                                                                            boolean compress,
                                                                            boolean usePython,
                                                                            boolean isUrgent,
                                                                            SqlStdEnum sqlStd)

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 connectTimeout,
                       int readTimeout)
                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,
                       int connectTimeout,
                       int readTimeout,
                       boolean reconnect)
                throws IOException

Throws:

IOException

connect

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

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       int connectTimeout,
                       int readTimeout,
                       boolean reconnect,
                       int tryReconnectNums)
                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

connect

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

Throws:

IOException

connect

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

Throws:

IOException

connect

public boolean connect(DBConnection.ConnectConfig connectConfig)
                throws IOException

Throws:

IOException

connect

public boolean connect(String hostName,
                       int port,
                       String userId,
                       String password,
                       String initialScript,
                       boolean enableHighAvailability,
                       String[] highAvailabilitySites,
                       boolean reconnect,
                       boolean enableLoadBalance,
                       int tryReconnectNums)
                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,
                  boolean enableSeqNo)
           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,
                  boolean enableSeqNo)
           throws IOException

Throws:

IOException

run

public Entity run(String function,
                  List<Entity> arguments,
                  int priority,
                  int parallelism,
                  int fetchSize,
                  boolean enableSeqNo,
                  ProgressListener listener)
           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()

getUserId

public String getUserId()

getPwd

public String getPwd()

getSessionID

public String getSessionID()

getLocalAddress

public InetAddress getLocalAddress()

getSocket

public Socket getSocket()

getDataInputStream

public ExtendedDataInput getDataInputStream()

isConnected

public boolean isConnected()