- developers-list - monetdb.org

Re: MonetDB: default - Get rid of Mx.
by Fabian Groffen 21 Nov '13

21 Nov '13

On 21-11-2013 12:54:34 +0100, Sjoerd Mullender wrote: > Changeset: f6606676fe5e for MonetDB > URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=f6606676fe5e > Branch: default > Log Message: > > Get rid of Mx. Hooray! Congratulations :) Fabian

1 0

Re: MonetDB: default - Prepare split of sql.mx
by Stefan Manegold 20 Nov '13

20 Nov '13

Martin, what's the (intended) difference between the newly added command mmath.rand{unsafe} (v:int) :int (see below) and the existing function mmath.rand{inline}( v:int ) :int; (see sql/backends/monet5/sql.mx line 1123) ? In particular, which of the two seemingly identical signatures will the MAL interpreter choose / use to evaluate, say, a:int:=mmath.rand(0:int); ? If they are identical / indistinguishable, one should be removed (again). Thanks, Stefan ps: Found by test clients/Tests/MAL-signatures ;-) ----- Original Message ----- > Changeset: 026d2c8bc8ee for MonetDB > URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=026d2c8bc8ee > Added Files: > sql/backends/monet5/sql.mal > sql/backends/monet5/sql_aggr_bte.mal > sql/backends/monet5/sql_aggr_flt.mal > sql/backends/monet5/sql_aggr_int.mal > sql/backends/monet5/sql_aggr_lng.mal > sql/backends/monet5/sql_aggr_sht.mal > sql/backends/monet5/sql_aggr_wrd.mal > sql/backends/monet5/sql_cast.mal > sql/backends/monet5/sql_inspect.mal > sql/backends/monet5/sql_octopus.mal > sql/backends/monet5/sql_rank.mal > sql/backends/monet5/sql_rdf.mal > sql/backends/monet5/sql_sort.mal > Modified Files: > monetdb5/modules/kernel/mmath.mal > sql/backends/monet5/Makefile.ag > Branch: default > Log Message: > > Prepare split of sql.mx > The first step in a dissection of the monster. > Splitting sql.mx into *mal and the rest > > times() has been removed. Also script 11_times > should be removed. > > sql_cast.mal calls for a shell script > whereafter we can finish the first step in > the dissection. > > > diffs (truncated from 1794 to 300 lines): > > diff --git a/monetdb5/modules/kernel/mmath.mal > b/monetdb5/modules/kernel/mmath.mal > --- a/monetdb5/modules/kernel/mmath.mal > +++ b/monetdb5/modules/kernel/mmath.mal > @@ -182,6 +182,10 @@ command rand{unsafe} () :int > address MATHrandint > comment "return a random number"; > > +command rand{unsafe} (v:int) :int > +address MATHrandint > +comment "return a random number"; > + > command srand(seed:int) :void > address MATHsrandint > comment "initialize the rand() function with a seed"; > diff --git a/sql/backends/monet5/Makefile.ag > b/sql/backends/monet5/Makefile.ag > --- a/sql/backends/monet5/Makefile.ag > +++ b/sql/backends/monet5/Makefile.ag > @@ -96,7 +96,7 @@ lib__sql = { > headers_mal = { > HEADERS = mal > DIR = libdir/monetdb5 > - SOURCES = sql.mx > + SOURCES = sql.mx sql_aggr_bte.mal sql_aggr_flt.mal sql_aggr_int.mal > sql_aggr_lng.mal sql_aggr_sht.mal sql_aggr_wrd.mal sql_cast.mal > sql_inspect.mal sql.mal sql_octopus.mal sql_rank.mal sql_rdf.mal > sql_sort.mal > } > > headers_autoload = { > diff --git a/sql/backends/monet5/sql.mal b/sql/backends/monet5/sql.mal > new file mode 100644 > --- /dev/null > +++ b/sql/backends/monet5/sql.mal > @@ -0,0 +1,1055 @@ > +# The contents of this file are subject to the MonetDB Public License > +# Version 1.1 (the "License"); you may not use this file except in > +# compliance with the License. You may obtain a copy of the License at > +# http://www.monetdb.org/Legal/MonetDBLicense > +# > +# Software distributed under the License is distributed on an "AS IS" > +# basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the > +# License for the specific language governing rights and limitations > +# under the License. > +# > +# The Original Code is the MonetDB Database System. > +# > +# The Initial Developer of the Original Code is CWI. > +# Portions created by CWI are Copyright (C) 1997-July 2008 CWI. > +# Copyright August 2008-2013 MonetDB B.V. > +# All Rights Reserved. > + > + > +module batsql; > +module sql; > + > +pattern start():void > +address SQLsession > +comment "Switch to processing SQL statements"; > + > +pattern start2():void > +address SQLsession2 > +comment "Switch to processing precompiled sql statements"; > + > +pattern init():void > +address SQLinitEnvironment > +comment "Initialize the environment for MAL"; > + > +pattern shutdown(delay:bte, force:bit):str > +address SQLshutdown_wrap; > +pattern shutdown(delay:sht, force:bit):str > +address SQLshutdown_wrap; > +pattern shutdown(delay:int, force:bit):str > +address SQLshutdown_wrap; > + > +pattern shutdown(delay:bte):str > +address SQLshutdown_wrap; > +pattern shutdown(delay:sht):str > +address SQLshutdown_wrap; > +pattern shutdown(delay:int):str > +address SQLshutdown_wrap; > + > +pattern mvc():int > +address SQLmvc > +comment "Get the multiversion catalog context. > +Needed for correct statement dependencies > +(ie sql.update, should be after sql.bind in concurrent execution)"; > + > +pattern trans(type:int,chain:int,name:str):void > +address SQLtransaction > +comment "A transaction statement (type can be commit,release,rollback or > start)"; > + > +pattern transaction{unsafe}() > +address SQLtransaction2 > +comment "Start an autocommit transaction"; > + > +pattern commit() > +address SQLcommit > +comment "Trigger the commit operation for a MAL block"; > + > +pattern abort() > +address SQLabort > +comment "Trigger the abort operation for a MAL block"; > + > +pattern catalog(type:int,sname:str,name:str,action:int):void > +address SQLcatalog; > +pattern > catalog(type:int,sname:str,name:str,funcid:int,ft:int,action:int):void > +address SQLcatalog; > +pattern > catalog(type:int,sname:str,name:str,tname:str,time:int,o:int,event:int,oname:str,nname:str,condition:str,query:str):void > +address SQLcatalog; > +pattern catalog(type:int,sname:str,t:ptr):void > +address SQLcatalog; > +pattern catalog(type:int,sname:str,t:ptr,temp:int):void > +address SQLcatalog; > +pattern catalog(type:int,sname:str,t:ptr,restart:lng):void > +address SQLcatalog > +comment "a catalog statement"; > + > +pattern catalog(type:int,grantee:str,role:str):void > +address SQLcatalog > +comment "a grant/revoke role statement"; > + > +pattern > catalog(type:int,user:str,passwd:str,enc:int,schema:str,fullname:str):void > +address SQLcatalog > +comment "a user catalog statement"; > + > +pattern > catalog(type:int,sname:str,tname:str,grantee:str,privs:int,cname:str,grant:int,grantor:int):void > +address SQLcatalog > +comment "a grant/revoke privileges statement"; > + > +pattern catalog(type:int,iname:str,itype:int,sname:str,tname:str...):void > +address SQLcatalog > +comment "a create index catalog statement"; > + > +pattern eval(cmd:str):void > +address SQLstatement; > +pattern eval(cmd:str, output:bit):void > +address SQLstatement > +comment "Compile and execute a single sql statement (and optionaly send > output on the output stream)"; > + > +pattern include(fname:str):void > +address SQLinclude > +comment "Compile and execute a sql statements on the file"; > + > +pattern evalAlgebra(cmd:str, optimize:bit):void > +address RAstatement > +comment "Compile and execute a single 'relational algebra' statement"; > + > +pattern assert(b:bit,msg:str):void > +address SQLassert; > +pattern assert(b:int,msg:str):void > +address SQLassertInt; > +pattern assert(b:wrd,msg:str):void > +address SQLassertWrd; > +pattern assert(b:lng,msg:str):void > +address SQLassertLng > +comment "Generate an exception when b!=0"; > + > +pattern setVariable(mvc:int, varname:str, value:any_1 ):int > +address setVariable > +comment "Set the value of a session variable"; > + > +pattern getVariable(mvc:int, varname:str ):any_1 > +address getVariable > +comment "Get the value of a session variable"; > + > +pattern logfile{unsafe}(filename:str):void > +address mvc_logfile > +comment "Enable/disable saving the sql statement traces"; > + > +pattern next_value( sname:str, sequence:str ):lng > +address mvc_next_value > +comment "return the next value of the sequence"; > + > +pattern batsql.next_value( sname:bat[:oid,:str], sequence:str ) > :bat[:oid,:lng] > +address mvc_bat_next_value > +comment "return the next value of the sequence"; > + > +pattern get_value( sname:str, sequence:str ):lng > +address mvc_get_value > +comment "return the current value of the sequence"; > + > +pattern restart{unsafe}( sname:str, sequence:str, start:lng ):lng > +address mvc_restart_seq > +comment "restart the sequence with value start"; > + > +pattern bind_idxbat(mvc:int, schema:str, table:str, index:str, > access:int):bat[:oid,:any_1] > +address mvc_bind_idxbat_wrap > +comment "Bind the 'schema.table.index' BAT with access kind: > + 0 - base table > + 1 - inserts > + 2 - updates"; > + > +pattern bind_idxbat(mvc:int, schema:str, table:str, index:str, > access:int)(uid:bat[:oid,:oid],uval:bat[:oid,:any_1]) > +address mvc_bind_idxbat_wrap > +comment "Bind the 'schema.table.index' BAT with access kind: > + 0 - base table > + 1 - inserts > + 2 - updates"; > + > +pattern bind_idxbat(mvc:int, schema:str, table:str, index:str, access:int, > part_nr:int, nr_parts:int):bat[:oid,:any_1] > +address mvc_bind_idxbat_wrap > +comment "Bind the 'schema.table.index' BAT with access kind: > + 0 - base table > + 1 - inserts > + 2 - updates"; > + > +pattern bind_idxbat(mvc:int, schema:str, table:str, index:str, access:int, > part_nr:int, nr_parts:int)(uid:bat[:oid,:oid],uval:bat[:oid,:any_1]) > +address mvc_bind_idxbat_wrap > +comment "Bind the 'schema.table.index' BAT with access kind: > + 0 - base table > + 1 - inserts > + 2 - updates"; > + > +pattern bind(mvc:int, schema:str, table:str, column:str, access:int > ):bat[:oid,:any_1] > +address mvc_bind_wrap > +comment "Bind the 'schema.table.column' BAT with access kind: > + 0 - base table > + 1 - inserts > + 2 - updates"; > + > +pattern bind(mvc:int, schema:str, table:str, column:str, access:int > )(uid:bat[:oid,:oid],uval:bat[:oid,:any_1]) > +address mvc_bind_wrap > +comment "Bind the 'schema.table.column' BAT with access kind: > + 0 - base table > + 1 - inserts > + 2 - updates"; > + > +pattern bind(mvc:int, schema:str, table:str, column:str, access:int, > part_nr:int, nr_parts:int ):bat[:oid,:any_1] > +address mvc_bind_wrap > +comment "Bind the 'schema.table.column' BAT partition with access kind: > + 0 - base table > + 1 - inserts > + 2 - updates"; > + > +pattern bind(mvc:int, schema:str, table:str, column:str, access:int, > part_nr:int, nr_parts:int )(uid:bat[:oid,:oid],uval:bat[:oid,:any_1]) > +address mvc_bind_wrap > +comment "Bind the 'schema.table.column' BAT with access kind: > + 0 - base table > + 1 - inserts > + 2 - updates"; > + > +command delta ( col:bat[:oid,:any_3], uid:bat[:oid,:oid], > uval:bat[:oid,:any_3], ins:bat[:oid,:any_3] ) > + :bat[:oid,:any_3] > +address DELTAbat > +comment "Return column bat with delta's applied."; > + > +command projectdelta( subselect:bat[:oid,:oid], col:bat[:oid,:any_3], > uid:bat[:oid,:oid], uval:bat[:oid,:any_3], ins:bat[:oid,:any_3] ) > :bat[:oid,:any_3] > +address DELTAproject > +comment "Return column bat with delta's applied."; > + > +command subdelta ( col:bat[:oid,:oid], cand:bat[:oid,:oid], > uid:bat[:oid,:oid], uval:bat[:oid,:oid], ins:bat[:oid,:oid] ) > :bat[:oid,:oid] > +address DELTAsub > +comment "Return a single bat of subselected delta."; > + > +command delta ( col:bat[:oid,:any_3], uid:bat[:oid,:oid], > uval:bat[:oid,:any_3]) :bat[:oid,:any_3] > +address DELTAbat2 > +comment "Return column bat with delta's applied."; > + > +command projectdelta( subselect:bat[:oid,:oid], col:bat[:oid,:any_3], > uid:bat[:oid,:oid], uval:bat[:oid,:any_3]) :bat[:oid,:any_3] > +address DELTAproject2 > +comment "Return column bat with delta's applied."; > + > +command subdelta ( col:bat[:oid,:oid], cand:bat[:oid,:oid], > uid:bat[:oid,:oid], uval:bat[:oid,:oid]) :bat[:oid,:oid] > +address DELTAsub2 > +comment "Return a single bat of subselected delta."; > + > +command getVersion(clientid:int):lng > +address mvc_getVersion > +comment "Return the database version identifier for a client"; > + > +pattern append(mvc:int, sname:str, tname:str, cname:str, ins:any):int > +address mvc_append_wrap > +comment "Append b to the column tname.cname (possibly optimized to replace > the insert bat of tname.cname (returns sequence number for order > dependence)"; > + > +pattern update(mvc:int, sname:str, tname:str, cname:str, rids:any, > upd:any):int > +address mvc_update_wrap > +comment "Update the values of the column tname.cname"; > + > +pattern clear_table{unsafe}(sname:str, tname:str) :wrd > +address mvc_clear_table_wrap > +comment "Clear table"; > + > +pattern tid( mvc:int, sname:str, tname:str):bat[:oid,:any_3] > +address SQLtid; > +pattern tid( mvc:int, sname:str, tname:str, part_nr:int, nr_parts:int > ):bat[:oid,:any_3] > +address SQLtid > +comment "Return the tables tid column."; > + > +pattern delete{unsafe}(mvc:int, sname:str, tname:str, b:any):int > +address mvc_delete_wrap > +comment "delete from table"; > + > +pattern resultSet{unsafe}( nr_cols:int, sep:str, rsep:str, ssep:str, ns:str, > order:any_1 ) :int > +address mvc_result_file_wrap; > +pattern resultSet{unsafe}( nr_cols:int, sep:str, rsep:str, ssep:str, ns:str, > order:bat[:oid,:any_1] ) :int > +address mvc_result_file_wrap; > +pattern resultSet{unsafe}( nr_cols:int, qtype:int, order:any_1 ) :int > +address mvc_result_row_wrap; > +pattern resultSet{unsafe}( nr_cols:int, qtype:int, order:bat[:oid,:any_1] ) > :int > +address mvc_result_table_wrap; > +pattern rsColumn{unsafe}(rs:int, tname:str, name:str, typename:str, > digits:int, scale:int, val:any_1 ) :void > +address mvc_result_value_wrap > +comment "Add the value to the row query result"; > _______________________________________________ > checkin-list mailing list > checkin-list(a)monetdb.org > https://www.monetdb.org/mailman/listinfo/checkin-list > -- | Stefan.Manegold(a)CWI.nl | DB Architectures (DA) | | www.CWI.nl/~manegold/ | Science Park 123 (L321) | | +31 (0)20 592-4212 | 1098 XG Amsterdam (NL) |

1 0

Default branch does not compile for builds with --enable_oid32
by Max Heimel 17 Nov '13

17 Nov '13

Hi, I stumbled upon a build error in the latest source from the default branch when I configure with --enable_oid32. The fix is a missing curly brace in the HASHputall macro at gdk/gdk_search.h:110.

2 1

Re: MonetDB: holindex - Comment lines that use papi in order to meas...
by Stefan Manegold 13 Nov '13

13 Nov '13

Eleni, this calls for a proper configure check and conditionals to reduce/eliminate (extra) code maintenance overhead ;-) Feel free to ask in case you need more detailed pointers ... Stefan ----- Original Message ----- > Changeset: da0067120542 for MonetDB > URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=da0067120542 > Modified Files: > monetdb5/extras/crackers/crackers_selectholpl_ops.mx > Branch: holindex > Log Message: > > Comment lines that use papi in order to measure hardware events. > > > diffs (59 lines): > > diff --git a/monetdb5/extras/crackers/crackers_selectholpl_ops.mx > b/monetdb5/extras/crackers/crackers_selectholpl_ops.mx > --- a/monetdb5/extras/crackers/crackers_selectholpl_ops.mx > +++ b/monetdb5/extras/crackers/crackers_selectholpl_ops.mx > @@ -77,6 +77,7 @@ crackers_export str CRKrandomholpl_@1(in > */ > #include "monetdb_config.h" > #include "crackers.h" > +//#include <papi.h> > > /* Local support functions and macros */ > @:TypeSwitch(crackOperations)@ > @@ -384,7 +385,7 @@ CRKrandomholpl_@1(int *bid, bit *inclusi > FN->c = FN->c + incr_pieces; > if(FN->weight > 0) > FN->weight = changeWeight(FN,countBatElements,L1); > - fprintf(ofp,"Idle_Query \t 0 \t Bat_id= \t %d \t Pieces= \t %d \t > Wait_time\t %9.6lf \t Selection_time\t %9.6lf \t Low= \t %d \t Thread_id= > \t" SZFMT "\n",FN->bid,FN->c,wt,ct,(int)*low,MT_getpid()); > + fprintf(ofp,"Idle_Query \t 0 \t Bat_id= \t %d \t Pieces= \t %d \t > Wait_time\t %9.6lf \t Selection_time\t %9.6lf \t Thread_id= \t" SZFMT > "\n",FN->bid,FN->c,wt,ct,MT_getpid()); > fclose(ofp); > MT_lock_unset(&frequencylock, "getFrequencyStruct"); > > @@ -1371,6 +1372,12 @@ CRKRangeLeftNilTree_@1(int *vid, int *bi > FrequencyNode *FrequencyStructA = getFrequencyStruct('A'); > FILE *ofp; > char *outputFilename1; > + //long long counters[2]; > + //int PAPI_events[] = { > + // PAPI_L2_DCA, > + // PAPI_L2_DCM}; > + > + //PAPI_start_counters(PAPI_events, 2); > > gettimeofday(&tv0,0); > > @@ -1444,8 +1451,10 @@ CRKRangeLeftNilTree_@1(int *vid, int *bi > FN->c = FN->c + incr_pieces; > FN->weight = changeWeight(FN,countBatElements,L1); > gettimeofday(&tv1,0); ct+=dt(tv0,tv1); tv0=tv1; > - fprintf(ofp,"User_Query \t 0 \t Bat_id= \t %d \t Pieces= \t %d \t > Wait_time\t %9.6lf \t Selection_time\t %9.6lf \t Hgh= \t %d \t Thread_id= > \t" SZFMT "\n",FN->bid,FN->c,wt,ct,(int)*hgh,MT_getpid()); > -+ fclose(ofp); > + //PAPI_read_counters(counters, 2); > + //fprintf(ofp,"User_Query \t 0 \t Bat_id= \t %d \t Pieces= \t %d \t > Wait_time\t %9.6lf \t Selection_time\t %9.6lf \t Thread_id= \t" SZFMT "\t > L2_DCA= \t %lld \t L2_DCM \t > %lld\n",FN->bid,FN->c,wt,ct,MT_getpid(),counters[0],counters[1]); > + fprintf(ofp,"User_Query \t 0 \t Bat_id= \t %d \t Pieces= \t %d \t > Wait_time\t %9.6lf \t Selection_time\t %9.6lf \t Thread_id= \t" SZFMT > "\n",FN->bid,FN->c,wt,ct,MT_getpid()); > + fclose(ofp); > MT_lock_unset(&frequencylock, "getFrequencyStruct"); > > BBPincref(b->batCacheid,TRUE); > @@ -1552,8 +1561,10 @@ CRKRangeLeftNilTree_@1(int *vid, int *bi > if(FN->weight > 0) > FN->weight = changeWeight(FN,countBatElements,L1); > gettimeofday(&tv1,0); ct+=dt(tv0,tv1); tv0=tv1; > - fprintf(ofp,"User_Query \t 0 \t Bat_id= \t %d \t Pieces= \t %d \t > Wait_time\t %9.6lf \t Selection_time\t %9.6lf \t Hgh= \t %d \t Thread_id= > \t" SZFMT "\n",FN->bid,FN->c,wt,ct,(int)*hgh,MT_getpid()); > -+ fclose(ofp); > + //PAPI_read_counters(counters, 2); > + //fprintf(ofp,"User_Query \t 0 \t Bat_id= \t %d \t Pieces= \t %d \t > Wait_time\t %9.6lf \t Selection_time\t %9.6lf \t Thread_id= \t" SZFMT "\t > L2_DCA \t %lld \t L2_DCM= \t %lld > \n",FN->bid,FN->c,wt,ct,MT_getpid(),counters[0],counters[1]); > + fprintf(ofp,"User_Query \t 0 \t Bat_id= \t %d \t Pieces= \t %d \t > Wait_time\t %9.6lf \t Selection_time\t %9.6lf \t Thread_id= \t" SZFMT > "\n",FN->bid,FN->c,wt,ct,MT_getpid()); > + fclose(ofp); > MT_lock_unset(&frequencylock, "getFrequencyStruct"); > > > _______________________________________________ > checkin-list mailing list > checkin-list(a)monetdb.org > https://www.monetdb.org/mailman/listinfo/checkin-list > -- | Stefan.Manegold(a)CWI.nl | DB Architectures (DA) | | www.CWI.nl/~manegold/ | Science Park 123 (L321) | | +31 (0)20 592-4212 | 1098 XG Amsterdam (NL) |

2 1

Re: MonetDB: default - handle added types also in declared tables
by Sjoerd Mullender 11 Nov '13

11 Nov '13

Is this the fix for bug 3394 that you just closed? If so, was this really intended for the default branch (in which case the bug should be NEXTFEATURERELEASE) or should this have gone to the Feb2013 branch? On 2013-11-11 22:14, Niels Nes wrote: > Changeset: 63c54046f8c4 for MonetDB > URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=63c54046f8c4 > Modified Files: > sql/backends/monet5/sql.mx > sql/test/BugTracker-2013/Tests/Cannot_Find_Column_Type.Bug-3394.sql > Branch: default > Log Message: > > handle added types also in declared tables > > > diffs (43 lines): > > diff --git a/sql/backends/monet5/sql.mx b/sql/backends/monet5/sql.mx > --- a/sql/backends/monet5/sql.mx > +++ b/sql/backends/monet5/sql.mx > @@ -3993,12 +3993,13 @@ mvc_declared_table_column_wrap(Client cn > str msg = getSQLContext(cntxt,mb, &m, NULL); > sql_schema *s = NULL; > sql_table *t = NULL; > + sql_type *type = NULL; > sql_subtype tpe; > int *ret = (int *) getArgReference(stk, pci, 0); > int *rs = (int *) getArgReference(stk, pci, 1); > str *tname = (str *) getArgReference(stk, pci, 2); > str *name = (str *) getArgReference(stk, pci, 3); > - str *type = (str *) getArgReference(stk, pci, 4); > + str *typename = (str *) getArgReference(stk, pci, 4); > int *digits = (int *) getArgReference(stk, pci, 5); > int *scale = (int *) getArgReference(stk, pci, 6); > > @@ -4006,8 +4007,11 @@ mvc_declared_table_column_wrap(Client cn > return msg; > if (*rs != 0) > throw(SQL, "sql.dtColumn", "Cannot access declared table"); > - if (!sql_find_subtype(&tpe, *type, *digits, *scale)) > + if (!sql_find_subtype(&tpe, *typename, *digits, *scale) && > + (type = mvc_bind_type(m, *typename)) == NULL) > throw(SQL, "sql.dtColumn", "Cannot find column type"); > + if (type) > + sql_init_subtype(&tpe, type, 0, 0); > s = mvc_bind_schema(m, dt_schema); > if ( s == NULL) > throw(SQL,"sql.declared_table_column","3F000!Schema missing"); > diff --git a/sql/test/BugTracker-2013/Tests/Cannot_Find_Column_Type.Bug-3394.sql b/sql/test/BugTracker-2013/Tests/Cannot_Find_Column_Type.Bug-3394.sql > --- a/sql/test/BugTracker-2013/Tests/Cannot_Find_Column_Type.Bug-3394.sql > +++ b/sql/test/BugTracker-2013/Tests/Cannot_Find_Column_Type.Bug-3394.sql > @@ -45,3 +45,8 @@ begin > end; > > select tmp4(); > + > +drop function tmp4; > +drop function tmp3; > +drop function tmp2; > +drop function tmp1; > _______________________________________________ > checkin-list mailing list > checkin-list(a)monetdb.org > https://www.monetdb.org/mailman/listinfo/checkin-list > -- Sjoerd Mullender

1 0

How do I get SQL decimal scale in MAL?
by Dru Nelson 11 Nov '13

11 Nov '13

HI, I"m working on writing an aggregate in in C that is a MAL function. I've run into a problem with decimal types. I've noticed that when I inspect the BAT inputs for various types, they are coerced to simpler types. (flt,dbl -> dbl). (int, decimal -> int). There is also no other information in the BAT structure to see the type. I notice that a SQL select gets the type info passed in as parameters for the 'exportValue' output. For example: >* sql.exportValue(1,".","second_single_value","decimal",9,3,8,_4,""); * How can I get this type information ('decimal', etc.) passed into my function? Dru

3 9

about "MT" in gdk module
by 张磊 06 Nov '13

06 Nov '13

hi all, I found that in gdk module of monetdb, the file gdk_posix.c has many functions which begin with “MT”, and I want to ask that what's "MT", is that "MoneT", "Multiple Thread" or others? what's the meaning of "MT"? :) -- Best Wishes! zhanglei

2 1

Monetdb ODBC datatype conversion problem
by baraa Mohamad 01 Nov '13

01 Nov '13

Dear MonetDB users, I have created a database link from oracle to monetdb using Monetdb ODBC driver, the link works fine but i have a strange results 😓 I have the following configurations: host1: Oracle (ubuntu 64bit)host2: MonetDB (ubntu 64bit)ODBC driver: MonetDB odbc (64bit) using unixODBC driver manager on monetdb i have the following table: emp (id integer , name varchar); test query: select id from emp where id<20; when I execute this query directly on montdb I get the following results (IDs from 1 to 19)ID123..19 BUT when I execute this query from oracle using dblink select "id" from "emp"@monetdb where "id"<20 ; I GET THE FOLLOWING RESULTS: ID-------- 18589934592 21.2885E+10 31.7180E+10 42.1475E+10 52.5770E+10 63.0065E+10 73.4360E+10 83.8655E+10 94.2950E+10 10 I cannot figure out the cause of the problem and how I can solve it (it seems a problem related to datatype conversion using ODBC) Could you please tell me what I should do.... Best regards,Baraa

1 0

Re: MonetDB: newstorage - pushing changes from laptop
by Lefteris 30 Oct '13

30 Oct '13

what is interesting is not from where you are pushing the changes but what the changes do:)) On Wed, Oct 30, 2013 at 10:30 AM, Rene Tassy <commits(a)monetdb.org> wrote: > Changeset: fb471128db99 for MonetDB > URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=fb471128db99 > Modified Files: > sql/storage/bat/bat_storage.c > Branch: newstorage > Log Message: > > pushing changes from laptop > > > diffs (144 lines): > > diff --git a/sql/storage/bat/bat_storage.c b/sql/storage/bat/bat_storage.c > --- a/sql/storage/bat/bat_storage.c > +++ b/sql/storage/bat/bat_storage.c > @@ -41,6 +41,14 @@ timestamp_dbat( sql_dbat *d, int ts) > return d; > } > > +/**static sql_timestamps * > +timestamp_tsbats(sql_timestamps *ts, int timestamp) { > + > + while (ts->next && ts->wtime > timestamp) > + ts = ts->next; > + return ts; > +}*/ > + > > static BAT * > delta_bind_del(sql_dbat *bat, int access) > @@ -1222,16 +1230,6 @@ load_timestamps(sql_timestamps *ts, int > } > > static int > -load_dbat(sql_dbat *bat, int bid) { > - > - BAT *b = quick_descriptor(bid); > - > - bat->dbid = temp_create(b); > - bat->cnt = BATcount(b); > - return LOG_OK; > -} > - > -static int > create_timestamps(sql_trans *tr, sql_table *t) { > > int ok = LOG_OK; > @@ -1275,6 +1273,16 @@ create_timestamps(sql_trans *tr, sql_tab > } > > static int > +load_dbat(sql_dbat *bat, int bid) { > + > + BAT *b = quick_descriptor(bid); > + > + bat->dbid = temp_create(b); > + bat->cnt = BATcount(b); > + return LOG_OK; > +} > + > +static int > create_del(sql_trans *tr, sql_table *t) > { > int ok = LOG_OK; > @@ -1369,8 +1377,7 @@ static int > snapshot_create_del(sql_trans *tr, sql_table *t) > { > sql_dbat *bat = t->data; > - BAT *b = temp_descriptor(bat->dbid); > - //BAT *trdb = temp_descriptor(bat->dtrbid); > + BAT *b = temp_descriptor(bat->dbid);; > > printf("in snapshot_create_del\n"); > > @@ -1383,13 +1390,6 @@ snapshot_create_del(sql_trans *tr, sql_t > BATmmap(b, STORE_MMAP, STORE_MMAP, STORE_MMAP, STORE_MMAP, 0); > bat_destroy(b); > > - /*bat_set_access(trdb, BAT_READ); > - if (BATcount(trdb) > SNAPSHOT_MINSIZE) > - BATmode(trdb, PERSISTENT); > - if (BATcount(trdb) > (BUN) REMAP_PAGE_MAXSIZE) > - BATmmap(trdb, STORE_MMAP, STORE_MMAP, STORE_MMAP, STORE_MMAP, 0); > - bat_destroy(trdb);*/ > - > return LOG_OK; > } > > @@ -1539,16 +1539,12 @@ destroy_dbat(sql_trans *tr, sql_dbat *ba > > if (bat->dname) > _DELETE(bat->dname); > - //if (bat->dtrname) > - //_DELETE(bat->dtrname); > + > if (bat->dbid) > temp_destroy(bat->dbid); > - //if (bat->dtrbid) > - //temp_destroy(bat->dtrbid); > + > bat->dbid = 0; > bat->dname = NULL; > - //bat->dtrbid = 0; > - //bat->dtrname = NULL; > _DELETE(bat); > if (n) > return destroy_dbat(tr, n); > @@ -1798,20 +1794,39 @@ clear_dbat(sql_trans *tr, sql_dbat *bat) > BATcommit(b); > bat_destroy(b); > } > - /*if(bat->dtrbid) { > - BAT *b = temp_descriptor(bat->dtrbid); > - > - sz+= BATcount(b); > - bat_clear(b); > - BATcommit(b); > - bat_destroy(b); > - }*/ > + > bat->cnt = 0; > bat->wtime = tr->wstime; > > return sz; > } > - > +/** > +static BUN > +clear_tsbats(sql_trans *tr, sql_timestamps *ts) { > + > + BUN sz =0; > + > + (void)tr; > + if(ts->insbid) { > + BAT *b = temp_descriptor(ts->insbid); > + > + sz += BATcount(b) > + } > +} > + > +static BUN > +clear_timestamps(sql_trans *tr, sql_table *t) { > + > + if(!t->timestamps || !t->base.allocated) { > + sql_table *ot = tr_find_table(tr->parent, t); > + sql_timestamps *ts = t->timestamps = ZNEW(sql_timestamps), *ots = timestamp_tsbats(ots->timestamps, tr->stime); > + dup_tsbats(tr, ts, ots, isNew(ot), isTempTable(t)); > + t->base.allocated = 1; > + } > + > + return clear_tsbats(tr, t->timestamps); > +} > +*/ > static BUN > clear_del(sql_trans *tr, sql_table *t) > { > _______________________________________________ > checkin-list mailing list > checkin-list(a)monetdb.org > https://www.monetdb.org/mailman/listinfo/checkin-list

1 0

Re: MonetDB: default - (try to) run GSL tests only if we do have GSL...
by Arjen de Rijke 29 Oct '13

29 Oct '13

Hoi Stefan, Dit zou toch niet nodig hoeven zijn. Dit wordt al geregeld via de conditional in de makefile van /sql/backends/monet5/, of vergis ik mij? De andere checkin zal ik even onthouden voor een volgende keer. Arjen ----- Original Message ----- > From: "Stefan Manegold" <commits(a)monetdb.org> > To: checkin-list(a)monetdb.org > Sent: Tuesday, October 29, 2013 9:44:26 AM > Subject: MonetDB: default - (try to) run GSL tests only if we do have GSL... > > Changeset: bb53a64a83fe for MonetDB > URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=bb53a64a83fe > Modified Files: > sql/backends/monet5/gsl/Tests/All > Branch: default > Log Message: > > (try to) run GSL tests only if we do have GSL support > > > diffs (8 lines): > > diff --git a/sql/backends/monet5/gsl/Tests/All > b/sql/backends/monet5/gsl/Tests/All > --- a/sql/backends/monet5/gsl/Tests/All > +++ b/sql/backends/monet5/gsl/Tests/All > @@ -1,2 +1,2 @@ > -gsl00 > -gsl01 > +HAVE_GSL?gsl00 > +HAVE_GSL?gsl01 > _______________________________________________ > checkin-list mailing list > checkin-list(a)monetdb.org > https://www.monetdb.org/mailman/listinfo/checkin-list >

2 2