com.edgeti.VisibilityServer.Database

Class DatabaseIf

java.lang.Object

com.edgeti.VisibilityServer.Database.DatabaseIf

public class DatabaseIf
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	connectCounter
private java.lang.String	database
private java.sql.Connection	dBconnection
static boolean	debugFlag
private java.lang.String	driver
private static boolean	FAIL
private java.lang.String	host
protected org.apache.log4j.Logger	logger
private java.lang.String	password
private static java.lang.String	PROP_FILE Name of the properties file which must exist on the classpath.
private java.sql.ResultSet	resultSet
private java.lang.String	sqlStr
private java.sql.Statement	statement
private static boolean	SUCCESS
static java.lang.String	TABLE_INFO_NAME
private java.lang.String	user

Constructor Summary

Constructors

Constructor and Description
DatabaseIf()
DatabaseIf(java.lang.String host, java.lang.String user, java.lang.String password, java.lang.String database, java.lang.String driver)

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	buildColumnList(java.util.List<ColumnInfoObject> columns)
java.lang.String	buildColumns(java.util.List<java.lang.String> columns)
java.util.List<java.lang.Integer>	buildRolesList(UserInfoObject user)
private java.lang.String	buildStr(java.util.List<java.lang.String> values)
java.lang.String	buildWhere(java.util.List<java.lang.String> columns)
boolean	checkValue(java.lang.String tableName, java.lang.String columnName, java.lang.String value)
boolean	compareColumns(java.lang.String tableName, java.util.ArrayList<java.lang.String> columns)
void	connect()
boolean	createTable(java.lang.String tableName, java.util.ArrayList<java.lang.String> columns)
boolean	delete(java.lang.String tableName, int id)
boolean	deleteTable(java.lang.String tableName)
void	disconnect()
java.util.List<java.util.List>	find(java.lang.String tableName, java.lang.String what, java.lang.String where)
java.lang.String	findFirst(java.lang.String tableName, java.lang.String what, java.lang.String where)
java.sql.Connection	getConnection()
java.util.ArrayList<java.lang.String>	getSafeTableColumns(java.lang.String tableName) Get column names from the table that are 'MySql safe', in that all are backticked (`)
java.util.List<java.util.List>	getSqlResult(java.lang.String sql)
java.util.ArrayList<java.lang.String>	getTableColumns(java.lang.String tableName) Get column names from the db
java.util.List<java.lang.String>	getTableNames()
java.util.List<java.lang.String>	getTablesInfo(UserInfoObject user)
boolean	insert(java.lang.String tableName, java.util.ArrayList<java.lang.String> values)
boolean	insert(java.lang.String tableName, java.lang.String columnsStr, java.util.ArrayList<Entry> entries)
boolean	insert(java.lang.String tableName, java.lang.String columnsStr, java.lang.String valuesStr)
boolean	insert2(java.lang.String tableName, java.lang.String columnsStr, java.util.ArrayList<Entry> entries)
boolean	insert2(java.lang.String tableName, java.lang.String columnsStr, java.lang.String valuesStr)
boolean	insertPreparedString(java.lang.String tableName, java.lang.String columnsStr, java.util.ArrayList<Entry> entries) Insert using prepared statements
static void	main(java.lang.String[] args)
java.util.List<java.util.List>	makeErrorTable(java.sql.SQLException e, java.lang.String statement) Turn a SQLException into a table of statement and error so that the result can be visualized in the flex app without breaking it
java.util.List<java.util.List>	parseResultSet(java.sql.ResultSet rs, java.lang.String[] names) Parse a result set into a list of lists, where the first list is the column headings and the subsequent lists contain the data
private void	printList(java.util.List<java.lang.String> list)
protected void	printListList(java.util.List<java.util.List> list)
java.sql.ResultSet	runRawSQL(java.lang.String stmt) adopted from Phil's code DbHelper.java Run an unchecked sql command
boolean	saveAutoIngest(FlexAutoIngestRowObject autoIngest)
java.util.List<java.util.List>	select(java.lang.String tableName)
java.util.List<java.util.List>	select(java.lang.String tableName, java.util.List<java.lang.String> columns)
private boolean	SQLError(java.lang.Exception e, java.lang.String sqlStr)
void	terminate()
boolean	update(java.lang.String tableName, java.util.ArrayList<java.lang.String> columns, java.util.ArrayList<java.lang.String> values)
void	updateTableInfo(java.lang.String tableName)

Methods inherited from class java.lang.Object

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

Field Detail

PROP_FILE

private static final java.lang.String PROP_FILE

Name of the properties file which must exist on the classpath.

See Also:

Constant Field Values

TABLE_INFO_NAME

public static final java.lang.String TABLE_INFO_NAME

See Also:

Constant Field Values

host

private java.lang.String host

database

private java.lang.String database

driver

private java.lang.String driver

user

private java.lang.String user

password

private java.lang.String password

dBconnection

private java.sql.Connection dBconnection

statement

private java.sql.Statement statement

resultSet

private java.sql.ResultSet resultSet

sqlStr

private java.lang.String sqlStr

debugFlag

public static boolean debugFlag

SUCCESS

private static final boolean SUCCESS

See Also:

Constant Field Values

FAIL

private static final boolean FAIL

See Also:

Constant Field Values

connectCounter

public static int connectCounter

logger

protected org.apache.log4j.Logger logger

Constructor Detail

DatabaseIf

public DatabaseIf()

DatabaseIf

public DatabaseIf(java.lang.String host,
          java.lang.String user,
          java.lang.String password,
          java.lang.String database,
          java.lang.String driver)

Method Detail

SQLError

private boolean SQLError(java.lang.Exception e,
               java.lang.String sqlStr)

connect

public void connect()

disconnect

public void disconnect()

getConnection

public java.sql.Connection getConnection()

terminate

public void terminate()

createTable

public boolean createTable(java.lang.String tableName,
                  java.util.ArrayList<java.lang.String> columns)

getTableNames

public java.util.List<java.lang.String> getTableNames()

buildRolesList

public java.util.List<java.lang.Integer> buildRolesList(UserInfoObject user)

getTablesInfo

public java.util.List<java.lang.String> getTablesInfo(UserInfoObject user)

getSafeTableColumns

public java.util.ArrayList<java.lang.String> getSafeTableColumns(java.lang.String tableName)

Get column names from the table that are 'MySql safe', in that all are backticked (`)

Parameters:

tableName -

Returns:

getTableColumns

public java.util.ArrayList<java.lang.String> getTableColumns(java.lang.String tableName)

Get column names from the db

Parameters:

tableName -

Returns:

select

public java.util.List<java.util.List> select(java.lang.String tableName)

select

public java.util.List<java.util.List> select(java.lang.String tableName,
                                    java.util.List<java.lang.String> columns)

find

public java.util.List<java.util.List> find(java.lang.String tableName,
                                  java.lang.String what,
                                  java.lang.String where)

findFirst

public java.lang.String findFirst(java.lang.String tableName,
                         java.lang.String what,
                         java.lang.String where)

insert

public boolean insert(java.lang.String tableName,
             java.util.ArrayList<java.lang.String> values)

buildStr

private java.lang.String buildStr(java.util.List<java.lang.String> values)

saveAutoIngest

public boolean saveAutoIngest(FlexAutoIngestRowObject autoIngest)

insert

public boolean insert(java.lang.String tableName,
             java.lang.String columnsStr,
             java.util.ArrayList<Entry> entries)

insert

public boolean insert(java.lang.String tableName,
             java.lang.String columnsStr,
             java.lang.String valuesStr)

insertPreparedString

public boolean insertPreparedString(java.lang.String tableName,
                           java.lang.String columnsStr,
                           java.util.ArrayList<Entry> entries)

Insert using prepared statements

Parameters:

tableName -

columnsStr -

entries -

Returns:

insert2

public boolean insert2(java.lang.String tableName,
              java.lang.String columnsStr,
              java.util.ArrayList<Entry> entries)

insert2

public boolean insert2(java.lang.String tableName,
              java.lang.String columnsStr,
              java.lang.String valuesStr)

update

public boolean update(java.lang.String tableName,
             java.util.ArrayList<java.lang.String> columns,
             java.util.ArrayList<java.lang.String> values)

delete

public boolean delete(java.lang.String tableName,
             int id)

getSqlResult

public java.util.List<java.util.List> getSqlResult(java.lang.String sql)

makeErrorTable

public java.util.List<java.util.List> makeErrorTable(java.sql.SQLException e,
                                            java.lang.String statement)

Turn a SQLException into a table of statement and error so that the result can be visualized in the flex app without breaking it

Parameters:

e -

statement -

Returns:

parseResultSet

public java.util.List<java.util.List> parseResultSet(java.sql.ResultSet rs,
                                            java.lang.String[] names)
                                              throws java.sql.SQLException

Parse a result set into a list of lists, where the first list is the column headings and the subsequent lists contain the data

Parameters:

rs -

names -

Returns:

Throws:

java.sql.SQLException

deleteTable

public boolean deleteTable(java.lang.String tableName)

checkValue

public boolean checkValue(java.lang.String tableName,
                 java.lang.String columnName,
                 java.lang.String value)

buildColumns

public java.lang.String buildColumns(java.util.List<java.lang.String> columns)

buildColumnList

public java.lang.String buildColumnList(java.util.List<ColumnInfoObject> columns)

buildWhere

public java.lang.String buildWhere(java.util.List<java.lang.String> columns)

printListList

protected void printListList(java.util.List<java.util.List> list)

printList

private void printList(java.util.List<java.lang.String> list)

runRawSQL

public java.sql.ResultSet runRawSQL(java.lang.String stmt)
                             throws java.lang.Exception

adopted from Phil's code DbHelper.java Run an unchecked sql command

Parameters:

stmt -

Returns:

Throws:

java.lang.Exception

compareColumns

public boolean compareColumns(java.lang.String tableName,
                     java.util.ArrayList<java.lang.String> columns)

updateTableInfo

public void updateTableInfo(java.lang.String tableName)

main

public static void main(java.lang.String[] args)