bcfbeaac80
On macos (darwin), sqlite3 is embedded using "the amalgamation". There is therefore no need to link to the system sqlite3, and doing so can cause unexpected behaviour/failures. Also be explicit about darwin vs. non-darwin port_specs sources. rebar3 seems to get confused when compiling under eunit command sometimes
126 lines
3.7 KiB
C
126 lines
3.7 KiB
C
// cl.exe defines macro _WIN32, but erl_interface.h checks for __WIN32__
|
|
#ifdef _WIN32
|
|
#define __WIN32__
|
|
#endif
|
|
|
|
#define _CRT_SECURE_NO_WARNINGS // secure functions aren't cross-platform
|
|
#define ERLANG_SQLITE3_LOAD_EXTENSION // comment out if SQLite is built with SQLITE_OMIT_LOAD_EXTENSION
|
|
|
|
#include <erl_driver.h>
|
|
#include <ei.h>
|
|
#include <sqlite3.h>
|
|
#include <stdio.h>
|
|
#include <ctype.h>
|
|
#include <string.h>
|
|
#include <assert.h>
|
|
|
|
#if SQLITE_VERSION_NUMBER < 3006001
|
|
#error "SQLite3 of version 3.6.1 minumum required"
|
|
#endif
|
|
|
|
// pre-R15B
|
|
#if ERL_DRV_EXTENDED_MAJOR_VERSION < 2
|
|
typedef int ErlDrvSizeT;
|
|
typedef int ErlDrvSSizeT;
|
|
#endif
|
|
|
|
// pre-R16B
|
|
#if (ERL_DRV_EXTENDED_MAJOR_VERSION < 2) || ((ERL_DRV_EXTENDED_MAJOR_VERSION == 2) && (ERL_DRV_EXTENDED_MINOR_VERSION == 0))
|
|
#define PRE_R16B
|
|
#endif
|
|
|
|
#if defined(_MSC_VER)
|
|
#pragma warning(disable: 4201)
|
|
#pragma warning(disable: 4127)
|
|
#pragma warning(disable: 4820)
|
|
#endif
|
|
|
|
// Binary commands between Erlang VM and Driver
|
|
#define CMD_SQL_EXEC 2
|
|
// #define CMD_DEL 3
|
|
#define CMD_SQL_BIND_AND_EXEC 4
|
|
#define CMD_PREPARE 5
|
|
#define CMD_PREPARED_BIND 6
|
|
#define CMD_PREPARED_STEP 7
|
|
#define CMD_PREPARED_RESET 8
|
|
#define CMD_PREPARED_CLEAR_BINDINGS 9
|
|
#define CMD_PREPARED_FINALIZE 10
|
|
#define CMD_PREPARED_COLUMNS 11
|
|
#define CMD_SQL_EXEC_SCRIPT 12
|
|
#define CMD_ENABLE_LOAD_EXTENSION 13
|
|
#define CMD_CHANGES 14
|
|
|
|
typedef struct ptr_list {
|
|
void *head;
|
|
struct ptr_list *tail;
|
|
} ptr_list;
|
|
|
|
// Define struct to hold state across calls
|
|
typedef struct sqlite3_drv_t {
|
|
ErlDrvPort port;
|
|
unsigned int key;
|
|
struct sqlite3 *db;
|
|
char* db_name;
|
|
FILE *log;
|
|
sqlite3_stmt **prepared_stmts;
|
|
unsigned int prepared_count;
|
|
unsigned int prepared_alloc;
|
|
ErlDrvTermData atom_blob;
|
|
ErlDrvTermData atom_error;
|
|
ErlDrvTermData atom_columns;
|
|
ErlDrvTermData atom_rows;
|
|
ErlDrvTermData atom_null;
|
|
ErlDrvTermData atom_rowid;
|
|
ErlDrvTermData atom_ok;
|
|
ErlDrvTermData atom_done;
|
|
ErlDrvTermData atom_unknown_cmd;
|
|
} sqlite3_drv_t;
|
|
|
|
typedef enum async_sqlite3_command_type {t_stmt, t_script} async_sqlite3_command_type;
|
|
|
|
typedef struct async_sqlite3_command {
|
|
sqlite3_drv_t *driver_data;
|
|
async_sqlite3_command_type type;
|
|
union {
|
|
sqlite3_stmt *statement;
|
|
struct {
|
|
char *script;
|
|
char *end;
|
|
};
|
|
};
|
|
ErlDrvTermData *dataset;
|
|
int term_count;
|
|
int term_allocated;
|
|
int row_count;
|
|
ptr_list *ptrs;
|
|
ptr_list *binaries;
|
|
int finalize_statement_on_free;
|
|
int error_code;
|
|
} async_sqlite3_command;
|
|
|
|
|
|
static ErlDrvData start(ErlDrvPort port, char* cmd);
|
|
static void stop(ErlDrvData handle);
|
|
static ErlDrvSSizeT control(ErlDrvData drv_data, unsigned int command, char *buf,
|
|
ErlDrvSizeT len, char **rbuf, ErlDrvSizeT rlen);
|
|
static int sql_exec(sqlite3_drv_t *drv, char *buf, int len);
|
|
static int sql_bind_and_exec(sqlite3_drv_t *drv, char *buf, int len);
|
|
static int sql_exec_script(sqlite3_drv_t *drv, char *buf, int len);
|
|
static int prepare(sqlite3_drv_t *drv, char *buf, int len);
|
|
static int prepared_bind(sqlite3_drv_t *drv, char *buf, int len);
|
|
static int prepared_step(sqlite3_drv_t *drv, char *buf, int len);
|
|
static int prepared_reset(sqlite3_drv_t *drv, char *buf, int len);
|
|
static int prepared_clear_bindings(sqlite3_drv_t *drv, char *buf, int len);
|
|
static int prepared_finalize(sqlite3_drv_t *drv, char *buf, int len);
|
|
static int prepared_columns(sqlite3_drv_t *drv, char *buf, int len);
|
|
static void sql_exec_async(void *async_command);
|
|
static void sql_free_async(void *async_command);
|
|
static void ready_async(ErlDrvData drv_data, ErlDrvThreadData thread_data);
|
|
static int unknown(sqlite3_drv_t *bdb_drv, char *buf, int len);
|
|
static int enable_load_extension(sqlite3_drv_t *drv, char *buf, int len);
|
|
static int changes(sqlite3_drv_t *drv, char *buf, int len);
|
|
|
|
#if defined(_MSC_VER)
|
|
#pragma warning(default: 4201)
|
|
#endif
|