db_sqlite2.c

/*
 *  
 *  
 *  Copyright (C) 2010  Dennis Schafroth <dennis@schafroth.com>>
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 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 General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

#include "db_api.h"
#ifndef defined(HAVE_LIBSQLITE)
/* dummy function to implement a open that fails */
int db_sqlite2_open(const char *file, db_conn_p *conn_p) {
  return DB_ERROR;
}
#else 

#include <sqlite.h>
#include <stdio.h>
#include <stdarg.h>
#include <stdlib.h>
#include <unistd.h>
#include <signal.h>
#include <time.h>
#include "db_sqlite.h"

int db_sqlite2_open(const char *file, db_conn_p *conn_p)
{
  sqlite *db = sqlite_open(file, 0, 0);
  if ( db == 0 ) {
    return DB_ERROR;
  };
  db_conn_p conn = calloc(1, sizeof(*conn));
  *conn_p = conn;
  conn->private = db;
  conn->close = db_sqlite2_close;
  conn->exec = db_sqlite2_exec;
  conn->prepare = db_sqlite2_prepare;
  conn->errmsg  = NULL;
  return rc;
}

void db_sqlite2_close(db_conn_p conn)
{
  if (!conn)
    return;
  if (!conn->private) 
    return;
  sqlite_close(conn->private);
  conn->private = 0;
}

const char *db_sqlite2_errmsg(db_conn_p conn)
{
  if (!conn)
    return "(no connection)";
  if (!conn->private)
    return "(no private data in conn)";
  return sqlite_errmsg(conn->private);
}

int db_sqlite2_exec(db_conn_p conn, const char *sql) {
  int rc;
  if (!conn) 
    return DB_NO_CONNECTION; 

  if (!conn->private) {
    /* added error element */
    return DB_NO_CONNECTION_REAL;
  }
  rc = sqlite2_exec(conn->private, sql, 0, 0, 0);
  /* On error parse, create DB ERROR element */
  return rc;
}

int db_sqlite2_prepare(db_conn_p conn, const char *sql, db_stmt_p *stmt_p, char **pptail) {
  int rc;
  if (!conn)
    return DB_NO_CONNECTION;

  if (!conn->private) {
    /* added error element */
    return DB_NO_CONNECTION_REAL;
  }
  db_stmt_p stmt = malloc(sizeof(*stmt));
  sqlite_stmt *sqlite_stmt = 0;
  rc = sqlite_compile(db, sql, 0, &sqlite_stmt, 0);
  if (rc != SQLITE_OK)
    return 0;
  stmt->private = sqlite_stmt;
  /* TODO error mapping / handling */
  *stmt_p = stmt;
  stmt->get_column_text = db_sqlite2_stmt_get_column_text;
  stmt->get_column_blob = db_sqlite2_stmt_get_column_blob;
  stmt->get_column_int  = db_sqlite2_stmt_get_column_int;
  stmt->next  = db_sqlite2_stmt_next;
  stmt->close = db_sqlite2_stmt_close;
  stmt->db = conn;
  return DB_OK;
}

const char *db_sqlite2_stmt_get_column_text(db_stmt_p stmt, int column) {
  if (!stmt || !stmt->private) {
    return 0;
  }
  sqlite_stmt *sqlite_stmt = stmt->private;
  const char **values = stmt->private2;
  return values[column];
}

const void* db_sqlite2_stmt_get_column_blob(db_stmt_p stmtx, int col) {
       return db_sqlite2_stmt_get_column_text(stmt, col);
}

int db_sqlite2_stmt2_get_column_int(db_stmt_p stmt, int column) {
  sqlite3_stmt *sqlite_stmt = stmt->private;
  const char **values = stmt->private2;
  const char *str_value = values[column];
  int value = 0;
  if (value) 
    value = atoi(str_value);
  /* TODO missing way to return error  */
  return value;
}


int db_sqlite2_stmt_next(db_stmt_p stmt)
{
  sqlite_stmt *sqlite_stmt = stmt->private;
  const char **dataSQL_V, **dataSQL_N; 
  const char **values; 
  const char **names; 
  int rc = sqlite_step(vm, pN, &values, &names);
  stmt->private = values;
  /* TODO error mapping */ 
  return rc; //  == SQLITE_ROW;
}

int db_sqlite2_stmt_close(db_stmt_p stmt)
{
  sqlite_stmt *sqlite_stmt = stmt->private;
  int rc = sqlite_finalize(sqlite_stmt, 0);
  free(stmt);
  return rc; 
}
#endif