Playlist database support.

This database helper will be used by upcoming playlist parsers.

diff --git a/src/lib/Makefile.am b/src/lib/Makefile.am
index 5006e67..86d2d92 100644 (file)
--- a/src/lib/Makefile.am
+++ b/src/lib/Makefile.am
@@ -17,7 +17,8 @@ liblightmediascanner_la_SOURCES = \
        lightmediascanner_db_common.c \
        lightmediascanner_db_image.c \
        lightmediascanner_db_audio.c \
-       lightmediascanner_db_video.c
+       lightmediascanner_db_video.c \
+       lightmediascanner_db_playlist.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 6bc18e4..416421e 100644 (file)
--- a/src/lib/lightmediascanner_db.h
+++ b/src/lib/lightmediascanner_db.h
@@ -105,6 +105,22 @@ extern "C" {
     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);
 
+    /* Playlist Records */
+    struct lms_playlist_info {
+        int64_t id;
+        struct lms_string_size title;
+        unsigned int n_entries;
+    };
+
+    typedef struct lms_db_playlist lms_db_playlist_t;
+
+    API lms_db_playlist_t *lms_db_playlist_new(sqlite3 *db) GNUC_NON_NULL(1);
+    API int lms_db_playlist_start(lms_db_playlist_t *ldp) GNUC_NON_NULL(1);
+    API int lms_db_playlist_free(lms_db_playlist_t *ldp) GNUC_NON_NULL(1);
+    API int lms_db_playlist_add(lms_db_playlist_t *ldp, struct lms_playlist_info *info) GNUC_NON_NULL(1, 2);
+
+
+
 #ifdef __cplusplus
 }
 #endif

diff --git a/src/lib/lightmediascanner_db_playlist.c b/src/lib/lightmediascanner_db_playlist.c
new file mode 100644 (file)
index 0000000..686e7be
--- /dev/null
+++ b/src/lib/lightmediascanner_db_playlist.c
@@ -0,0 +1,177 @@
+#include <lightmediascanner_db.h>
+#include "lightmediascanner_db_private.h"
+#include <stdlib.h>
+#include <stdio.h>
+
+struct lms_db_playlist {
+    sqlite3 *db;
+    sqlite3_stmt *insert;
+    unsigned int _references;
+    unsigned int _is_started:1;
+};
+
+static lms_db_playlist_t *_singleton = NULL;
+
+static int
+_db_table_updater_playlists_0(sqlite3 *db, const char *table, unsigned int current_version, int is_last_run) {
+    char *errmsg;
+    int r, ret;
+
+    errmsg = NULL;
+    r = sqlite3_exec(db,
+                     "CREATE TABLE IF NOT EXISTS playlists ("
+                     "id INTEGER PRIMARY KEY, "
+                     "title TEXT, "
+                     "n_entries INTEGER NOT NULL"
+                     ")",
+                     NULL, NULL, &errmsg);
+    if (r != SQLITE_OK) {
+        fprintf(stderr, "ERROR: could not create 'playlists' table: %s\n",
+                errmsg);
+        sqlite3_free(errmsg);
+        return -1;
+    }
+
+    ret = lms_db_create_trigger_if_not_exists(db,
+        "delete_playlists_on_files_deleted "
+        "DELETE ON files FOR EACH ROW BEGIN "
+        " DELETE FROM playlists WHERE id = OLD.id; END;");
+    if (ret != 0)
+        goto done;
+
+    ret = lms_db_create_trigger_if_not_exists(db,
+        "delete_files_on_playlists_deleted "
+        "DELETE ON playlists FOR EACH ROW BEGIN "
+        " DELETE FROM files WHERE id = OLD.id; END;");
+
+  done:
+    return ret;
+}
+
+static lms_db_table_updater_t _db_table_updater_playlists[] = {
+    _db_table_updater_playlists_0
+};
+
+
+static int
+_db_create_table_if_required(sqlite3 *db)
+{
+    return lms_db_table_update_if_required(db, "playlists",
+         LMS_ARRAY_SIZE(_db_table_updater_playlists),
+         _db_table_updater_playlists);
+}
+
+lms_db_playlist_t *
+lms_db_playlist_new(sqlite3 *db)
+{
+    lms_db_playlist_t *ldp;
+
+    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;
+    }
+
+    ldp = calloc(1, sizeof(lms_db_playlist_t));
+    ldp->_references = 1;
+    ldp->db = db;
+
+    return ldp;
+}
+
+int
+lms_db_playlist_start(lms_db_playlist_t *ldp)
+{
+    if (!ldp)
+        return -1;
+    if (ldp->_is_started)
+        return 0;
+
+    ldp->insert = lms_db_compile_stmt(ldp->db,
+        "INSERT OR REPLACE INTO playlists (id, title, n_entries) "
+        "VALUES (?, ?, ?)");
+    if (!ldp->insert)
+        return -2;
+
+    ldp->_is_started = 1;
+    return 0;
+}
+
+int
+lms_db_playlist_free(lms_db_playlist_t *ldp)
+{
+    if (!ldp)
+        return -1;
+    if (ldp->_references == 0) {
+        fprintf(stderr, "ERROR: over-called lms_db_playlist_free(%p)\n", ldp);
+        return -1;
+    }
+
+    ldp->_references--;
+    if (ldp->_references > 0)
+        return 0;
+
+    if (ldp->insert)
+        lms_db_finalize_stmt(ldp->insert, "insert");
+
+    free(ldp);
+    _singleton = NULL;
+
+    return 0;
+}
+
+static int
+_db_insert(lms_db_playlist_t *ldp, const struct lms_playlist_info *info)
+{
+    sqlite3_stmt *stmt;
+    int r, ret;
+
+    stmt = ldp->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_int(stmt, 3, info->n_entries);
+    if (ret != 0)
+        goto done;
+
+    r = sqlite3_step(stmt);
+    if (r != SQLITE_DONE) {
+        fprintf(stderr, "ERROR: could not insert playlist info: %s\n",
+                sqlite3_errmsg(ldp->db));
+        ret = -4;
+        goto done;
+    }
+
+    ret = 0;
+
+  done:
+    lms_db_reset_stmt(stmt);
+
+    return ret;
+}
+
+int
+lms_db_playlist_add(lms_db_playlist_t *ldp, struct lms_playlist_info *info)
+{
+    if (!ldp)
+        return -1;
+    if (!info)
+        return -2;
+    if (info->id < 1)
+        return -3;
+
+    return _db_insert(ldp, info);
+}