Add data performance tests, revise block diagram, add pthread_mutex_init

[matches/MCTX3420.git] / testing / data_performance / sqlite.c

diff --git a/testing/data_performance/sqlite.c b/testing/data_performance/sqlite.c
new file mode 100644 (file)
index 0000000..b0ffb36
--- /dev/null
+++ b/testing/data_performance/sqlite.c
@@ -0,0 +1,65 @@
+#include <stdlib.h>
+#include <stdio.h>
+#include <assert.h>
+#include <sys/time.h>
+#include <sqlite3.h>
+
+typedef struct
+{
+       float time;
+       float value;
+} DataPoint;
+
+
+
+
+int main(int argc, char ** argv)
+{
+       assert(argc == 3);
+       
+       int bufsiz = atoi(argv[1]);
+       int numpoints = atoi(argv[2]);
+       assert(bufsiz > 0);
+       DataPoint * buffer = (DataPoint*)(calloc(bufsiz, sizeof(DataPoint)));
+
+
+
+       sqlite3 * db;
+       sqlite3_open("sqlite.db", &db);
+
+       
+       char query[BUFSIZ];
+       char * query_value = query+sprintf(query,"insert into sensor values(");
+       
+
+       struct timeval start_time;
+       gettimeofday(&start_time, NULL);
+
+       int i = 0;
+       while (i < numpoints)
+       {
+               int j = 0;
+               for (j = 0; j < bufsiz && i < numpoints; ++j)
+               {
+                       buffer[j].time = i;
+                       buffer[j].value = i;
+                       
+               }
+               i += j;
+               for (int k = 0; k < j; ++k)
+               {
+                       sprintf(query_value,"%f,%f)", buffer[k].time, buffer[k].value);
+                       sqlite3_exec(db, query, NULL, NULL, NULL);
+               }
+       }
+
+       struct timeval end_time;
+       gettimeofday(&end_time, NULL);
+
+
+       sqlite3_close(db);
+       free(buffer);
+       float time_elapsed = (float)(end_time.tv_sec - start_time.tv_sec) + 1e-6*(end_time.tv_usec - start_time.tv_usec);
+       printf("%f\n", time_elapsed);
+       return 0;
+}