diff --git a/vldb-protocols.py b/vldb-protocols.py index 8afccb7e5898e6c0fd9366883cbb8001e530d82b..897f450edbd83ee8119c6268f7bc72fc0af1a7c4 100644 --- a/vldb-protocols.py +++ b/vldb-protocols.py @@ -23,8 +23,9 @@ systems = [ {'name':'hbase-default', 'db':'hbase'}, {'name':'mongodb-default', 'db':'mongodb'}] + networks = [ - {'name':'unlimited', 'throughput': -1, 'latency':-1}], + {'name':'unlimited', 'throughput': -1, 'latency':-1}, {'name':'gigabitethld', 'throughput': 1000, 'latency':0.3}, {'name':'10mbitethhd', 'throughput': 10, 'latency':150}] @@ -47,6 +48,12 @@ for chunksize in chunksizes: 'chunksize': chunksize, 'compress': compression_method}) +systems = [{'name':'monetdb-colprot-nocomp', 'db':'monetdb', 'params': '--protocol=prot10'}, + {'name':'monetdb-colprot-compsnappy', 'db':'monetdb', 'params': '--protocol=prot10compressed --compression=snappy'}, + {'name':'monetdb-colprot-complz4', 'db':'monetdb', 'params': '--protocol=prot10compressed --compression=lz4'}, + {'name':'monetdb-prot9', 'db':'monetdb', 'params': '--protocol=prot9'}] + + nruns = 5 timeout = "10m" @@ -150,9 +157,15 @@ for r in range(nruns): jdbcflags = 'org.mariadb.jdbc.Driver jdbc:mysql://127.0.0.1/user user null' odbccmd = 'isql MySQL -d, < query > /dev/null' elif system['db'] == 'monetdb': - querycmd = 'mclient -h 127.0.0.1 -p 50001 -fcsv -s "%s" > /dev/null' % query - jdbcflags = 'nl.cwi.monetdb.jdbc.MonetDriver jdbc:monetdb://127.0.0.1:50001/database monetdb monetdb' - odbccmd = 'isql MonetDB -d, < query > /dev/null' + if 'params' in system: + querycmd = '/home/user/monetdb-install/bin/mclient -h 127.0.0.1 -p 50001 -fcsv -s "%s" %s > /dev/null' % (query, system['params']) + jdbcflags = None + odbccmd = None + odbcdriver = None + else: + querycmd = 'mclient -h 127.0.0.1 -p 50001 -fcsv -s "%s" > /dev/null' % query + jdbcflags = 'nl.cwi.monetdb.jdbc.MonetDriver jdbc:monetdb://127.0.0.1:50001/database monetdb monetdb' + odbccmd = 'isql MonetDB -d, < query > /dev/null' elif system['db'] == 'db2': db2qfile = open("db2query", "w") db2qfile.write("connect to remotedb user user using user; \n" + query + ";\n") @@ -167,7 +180,7 @@ for r in range(nruns): jdbcflags = 'oracle.jdbc.driver.OracleDriver jdbc:oracle:thin:@127.0.0.1:49161:XE system oracle' odbccmd = 'isql Oracle -d, < query > /dev/null' # for JDBC/ODBCV - query = "SELECT * FROM lineitem where rownum < %d;" % tuple + query = "SELECT * FROM lineitem where rownum < %d" % tuple elif system['db'] == 'mongodb': querycmd = 'mongoexport -d lineitem -c things --csv --fields "l_orderkey,l_partkey,l_suppkey,l_linenumber,l_quantity,l_extendedprice,l_discount,l_tax,l_returnflag,l_linestatus,l_shipdate,l_commitdate,l_receiptdate,l_shipinstruct,l_shipmode,l_comment" --limit %d > /dev/null 2> /dev/null' % tuple jdbcflags = None