Update of /cvsroot/monetdb/sql/src/backends/monet5
In directory 23jxhf1.ch3.sourceforge.com:/tmp/cvs-serv19578/backends/monet5
Modified Files:
sql.mx
Log Message:
Handles for the SQL octopus utilities
U sql.mx
Index: sql.mx
===================================================================
RCS file: /cvsroot/monetdb/sql/src/backends/monet5/sql.mx,v
retrieving revision 1.311
retrieving revision 1.312
diff -u -d -r1.311 -r1.312
--- sql.mx 8 Jan 2009 21:05:43 -0000 1.311
+++ sql.mx 9 Jan 2009 23:00:54 -0000 1.312
@@ -728,6 +728,14 @@
address SQLcluster2
comment "Cluster the columns of a table on the (first) primary key";
+pattern newAquarium(nme:str, host:str, port:int, usr:string, pw:string):void
+address SQLnewAquarium
+comment "Add a new site to the list of servers to consider in
+distributed processing";
+pattern dropAquarium(nme:stra):void
+address SQLdropAquarium
+comment "Remove a site from the list of servers";
+
command prelude()
address SQLprelude;
@@ -861,6 +869,8 @@
sql5_export str not_unique(bit *ret, int *bid);
sql5_export str not_unique_oids(bat *ret, bat *bid);
sql5_export str SQLcluster(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr
pci);
+sql5_export str SQLnewAquarium(Client cntxt, MalBlkPtr mb, MalStkPtr stk,
InstrPtr pci);
+sql5_export str SQLdropAquarium(Client cntxt, MalBlkPtr mb, MalStkPtr stk,
InstrPtr pci);
sql5_export str SQLargRecord(Client cntxt, MalBlkPtr mb, MalStkPtr stk,
InstrPtr pci);
sql5_export str month_interval_str( int *ret, str *s, int *ek, int *sk );
sql5_export str second_interval_str( lng *res, str *s, int *ek, int *sk );
@@ -1022,6 +1032,7 @@
#include <rel_bin.h>
#include <math.h>
#include <cluster.h>
+#include <run_octopus.h>
backend *
backend_reset(backend *b)
@@ -3997,3 +4008,18 @@
}
return MAL_SUCCEED;
}
+
+str SQLnewAquarium(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci)
+{
+ /* add the element to the SQL tables */
+ /* todo */
+ return OCTOPUSworker(cntxt,mb,stk,pci);
+}
+str SQLdropAquarium(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci)
+{
+ /* remove it from the SQL tables */
+ /* todo */
+ return OCTOPUSdrop(cntxt,mb,stk,pci);
+ return MAL_SUCCEED;
+}
+
------------------------------------------------------------------------------
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
