Update of /cvsroot/monetdb/sql/src/sql
In directory 23jxhf1.ch3.sourceforge.com:/tmp/cvs-serv7949
Modified Files:
octopus.sql
Log Message:
Use triggers to propagate information from the catalog to scheduler.
U octopus.sql
Index: octopus.sql
===================================================================
RCS file: /cvsroot/monetdb/sql/src/sql/octopus.sql,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -d -r1.1 -r1.2
--- octopus.sql 9 Jan 2009 23:00:55 -0000 1.1
+++ octopus.sql 10 Jan 2009 09:19:46 -0000 1.2
@@ -14,22 +14,22 @@
-- Copyright August 2008-2009 MonetDB B.V.
-- All Rights Reserved.
--- The Octopus code base aims at Cloud based distribution of work
--- A SQL catalog table contains names and access attributes of workers
--- that can be used toe execute queries
+-- The Octopus code base aims at Cloud based distribution of work.
+-- A SQL catalog table contains names and access properties of workers
+-- that can be used to execute queries
-- The default 'merovingian' allows the optimizer to use merovigian
--- to discover and use every site in view.
+-- to discover and use every site in view using local credentials.
create table aquarium(
- connection string,
- host string,
- prt int,
+ connection string not null primary key,
+ host string not null,
+ prt int not null,
usr string,
pwd string
);
-- insert into octopusWorkers
values('merovingian','localhost',50000,'monetdb','monetdb');
--- inter the details of a new octopus acquarium
+-- enter the details of a new octopus acquarium
-- each call will update the list of platforms for execution.
create procedure newAquarium(nme string,
host string,
@@ -37,3 +37,11 @@
usr string,
pw string) external name sql.newAquarium;
create procedure dropAquarium(nme string) external name sql.dropAquarium;
+
+-- updates on these tables are propagated to the octopus scheduler.
+create trigger acquariumInsert
+ after insert on aquarium referencing new row as r
+ for each row call newAquarium(r.connection,r.host,r.prt,r.usr,r.pwd);
+create trigger octopusDelete
+ after insert on aquarium referencing old row as r
+ for each row call dropAquarium(r.connection);
------------------------------------------------------------------------------
Check out the new SourceForge.net Marketplace.
It is the best place to buy or sell services for
just about anything Open Source.
http://p.sf.net/sfu/Xq1LFB
_______________________________________________
Monetdb-sql-checkins mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/monetdb-sql-checkins
