LibSDB/shsql_driver.c at master · UlricE/LibSDB · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
/*
   Copyright (C) 2000-2008  Ulric Eriksson <ulric@siag.nu>

   This library is free software; you can redistribute it and/or
   modify it under the terms of the GNU Library General Public
   License as published by the Free Software Foundation; either
   version 2 of the Licence, or (at your option) any later version.

   This library 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
   Library General Public License for more details.

   You should have received a copy of the GNU Library General Public
   License along with this library; if not, write to the Free Software
   Foundation, Inc., 59 Temple Place - Suite 330, Boston,
   MA 02111-1307, USA.
 */

#ifdef HAVE_LIBSHSQL

/* Highly experimental! */

#include <stdio.h>
#include <stdlib.h>
#include "common.h"
#include "sdb.h"

extern int SHSQL_allconfig(void);
extern int SHSQL_sql( int dbc, char *sql );
extern int SHSQL_getrow( int dbc, char *fields[], int *n );

static void shsql_error(int code)
{
	switch (code) {
	case 0:
		fprintf(stderr, "Success [0]\n");
		break;
	case 1:
		fprintf(stderr, "Requested record not found [1]\n");
		break;
	case 7:
		fprintf(stderr, "Record locked [7]\n");
		break;
	case 9:
		fprintf(stderr, "The table is write-locked [9]\n");
		break;
	case 20:
		fprintf(stderr, "Attempt to update read-only database [20]\n");
		break;
	default:
		fprintf(stderr, "Other error [%d]\n", code);
		break;
	}
}

/* Parameters:
   pdb = pointer to previously opened database connection, or NULL
   d = url string
   q = query string
   callback = function to send the data to
   closure = pointer to data passed from application
*/
static int shsql_driver(void *pdb, char *d, char *q,
	int (*callback)(int, char **, void *), void *closure)
{
	char *channel;
	char *fields[80];
	int i, n, nfields, dbc;

        channel = sdb_url_value(d, "dbc");
	if (channel) {
		dbc = atoi(channel);
	} else {
		dbc = 0;
	}

	n = SHSQL_sql(dbc, q);
	if (n != 0) {
		shsql_error(n);
		return -1;
	}

	i = 0;
	while (SHSQL_getrow(dbc, fields, &nfields) == 0) {
		(*callback)(nfields, fields, closure);
		i++;
	}

	return i;
}

void sdb_init_shsql(void)
{
	int n = SHSQL_allconfig();
	if (n) shsql_error(n);
	sdb_register_driver("shsql", shsql_driver,
		NULL, NULL);
}

#else

void sdb_init_shsql(void)
{
	;
}

#endif	/* SHSQL */