add more helper in sql_utils:

- update_with_clause (make conditional update) - get_all_to_json (extract only fields by given extractors from the table cursor result to a list of JSON value)

add more helper in sql_utils:
- update_with_clause (make conditional update) - get_all_to_json (extract only fields by given extractors from the table cursor result to a list of JSON value)
totoro
1 parent f80bd32b
Showing 1 changed file with 60 additions and 0 deletions Show diff stats
controller/hk_sql_utils.anubis
@@ -235,6 +235,46 @@ public define (String, String, String, String) -&gt; Maybe(One -&gt; SQLite3Row)
     ok(_, cursor, _) then success(cursor)
   }
 .
+ 
+ /***** JSON *****/
+
+public define Maybe(JsonValue)
+  extract_cursor_to_json
+  (
+    SQLite3DataBase                             db,
+    List(((Int -> SQLite3Datum) -> JsonMember)) extractors,
+    One -> SQLite3Row                           table_cursor
+  ) =
+  //get next cursor
+  if table_cursor(unique) is
+  {
+    error(sql_error)  then println(db_error(sql_error, "extract_cursor_to_json")); failure,
+    no_more_row       then failure,
+    row(cursor)       then
+      success(
+        json_object(
+          map(((Int -> SQLite3Datum) -> JsonMember extractor) |-> extractor(cursor) , extractors)
+        ))
+  }
+.
+
+public define List(JsonValue)
+  get_all_to_json
+  (
+    SQLite3DataBase   db,
+    List(((Int -> SQLite3Datum) -> JsonMember)) extractors,
+    One -> SQLite3Row table_cursor,
+    List(JsonValue)   so_far
+  ) =
+  if extract_cursor_to_json(db, extractors, table_cursor) is
+  {
+    failure       then reverse(so_far),
+    success(data) then get_all_to_json(db, extractors, table_cursor, [data . so_far])
+  }
+.
+
+  
+ /***** Type $T ******/
 define (One -> SQLite3Row, List($T)) ->List($T)
   _get_all
@@ -459,6 +499,7 @@ public define Maybe($T)
     success(id) then get_by_clause_to_mb_type(db, "id = "+id)      
   }
 .
+
 public define Maybe(Int)
   insert_or_update
   (
@@ -501,3 +542,22 @@ public define Maybe(Int)
       }
   }
 .
+
+public define Maybe(One)
+  update_with_clause
+  (
+    SQLite3DataBase             db,
+    String                      table_name,
+    String                      clause,
+    List(SQLite3_update_field)  fields
+  )=
+
+  since make_update_clause_and_binds(fields) is (binds, set_string),
+  if sql_query_timeout(db, "UPDATE "+table_name+" SET "+set_string +" "+clause+";", binds, table_name+" (UPDATE)") is
+  {
+    error(sql_error) then 
+      //logError(debug_log, db_error(sql_error, table_name));
+      failure,
+    ok(_, _, _)      then success(unique)
+  }
+.