Dump the db content in form of a ; CSV

1 files changed, 62 insertions, 2 deletions

diff --git a/src/database_interaction.c b/src/database_interaction.c
index 0dd729d..37ce32c 100644
--- a/src/database_interaction.c
+++ b/src/database_interaction.c
@@ -134,6 +134,8 @@ void dbi_close() {
     LOCAL_FINALIZE(select_fileinfo_by_filename_id);
     LOCAL_FINALIZE(select_fileinfo_by_path_filename_ids);
     LOCAL_FINALIZE(select_fileinfo_by_hash_id);
+    LOCAL_FINALIZE(select_fileinfo_complete_table);
+    LOCAL_FINALIZE(select_fileinfo_complete_table_resolved);
 
     LOCAL_FINALIZE(insert_filename);
     LOCAL_FINALIZE(insert_pathname);
@@ -220,8 +222,8 @@ int prepare_statements() {
     /* TODO: so far the only query with JOINs or masking it in another way?
      * Many years since
      */
-    LOCAL_PREP_STMT("SELECT paths.path_name, filenames.name, hashes.blake2, hashes.sha256, hashes.512, fileinfo.size, fileinfo.last_seen, fileinfo.stat_struct FROM fileinfo INNER JOIN paths ON fileinfo.p_id = paths.id INNER JOIN filenames ON fileinfo.fn_id = filenames.id INNER JOIN hashes ON fileinfo.h_id = hashes.id WHERE fileinfo.id = ? ;", &select_fileinfo_by_id_resolved);
-    LOCAL_PREP_STMT("SELECT paths.path_name, filenames.name, hashes.blake2, hashes.sha256, hashes.512, fileinfo.size, fileinfo.last_seen, fileinfo.stat_struct FROM fileinfo INNER JOIN paths ON fileinfo.p_id = paths.id INNER JOIN filenames ON fileinfo.fn_id = filenames.id INNER JOIN hashes ON fileinfo.h_id = hashes.id ;", &select_fileinfo_complete_table_resolved);
+    LOCAL_PREP_STMT("SELECT paths.pathname, filenames.name, hashes.blake2, hashes.sha256, hashes.sha512, fileinfo.size, fileinfo.last_seen, fileinfo.stat_struct FROM fileinfo INNER JOIN paths ON fileinfo.p_id = paths.id INNER JOIN filenames ON fileinfo.fn_id = filenames.id INNER JOIN hashes ON fileinfo.h_id = hashes.id WHERE fileinfo.id = ? ;", &select_fileinfo_by_id_resolved);
+    LOCAL_PREP_STMT("SELECT paths.pathname, filenames.name, hashes.blake2, hashes.sha256, hashes.sha512, fileinfo.size, fileinfo.last_seen, fileinfo.stat_struct FROM fileinfo INNER JOIN paths ON fileinfo.p_id = paths.id INNER JOIN filenames ON fileinfo.fn_id = filenames.id INNER JOIN hashes ON fileinfo.h_id = hashes.id ;", &select_fileinfo_complete_table_resolved);
     LOCAL_PREP_STMT("SELECT p_id, fn_id, h_id, size, last_seen, stat_struct FROM fileinfo ;", &select_fileinfo_complete_table);
 
     /* INSERT */
@@ -875,6 +877,64 @@ int dbi_insert_fileinfo(struct df_fileinfo *fi) {
     return rc;
 };
 
+
+/**
+ * Print the database content to the given filedescriptor in a CSV form which can be processed with grep awk etc.
+ *
+ * @param out output descriptor, if NULL stdout is used.
+ * @return 0 on success,
+ *        -1 on failure
+ */
+int dbi_print_fileinfo_resolved(FILE *out) {
+    int rc = 0;
+    int64_t i;
+    int strc = 0;
+    FILE *fd = out;
+    const unsigned char *txt = NULL;
+    sqlite3_stmt *st = select_fileinfo_complete_table_resolved;
+
+    DBCONN_CHECK(-1);
+
+    sqlite3_reset(st);
+
+
+    if (fd == NULL) { fd = stdout; }
+
+    /* We ignore the struct_stat and last_seen columns */
+
+    do {
+        strc = sqlite3_step(st);
+
+        if (strc == SQLITE_DONE) {
+            break;
+        }
+
+        if (strc != SQLITE_ROW) {
+            LOGERR("ERROR: Failed step: %s\n", sqlite3_errmsg(dbconn));
+            rc = -1;
+            break;
+        }
+
+        txt = sqlite3_column_text(st, 0); /* paths.pathname */
+        fprintf(fd, "%s/", txt);
+        txt = sqlite3_column_text(st, 1); /* filenames.name */
+        fprintf(fd, "%s;", txt);
+        txt = sqlite3_column_text(st, 2); /* hashes.blake2 */
+        fprintf(fd, "%s;", txt);
+        txt = sqlite3_column_text(st, 3); /* hashes.sha256 */
+        fprintf(fd, "%s;", txt);
+        txt = sqlite3_column_text(st, 4); /* hashes.sha512 */
+        fprintf(fd, "%s;", txt);
+        i = (int64_t) sqlite3_column_int64(st, 5); /* fileinfo.size */
+        fprintf(fd, "%ld\n", i);
+
+    } while (strc == SQLITE_ROW);
+
+    sqlite3_reset(st);
+
+    return rc;
+}
+
 #if 0
              *select_fileinfo_by_id,
              *select_fileinfo_by_id_resolved,