initial upload

git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@459 20353a03-c40f-0410-a6d1-a30d3c3de9de

product/CMFActivity/skins/activity/SQLQueue_assignMessage.zsql

+<dtml-comment>
+title:
+connection_id:erp5_sql_connection
+max_rows:1
+max_cache:0
+cache_time:0
+class_name:
+class_file:
+</dtml-comment>
+<params>path
+processing_node
+method_id
+uid:int=0</params>
+UPDATE message_queue
+SET
+  processing_node=<dtml-sqlvar processing_node type="int">,
+  processing=0
+WHERE
+<dtml-if path> path = <dtml-sqlvar path type="string"> 
+<dtml-else> uid = <dtml-sqlvar uid type="int"> </dtml-if>
+<dtml-if method_id> AND method_id = <dtml-sqlvar method_id type="string"></dtml-if>

product/CMFActivity/skins/activity/SQLQueue_createMessageTable.zsql

+<dtml-comment>
+title:
+connection_id:erp5_sql_connection
+max_rows:1000
+max_cache:100
+cache_time:0
+class_name:
+class_file:
+</dtml-comment>
+<params></params>
+CREATE TABLE `message_queue` (
+  `uid` int(11) NOT NULL auto_increment,
+  `path` VARCHAR(255),
+  `method_id` VARCHAR(40),
+  `processing_node` INT DEFAULT -1,
+  `processing` INT DEFAULT 0,
+  `priority` INT DEFAULT 0,
+  `message` BLOB,
+  PRIMARY KEY  (`uid`),
+  KEY `path` (`path`),
+  KEY `method_id` (`method_id`),
+  KEY `processing_node` (`processing_node`),
+  KEY `processing` (`processing`),
+  KEY `priority` (`priority`),
+) TYPE = InnoDB;

product/CMFActivity/skins/activity/SQLQueue_delMessage.zsql

+<dtml-comment>
+title:
+connection_id:erp5_sql_connection
+max_rows:1000
+max_cache:100
+cache_time:0
+class_name:
+class_file:
+</dtml-comment>
+<params>uid</params>
+DELETE FROM
+  message_queue
+WHERE
+  uid = <dtml-sqlvar uid type="int">

product/CMFActivity/skins/activity/SQLQueue_hasMessage.zsql

+<dtml-comment>
+title:
+connection_id:erp5_sql_connection
+max_rows:1
+max_cache:100
+cache_time:1
+class_name:
+class_file:
+</dtml-comment>
+<params>path
+method_id</params>
+SELECT count(path) as message_count FROM
+  message_queue
+<dtml-if "path or method_id"> 
+WHERE
+<dtml-if path>  path = <dtml-sqlvar path type="string"></dtml-if>
+<dtml-if method_id>AND method_id = <dtml-sqlvar method_id type="string"></dtml-if>
+</dtml-if>
+  

product/CMFActivity/skins/activity/SQLQueue_processMessage.zsql

+<dtml-comment>
+title:
+connection_id:erp5_sql_connection
+max_rows:1
+max_cache:0
+cache_time:0
+class_name:
+class_file:
+</dtml-comment>
+<params>uid</params>
+UPDATE message_queue
+SET processing=1
+WHERE
+    uid = <dtml-sqlvar uid type="int">

product/CMFActivity/skins/activity/SQLQueue_readMessage.zsql

+<dtml-comment>
+title:
+connection_id:erp5_sql_connection
+max_rows:1
+max_cache:0
+cache_time:0
+class_name:
+class_file:
+</dtml-comment>
+<params>processing_node
+priority</params>
+SELECT * FROM
+    message_queue
+WHERE
+    processing <> 1
+<dtml-if processing_node> AND processing_node = <dtml-sqlvar processing_node type="int"></dtml-if>
+<dtml-if priority> AND priority = <dtml-sqlvar priority type="int"> </dtml-if>

product/CMFActivity/skins/activity/SQLQueue_readMessageList.zsql

+<dtml-comment>
+title:
+connection_id:erp5_sql_connection
+max_rows:1000
+max_cache:0
+cache_time:0
+class_name:
+class_file:
+</dtml-comment>
+<params>path
+method_id
+processing_node
+priority</params>
+SELECT * FROM
+    message_queue
+WHERE
+    processing <> 1
+<dtml-if processing_node>AND processing_node = <dtml-sqlvar processing_node type="int"> </dtml-if>
+<dtml-if priority>AND priority = <dtml-sqlvar priority type="int"> </dtml-if>
+<dtml-if path>AND path = <dtml-sqlvar path type="string"></dtml-if>
+<dtml-if method_id>AND method_id = <dtml-sqlvar method_id type="string"></dtml-if>

product/CMFActivity/skins/activity/SQLQueue_setPriority.zsql

+<dtml-comment>
+title:
+connection_id:erp5_sql_connection
+max_rows:1000
+max_cache:100
+cache_time:0
+class_name:
+class_file:
+</dtml-comment>
+<params>uid
+priority</params>
+UPDATE
+	message_queue
+SET
+	priority = <dtml-sqlvar priority type="int">,
+	processing = 0
+WHERE
+	uid = <dtml-sqlvar uid type="int">

product/CMFActivity/skins/activity/SQLQueue_writeMessage.zsql

+<dtml-comment>
+title:
+connection_id:erp5_sql_connection
+max_rows:1000
+max_cache:100
+cache_time:0
+class_name:
+class_file:
+</dtml-comment>
+<params>path
+method_id
+message
+priority</params>
+INSERT INTO message_queue
+SET
+	path = <dtml-sqlvar path type="string">,
+	method_id = <dtml-sqlvar method_id type="string">,
+	processing_node = -1,
+	processing = -1,
+	priority = <dtml-sqlvar priority type="int">,
+	message = <dtml-sqlvar message type="string">