Package database

Class Database

java.lang.Object

database.Database

Direct Known Subclasses:

Cassandra

public abstract class Database
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	databaseName
protected final String	host
protected final String	password
protected final Integer	port
protected final String	username

Constructor Summary

Constructors

Constructor	Description
Database(Configuration conf)
Database(String host, Integer port, String username, String password, String databaseName)

Method Summary

Modifier and Type	Method	Description
abstract void	connect()
abstract void	createDatabaseIfNotExists()
abstract void	disconnect()
abstract void	dropDatabaseIfExists()
abstract Object	execute(com.datastax.oss.driver.api.core.cql.SimpleStatement statement)
abstract Object	executeAsync(com.datastax.oss.driver.api.core.cql.SimpleStatement statement)
abstract Object	executeAsyncWithSession(com.datastax.oss.driver.api.core.cql.SimpleStatement statement)
String	getDatabaseName()
String	getHost()
String	getPassword()
Integer	getPort()
abstract Object	getSession()
String	getUsername()

Methods inherited from class java.lang.Object

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

Field Details

host

protected final String host

port

protected final Integer port

username

protected final String username

password

protected final String password

databaseName

protected final String databaseName

Constructor Details

Database

public Database(Configuration conf)

Database

public Database(String host,
 Integer port,
 String username,
 String password,
 String databaseName)

Method Details

connect

public abstract void connect()
                      throws DBInitException

Throws:

DBInitException

disconnect

public abstract void disconnect()

createDatabaseIfNotExists

public abstract void createDatabaseIfNotExists()

dropDatabaseIfExists

public abstract void dropDatabaseIfExists()

execute

public abstract Object execute(com.datastax.oss.driver.api.core.cql.SimpleStatement statement)

executeAsync

public abstract Object executeAsync(com.datastax.oss.driver.api.core.cql.SimpleStatement statement)

executeAsyncWithSession

public abstract Object executeAsyncWithSession(com.datastax.oss.driver.api.core.cql.SimpleStatement statement)

getSession

public abstract Object getSession()

getHost

public String getHost()

getPort

public Integer getPort()

getUsername

public String getUsername()

getPassword

public String getPassword()

getDatabaseName

public String getDatabaseName()