jdb-internal.h

Go to the documentation of this file.

/*
 * JULEA - Flexible storage framework
 * Copyright (C) 2019 Benjamin Warnke
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
 
#ifndef JULEA_DB_INTERNAL_H
#define JULEA_DB_INTERNAL_H
 
#if !defined(JULEA_DB_H) && !defined(JULEA_DB_COMPILATION)
#error "Only <julea-db.h> can be included directly."
#endif
 
#include <glib.h>
 
#include <bson.h>
 
#include <julea.h>
 
#include <db-util/jbson.h>
 
#include <db/jdb-entry.h>
#include <db/jdb-iterator.h>
#include <db/jdb-schema.h>
#include <db/jdb-selector.h>
 
G_BEGIN_DECLS
 
struct JDBEntry
{
    bson_t bson;
    bson_t id;
 
    JDBSchema* schema;
 
    gint ref_count;
};
 
struct JDBIterator
{
    bson_t bson;
 
    JDBSchema* schema;
    JDBSelector* selector;
 
    gpointer iterator;
 
    gint ref_count;
 
    gboolean valid;
    gboolean bson_valid;
};
 
struct JDBSchemaIndex
{
    GHashTable* variables;
 
    guint variable_count;
};
 
struct JDBSchema
{
    bson_t bson;
    bson_t bson_index;
 
    GHashTable* variables; //contains char*
    GArray* index; //contains GHashTable * which contain char*
 
    gchar* namespace;
    gchar* name;
 
    guint bson_index_count;
    gint ref_count;
 
    gboolean bson_initialized;
    gboolean bson_index_initialized;
    gboolean server_side;
};
 
struct JDBSelector
{
    bson_t selection; 
    bson_t joins; 
 
    bson_t final;
 
    gboolean final_valid; 
 
    JDBSelectorMode mode;
    JDBSchema* schema; 
 
    GHashTable* join_schema; 
 
    guint selection_count; 
    gint ref_count;
};
 
// Client-side wrappers for backend functions
gboolean j_db_internal_schema_create(JDBSchema* j_db_schema, JBatch* batch, GError** error);
gboolean j_db_internal_schema_get(JDBSchema* j_db_schema, JBatch* batch, GError** error);
gboolean j_db_internal_schema_delete(JDBSchema* j_db_schema, JBatch* batch, GError** error);
gboolean j_db_internal_insert(JDBEntry* j_db_entry, JBatch* batch, GError** error);
gboolean j_db_internal_update(JDBEntry* j_db_entry, JDBSelector* j_db_selector, JBatch* batch, GError** error);
gboolean j_db_internal_delete(JDBEntry* j_db_entry, JDBSelector* j_db_selector, JBatch* batch, GError** error);
gboolean j_db_internal_query(JDBSchema* j_db_schema, JDBSelector* j_db_selector, JDBIterator* j_db_iterator, JBatch* batch, GError** error);
gboolean j_db_internal_iterate(JDBIterator* j_db_iterator, GError** error);
 
// Client-side additional internal functions
 
bson_t* j_db_selector_get_bson(JDBSelector* selector);
 
gboolean j_db_selector_finalize(JDBSelector* selector, GError** error);
 
G_GNUC_INTERNAL JBackend* j_db_get_backend(void);
 
G_END_DECLS
 
#endif