dbutils/sqlite.h

/*
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
 *
 * Copyright 2024 Olaf Wintermann. 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 COPYRIGHT HOLDERS AND CONTRIBUTORS "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 COPYRIGHT HOLDER OR CONTRIBUTORS 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.
 */

#ifdef DBU_SQLITE

#ifndef DBU_SQLITE_H
#define DBU_SQLITE_H

#include "dbutils/sqlite.h"

#ifdef __cplusplus
extern "C" {
#endif

typedef struct DBUSQLiteQuery DBUSQLiteQuery;
typedef struct DBUSQLiteResult DBUSQLiteResult;
    
typedef struct DBUSQLiteConnection {
    DBUConnection connection;
    sqlite3 *db;
    bool autoclose;
} DBUSQLiteConnection;

struct DBUSQLiteQuery {
    DBUQuery query;
    sqlite3 *db;
    sqlite3_stmt *stmt;
    DBUSQLiteResult *result;
    int step;
};

struct DBUSQLiteResult {
    DBUResult result;
    sqlite3_stmt *stmt;
    DBUSQLiteQuery *query;
    int step;
};

DBUQuery* dbuSQLiteConnCreateQuery(DBUConnection *connection, const CxAllocator *a) ;
int dbuSQLiteConnIsActive(DBUConnection *connection);
void dbuSQLiteConnFree(DBUConnection *connection);

int dbuSQLiteQuerySetSQL(DBUQuery *q, const char *sql);
int dbuSQLiteQuerySetParamString(DBUQuery *q, int index, cxstring str);
int dbuSQLiteQuerySetParamInt(DBUQuery *q, int index, int i);
int dbuSQLiteQuerySetParamInt64(DBUQuery *q, int index, int64_t i);
int dbuSQLiteQuerySetParamDouble(DBUQuery *q, int index, double d);
int dbuSQLiteQuerySetParamNull(DBUQuery *q, int index);
int dbuSQLiteQuerySetParamBytes(DBUQuery *q, int index, void *bytes, int len);
int dbuSQLiteQueryExec(DBUQuery *q);
DBUResult* dbuSQLiteQueryGetResult(DBUQuery *q);
int dbuSQLiteQueryReset(DBUQuery *q);
void dbuSQLiteQueryFree(DBUQuery *q);

int dbuSQLiteResultNumFields(DBUResult *result);
int dbuSQLiteResultHasData(DBUResult *result);
int dbuSQLiteResultIsOk(DBUResult *result);
int dbuSQLiteResultNextRow(DBUResult *result);
const char* dbuSQLiteResultFieldName(DBUResult *result, int field);
DBUFieldType dbuSQLiteResultFieldType(DBUResult *result, int field);
int dbuSQLiteResultIsNull(DBUResult *result, int field);
cxstring dbuSQLiteResultGetText(DBUResult *result, int field);
int64_t dbuSQLiteResultGetInt(DBUResult *result, int field);
double dbuSQLiteResultGetDouble(DBUResult *result, int field);
DBUBytes dbuSQLiteResultGetBinary(DBUResult *result, int field);
void dbuSQLiteResultFree(DBUResult *result);

#ifdef __cplusplus
}
#endif

#endif /* DBU_SQLITE_H */

#endif /* DBU_SQLITE */