Video database support.

This database helper will be used by upcoming video parser.

diff --git a/src/lib/Makefile.am b/src/lib/Makefile.am
index 411f58e..5006e67 100644 (file)
--- a/src/lib/Makefile.am
+++ b/src/lib/Makefile.am
@@ -16,7 +16,8 @@ liblightmediascanner_la_SOURCES = \
        lightmediascanner_utils.c \
        lightmediascanner_db_common.c \
        lightmediascanner_db_image.c \
-       lightmediascanner_db_audio.c
+       lightmediascanner_db_audio.c \
+       lightmediascanner_db_video.c
 
 liblightmediascanner_la_LIBADD = -ldl @SQLITE3_LIBS@
 liblightmediascanner_la_LDFLAGS = -version-info @version_info@

diff --git a/src/lib/lightmediascanner_db.h b/src/lib/lightmediascanner_db.h
index c764259..6bc18e4 100644 (file)
--- a/src/lib/lightmediascanner_db.h
+++ b/src/lib/lightmediascanner_db.h
@@ -91,6 +91,20 @@ extern "C" {
     API int lms_db_audio_free(lms_db_audio_t *lms_db_audio) GNUC_NON_NULL(1);
     API int lms_db_audio_add(lms_db_audio_t *lms_db_audio, struct lms_audio_info *info) GNUC_NON_NULL(1, 2);
 
+    /* Video Records */
+    struct lms_video_info {
+        int64_t id;
+        struct lms_string_size title;
+        struct lms_string_size artist;
+    };
+
+    typedef struct lms_db_video lms_db_video_t;
+
+    API lms_db_video_t *lms_db_video_new(sqlite3 *db) GNUC_NON_NULL(1);
+    API int lms_db_video_start(lms_db_video_t *ldi) GNUC_NON_NULL(1);
+    API int lms_db_video_free(lms_db_video_t *lms_db_video) GNUC_NON_NULL(1);
+    API int lms_db_video_add(lms_db_video_t *lms_db_video, struct lms_video_info *info) GNUC_NON_NULL(1, 2);
+
 #ifdef __cplusplus
 }
 #endif

diff --git a/src/lib/lightmediascanner_db_video.c b/src/lib/lightmediascanner_db_video.c
new file mode 100644 (file)
index 0000000..0bca4fa
--- /dev/null
+++ b/src/lib/lightmediascanner_db_video.c
@@ -0,0 +1,163 @@
+#include <lightmediascanner_db.h>
+#include "lightmediascanner_db_private.h"
+#include <stdlib.h>
+#include <stdio.h>
+
+struct lms_db_video {
+    sqlite3 *db;
+    sqlite3_stmt *insert;
+    unsigned int _references;
+    unsigned int _is_started:1;
+};
+
+static lms_db_video_t *_singleton = NULL;
+
+static int
+_db_create_table_if_required(sqlite3 *db)
+{
+    char *errmsg;
+    int r, ret;
+
+    errmsg = NULL;
+    r = sqlite3_exec(db,
+                     "CREATE TABLE IF NOT EXISTS videos ("
+                     "id INTEGER PRIMARY KEY, "
+                     "title TEXT, "
+                     "artist TEXT"
+                     ")",
+                     NULL, NULL, &errmsg);
+    if (r != SQLITE_OK) {
+        fprintf(stderr, "ERROR: could not create 'videos' table: %s\n", errmsg);
+        sqlite3_free(errmsg);
+        return -1;
+    }
+
+    ret = lms_db_create_trigger_if_not_exists(db,
+        "delete_videos_on_files_deleted "
+        "DELETE ON files FOR EACH ROW BEGIN "
+        " DELETE FROM videos WHERE id = OLD.id; END;");
+    if (ret != 0)
+        goto done;
+
+    ret = lms_db_create_trigger_if_not_exists(db,
+        "delete_files_on_videos_deleted "
+        "DELETE ON videos FOR EACH ROW BEGIN "
+        " DELETE FROM files WHERE id = OLD.id; END;");
+
+  done:
+    return ret;
+}
+
+lms_db_video_t *
+lms_db_video_new(sqlite3 *db)
+{
+    lms_db_video_t *ldi;
+
+    if (_singleton) {
+        _singleton->_references++;
+        return _singleton;
+    }
+
+    if (!db)
+        return NULL;
+
+    if (_db_create_table_if_required(db) != 0) {
+        fprintf(stderr, "ERROR: could not create table.\n");
+        return NULL;
+    }
+
+    ldi = calloc(1, sizeof(lms_db_video_t));
+    ldi->_references = 1;
+    ldi->db = db;
+
+    return ldi;
+}
+
+int
+lms_db_video_start(lms_db_video_t *ldi)
+{
+    if (!ldi)
+        return -1;
+    if (ldi->_is_started)
+        return 0;
+
+    ldi->insert = lms_db_compile_stmt(ldi->db,
+        "INSERT OR REPLACE INTO videos (id, title, artist) VALUES (?, ?, ?)");
+    if (!ldi->insert)
+        return -2;
+
+    ldi->_is_started = 1;
+    return 0;
+}
+
+int
+lms_db_video_free(lms_db_video_t *ldi)
+{
+    if (!ldi)
+        return -1;
+    if (ldi->_references == 0) {
+        fprintf(stderr, "ERROR: over-called lms_db_video_free(%p)\n", ldi);
+        return -1;
+    }
+
+    ldi->_references--;
+    if (ldi->_references > 0)
+        return 0;
+
+    if (ldi->insert)
+        lms_db_finalize_stmt(ldi->insert, "insert");
+
+    free(ldi);
+    _singleton = NULL;
+
+    return 0;
+}
+
+static int
+_db_insert(lms_db_video_t *ldi, const struct lms_video_info *info)
+{
+    sqlite3_stmt *stmt;
+    int r, ret;
+
+    stmt = ldi->insert;
+
+    ret = lms_db_bind_int64(stmt, 1, info->id);
+    if (ret != 0)
+        goto done;
+
+    ret = lms_db_bind_text(stmt, 2, info->title.str, info->title.len);
+    if (ret != 0)
+        goto done;
+
+    ret = lms_db_bind_text(stmt, 3, info->artist.str, info->artist.len);
+    if (ret != 0)
+        goto done;
+
+    r = sqlite3_step(stmt);
+    if (r != SQLITE_DONE) {
+        fprintf(stderr, "ERROR: could not insert video info: %s\n",
+                sqlite3_errmsg(ldi->db));
+        ret = -4;
+        goto done;
+    }
+
+    ret = 0;
+
+  done:
+    lms_db_reset_stmt(stmt);
+
+    return ret;
+}
+
+int
+lms_db_video_add(lms_db_video_t *ldi, struct lms_video_info *info)
+{
+    if (!ldi)
+        return -1;
+    if (!info)
+        return -2;
+    if (info->id < 1)
+        return -3;
+
+    return _db_insert(ldi, info);
+}