109 lines
2.9 KiB
C
109 lines
2.9 KiB
C
|
#include <stdlib.h>
|
||
|
|
#include <stdio.h>
|
||
|
|
#include <string.h>
|
||
|
|
|
||
|
|
#include "smart_records.h"
|
||
|
|
#include "smart_records_internals.h"
|
||
|
|
|
||
|
|
#ifdef _HAS_MYSQL
|
||
|
|
#include "mysql_backend.h"
|
||
|
|
#endif
|
||
|
|
|
||
|
|
#ifdef _HAS_SQLITE
|
||
|
|
#include "sqlite_backend.h"
|
||
|
|
#endif
|
||
|
|
|
||
|
|
#ifdef _HAS_UDP
|
||
|
|
#include "udp_backend.h"
|
||
|
|
#endif
|
||
|
|
|
||
|
|
#ifdef _HAS_CSV
|
||
|
|
#include "csv_backend.h"
|
||
|
|
#endif
|
||
|
|
|
||
|
|
|
||
|
|
// nothing but give a context for the moment
|
||
|
|
smart_records_ctx_t *smart_records_init(){
|
||
|
|
return malloc(sizeof(smart_records_ctx_t));
|
||
|
|
}
|
||
|
|
|
||
|
|
int smart_records_open_base(smart_records_ctx_t *ctx, char *uri, char **error)
|
||
|
|
{
|
||
|
|
int len_uri;
|
||
|
|
|
||
|
|
if(!uri) {
|
||
|
|
set_error_and_fails("URI is null");
|
||
|
|
}
|
||
|
|
|
||
|
|
len_uri = strlen(uri);
|
||
|
|
if(!strncmp("mysql://", uri, len_uri < 8 ? len_uri : 8)) {
|
||
|
|
#ifdef _HAS_MYSQL
|
||
|
|
ctx->CTX = malloc(sizeof(mysql_backend_ctx_t));
|
||
|
|
ctx->write_record = mysql_backend_write_record;
|
||
|
|
ctx->set_format = mysql_backend_set_format;
|
||
|
|
ctx->close_records_base = mysql_backend_close_records_base;
|
||
|
|
if ( mysql_backend_init(ctx->CTX, error) < 0)
|
||
|
|
goto failed;
|
||
|
|
#else
|
||
|
|
set_error_and_fails("built without support for mysql:// URIs");
|
||
|
|
goto failed;
|
||
|
|
#endif
|
||
|
|
}
|
||
|
|
|
||
|
|
else if(!strncmp("sqlite://", uri, len_uri < 9 ? len_uri : 9)) {
|
||
|
|
#ifdef _HAS_SQLITE
|
||
|
|
ctx->CTX = malloc(sizeof(sqlite_backend_ctx_t));
|
||
|
|
ctx->write_record = sqlite_backend_write_record(char *uri);
|
||
|
|
ctx->close_records_base = sqlite_backend_close_records_base(char *uri);
|
||
|
|
if ( sqlite_backend_init(ctx->CTX, error) < 0)
|
||
|
|
goto failed;
|
||
|
|
#else
|
||
|
|
if(error) *error = strdup("built without support for sqlite:// URIs");
|
||
|
|
goto failed;
|
||
|
|
}
|
||
|
|
#endif
|
||
|
|
|
||
|
|
else if(!strncmp("udp://", uri, len_uri < 8 ? len_uri : 8)) {
|
||
|
|
#ifdef _HAS_UDP
|
||
|
|
ctx->CTX = malloc(sizeof(udp_backend_ctx_t));
|
||
|
|
ctx->write_record = udp_backend_write_record(char *uri);
|
||
|
|
ctx->close_records_base = udp_backend_close_records_base(char *uri);
|
||
|
|
if ( udp_backend_init(ctx->CTX, error) < 0)
|
||
|
|
goto failed;
|
||
|
|
#else
|
||
|
|
if(error) *error = strdup("built without support for udp:// URIs");
|
||
|
|
goto failed;
|
||
|
|
}
|
||
|
|
#endif
|
||
|
|
|
||
|
|
else if(!strncmp("csv://", uri, len_uri < 8 ? len_uri : 8)) {
|
||
|
|
#ifdef _HAS_CSV
|
||
|
|
ctx->CTX = malloc(sizeof(csv_backend_ctx_t));
|
||
|
|
ctx->write_record = csv_backend_write_record(char *uri);
|
||
|
|
ctx->close_records_base = csv_backend_close_records_base(char *uri);
|
||
|
|
if ( csv_backend_init(ctx->CTX, error) < 0)
|
||
|
|
goto failed;
|
||
|
|
#else
|
||
|
|
if(error) *error = strdup("built without suppor fort csv:// URIs");
|
||
|
|
goto failed;
|
||
|
|
#endif
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
if(error) *error = strdup("Unknown scheme or bad URI.");
|
||
|
|
goto failed;
|
||
|
|
}
|
||
|
|
return 0;
|
||
|
|
failed:
|
||
|
|
return -1;
|
||
|
|
}
|
||
|
|
|
||
|
|
int smart_records_close_base(smart_records_ctx_t *ctx)
|
||
|
|
{
|
||
|
|
return ctx->close_records_base(ctx);
|
||
|
|
}
|
||
|
|
|
||
|
|
int smart_records_write(smart_records_ctx_t *ctx, char **error, va_list ap)
|
||
|
|
{
|
||
|
|
return ctx->write_record(ctx, error, ap);
|
||
|
|
}
|