Changeset 391 for vtcross/trunk/src/cognitive_engines/DSA_CE/cbr.c

Timestamp:

07/29/09 16:10:39 (15 years ago)

Author:

trnewman

Message:

Fleshed out DSA reference implementation

Files:

• vtcross/trunk/src/cognitive_engines/DSA_CE/cbr.c (modified) (5 diffs)

vtcross/trunk/src/cognitive_engines/DSA_CE/cbr.c

@@ -57 +57 @@
     char *zErrMsg = 0;
 
-    printf("command: %s\n", _cbr->command);
+    //printf("command: %s\n", _cbr->command);
     rc = sqlite3_exec(_cbr->db, _cbr->command, callback, 0, &zErrMsg);
     if( rc!=SQLITE_OK){
@@ -93 +93 @@
 }
 
+// create database
+cbr cbr_create_with_primary(char * _filename, char * _tablename, 
+        char * _cols[], char * _primcols[], unsigned int _len,
+        unsigned int _primlen)
+{
+    // cbr is a pointer to struct cbr_s
+    cbr _cbr = (cbr) malloc(sizeof(struct cbr_s));
+
+    // create database
+
+    // copy filename
+    unsigned int i=0;
+    strcpy(_cbr->filename, _filename);
+
+    // execute create database command
+    // database handle
+    //_cbr->db = NULL;
+    OpenDatabase(_cbr);
+
+    // create table
+
+    // copy tablename
+    strcpy(_cbr->tablename, _tablename);
+
+    // number of columns in the table
+    _cbr->num_columns = _len;
+
+    // generate command
+    strcpy(_cbr->command, "CREATE TABLE ");
+    strcat(_cbr->command, _cbr->tablename);
+    strcat(_cbr->command, "(");
+    for (i=0; i<_cbr->num_columns; i++) {
+        strcat(_cbr->command, _cols[i]);
+        strcat(_cbr->command, " FLOAT");
+        strcat(_cbr->command, ", ");
+    }
+   strcat(_cbr->command, "PRIMARY KEY (");
+    for (i=0; i<_primlen; i++) {
+        strcat(_cbr->command, _primcols[i]);
+        if (i != _primlen-1) // not last entry
+            strcat(_cbr->command, ", ");
+    }
+    strcat(_cbr->command, "));");
+
+    // execute create table command
+    ExecuteCommand(_cbr);
+
+    return _cbr;
+}
 
 // create database
@@ -181 +230 @@
 const char * ops_str[] = {
     "==", "!=", ">", ">=", "<", "<="};
+
+
+// cbr search for a sum
+int cbr_search_sum(
+    cbr _cbr,
+    char *_name,
+    float *_retvals)
+{   
+    int rc;
+    // generate command
+    strcpy(_cbr->command, "select SUM( ");
+    strcat(_cbr->command, _cbr->tablename);
+    strcat(_cbr->command, ".");
+    strcat(_cbr->command, _name);
+    strcat(_cbr->command, ") from ");
+    strcat(_cbr->command, _cbr->tablename);
+    strcat(_cbr->command, ";");
+
+    //printf("search command: %s\n", _cbr->command);
+
+    rc = ExecuteSearchCommand(_cbr, _retvals);
+    /*printf("search result: ");
+    for (int i=0; i<_cbr->num_columns; i++)
+        printf("%f, ",_retvals[i]);
+    printf("\n");
+    */
+    return rc;
+}
+
+
+// cbr search
+int cbr_search_rand(
+    cbr _cbr,
+    char *_names[],
+    int * _ops,
+    float *_vals,
+    unsigned int _n,
+    float *_retvals)
+{   
+    int rc;
+    // generate command
+    strcpy(_cbr->command, "select ");
+    strcat(_cbr->command, _cbr->tablename);
+    strcat(_cbr->command, ".* from ");
+    strcat(_cbr->command, _cbr->tablename);
+    strcat(_cbr->command, " where ");
+
+    unsigned int i;
+    char str_buffer[64];
+    for (i=0; i<_n; i++) {
+        // ensure valid ops value
+        if (_ops[i] < 0 || _ops[i] > 5) {
+            printf("error: cbr_search(), invalid ops id : %d\n", _ops[i]);
+            exit(1);
+        }
+
+        strcat(_cbr->command, _names[i]);
+        strcat(_cbr->command, ops_str[_ops[i]]);
+        sprintf(str_buffer, "%E", _vals[i]);
+        strcat(_cbr->command, str_buffer);
+
+        if (i<_n-1)
+            strcat(_cbr->command, " AND ");
+        else
+            strcat(_cbr->command, " order by RAND();");
+    }
+
+    //printf("search command: %s\n", _cbr->command);
+
+    rc = ExecuteSearchCommand(_cbr, _retvals);
+    
+    /*printf("search result: ");
+    for (i=0; i<_cbr->num_columns; i++)
+        printf("%f, ",_retvals[i]);
+    printf("\n");
+*/
+    return rc;
+}
 
 
@@ -220 +347 @@
     }
 
-    printf("search command: %s\n", _cbr->command);
+    //printf("search command: %s\n", _cbr->command);
 
     rc = ExecuteSearchCommand(_cbr, _retvals);
@@ -279 +406 @@
     // generate command
     //printf("%s\n", _cbr->command);
-    strcpy(_cbr->command, "insert into ");
+    strcpy(_cbr->command, "replace into ");
     strcat(_cbr->command, _cbr->tablename);