diff options
Diffstat (limited to 'src/analysis/db')
| -rw-r--r-- | src/analysis/db/cdb.c | 47 | ||||
| -rw-r--r-- | src/analysis/db/cdb.h | 2 | ||||
| -rw-r--r-- | src/analysis/db/client.c | 43 | ||||
| -rw-r--r-- | src/analysis/db/client.h | 3 | ||||
| -rw-r--r-- | src/analysis/db/collection.c | 162 | ||||
| -rw-r--r-- | src/analysis/db/collection.h | 6 | ||||
| -rw-r--r-- | src/analysis/db/item-int.h | 10 | ||||
| -rw-r--r-- | src/analysis/db/item.c | 93 | ||||
| -rw-r--r-- | src/analysis/db/item.h | 18 | ||||
| -rw-r--r-- | src/analysis/db/items/bookmark.c | 61 | ||||
| -rw-r--r-- | src/analysis/db/items/bookmark.h | 2 | ||||
| -rw-r--r-- | src/analysis/db/protocol.h | 27 |
12 files changed, 442 insertions, 32 deletions
diff --git a/src/analysis/db/cdb.c b/src/analysis/db/cdb.c index 563aa40..55d1b2d 100644 --- a/src/analysis/db/cdb.c +++ b/src/analysis/db/cdb.c @@ -34,7 +34,6 @@ #include <pthread.h> #include <signal.h> #include <stdio.h> -#include <sqlite3.h> #include <string.h> #include <unistd.h> #include <sys/stat.h> @@ -283,6 +282,8 @@ GCdbArchive *g_cdb_archive_new(const char *owner, const rle_string *hash, const result->filename = get_xdg_config_dir(suffix); + printf("dealing with '%s'...\n", result->filename); + free(suffix); if (!mkpath(result->filename)) @@ -318,7 +319,7 @@ GCdbArchive *g_cdb_archive_new(const char *owner, const rle_string *hash, const g_cdb_archive_create_xml_desc(result, user); g_cdb_archive_create_db(result, NULL); - if (!g_cdb_archive_write(result)) + if (g_cdb_archive_write(result) != DBE_NONE) goto gcan_error; } @@ -473,13 +474,13 @@ static bool g_cdb_archive_read(GCdbArchive *archive) * * ******************************************************************************/ -bool g_cdb_archive_write(const GCdbArchive *archive) +DBError g_cdb_archive_write(const GCdbArchive *archive) { - bool result; /* Conclusion à retourner */ + DBError result; /* Conclusion à retourner */ struct archive *out; /* Archive à constituer */ int ret; /* Bilan d'un appel */ - result = false; + result = DBE_ARCHIVE_ERROR; out = archive_write_new(); archive_write_add_filter_xz(out); @@ -488,16 +489,19 @@ bool g_cdb_archive_write(const GCdbArchive *archive) ret = archive_write_open_filename(out, archive->filename); if (ret != ARCHIVE_OK) goto gcaw_exit; - bool add_file_to_archive(struct archive *out, const char *src, const char *path) + DBError add_file_to_archive(struct archive *out, const char *src, const char *path) { + DBError status; /* Bilan à renvoyer */ struct stat info; /* Informations d'origine */ struct archive_entry *entry; /* Elément de l'archive */ int fd; /* Flux ouvert en lecture */ char buffer[ARCHIVE_RBUF_SIZE]; /* Tampon pour les transferts */ ssize_t len; /* Quantité de données lues */ + status = DBE_ARCHIVE_ERROR; + ret = stat(src, &info); - if (ret != 0) return false; + if (ret != 0) return DBE_SYS_ERROR; entry = archive_entry_new(); @@ -508,7 +512,11 @@ bool g_cdb_archive_write(const GCdbArchive *archive) if (ret != 0) goto afta_error; fd = open(src, O_RDONLY); - if (fd == -1) goto afta_error; + if (fd == -1) + { + status = DBE_SYS_ERROR; + goto afta_error; + } for (len = safe_read(fd, buffer, ARCHIVE_RBUF_SIZE); len > 0; @@ -522,18 +530,20 @@ bool g_cdb_archive_write(const GCdbArchive *archive) archive_entry_free(entry); - return true; + return DBE_NONE; afta_error: archive_entry_free(entry); - return false; + return status; } result = add_file_to_archive(out, archive->xml_desc, "desc.xml"); - result &= add_file_to_archive(out, archive->sql_db, "sql.db"); + + if (result == DBE_NONE) + result = add_file_to_archive(out, archive->sql_db, "sql.db"); gcaw_exit: @@ -781,6 +791,7 @@ static void *g_cdb_archive_process(GCdbArchive *archive) uint32_t val32; /* Valeur sur 32 bits */ bool status; /* Bilan de lecture initiale */ uint32_t command; /* Commande de la requête */ + DBError error; /* Bilan d'une opération */ GDbCollection *collec; /* Collection visée au final */ void interrupt_poll_with_sigusr1(int sig) { }; @@ -843,6 +854,18 @@ static void *g_cdb_archive_process(GCdbArchive *archive) switch (command) { + case DBC_SAVE: + + error = g_cdb_archive_write(archive); + + if (!safe_send(fds[i].fd, (uint32_t []) { htobe32(DBC_SAVE) }, sizeof(uint32_t), 0)) + goto gcap_bad_exchange; + + if (!safe_send(fds[i].fd, (uint32_t []) { htobe32(error) }, sizeof(uint32_t), 0)) + goto gcap_bad_exchange; + + break; + case DBC_COLLECTION: status = safe_recv(fds[i].fd, &val32, sizeof(uint32_t), 0); @@ -851,7 +874,7 @@ static void *g_cdb_archive_process(GCdbArchive *archive) collec = find_collection_in_list(archive->collections, be32toh(val32)); if (collec == NULL) goto gcap_bad_exchange; - status = g_db_collection_recv(collec, fds[i].fd); + status = g_db_collection_recv(collec, fds[i].fd, archive->db); if (!status) goto gcap_bad_exchange; printf("## CDB ## Got something for collection %p...\n", collec); diff --git a/src/analysis/db/cdb.h b/src/analysis/db/cdb.h index 17327f5..e9abb02 100644 --- a/src/analysis/db/cdb.h +++ b/src/analysis/db/cdb.h @@ -60,7 +60,7 @@ GType g_cdb_archive_get_type(void); GCdbArchive *g_cdb_archive_new(const char *, const rle_string *, const rle_string *, DBError *); /* Enregistre une archive avec tous les éléments à conserver. */ -bool g_cdb_archive_write(const GCdbArchive *); +DBError g_cdb_archive_write(const GCdbArchive *); /* Détermine si une empreinte correspond à celle d'une archive. */ int g_cdb_archive_compare_hash(const GCdbArchive *, const rle_string *); diff --git a/src/analysis/db/client.c b/src/analysis/db/client.c index 4b807ae..71df99c 100644 --- a/src/analysis/db/client.c +++ b/src/analysis/db/client.c @@ -328,6 +328,7 @@ static void *g_db_client_update(GDbClient *client) uint32_t val32; /* Valeur sur 32 bits */ bool status; /* Bilan d'une opération */ uint32_t command; /* Commande de la requête */ + DBError error; /* Bilan d'une commande passée */ GDbCollection *collec; /* Collection visée au final */ fds.fd = client->fd; @@ -353,6 +354,19 @@ static void *g_db_client_update(GDbClient *client) switch (command) { + case DBC_SAVE: + + status = safe_recv(fds.fd, &val32, sizeof(uint32_t), 0); + if (!status) goto gdcu_bad_exchange; + + error = be32toh(val32); + + printf("## CLIENT ## Saved ? %d\n", error); + + + + break; + case DBC_COLLECTION: status = safe_recv(fds.fd, &val32, sizeof(uint32_t), 0); @@ -361,7 +375,7 @@ static void *g_db_client_update(GDbClient *client) collec = find_collection_in_list(client->collections, be32toh(val32)); if (collec == NULL) goto gdcu_bad_exchange; - status = g_db_collection_recv(collec, fds.fd); + status = g_db_collection_recv(collec, fds.fd, NULL); if (!status) goto gdcu_bad_exchange; @@ -459,3 +473,30 @@ void g_db_client_put_fd(GDbClient *client) g_mutex_unlock(&client->sending_lock); } + + +/****************************************************************************** +* * +* Paramètres : client = client pour les accès distants à manipuler. * +* * +* Description : Effectue une demande de sauvegarde de l'état courant. * +* * +* Retour : true si la commande a bien été envoyée, false sinon. * +* * +* Remarques : - * +* * +******************************************************************************/ + +bool g_db_client_save(GDbClient *client) +{ + bool result; /* Bilan partiel à remonter */ + + g_db_client_get_fd(client); + + result = safe_send(client->fd, (uint32_t []) { htobe32(DBC_SAVE) }, sizeof(uint32_t), 0); + + g_db_client_put_fd(client); + + return result; + +} diff --git a/src/analysis/db/client.h b/src/analysis/db/client.h index a1a9f8e..963744b 100644 --- a/src/analysis/db/client.h +++ b/src/analysis/db/client.h @@ -65,6 +65,9 @@ int g_db_client_get_fd(GDbClient *); /* Marque le canal de communication comme disponible. */ void g_db_client_put_fd(GDbClient *); +/* Effectue une demande de sauvegarde de l'état courant. */ +bool g_db_client_save(GDbClient *); + #endif /* _ANALYSIS_DB_CLIENT_H */ diff --git a/src/analysis/db/collection.c b/src/analysis/db/collection.c index 20b1ff3..5c25720 100644 --- a/src/analysis/db/collection.c +++ b/src/analysis/db/collection.c @@ -24,6 +24,11 @@ #include "collection.h" +#include <stdio.h> +#include <string.h> + + +#include "../../common/extstr.h" #include "../../common/io.h" #include "../../glibext/chrysamarshal.h" @@ -36,6 +41,7 @@ struct _GDbCollection uint32_t featuring; /* Fonctionnalité représentée */ GType type; /* Identifiant GLib équivalent */ + const char *name; /* Nom en base de données */ GList *items; /* Eléments rassemblés */ GList *sorted; /* Eléments triés */ @@ -71,6 +77,15 @@ static void g_db_collection_finalize(GDbCollection *); +/* --------------------- MANIPULATIONS AVEC UNE BASE DE DONNEES --------------------- */ + + +/* Enregistre un élément de collection dans une base de données. */ +static bool g_db_collection_store_item(const GDbCollection *, const GDbItem *, sqlite3 *); + + + + /* Indique le type défini pour une collection générique d'éléments. */ G_DEFINE_TYPE(GDbCollection, g_db_collection, G_TYPE_OBJECT); @@ -170,7 +185,8 @@ static void g_db_collection_finalize(GDbCollection *collec) /****************************************************************************** * * * Paramètres : id = identifiant réseau des éléments à traiter. * -* type = type GLib des éléments à intégrer dans la collection. * +* type = type GLib des éléments à placer dans la collection. * +* name = indique le nom désignant la table associée. * * * * Description : Prépare la mise en place d'une nouvelle collection. * * * @@ -180,7 +196,7 @@ static void g_db_collection_finalize(GDbCollection *collec) * * ******************************************************************************/ -GDbCollection *g_db_collection_new(uint32_t id, GType type) +GDbCollection *g_db_collection_new(uint32_t id, GType type, const char *name) { GDbCollection *result; /* Adresse à retourner */ @@ -188,6 +204,7 @@ GDbCollection *g_db_collection_new(uint32_t id, GType type) result->featuring = id; result->type = type; + result->name = name; return result; @@ -233,6 +250,7 @@ uint32_t g_db_collection_get_feature(const GDbCollection *collec) * * * Paramètres : collec = ensemble d'éléments à considérer. * * fd = flux ouvert en lecture pour la réception de données.* +* db = base de données à mettre à jour. * * * * Description : Réceptionne et traite une requête réseau pour collection. * * * @@ -244,7 +262,7 @@ uint32_t g_db_collection_get_feature(const GDbCollection *collec) * * ******************************************************************************/ -bool g_db_collection_recv(GDbCollection *collec, int fd) +bool g_db_collection_recv(GDbCollection *collec, int fd, sqlite3 *db) { bool result; /* Bilan à faire remonter */ uint32_t val32; /* Valeur sur 32 bits */ @@ -269,6 +287,8 @@ bool g_db_collection_recv(GDbCollection *collec, int fd) { case DBA_ADD_ITEM: result = g_db_collection_add_item(collec, item); + if (result && db != NULL) + result = g_db_collection_store_item(collec, item, db); break; case DBA_REM_ITEM: @@ -430,6 +450,10 @@ bool g_db_collection_add_item(GDbCollection *collec, GDbItem *item) g_signal_emit_by_name(collec, "content-changed", DBA_ADD_ITEM, item); + + printf(" ==== CONTENT CHANGED !!!\n"); + + result = true; } @@ -478,6 +502,138 @@ bool g_db_collection_modify_item(GDbCollection *collec, GDbItem *item) /* ---------------------------------------------------------------------------------- */ /* CREATION DE L'ABSTRACTION POUR COLLECTIONS */ +/* MANIPULATIONS AVEC UNE BASE DE DONNEES */ +/* ---------------------------------------------------------------------------------- */ + + +/****************************************************************************** +* * +* Paramètres : collec = ensemble d'éléments à considérer. * +* item = élément de collection à enregistrer. * +* db = base de données à mettre à jour. * +* * +* Description : Enregistre un élément de collection dans une base de données.* +* * +* Retour : Bilan de l'exécution de l'opération. * +* * +* Remarques : - * +* * +******************************************************************************/ + +static bool g_db_collection_store_item(const GDbCollection *collec, const GDbItem *item, sqlite3 *db) +{ + bool result; /* Conclusion à faire remonter */ + bound_value *values; /* Champs de table à inclure */ + size_t count; /* Nombre de ces champs */ + char *sql; /* Requête SQL à construire */ + size_t i; /* Boucle de parcours */ + sqlite3_stmt *stmt; /* Déclaration mise en place */ + int ret; /* Bilan d'un appel à SQLite */ + int index; /* Indice de valeur attachée */ + + if (!g_db_item_prepare_db_statement(item, true, &values, &count)) + return false; + + result = false; + + /* Préparation de la requête */ + + sql = strdup("INSERT INTO "); + sql = stradd(sql, collec->name); + sql = stradd(sql, " ("); + + for (i = 0; i < count; i++) + { + if (i > 0) sql = stradd(sql, ", "); + + sql = stradd(sql, values[i].name); + + } + + sql = stradd(sql, ") VALUES ("); + + for (i = 0; i < count; i++) + { + if (i > 0) sql = stradd(sql, ", "); + + if (values[i].type == SQLITE_RAW) + sql = stradd(sql, values[i].cstring); + else + sql = stradd(sql, "?"); + + } + + sql = stradd(sql, ");"); + + ret = sqlite3_prepare_v2(db, sql, -1, &stmt, NULL); + if (ret != SQLITE_OK) + { + fprintf(stderr, "Can't prepare INSERT statment '%s' (ret=%d): %s\n", sql, ret, sqlite3_errmsg(db)); + goto gdcsi_exit; + } + + /* Attribution des valeurs */ + + index = 1; + + for (i = 0; i < count; i++) + { + switch (values[i].type) + { + case SQLITE_INT64: + ret = sqlite3_bind_int64(stmt, index, values[i].integer64); + index++; + break; + + case SQLITE_TEXT: + ret = sqlite3_bind_text(stmt, index, values[i].string, -1, values[i].delete); + index++; + break; + + default: + ret = SQLITE_OK; + break; + + } + + if (ret != SQLITE_OK) + { + fprintf(stderr, "Can't bind value for parameter nb %d in '%s' (ret=%d): %s\n", + index - 1, sql, ret, sqlite3_errmsg(db)); + goto gdcsi_exit; + } + + } + + /* Exécution finale */ + + ret = sqlite3_step(stmt); + + if (ret != SQLITE_DONE) + { + fprintf(stderr, "INSERT statement '%s' didn't return DONE (ret=%d): %s\n", sql, ret, sqlite3_errmsg(db)); + goto gdcsi_exit; + } + + sqlite3_finalize(stmt); + + result = true; + + gdcsi_exit: + + free(sql); + + printf("INSERT ? %d\n", result); + + return result; + +} + + + + +/* ---------------------------------------------------------------------------------- */ +/* CREATION DE L'ABSTRACTION POUR COLLECTIONS */ /* ---------------------------------------------------------------------------------- */ diff --git a/src/analysis/db/collection.h b/src/analysis/db/collection.h index 75ee7df..b400820 100644 --- a/src/analysis/db/collection.h +++ b/src/analysis/db/collection.h @@ -26,6 +26,8 @@ #include <glib-object.h> +#include <sqlite3.h> +#include <stdbool.h> #include <stdint.h> @@ -52,7 +54,7 @@ typedef struct _GDbCollectionClass GDbCollectionClass; GType g_db_collection_get_type(void); /* Prépare la mise en place d'une nouvelle collection. */ -GDbCollection *g_db_collection_new(uint32_t, GType); +GDbCollection *g_db_collection_new(uint32_t, GType, const char *); @@ -63,7 +65,7 @@ uint32_t g_db_collection_get_feature(const GDbCollection *); /* Réceptionne et traite une requête réseau pour collection. */ -bool g_db_collection_recv(GDbCollection *, int); +bool g_db_collection_recv(GDbCollection *, int, sqlite3 *); /* Envoie pour traitement une requête réseau pour collection. */ bool g_db_collection_send(GDbCollection *, int, DBAction, GDbItem *); diff --git a/src/analysis/db/item-int.h b/src/analysis/db/item-int.h index b6d8f9c..0f75ed4 100644 --- a/src/analysis/db/item-int.h +++ b/src/analysis/db/item-int.h @@ -32,12 +32,20 @@ + + + + + /* Importe la définition d'une base d'éléments pour collection. */ typedef bool (* recv_db_item_fc) (GDbItem *, int, int); /* Exporte la définition d'une base d'éléments pour collection. */ typedef bool (* send_db_item_fc) (const GDbItem *, int, int); +/* Constitue les champs destinés à une insertion / modification. */ +typedef bool (* prepare_db_statement) (const GDbItem *, bool, bound_value **, size_t *); + /* Base d'un élément pour collection générique (instance) */ struct _GDbItem @@ -61,6 +69,8 @@ struct _GDbItemClass recv_db_item_fc recv; /* Réception depuis le réseau */ send_db_item_fc send; /* Emission depuis le réseau */ + prepare_db_statement prepare_stmt; /* Préparation d'une requête */ + }; diff --git a/src/analysis/db/item.c b/src/analysis/db/item.c index e2fd7f3..7fa1a52 100644 --- a/src/analysis/db/item.c +++ b/src/analysis/db/item.c @@ -24,8 +24,13 @@ #include "item.h" +#include <malloc.h> +#include <sqlite3.h> + + #include "item-int.h" #include "../../common/io.h" +#include "../../core/params.h" @@ -52,6 +57,13 @@ static bool g_db_item_send_to_fd(const GDbItem *, int, int); +/* --------------------- MANIPULATIONS AVEC UNE BASE DE DONNEES --------------------- */ + + +/* Constitue les champs destinés à une insertion / modification. */ +static bool _g_db_item_prepare_db_statement(const GDbItem *, bool, bound_value **, size_t *); + + /* Indique le type défini pour une base d'élément de collection générique. */ G_DEFINE_TYPE(GDbItem, g_db_item, G_TYPE_OBJECT); @@ -83,6 +95,8 @@ static void g_db_item_class_init(GDbItemClass *klass) klass->recv = (recv_db_item_fc)g_db_item_recv_from_fd; klass->send = (send_db_item_fc)g_db_item_send_to_fd; + klass->prepare_stmt = (prepare_db_statement)_g_db_item_prepare_db_statement; + } @@ -354,3 +368,82 @@ bool g_db_item_is_volatile(const GDbItem *item) return item->is_volatile; } + + + +/* ---------------------------------------------------------------------------------- */ +/* MANIPULATIONS AVEC UNE BASE DE DONNEES */ +/* ---------------------------------------------------------------------------------- */ + + +/****************************************************************************** +* * +* Paramètres : item = base d'éléments sur laquelle s'appuyer. * +* create = indique si la préparation vise une création ou non. * +* values = couples de champs et de valeurs à lier. [OUT] * +* count = nombre de ces couples. [OUT] * +* * +* Description : Constitue les champs destinés à une insertion / modification.* +* * +* Retour : Bilan de l'opération : succès ou non. * +* * +* Remarques : - * +* * +******************************************************************************/ + +static bool _g_db_item_prepare_db_statement(const GDbItem *item, bool create, bound_value **values, size_t *count) +{ + char *author; /* Identification à diffuser */ + bound_value *value; /* Valeur à éditer / définir */ + + if (!g_generic_config_get_value(get_main_configuration(), MPK_AUTHOR_NAME, &author)) + return false; + + *values = (bound_value *)realloc(*values, ++(*count) * sizeof(bound_value)); + value = &(*values)[*count - 1]; + + value->name = "user"; + value->type = SQLITE_TEXT; + value->string = author; + value->delete = free; + + if (!create) + { + *values = (bound_value *)realloc(*values, ++(*count) * sizeof(bound_value)); + value = &(*values)[*count - 1]; + + value->name = "modified"; + value->type = SQLITE_RAW; + value->string = "CURRENT_TIMESTAMP"; + value->delete = SQLITE_STATIC; + + } + + return true; + +} + + +/****************************************************************************** +* * +* Paramètres : item = base d'éléments sur laquelle s'appuyer. * +* create = indique si la préparation vise une création ou non. * +* values = couples de champs et de valeurs à lier. [OUT] * +* count = nombre de ces couples. [OUT] * +* * +* Description : Constitue les champs destinés à une insertion / modification.* +* * +* Retour : Bilan de l'opération : succès ou non. * +* * +* Remarques : - * +* * +******************************************************************************/ + +bool g_db_item_prepare_db_statement(const GDbItem *item, bool create, bound_value **values, size_t *count) +{ + *values = NULL; + *count = 0; + + return G_DB_ITEM_GET_CLASS(item)->prepare_stmt(item, create, values, count); + +} diff --git a/src/analysis/db/item.h b/src/analysis/db/item.h index 3938610..2f8ee60 100644 --- a/src/analysis/db/item.h +++ b/src/analysis/db/item.h @@ -29,6 +29,9 @@ #include <stdbool.h> +#include "../../common/sqlite.h" + + #define G_TYPE_DB_ITEM g_db_item_get_type() #define G_DB_ITEM(obj) (G_TYPE_CHECK_INSTANCE_CAST((obj), g_db_item_get_type(), GDbItem)) @@ -65,4 +68,19 @@ bool g_db_item_is_volatile(const GDbItem *); +/* --------------------- MANIPULATIONS AVEC UNE BASE DE DONNEES --------------------- */ + + +/* Définition du tronc commun pour les créations SQLite */ +#define SQLITE_DB_ITEM_CREATE \ + "user TEXT, " \ + "created TIMESTAMP DEFAULT CURRENT_TIMESTAMP, " \ + "modified TIMESTAMP DEFAULT CURRENT_TIMESTAMP, " + + +/* Constitue les champs destinés à une insertion / modification. */ +bool g_db_item_prepare_db_statement(const GDbItem *, bool, bound_value **, size_t *); + + + #endif /* _ANALYSIS_DB_ITEM_H */ diff --git a/src/analysis/db/items/bookmark.c b/src/analysis/db/items/bookmark.c index c28a837..6ff386c 100644 --- a/src/analysis/db/items/bookmark.c +++ b/src/analysis/db/items/bookmark.c @@ -75,6 +75,9 @@ static bool g_db_bookmark_recv_from_fd(GDbBookmark *, int, int); /* Exporte la définition d'un signet dans un flux réseau. */ static bool g_db_bookmark_send_to_fd(const GDbBookmark *, int, int); +/* Constitue les champs destinés à une insertion / modification. */ +static bool g_db_bookmark_prepare_db_statement(const GDbBookmark *, bool, bound_value **, size_t *); + @@ -97,10 +100,8 @@ bool create_bookmark_db_table(sqlite3 *db) char *msg; /* Message d'erreur */ sql = "CREATE TABLE Bookmarks (" \ - "id INT PRIMARY KEY NOT NULL, " \ - "user TEXT NOT NULL, " \ - "created INT NOT NULL, " \ - "address INT NOT NULL, " \ + SQLITE_DB_ITEM_CREATE \ + SQLITE_VMPA_CREATE \ "comment TEXT" \ ");"; @@ -157,6 +158,8 @@ static void g_db_bookmark_class_init(GDbBookmarkClass *klass) item->recv = (recv_db_item_fc)g_db_bookmark_recv_from_fd; item->send = (send_db_item_fc)g_db_bookmark_send_to_fd; + item->prepare_stmt = (prepare_db_statement)g_db_bookmark_prepare_db_statement; + } @@ -235,13 +238,7 @@ GDbBookmark *g_db_bookmark_new(const vmpa2t *addr, const char *comment) result = g_object_new(G_TYPE_DB_BOOKMARK, NULL); - - - - /* TODO */ - - //dup addr; - + copy_vmpa(&result->addr, addr); g_db_bookmark_set_comment(result, comment); @@ -351,6 +348,46 @@ static bool g_db_bookmark_send_to_fd(const GDbBookmark *bookmark, int fd, int fl } +/****************************************************************************** +* * +* Paramètres : item = base d'éléments sur laquelle s'appuyer. * +* create = indique si la préparation vise une création ou non. * +* values = couples de champs et de valeurs à lier. [OUT] * +* count = nombre de ces couples. [OUT] * +* * +* Description : Constitue les champs destinés à une insertion / modification.* +* * +* Retour : Etat du besoin en sauvegarde. * +* * +* Remarques : - * +* * +******************************************************************************/ + +static bool g_db_bookmark_prepare_db_statement(const GDbBookmark *bookmark, bool create, bound_value **values, size_t *count) +{ + bool status; /* Bilan d'opération initiale */ + bound_value *value; /* Valeur à éditer / définir */ + + status = G_DB_ITEM_CLASS(g_db_bookmark_parent_class)->prepare_stmt(G_DB_ITEM(bookmark), create, values, count); + if (!status) return false; + + status = prepare_vmpa_db_statement(&bookmark->addr, create, values, count); + if (!status) return false; + + *values = (bound_value *)realloc(*values, ++(*count) * sizeof(bound_value)); + value = &(*values)[*count - 1]; + + value->name = "comment"; + value->type = SQLITE_TEXT; + value->cstring = g_db_bookmark_get_comment(bookmark); + value->delete = SQLITE_STATIC; + + return true; + +} + + + @@ -370,7 +407,7 @@ static bool g_db_bookmark_send_to_fd(const GDbBookmark *bookmark, int fd, int fl * * ******************************************************************************/ -vmpa2t *g_db_bookmark_get_address(GDbBookmark *bookmark) +const vmpa2t *g_db_bookmark_get_address(GDbBookmark *bookmark) { return &bookmark->addr; diff --git a/src/analysis/db/items/bookmark.h b/src/analysis/db/items/bookmark.h index d1b073c..cd5e202 100644 --- a/src/analysis/db/items/bookmark.h +++ b/src/analysis/db/items/bookmark.h @@ -66,7 +66,7 @@ GType g_db_bookmark_get_type(void); GDbBookmark *g_db_bookmark_new(const vmpa2t *, const char *); /* Fournit l'adresse associée à un signet. */ -vmpa2t *g_db_bookmark_get_address(GDbBookmark *); +const vmpa2t *g_db_bookmark_get_address(GDbBookmark *); /* Fournit le commentaire associé à un signet. */ const char *g_db_bookmark_get_comment(const GDbBookmark *); diff --git a/src/analysis/db/protocol.h b/src/analysis/db/protocol.h index 05b559e..85d44cb 100644 --- a/src/analysis/db/protocol.h +++ b/src/analysis/db/protocol.h @@ -113,6 +113,7 @@ typedef enum _DBCommand { DBC_HELO, /* Connexion initiale C -> S */ DBC_WELCOME, /* Réponse initiale S -> C */ + DBC_SAVE, /* Enregistrement de l'archive */ DBC_COLLECTION, /* Implication d'une collection*/ DBC_COUNT @@ -132,6 +133,8 @@ typedef enum _DBError { DBE_NONE, /* Succès d'une opération */ DBE_WRONG_VERSION, /* Proto Client != Serveur */ + DBE_SYS_ERROR, /* Erreur suite à un appel sys.*/ + DBE_ARCHIVE_ERROR, /* Soucis du côté libarchive */ DBE_COUNT @@ -141,6 +144,30 @@ typedef enum _DBError +/** + * Gestion de la commande 'DBC_SAVE'. + * + * Le client connecté envoie un paquet de la forme suivante : + * + * [ Ordre de sauvegarde : DBC_SAVE ] + * + * Le serveur s'exécute et renvoie un bilan : + * + * [ Ordre de sauvegarde : DBC_SAVE ] + * [ Statut d'exécution ; cf. DBError ] + * + * Les traitements se réalisent dans : + * - g_db_client_save() pour la partie client en émission. + * - g_cdb_archive_process() pour la partie serveur. + * - g_db_client_update() pour la partie client en réception. + * + */ + + + + + + |