org.tango.jhdb

Class Hdb

java.lang.Object

org.tango.jhdb.Hdb

public class Hdb
extends Object

The Hdb framework allows accessing data from Tango HDB++.

 Hdb hdb = new Hdb();
 try {

   hdb.connect();
   String[] attList = hdb.getReader().getAttributeList();
   ArrayList<HdbData> data = hdb.getReader().getData(attName[0],"09/07/2015 12:00:00","10/07/2015 12:00:00");
   for(int i=0;i<data.size();i++)
     System.out.println("  Rec #"+i+" :"+data.get(i));

 } catch (HdbFailed e) {
   System.out.println(e.getMessage());
 }

 

Author:

JL Pons

Field Summary

Fields

Modifier and Type	Field and Description
static int	HDB_CASSANDRA Cassandra HDB++
static int	HDB_MYSQL MySQL HDB++
static int	HDB_ORACLE Oracle HDB
static SimpleDateFormat	hdbDateFormat Date format used in getDataFromDB calls

Constructor Summary

Constructors

Constructor and Description
Hdb() Constructs a Hdb Object

Method Summary

Methods

Modifier and Type	Method and Description
void	connect() Connect to HDB either using MySQL or Cassandra according to the following environment variables.
void	connectCassandra() Connects to a Cassandra HDB.
void	connectCassandra(String[] contacts, String db, String user, String passwd) Connects to a Cassandra HDB.
void	connectMySQL() Connects to a MySQL HDB.
void	connectMySQL(String host, String db, String user, String passwd, short port) Connects to a MySQL HDB.
void	connectOracle() Connects to a Oracle HDB.
void	disconnect() Close connection to HDB
int	getDBType() Returns type of connection
String	getDBTypeName() Returns type of connection
HdbReader	getReader() Returns a handle to the HDB reader
static String	getVersion()
static void	main(String[] args)
static void	test(Hdb hdb, String start, String stop, String attName)

Methods inherited from class java.lang.Object

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

Field Detail

hdbDateFormat

public static final SimpleDateFormat hdbDateFormat

Date format used in getDataFromDB calls

HDB_CASSANDRA

public static final int HDB_CASSANDRA

Cassandra HDB++

See Also:

Constant Field Values

HDB_MYSQL

public static final int HDB_MYSQL

MySQL HDB++

See Also:

Constant Field Values

HDB_ORACLE

public static final int HDB_ORACLE

Oracle HDB

See Also:

Constant Field Values

Constructor Detail

Hdb

public Hdb()

Constructs a Hdb Object

Method Detail

getReader

public HdbReader getReader()

Returns a handle to the HDB reader

getDBType

public int getDBType()

Returns type of connection

getDBTypeName

public String getDBTypeName()

Returns type of connection

connectMySQL

public void connectMySQL(String host,
                String db,
                String user,
                String passwd,
                short port)
                  throws HdbFailed

Connects to a MySQL HDB.

Parameters:

host - MySQL hostname

db - Database name (default is "hdb")

user - MySQL user name

passwd - MySQL user password

port - MySQL databse port (pass 0 for default Mysql port)

Throws:

HdbFailed - in case of failure

connectMySQL

public void connectMySQL()
                  throws HdbFailed

Connects to a MySQL HDB.

Throws:

HdbFailed

connectCassandra

public void connectCassandra(String[] contacts,
                    String db,
                    String user,
                    String passwd)
                      throws HdbFailed

Connects to a Cassandra HDB.

Parameters:

contacts - List of contact points (at least one of the hostname of the cassandra cluster)

db - Database name (default is "hdb")

user - Cassandra user name

passwd - Cassandra user password

Throws:

HdbFailed

connectCassandra

public void connectCassandra()
                      throws HdbFailed

Connects to a Cassandra HDB.

Throws:

HdbFailed

connectOracle

public void connectOracle()
                   throws HdbFailed

Connects to a Oracle HDB.

Throws:

HdbFailed

connect

public void connect()
             throws HdbFailed

Connect to HDB either using MySQL or Cassandra according to the following environment variables. HDB_TYPE Connection type (MYSQL or CASSANDRA) HDB_NAME Database name (default is "hdb") HDB_USER HDB_PASSWORD MySQL specific HDB_MYSQL_PORT HDB_MYSQL_HOST Cassandra specific HDB_CONTACT_POINTS

Throws:

HdbFailed

disconnect

public void disconnect()

Close connection to HDB

test

public static void test(Hdb hdb,
        String start,
        String stop,
        String attName)
                 throws HdbFailed

Throws:

HdbFailed

getVersion

public static String getVersion()

main

public static void main(String[] args)