db_result.c
Go to the documentation of this file.
/*
* Copyright (c) 2014 Jerry Lundström <lundstrom.jerry@gmail.com>
* Copyright (c) 2014 .SE (The Internet Infrastructure Foundation).
* Copyright (c) 2014 OpenDNSSEC AB (svb)
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
*
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE
* GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER
* IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
* OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
* IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
*/
#include "db_result.h"
#include "db_error.h"
/* DB RESULT */
db_result_t* db_result_new(void) {
db_result_t* result =
(db_result_t*)calloc(1, sizeof(db_result_t));
return result;
}
/* TODO: unit test */
db_result_t* db_result_new_copy(const db_result_t* from_result) {
db_result_t* result;
if (!from_result) {
return NULL;
}
if ((result = db_result_new())) {
if (db_result_copy(result, from_result)) {
db_result_free(result);
return NULL;
}
}
return result;
}
void db_result_free(db_result_t* result) {
if (result) {
if (result->value_set) {
db_value_set_free(result->value_set);
}
free(result);
}
}
/* TODO: unit test */
int db_result_copy(db_result_t* result, const db_result_t* from_result) {
db_value_set_t* value_set = NULL;
if (!result) {
return DB_ERROR_UNKNOWN;
}
if (!from_result) {
return DB_ERROR_UNKNOWN;
}
if (from_result->value_set
&& !(value_set = db_value_set_new_copy(from_result->value_set)))
{
return DB_ERROR_UNKNOWN;
}
if (result->value_set) {
db_value_set_free(result->value_set);
}
result->value_set = value_set;
return DB_OK;
}
const db_value_set_t* db_result_value_set(const db_result_t* result) {
if (!result) {
return NULL;
}
return result->value_set;
}
int db_result_set_value_set(db_result_t* result, db_value_set_t* value_set) {
if (!result) {
return DB_ERROR_UNKNOWN;
}
if (!value_set) {
return DB_ERROR_UNKNOWN;
}
if (result->value_set) {
return DB_ERROR_UNKNOWN;
}
result->value_set = value_set;
return DB_OK;
}
int db_result_not_empty(const db_result_t* result) {
if (!result) {
return DB_ERROR_UNKNOWN;
}
if (!result->value_set) {
return DB_ERROR_UNKNOWN;
}
return DB_OK;
}
/* DB RESULT LIST */
db_result_list_t* db_result_list_new(void) {
db_result_list_t* result_list =
(db_result_list_t*)calloc(1, sizeof(db_result_list_t));
return result_list;
}
/* TODO: unit test */
db_result_list_t* db_result_list_new_copy(const db_result_list_t* from_result_list) {
db_result_list_t* result_list;
if (!from_result_list) {
return NULL;
}
result_list = (db_result_list_t*)calloc(1, sizeof(db_result_list_t));
if (result_list) {
if (db_result_list_copy(result_list, from_result_list)) {
db_result_list_free(result_list);
return NULL;
}
}
return result_list;
}
void db_result_list_free(db_result_list_t* result_list) {
if (result_list) {
if (result_list->begin) {
db_result_t* this = result_list->begin;
db_result_t* next = NULL;
while (this) {
next = this->next;
db_result_free(this);
this = next;
}
}
if (result_list->next_function) {
(void)result_list->next_function(result_list->next_data, 1);
if (result_list->current) {
db_result_free(result_list->current);
}
}
free(result_list);
}
}
/* TODO: unit test */
int db_result_list_copy(db_result_list_t* result_list, const db_result_list_t* from_result_list) {
db_result_t* result;
db_result_t* result_copy;
if (!result_list) {
return DB_ERROR_UNKNOWN;
}
/*
* TODO: Should we be able to copy into a result list that already contains
* data?
*/
if (result_list->begin) {
return DB_ERROR_UNKNOWN;
}
if (result_list->end) {
return DB_ERROR_UNKNOWN;
}
if (result_list->current) {
return DB_ERROR_UNKNOWN;
}
if (result_list->size) {
return DB_ERROR_UNKNOWN;
}
if (result_list->next_function) {
return DB_ERROR_UNKNOWN;
}
if (!from_result_list) {
return DB_ERROR_UNKNOWN;
}
if (from_result_list->next_function) {
return DB_ERROR_UNKNOWN;
}
result = from_result_list->begin;
while (result) {
if (!(result_copy = db_result_new_copy(result))
|| db_result_list_add(result_list, result_copy))
{
return DB_ERROR_UNKNOWN;
}
if (result == from_result_list->current) {
result_list->current = result_copy;
}
result = result->next;
}
return DB_OK;
}
int db_result_list_set_next(db_result_list_t* result_list, db_result_list_next_t next_function, void* next_data, size_t size) {
if (!result_list) {
return DB_ERROR_UNKNOWN;
}
if (result_list->begin) {
return DB_ERROR_UNKNOWN;
}
if (result_list->next_function) {
return DB_ERROR_UNKNOWN;
}
if (!next_data) {
return DB_ERROR_UNKNOWN;
}
if (result_list->next_data) {
return DB_ERROR_UNKNOWN;
}
result_list->next_function = next_function;
result_list->next_data = next_data;
result_list->size = size;
return 0;
}
int db_result_list_add(db_result_list_t* result_list, db_result_t* result) {
if (!result_list) {
return DB_ERROR_UNKNOWN;
}
if (!result) {
return DB_ERROR_UNKNOWN;
}
if (db_result_not_empty(result)) {
return DB_ERROR_UNKNOWN;
}
if (result->next) {
return DB_ERROR_UNKNOWN;
}
if (result_list->next_function) {
return DB_ERROR_UNKNOWN;
}
if (result_list->begin) {
if (!result_list->end) {
return DB_ERROR_UNKNOWN;
}
result_list->end->next = result;
result_list->end = result;
}
else {
result_list->begin = result;
result_list->end = result;
}
result_list->size++;
return DB_OK;
}
const db_result_t* db_result_list_begin(db_result_list_t* result_list) {
if (!result_list) {
return NULL;
}
if (result_list->next_function) {
/*
* Can not start over a list that uses next function
*/
if (result_list->current) {
return NULL;
}
result_list->current = result_list->next_function(result_list->next_data, 0);
return result_list->current;
}
result_list->current = result_list->begin;
result_list->begun = 1;
return result_list->current;
}
const db_result_t* db_result_list_next(db_result_list_t* result_list) {
if (!result_list) {
return NULL;
}
if (result_list->next_function) {
if (result_list->current) {
db_result_free(result_list->current);
}
result_list->current = result_list->next_function(result_list->next_data, 0);
return result_list->current;
}
if (!result_list->begun) {
result_list->begun = 1;
result_list->current = result_list->begin;
}
else if (result_list->current) {
result_list->current = result_list->current->next;
}
return result_list->current;
}
size_t db_result_list_size(const db_result_list_t* result_list) {
if (!result_list) {
return 0;
}
return result_list->size;
}
int db_result_list_fetch_all(db_result_list_t* result_list) {
db_result_t* result;
db_result_list_next_t next_function;
if (!result_list) {
return DB_ERROR_UNKNOWN;
}
if (result_list->next_function) {
if (result_list->current) {
return DB_ERROR_UNKNOWN;
}
next_function = result_list->next_function;
result_list->next_function = NULL;
result_list->size = 0;
while ((result = next_function(result_list->next_data, 0))) {
if (db_result_list_add(result_list, result)) {
next_function(result_list->next_data, 1);
result_list->next_data = NULL;
db_result_free(result);
return DB_ERROR_UNKNOWN;
}
}
next_function(result_list->next_data, 1);
result_list->next_data = NULL;
}
return DB_OK;
}
db_error.h
DB_ERROR_UNKNOWN
#define DB_ERROR_UNKNOWN
Definition db_error.h:40
DB_OK
#define DB_OK
Definition db_error.h:36
db_result_not_empty
int db_result_not_empty(const db_result_t *result)
Definition db_result.c:120
db_result_list_fetch_all
int db_result_list_fetch_all(db_result_list_t *result_list)
Definition db_result.c:341
db_result_list_add
int db_result_list_add(db_result_list_t *result_list, db_result_t *result)
Definition db_result.c:257
db_result_list_size
size_t db_result_list_size(const db_result_list_t *result_list)
Definition db_result.c:333
db_result_set_value_set
int db_result_set_value_set(db_result_t *result, db_value_set_t *value_set)
Definition db_result.c:105
db_result_list_new
db_result_list_t * db_result_list_new(void)
Definition db_result.c:134
db_result_list_set_next
int db_result_list_set_next(db_result_list_t *result_list, db_result_list_next_t next_function, void *next_data, size_t size)
Definition db_result.c:234
db_result_new
db_result_t * db_result_new(void)
Definition db_result.c:38
db_result_list_next
const db_result_t * db_result_list_next(db_result_list_t *result_list)
Definition db_result.c:310
db_result_free
void db_result_free(db_result_t *result)
Definition db_result.c:63
db_result_list_begin
const db_result_t * db_result_list_begin(db_result_list_t *result_list)
Definition db_result.c:290
db_result_list_free
void db_result_list_free(db_result_list_t *result_list)
Definition db_result.c:160
db_result_copy
int db_result_copy(db_result_t *result, const db_result_t *from_result)
Definition db_result.c:73
db_result_list_new_copy
db_result_list_t * db_result_list_new_copy(const db_result_list_t *from_result_list)
Definition db_result.c:142
db_result_list_copy
int db_result_list_copy(db_result_list_t *result_list, const db_result_list_t *from_result_list)
Definition db_result.c:183
db_result_value_set
const db_value_set_t * db_result_value_set(const db_result_t *result)
Definition db_result.c:97
db_result_new_copy
db_result_t * db_result_new_copy(const db_result_t *from_result)
Definition db_result.c:46
db_result.h
db_result_list_next_t
db_result_t *(* db_result_list_next_t)(void *data, int finish)
Definition db_result.h:47
db_value_set_free
void db_value_set_free(db_value_set_t *value_set)
Definition db_value.c:697
db_value_set_new_copy
db_value_set_t * db_value_set_new_copy(const db_value_set_t *from_value_set)
Definition db_value.c:670
db_result_list
Definition db_result.h:114
db_result_list::begun
int begun
Definition db_result.h:121
db_result_list::begin
db_result_t * begin
Definition db_result.h:115
db_result_list::current
db_result_t * current
Definition db_result.h:117
db_result_list::next_function
db_result_list_next_t next_function
Definition db_result.h:118
db_result_list::next_data
void * next_data
Definition db_result.h:119
db_result_list::end
db_result_t * end
Definition db_result.h:116
db_result_list::size
size_t size
Definition db_result.h:120
db_result
Definition db_result.h:56
db_result::next
db_result_t * next
Definition db_result.h:57
db_result::value_set
db_value_set_t * value_set
Definition db_result.h:58
db_value_set
Definition db_value.h:281