/home/gomez/Documents/workspaces/treqs/treqs/src/sql_statements.h File Reference

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Defines

#define STRING_SIZE   1024
#define SQL_GETJOBS   "SELECT id,user,hpss_file FROM requests WHERE status=?"
#define SQL_GETNEWJOBS   "SELECT id,user,hpss_file,tries FROM requests WHERE status=0"
#define SQL_NEW_REQUESTS   "UPDATE requests\ SET status=0 \ WHERE status BETWEEN 1 AND 3"
#define SQL_UPDATE_REQUEST_ID   "UPDATE requests\ SET status=?,\ message=?\ WHERE id=?"
#define SQL_UPDATE_FINAL_REQUEST_ID   "UPDATE requests\ SET status=?,\ errorcode=?,\ message=?,\ end_time=FROM_UNIXTIME(?)\ WHERE id=?"
#define SQL_UPDATE_REQUEST_SUBMITTED   "UPDATE requests\ SET status=?,\ message=?,\ queue_id=?,\ cartridge=?,\ position=?,\ cos=?,\ size=?,\ errorcode=0,\ submission_time=FROM_UNIXTIME(?) \ WHERE hpss_file=? AND end_time IS NULL"
#define SQL_UPDATE_REQUEST_RESUBMITTED   "UPDATE requests\ SET queued_time=NULL, \ queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL"
#define SQL_UPDATE_REQUEST_QUEUED   "UPDATE requests\ SET queued_time=FROM_UNIXTIME(?), \ queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL"
#define SQL_UPDATE_REQUEST_RETRY   "UPDATE requests\ SET queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL"
#define SQL_UPDATE_REQUEST_ENDED   "UPDATE requests\ SET end_time=FROM_UNIXTIME(?), \ queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL"
#define SQL_INSERT_QUEUE   "INSERT INTO queues\ (status,name,nbjobs,master_queue,owner, byte_size,creation_time)\ VALUES (?,?,?,?,?,?,FROM_UNIXTIME(?))"
#define SQL_UPDATE_QUEUE_ADD_REQUEST   "UPDATE queues\ SET nbjobs=?,\ owner=?,\ byte_size=?\ WHERE id=?"
#define SQL_UPDATE_QUEUE_ACTIVATED   "UPDATE queues\ SET activation_time=FROM_UNIXTIME(?),\ status=?,\ nbjobs=?,\ nbdone=?,\ nbfailed=?,\ owner=?,\ byte_size=?\ WHERE id=?"
#define SQL_UPDATE_QUEUE_ENDED   "UPDATE queues\ SET end_time=FROM_UNIXTIME(?),\ status=?,\ nbjobs=?,\ nbdone=?,\ nbfailed=?,\ owner=?,\ byte_size=?\ WHERE id=?"
#define SQL_UPDATE_QUEUE_UNSUSPENDED   "UPDATE queues\ SET activation_time=NULL,\ end_time=NULL,\ status=?,\ nbjobs=?,\ nbdone=?,\ nbfailed=?,\ owner=?,\ byte_size=?\ WHERE id=?"
#define SQL_UPDATE_QUEUES_ON_STARTUP   "UPDATE queues\ SET status=3,\ end_time=FROM_UNIXTIME(UNIX_TIMESTAMP())\ WHERE status<3"
#define SQL_SELECTMEDIA   "SELECT pvrname FROM mediatype WHERE ? LIKE volume_pattern"
#define SQL_SELECTPVRID   "SELECT pvrid FROM mediatype WHERE pvrname=?"
#define SQL_TABLE_JOBS_REQUESTS   "(\ `id` int(11) NOT NULL auto_increment,\ `email` varchar(128) default NULL,\ `user` varchar(32) default NULL,\ `hpss_file` varchar(256),\ `client` varchar(128),\ `creation_time` datetime default NULL,\ `expiration_time` mediumint(9) default NULL,\ `status` tinyint(4) default 0,\ `message` varchar(128) default NULL,\ `tries` int(11) default '0',\ `errorcode` int(11) default '0',\ `submission_time` datetime default NULL,\ `queued_time` datetime default NULL,\ `end_time` datetime default NULL,\ `cartridge` varchar(8) default '',\ `position` int(11) default '-1',\ `cos` int(11) default '-1',\ `size` bigint(20) unsigned default '0',\ `queue_id` int(11) default NULL,\ PRIMARY KEY (`id`,`hpss_file`)\)"
#define SQL_TABLE_JOBS_QUEUES   "(\ `id` int(11) NOT NULL auto_increment,\ `name` char(12) default NULL,\ `nbjobs` int(11) default 0,\ `nbdone` int(11) default 0,\ `nbfailed` int(11) default 0,\ `status` tinyint(1) default NULL,\ `master_queue` int(11) default NULL,\ `owner` char(20) default NULL,\ `creation_time` datetime default NULL,\ `activation_time` datetime default NULL,\ `end_time` datetime default NULL,\ `byte_size` bigint(20) default 0,\ PRIMARY KEY (`id`)\) "
#define SQL_CREATE_TABLE_CONF_MEDIATYPE   "CREATE TABLE `mediatype` (\ `pvrid` int(11) NOT NULL,\ `pvrname` char(20) default NULL,\ `drives` int(11) default NULL,\ `lock_time` mediumtext,\ `volume_pattern` char(20) default NULL,\ PRIMARY KEY (`pvrid`)\) "
#define SQL_CREATE_TABLE_CONF_USERS   "CREATE TABLE `allocation` (\ `user` varchar(32) default NULL,\ `pvrid` int(11) default NULL,\ `default_share` decimal(5,2) default NULL,\ `share` decimal(5,2) default NULL,\ `default_depth` int(11) default NULL,\ `depth` int(11) default NULL,\ `grp` varchar(10) default NULL,\ `expr` varchar(10) default NULL,\ `org` varchar(10) default NULL\)"
#define SQL_SELECT_ALLOCATIONS   "SELECT pvrid,user,default_share,share FROM allocation"
#define SQL_SELECT_DRIVES   "SELECT pvrid,drives FROM mediatype"

Define Documentation

#define SQL_CREATE_TABLE_CONF_MEDIATYPE   "CREATE TABLE `mediatype` (\ `pvrid` int(11) NOT NULL,\ `pvrname` char(20) default NULL,\ `drives` int(11) default NULL,\ `lock_time` mediumtext,\ `volume_pattern` char(20) default NULL,\ PRIMARY KEY (`pvrid`)\) "
#define SQL_CREATE_TABLE_CONF_USERS   "CREATE TABLE `allocation` (\ `user` varchar(32) default NULL,\ `pvrid` int(11) default NULL,\ `default_share` decimal(5,2) default NULL,\ `share` decimal(5,2) default NULL,\ `default_depth` int(11) default NULL,\ `depth` int(11) default NULL,\ `grp` varchar(10) default NULL,\ `expr` varchar(10) default NULL,\ `org` varchar(10) default NULL\)"
#define SQL_GETJOBS   "SELECT id,user,hpss_file FROM requests WHERE status=?"
#define SQL_GETNEWJOBS   "SELECT id,user,hpss_file,tries FROM requests WHERE status=0"
#define SQL_INSERT_QUEUE   "INSERT INTO queues\ (status,name,nbjobs,master_queue,owner, byte_size,creation_time)\ VALUES (?,?,?,?,?,?,FROM_UNIXTIME(?))"
#define SQL_NEW_REQUESTS   "UPDATE requests\ SET status=0 \ WHERE status BETWEEN 1 AND 3"
#define SQL_SELECT_ALLOCATIONS   "SELECT pvrid,user,default_share,share FROM allocation"
#define SQL_SELECT_DRIVES   "SELECT pvrid,drives FROM mediatype"
#define SQL_SELECTMEDIA   "SELECT pvrname FROM mediatype WHERE ? LIKE volume_pattern"
#define SQL_SELECTPVRID   "SELECT pvrid FROM mediatype WHERE pvrname=?"
#define SQL_TABLE_JOBS_QUEUES   "(\ `id` int(11) NOT NULL auto_increment,\ `name` char(12) default NULL,\ `nbjobs` int(11) default 0,\ `nbdone` int(11) default 0,\ `nbfailed` int(11) default 0,\ `status` tinyint(1) default NULL,\ `master_queue` int(11) default NULL,\ `owner` char(20) default NULL,\ `creation_time` datetime default NULL,\ `activation_time` datetime default NULL,\ `end_time` datetime default NULL,\ `byte_size` bigint(20) default 0,\ PRIMARY KEY (`id`)\) "
#define SQL_TABLE_JOBS_REQUESTS   "(\ `id` int(11) NOT NULL auto_increment,\ `email` varchar(128) default NULL,\ `user` varchar(32) default NULL,\ `hpss_file` varchar(256),\ `client` varchar(128),\ `creation_time` datetime default NULL,\ `expiration_time` mediumint(9) default NULL,\ `status` tinyint(4) default 0,\ `message` varchar(128) default NULL,\ `tries` int(11) default '0',\ `errorcode` int(11) default '0',\ `submission_time` datetime default NULL,\ `queued_time` datetime default NULL,\ `end_time` datetime default NULL,\ `cartridge` varchar(8) default '',\ `position` int(11) default '-1',\ `cos` int(11) default '-1',\ `size` bigint(20) unsigned default '0',\ `queue_id` int(11) default NULL,\ PRIMARY KEY (`id`,`hpss_file`)\)"
#define SQL_UPDATE_FINAL_REQUEST_ID   "UPDATE requests\ SET status=?,\ errorcode=?,\ message=?,\ end_time=FROM_UNIXTIME(?)\ WHERE id=?"
#define SQL_UPDATE_QUEUE_ACTIVATED   "UPDATE queues\ SET activation_time=FROM_UNIXTIME(?),\ status=?,\ nbjobs=?,\ nbdone=?,\ nbfailed=?,\ owner=?,\ byte_size=?\ WHERE id=?"
#define SQL_UPDATE_QUEUE_ADD_REQUEST   "UPDATE queues\ SET nbjobs=?,\ owner=?,\ byte_size=?\ WHERE id=?"
#define SQL_UPDATE_QUEUE_ENDED   "UPDATE queues\ SET end_time=FROM_UNIXTIME(?),\ status=?,\ nbjobs=?,\ nbdone=?,\ nbfailed=?,\ owner=?,\ byte_size=?\ WHERE id=?"
#define SQL_UPDATE_QUEUE_UNSUSPENDED   "UPDATE queues\ SET activation_time=NULL,\ end_time=NULL,\ status=?,\ nbjobs=?,\ nbdone=?,\ nbfailed=?,\ owner=?,\ byte_size=?\ WHERE id=?"
#define SQL_UPDATE_QUEUES_ON_STARTUP   "UPDATE queues\ SET status=3,\ end_time=FROM_UNIXTIME(UNIX_TIMESTAMP())\ WHERE status<3"
#define SQL_UPDATE_REQUEST_ENDED   "UPDATE requests\ SET end_time=FROM_UNIXTIME(?), \ queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL"
#define SQL_UPDATE_REQUEST_ID   "UPDATE requests\ SET status=?,\ message=?\ WHERE id=?"
#define SQL_UPDATE_REQUEST_QUEUED   "UPDATE requests\ SET queued_time=FROM_UNIXTIME(?), \ queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL"
#define SQL_UPDATE_REQUEST_RESUBMITTED   "UPDATE requests\ SET queued_time=NULL, \ queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL"
#define SQL_UPDATE_REQUEST_RETRY   "UPDATE requests\ SET queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL"
#define SQL_UPDATE_REQUEST_SUBMITTED   "UPDATE requests\ SET status=?,\ message=?,\ queue_id=?,\ cartridge=?,\ position=?,\ cos=?,\ size=?,\ errorcode=0,\ submission_time=FROM_UNIXTIME(?) \ WHERE hpss_file=? AND end_time IS NULL"
#define STRING_SIZE   1024

Generated on 4 Mar 2010 for TReqS by  doxygen 1.6.1