org.syrup.sql
Class SQLStatements

java.lang.Object
  extended byorg.syrup.sql.Functions
      extended byorg.syrup.sql.SQLStatements
Direct Known Subclasses:
MySQLStatements

public class SQLStatements
extends Functions

Utility class that provides all the SQL statements needed for the creation, updating and deletion of Syrup objects.

Author:
Robbert van Dalen

Constructor Summary
SQLStatements(SQLImpl sqlImpl)
          Constructor for the SQLStatements object
 
Method Summary
 java.lang.String checkInLinkFullStatement()
          Returns select from_task task from link where to_task = ?
 java.lang.String checkIsExecutableTaskStatement()
          Returns select worker from task where key_ = ?
 java.lang.String checkOutLinkFullStatement()
          Returns select to_task task from link where from_task = ?
 java.lang.String checkWorkerStatement()
          Returns select worker from task where key_ = ?
 java.lang.String clearLinkTableStatement()
          Returns delete from link
 java.lang.String clearTaskTableStatement()
          Returns delete from task
 java.lang.String createExternalStatement()
          Returns insert into task(key_, parent_key, function_class, name, description, or_type, worker, executable, done, creation_time, modification_time, modifications, is_parent, environment) values('0', '0', '', 'external', 'External world representation', 1, '', 0, 0, 0, 0, 0, 0, '')
 java.lang.String createLauncherStatement()
          Returns insert into task(key_, parent_key, function_class, name, description, or_type, worker, executable, done, creation_time, modification_time, modifications, is_parent) values('1', '0', 'org.syrup.functions.Launch', 'root', 'This is the bootstrapping task', 1, '', 0, 0, 0, 0, 0, 0)
 java.lang.String createLink1Statement()
          Returns insert into link(from_task, from_port, to_task, to_port, data) values('1', 0, '2', 0, null)
 java.lang.String createLink2Statement()
          Returns insert into link(from_task, from_port, to_task, to_port, data) values('1', 1, '2', 1, null)
 java.lang.String createLink3Statement()
          Returns insert into link(from_task, from_port, to_task, to_port, data) values('2', 0, '1', 0, null)
 java.lang.String createLink4Statement()
          Returns insert into link(from_task, from_port, to_task, to_port, data) values('2', 1, '1', 1, null)
 java.lang.String createLinkTableStatement()
          Returns create table link(from_task varchar(255), from_port SMALLINT, to_task varchar(255), to_port SMALLINT, data BLOB)
 java.lang.String createLogTableStatement()
          Returns create table syrup_log(creation_time BIGINT not null, key_ varchar(255) not null, event INT not null, worker varchar(255) not null)
 java.lang.String createNewLinkStatement()
          Returns insert into link(from_task, from_port, to_task, to_port, data) values(?
 java.lang.String createNewLogEntryStatement()
          Returns insert into syrup_log(creation_time, key_, event, worker) values(?
 java.lang.String createNewTaskStatement()
          Returns insert into task(key, parent_key, name, function_class, or_type, description, parameter, environment, modifications, modification_time, creation_time, worker, executable, done, is_parent) values(?
 java.lang.String createTaskTableStatement()
          Returns create table task(key_ varchar(255) not null, parent_key varchar(255) not null, function_class varchar(255) not null, name varchar(255), description varchar(255), parameter varchar(255), environment varchar(255), or_type SMALLINT not null, worker varchar(255) not null, executable SMALLINT not null, done SMALLINT not null, creation_time BIGINT not null, modification_time BIGINT not null, modifications BIGINT not null, is_parent SMALLINT not null)
 java.lang.String dropLinkTableStatement()
          Returns Returns drop table link
 java.lang.String dropTaskTableStatement()
          Returns drop table task
 java.lang.String resetWorkerStatement()
          Returns update task set worker = '' where key_ = ?
 java.lang.String rewireInLinkStatement()
          Returns update link set to_task = ?
 java.lang.String rewireOutLinkStatement()
          Returns update link set from_task = ?
 java.lang.String selectDoneStatement()
          Returns select done from task where key_ = ?
 java.lang.String selectFromTaskStatement()
          Returns select from_task task from link where to_task=?
 java.lang.String selectInLinkStatement()
          Returns select from_task task, from_port port, data from link where to_task = ?
 java.lang.String selectInLinkTaskStatement()
          Returns select from_task task from link where to_task = ?
 java.lang.String selectLogEntriesStatement()
           
 java.lang.String selectOutLinkStatement()
          Returns select to_task task, to_port port, data from link where from_task = ?
 java.lang.String selectOutLinkTaskStatement()
          Returns select to_task task from link where from_task = ?
 java.lang.String selectTaskKeyStatement()
          Returns select key_ from task where key_ = ?
 java.lang.String selectTasksStatement()
          Returns select task.key_, task.parent_key, task.or_type, task.function_class, task.name, task.description, task.parameter, task.environment, task.done, task.creation_time, task.modification_time, task.modifications, task.worker, task.executable, task.is_parent from task
 java.lang.String selectTaskStatement()
          Returns select task.key_, task.parent_key, task.or_type, task.function_class, task.name, task.description, task.parameter, task.environment, task.done, task.creation_time, task.modification_time, task.modifications, task.worker, task.executable, task.is_parent from task where key_=?
 java.lang.String selectToTaskStatement()
          Returns select to_task task from link where from_task=?
 java.lang.String selectTypeStatement()
          Returns select or_type from task where key_ = ?
 java.lang.String updateDoneTaskStatement()
          Returns update task set done = 1 where key_ = ?
 java.lang.String updateExecutableTaskStatement()
          Returns update task set executable = ?
 java.lang.String updateInLinkStatement()
          Returns update link set data=?
 java.lang.String updateOutLinkStatement()
          Returns update link set data=?
 java.lang.String updateTaskModificationStatement()
          Returns update task set worker = '', modifications = modifications + 1, modification_time = ?
 java.lang.String updateWorkerStatement()
          Returns update task set worker = ?
 
Methods inherited from class org.syrup.sql.Functions
sqlImpl
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SQLStatements

public SQLStatements(SQLImpl sqlImpl)
Constructor for the SQLStatements object

Parameters:
sqlImpl - The SQLImpl that is held by the Function instance.
Method Detail

dropTaskTableStatement

public java.lang.String dropTaskTableStatement()
Returns drop table task


dropLinkTableStatement

public java.lang.String dropLinkTableStatement()
Returns Returns drop table link


clearTaskTableStatement

public java.lang.String clearTaskTableStatement()
Returns delete from task


clearLinkTableStatement

public java.lang.String clearLinkTableStatement()
Returns delete from link


createLauncherStatement

public java.lang.String createLauncherStatement()
Returns insert into task(key_, parent_key, function_class, name, description, or_type, worker, executable, done, creation_time, modification_time, modifications, is_parent) values('1', '0', 'org.syrup.functions.Launch', 'root', 'This is the bootstrapping task', 1, '', 0, 0, 0, 0, 0, 0)


createExternalStatement

public java.lang.String createExternalStatement()
Returns insert into task(key_, parent_key, function_class, name, description, or_type, worker, executable, done, creation_time, modification_time, modifications, is_parent, environment) values('0', '0', '', 'external', 'External world representation', 1, '', 0, 0, 0, 0, 0, 0, '')


createLink1Statement

public java.lang.String createLink1Statement()
Returns insert into link(from_task, from_port, to_task, to_port, data) values('1', 0, '2', 0, null)


createLink2Statement

public java.lang.String createLink2Statement()
Returns insert into link(from_task, from_port, to_task, to_port, data) values('1', 1, '2', 1, null)


createLink3Statement

public java.lang.String createLink3Statement()
Returns insert into link(from_task, from_port, to_task, to_port, data) values('2', 0, '1', 0, null)


createLink4Statement

public java.lang.String createLink4Statement()
Returns insert into link(from_task, from_port, to_task, to_port, data) values('2', 1, '1', 1, null)


createLogTableStatement

public java.lang.String createLogTableStatement()
Returns create table syrup_log(creation_time BIGINT not null, key_ varchar(255) not null, event INT not null, worker varchar(255) not null)


createTaskTableStatement

public java.lang.String createTaskTableStatement()
Returns create table task(key_ varchar(255) not null, parent_key varchar(255) not null, function_class varchar(255) not null, name varchar(255), description varchar(255), parameter varchar(255), environment varchar(255), or_type SMALLINT not null, worker varchar(255) not null, executable SMALLINT not null, done SMALLINT not null, creation_time BIGINT not null, modification_time BIGINT not null, modifications BIGINT not null, is_parent SMALLINT not null)


createLinkTableStatement

public java.lang.String createLinkTableStatement()
Returns create table link(from_task varchar(255), from_port SMALLINT, to_task varchar(255), to_port SMALLINT, data BLOB)


selectTasksStatement

public java.lang.String selectTasksStatement()
Returns select task.key_, task.parent_key, task.or_type, task.function_class, task.name, task.description, task.parameter, task.environment, task.done, task.creation_time, task.modification_time, task.modifications, task.worker, task.executable, task.is_parent from task


selectLogEntriesStatement

public java.lang.String selectLogEntriesStatement()

selectTaskStatement

public java.lang.String selectTaskStatement()
Returns select task.key_, task.parent_key, task.or_type, task.function_class, task.name, task.description, task.parameter, task.environment, task.done, task.creation_time, task.modification_time, task.modifications, task.worker, task.executable, task.is_parent from task where key_=?


selectInLinkTaskStatement

public java.lang.String selectInLinkTaskStatement()
Returns select from_task task from link where to_task = ? and to_port = ?


selectOutLinkTaskStatement

public java.lang.String selectOutLinkTaskStatement()
Returns select to_task task from link where from_task = ? and from_port = ?


selectInLinkStatement

public java.lang.String selectInLinkStatement()
Returns select from_task task, from_port port, data from link where to_task = ? and to_port = ?


selectOutLinkStatement

public java.lang.String selectOutLinkStatement()
Returns select to_task task, to_port port, data from link where from_task = ? and from_port = ?


checkInLinkFullStatement

public java.lang.String checkInLinkFullStatement()
Returns select from_task task from link where to_task = ? and to_port = ? and data is not null


checkOutLinkFullStatement

public java.lang.String checkOutLinkFullStatement()
Returns select to_task task from link where from_task = ? and from_port = ? and data is not null


selectTypeStatement

public java.lang.String selectTypeStatement()
Returns select or_type from task where key_ = ?


selectDoneStatement

public java.lang.String selectDoneStatement()
Returns select done from task where key_ = ?


selectTaskKeyStatement

public java.lang.String selectTaskKeyStatement()
Returns select key_ from task where key_ = ?


createNewTaskStatement

public java.lang.String createNewTaskStatement()
Returns insert into task(key, parent_key, name, function_class, or_type, description, parameter, environment, modifications, modification_time, creation_time, worker, executable, done, is_parent) values(?, ?, ?, ?, ?, ?, ?, 0, ?, ?, '', 0, 0, 0)


createNewLinkStatement

public java.lang.String createNewLinkStatement()
Returns insert into link(from_task, from_port, to_task, to_port, data) values(?, ?, ?, ?, ?)


rewireInLinkStatement

public java.lang.String rewireInLinkStatement()
Returns update link set to_task = ?, to_port=? where to_task = ? and to_port = ?


rewireOutLinkStatement

public java.lang.String rewireOutLinkStatement()
Returns update link set from_task = ?, from_port=? where from_task = ? and from_port = ?


checkIsExecutableTaskStatement

public java.lang.String checkIsExecutableTaskStatement()
Returns select worker from task where key_ = ? and worker = '' and executable = 1


updateWorkerStatement

public java.lang.String updateWorkerStatement()
Returns update task set worker = ? where key_ = ?


updateTaskModificationStatement

public java.lang.String updateTaskModificationStatement()
Returns update task set worker = '', modifications = modifications + 1, modification_time = ?, is_parent = ? where key_ = ?


checkWorkerStatement

public java.lang.String checkWorkerStatement()
Returns select worker from task where key_ = ? and worker != ''


resetWorkerStatement

public java.lang.String resetWorkerStatement()
Returns update task set worker = '' where key_ = ?


createNewLogEntryStatement

public java.lang.String createNewLogEntryStatement()
Returns insert into syrup_log(creation_time, key_, event, worker) values(?, ?, ?, ?)


updateOutLinkStatement

public java.lang.String updateOutLinkStatement()
Returns update link set data=? where from_task =? and from_port=?


updateInLinkStatement

public java.lang.String updateInLinkStatement()
Returns update link set data=? where to_task =? and to_port=?


selectFromTaskStatement

public java.lang.String selectFromTaskStatement()
Returns select from_task task from link where to_task=? and to_port=?


selectToTaskStatement

public java.lang.String selectToTaskStatement()
Returns select to_task task from link where from_task=? and from_port=?


updateDoneTaskStatement

public java.lang.String updateDoneTaskStatement()
Returns update task set done = 1 where key_ = ?


updateExecutableTaskStatement

public java.lang.String updateExecutableTaskStatement()
Returns update task set executable = ? where key_ = ?