pt.lsts.neptus.util.logdb

Class SQLiteSerialization

java.lang.Object

pt.lsts.neptus.util.logdb.SQLiteSerialization

public class SQLiteSerialization
extends java.lang.Object

Author:

zp

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.LinkedHashMap<java.lang.Integer,java.sql.PreparedStatement>	messageInserts

Method Summary

Modifier and Type	Method and Description
protected void	commit() Commit any uncommited transactions to the database
static SQLiteSerialization	connect() Creates a new SQLite DB and connects to it
static SQLiteSerialization	connect(java.lang.String filename) Connect to an existing DB
static java.lang.Object	extractValue(java.lang.String imcType, java.lang.String column, java.sql.ResultSet rs)
java.sql.Connection	getConn()
static SQLiteSerialization	getDb()
java.lang.String	getFilename()
pt.lsts.imc.IMCMessage	getLastMessageOfType(int messageType) Fetch the last message of some type
pt.lsts.imc.IMCMessage	getLastMessageOfType(java.lang.String messageAbbrev) Fetch the last message of some type
pt.lsts.imc.IMCMessage	getLatestMessageOfType(int messageType) Fetch the last message of some type
protected java.sql.PreparedStatement	getMessageInsertStatement(int msgType)
static void	main(java.lang.String[] args)
long	store(pt.lsts.imc.IMCMessage msg) Stores the given message in the Database
protected long	storeHeader(pt.lsts.imc.IMCMessage header)

Methods inherited from class java.lang.Object

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

Field Detail

messageInserts

protected java.util.LinkedHashMap<java.lang.Integer,java.sql.PreparedStatement> messageInserts

Method Detail

getDb

public static SQLiteSerialization getDb()

connect

public static SQLiteSerialization connect()

Creates a new SQLite DB and connects to it

Returns:

A new SQLiteSerialization object, associated with a newly created DB

connect

public static SQLiteSerialization connect(java.lang.String filename)

Connect to an existing DB

Parameters:

filename - The filename of the SQLite database data. If this file does not exist, a new DB is created in that file.

Returns:

A new SQLiteSerialization object, associated with the DB in the given filename

getLatestMessageOfType

public pt.lsts.imc.IMCMessage getLatestMessageOfType(int messageType)
                                              throws java.sql.SQLException

Fetch the last message of some type

Parameters:

messageType - The IMC type of the message to be returned

Returns:

the message of the given type with highest timestamp in the DB

Throws:

java.sql.SQLException

getLastMessageOfType

public pt.lsts.imc.IMCMessage getLastMessageOfType(java.lang.String messageAbbrev)
                                            throws java.sql.SQLException

Fetch the last message of some type

Parameters:

messageType - The abbreviated name of the message to be returned

Returns:

the message of the given type with highest timestamp in the DB

Throws:

java.sql.SQLException

getLastMessageOfType

public pt.lsts.imc.IMCMessage getLastMessageOfType(int messageType)
                                            throws java.sql.SQLException

Fetch the last message of some type

Parameters:

messageType - The IMC type of the message to be returned

Returns:

the message of the given type with highest timestamp in the DB

Throws:

java.sql.SQLException

store

public long store(pt.lsts.imc.IMCMessage msg)
           throws java.sql.SQLException

Stores the given message in the Database

Parameters:

msg - The message to be serialized onto the DB

Returns:

The row id of the Header associated with this message

Throws:

java.sql.SQLException

commit

protected void commit()
               throws java.sql.SQLException

Commit any uncommited transactions to the database

Throws:

java.sql.SQLException

getMessageInsertStatement

protected java.sql.PreparedStatement getMessageInsertStatement(int msgType)
                                                        throws java.sql.SQLException

Throws:

java.sql.SQLException

extractValue

public static java.lang.Object extractValue(java.lang.String imcType,
                                            java.lang.String column,
                                            java.sql.ResultSet rs)
                                     throws java.sql.SQLException

Throws:

java.sql.SQLException

storeHeader

protected long storeHeader(pt.lsts.imc.IMCMessage header)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

getConn

public java.sql.Connection getConn()

Returns:

the conn

getFilename

public java.lang.String getFilename()

Returns:

the filename

main

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

Throws:

java.sql.SQLException