evsql: src/evsql/util.c@7804cd7b5cd5 (annotated)

29 5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	1	#include <assert.h>
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	2
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	3	#include "evsql.h"
31 7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	4	#include "../lib/log.h"
29 5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	5	#include "../lib/misc.h"
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	6
31 7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	7	#define _PARAM_TYPE_CASE(typenam) case EVSQL_PARAM_ ## typenam: return #typenam
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	8
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	9	#define _PARAM_VAL_BUF_MAX 120
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	10	#define _PARAM_VAL_CASE(typenam, ...) case EVSQL_PARAM_ ## typenam: if (param->data_raw) ret = snprintf(buf, _PARAM_VAL_BUF_MAX, __VA_ARGS__); else return "(null)"; break
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	11
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	12	const char evsql_param_type (const struct evsql_query_param param) {
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	13	switch (param->type) {
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	14	_PARAM_TYPE_CASE (INVALID );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	15	_PARAM_TYPE_CASE (NULL_ );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	16	_PARAM_TYPE_CASE (BINARY );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	17	_PARAM_TYPE_CASE (STRING );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	18	_PARAM_TYPE_CASE (UINT16 );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	19	_PARAM_TYPE_CASE (UINT32 );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	20	_PARAM_TYPE_CASE (UINT64 );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	21	default: return "???";
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	22	}
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	23	}
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	24
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	25
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	26	static const char evsql_param_val (const struct evsql_query_param param) {
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	27	static char buf[_PARAM_VAL_BUF_MAX];
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	28	int ret;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	29
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	30	switch (param->type) {
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	31	_PARAM_VAL_CASE (INVALID, "???" );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	32	_PARAM_VAL_CASE (NULL_, "(null)" );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	33	_PARAM_VAL_CASE (BINARY, "%zu:%s", param->length, "..." );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	34	_PARAM_VAL_CASE (STRING, "%s", param->data_raw );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	35	_PARAM_VAL_CASE (UINT16, "%hu", (unsigned short int) ntohs(param->data.uint16) );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	36	_PARAM_VAL_CASE (UINT32, "%lu", (unsigned long int) ntohl(param->data.uint32) );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	37	_PARAM_VAL_CASE (UINT64, "%llu", (unsigned long long int) ntohq(param->data.uint64) );
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	38	default: return "???";
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	39	}
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	40
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	41	return buf;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	42	}
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	43
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	44	int evsql_params_clear (struct evsql_query_params *params) {
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	45	struct evsql_query_param *param;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	46
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	47	for (param = params->list; param->type; param++)
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	48	param->data_raw = NULL;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	49
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	50	return 0;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	51	}
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	52
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	53	int evsql_param_binary (struct evsql_query_params params, size_t param, const char ptr, size_t len) {
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	54	struct evsql_query_param *p = &params->list[param];
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	55
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	56	assert(p->type == EVSQL_PARAM_BINARY);
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	57
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	58	p->data_raw = ptr;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	59	p->length = len;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	60
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	61	return 0;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	62	}
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	63
29 5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	64	int evsql_param_string (struct evsql_query_params params, size_t param, const char ptr) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	65	struct evsql_query_param *p = &params->list[param];
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	66
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	67	assert(p->type == EVSQL_PARAM_STRING);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	68
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	69	p->data_raw = ptr;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	70	p->length = 0;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	71
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	72	return 0;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	73	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	74
31 7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	75	int evsql_param_uint16 (struct evsql_query_params *params, size_t param, uint16_t uval) {
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	76	struct evsql_query_param *p = &params->list[param];
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	77
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	78	assert(p->type == EVSQL_PARAM_UINT16);
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	79
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	80	p->data.uint16 = htons(uval);
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	81	p->data_raw = (const char *) &p->data.uint16;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	82	p->length = sizeof(uval);
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	83
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	84	return 0;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	85	}
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	86
29 5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	87	int evsql_param_uint32 (struct evsql_query_params *params, size_t param, uint32_t uval) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	88	struct evsql_query_param *p = &params->list[param];
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	89
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	90	assert(p->type == EVSQL_PARAM_UINT32);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	91
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	92	p->data.uint32 = htonl(uval);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	93	p->data_raw = (const char *) &p->data.uint32;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	94	p->length = sizeof(uval);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	95
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	96	return 0;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	97	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	98
31 7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	99	void evsql_query_debug (const char sql, const struct evsql_query_params params) {
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	100	const struct evsql_query_param *param;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	101	size_t param_count = 0, idx = 0;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	102
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	103	// count the params
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	104	for (param = params->list; param->type; param++)
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	105	param_count++;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	106
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	107	DEBUG("sql: %s", sql);
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	108	DEBUG("params: %zu", param_count);
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	109
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	110	for (param = params->list; param->type; param++) {
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	111	DEBUG("\t%2zu : %8s = %s", ++idx, evsql_param_type(param), evsql_param_val(param));
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	112	}
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	113	}
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	114
29 5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	115	const char evsql_result_error (const struct evsql_result_info res) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	116	if (!res->error)
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	117	return "No error";
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	118
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	119	switch (res->evsql->type) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	120	case EVSQL_EVPQ:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	121	if (!res->result.pq)
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	122	return "unknown error (no result)";
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	123
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	124	return PQresultErrorMessage(res->result.pq);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	125
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	126	default:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	127	FATAL("res->evsql->type");
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	128	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	129
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	130	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	131
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	132	size_t evsql_result_rows (const struct evsql_result_info *res) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	133	switch (res->evsql->type) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	134	case EVSQL_EVPQ:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	135	return PQntuples(res->result.pq);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	136
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	137	default:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	138	FATAL("res->evsql->type");
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	139	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	140	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	141
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	142	size_t evsql_result_cols (const struct evsql_result_info *res) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	143	switch (res->evsql->type) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	144	case EVSQL_EVPQ:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	145	return PQnfields(res->result.pq);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	146
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	147	default:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	148	FATAL("res->evsql->type");
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	149	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	150	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	151
31 7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	152	int evsql_result_binary (const struct evsql_result_info res, size_t row, size_t col, const char ptr, size_t size, int nullok) {
29 5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	153	*ptr = NULL;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	154
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	155	switch (res->evsql->type) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	156	case EVSQL_EVPQ:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	157	if (PQgetisnull(res->result.pq, row, col)) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	158	if (nullok)
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	159	return 0;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	160	else
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	161	ERROR("[%zu:%zu] field is null", row, col);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	162	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	163
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	164	if (PQfformat(res->result.pq, col) != 1)
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	165	ERROR("[%zu:%zu] PQfformat is not binary: %d", row, col, PQfformat(res->result.pq, col));
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	166
30 d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	167	*size = PQgetlength(res->result.pq, row, col);
d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	168	*ptr = PQgetvalue(res->result.pq, row, col);
29 5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	169
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	170	return 0;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	171
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	172	default:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	173	FATAL("res->evsql->type");
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	174	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	175
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	176	error:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	177	return -1;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	178	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	179
31 7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	180	int evsql_result_binlen (const struct evsql_result_info res, size_t row, size_t col, const char *ptr, size_t size, int nullok) {
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	181	size_t real_size = 0;
30 d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	182
31 7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	183	if (evsql_result_binary(res, row, col, ptr, &real_size, nullok))
30 d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	184	goto error;
31 7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	185
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	186	if (*ptr == NULL) {
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	187	assert(nullok);
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	188	return 0;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	189	}
30 d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	190
d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	191	if (size && real_size != size)
d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	192	ERROR("[%zu:%zu] field size mismatch: %zu -> %zu", row, col, size, real_size);
d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	193
d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	194	return 0;
d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	195
d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	196	error:
d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	197	return -1;
d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	198	}
d8fabd347a8e working open+read+flush+release Tero Marttila <terom@fixme.fi> parents: 29 diff changeset	199
29 5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	200	int evsql_result_string (const struct evsql_result_info res, size_t row, size_t col, const char *ptr, int nullok) {
31 7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	201	size_t real_size;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	202
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	203	if (evsql_result_binary(res, row, col, ptr, &real_size, nullok))
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	204	goto error;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	205
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	206	assert(real_size == strlen(*ptr));
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	207
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	208	return 0;
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	209
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	210	error:
7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	211	return -1;
29 5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	212	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	213
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	214	int evsql_result_uint16 (const struct evsql_result_info res, size_t row, size_t col, uint16_t uval, int nullok) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	215	const char *data;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	216	int16_t sval;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	217
31 7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	218	if (evsql_result_binlen(res, row, col, &data, sizeof(*uval), nullok))
29 5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	219	goto error;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	220
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	221	if (!data)
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	222	return 0;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	223
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	224	sval = ntohs(((int16_t ) data));
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	225
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	226	if (sval < 0)
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	227	ERROR("negative value for unsigned: %d", sval);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	228
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	229	*uval = sval;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	230
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	231	return 0;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	232
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	233	error:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	234	return nullok ? 0 : -1;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	235	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	236
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	237	int evsql_result_uint32 (const struct evsql_result_info res, size_t row, size_t col, uint32_t uval, int nullok) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	238	const char *data;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	239	int32_t sval;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	240
31 7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	241	if (evsql_result_binlen(res, row, col, &data, sizeof(*uval), nullok))
29 5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	242	goto error;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	243
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	244	if (!data)
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	245	return 0;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	246
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	247	sval = ntohl((int32_t ) data);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	248
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	249	if (sval < 0)
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	250	ERROR("negative value for unsigned: %d", sval);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	251
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	252	*uval = sval;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	253
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	254	return 0;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	255
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	256	error:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	257	return nullok ? 0 : -1;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	258	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	259
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	260	int evsql_result_uint64 (const struct evsql_result_info res, size_t row, size_t col, uint64_t uval, int nullok) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	261	const char *data;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	262	int64_t sval;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	263
31 7804cd7b5cd5 write+setattr Tero Marttila <terom@fixme.fi> parents: 30 diff changeset	264	if (evsql_result_binlen(res, row, col, &data, sizeof(*uval), nullok))
29 5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	265	goto error;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	266
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	267	if (!data)
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	268	return 0;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	269
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	270	sval = ntohq((int64_t ) data);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	271
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	272	if (sval < 0)
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	273	ERROR("negative value for unsigned: %ld", sval);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	274
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	275	*uval = sval;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	276
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	277	return 0;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	278
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	279	error:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	280	return nullok ? 0 : -1;
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	281	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	282
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	283	void evsql_result_free (const struct evsql_result_info *res) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	284	switch (res->evsql->type) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	285	case EVSQL_EVPQ:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	286	return PQclear(res->result.pq);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	287
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	288	default:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	289	FATAL("res->evsql->type");
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	290	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	291	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	292
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	293	const char evsql_conn_error (struct evsql_conn conn) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	294	switch (conn->evsql->type) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	295	case EVSQL_EVPQ:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	296	if (!conn->engine.evpq)
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	297	return "unknown error (no conn)";
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	298
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	299	return evpq_error_message(conn->engine.evpq);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	300
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	301	default:
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	302	FATAL("res->evsql->type");
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	303	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	304	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	305
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	306	const char evsql_trans_error (struct evsql_trans trans) {
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	307	if (trans->conn == NULL)
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	308	return "unknown error (no trans conn)";
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	309
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	310	return evsql_conn_error(trans->conn);
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	311	}
5de62ca9a5aa reorganize evsql into a separate dir, rename dbfs slightly, and split dbfs_op out from dirop (in prep for fileop) Tero Marttila <terom@fixme.fi> parents: diff changeset	312

author	Tero Marttila <terom@fixme.fi>
	Fri, 17 Oct 2008 02:04:03 +0300
changeset 31	7804cd7b5cd5
parent 30	d8fabd347a8e
child 34	460f995d3769
permissions	-rw-r--r--