blackbeard420/kore
1
0
Fork 0
mirror of https://github.com/jorisvink/kore synced 2025-03-10 13:09:02 -04:00
Code Issues Projects Releases Wiki Activity
kore/includes/pgsql.h

77 lines
2.1 KiB
C
Raw Normal View History

Initial stab at entering postgresql contrib code. Has support for full async pgsql queries. Most of the logic is hidden behind a KORE_PGSQL() macro allowing you to insert these pgsql calls in your page handlers without blocking the kore worker while the query is going off. There is place for improvement here, and perhaps KORE_PGSQL won't stay as I feel this might overcomplicate things instead of making them simpler as I thought it would.
2014-03-30 23:54:35 +02:00
/*
* Copyright (c) 2014 Joris Vink <joris@coders.se>
*
* Permission to use, copy, modify, and distribute this software for any
* purpose with or without fee is hereby granted, provided that the above
* copyright notice and this permission notice appear in all copies.
*
* THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
* MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
* ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
* ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
* OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
*/
#ifndef _H_KORE_PGSQL
#define _H_KORE_PGSQL
#include <libpq-fe.h>
Add kore_pgsql_query_params(). This function uses PQsendQueryParams() instead of the normal PQsendQuery() allowing you to pass binary data in a cleaner fashion. A basic call would look something like: char *mydata = "Hello"; size_t mydata_len = strlen(mydata); kore_pgsql_query_params(&pgsql, req, "INSERT INTO foo VALUES($1::text)", KORE_PGSQL_FORMAT_TEXT, 1 mydata, mydata_len, KORE_PGSQL_FORMAT_TEXT); kore_pgsql_query_params() is variadic, allowing you to pass any count of parameters where each parameter has the following: data pointer, data length, type of parameter.
2014-09-28 21:39:16 +02:00
#define KORE_PGSQL_FORMAT_TEXT 0
#define KORE_PGSQL_FORMAT_BINARY 1
Add __cplusplus macros to headers.
2015-04-01 07:25:10 -04:00
#if defined(__cplusplus)
extern "C" {
#endif
Major pgsql rework. Gone is the ugly KORE_PGSQL macro that hid an overly complex state machine for the pgsql api. Gone is the pgsql array that was attached to http_requests. Gone are the callback hacks inside the pgsql api. Instead, I strongly encourage people to use the new state machine api Kore offers to properly deal with asynchronous queries. The pgsql example in examples/pgsql has been updated to reflect these changes.
2014-08-14 14:34:23 +02:00
struct pgsql_conn {
u_int8_t type;
u_int8_t flags;
PGconn *db;
struct pgsql_job *job;
TAILQ_ENTRY(pgsql_conn) list;
};
Initial stab at entering postgresql contrib code. Has support for full async pgsql queries. Most of the logic is hidden behind a KORE_PGSQL() macro allowing you to insert these pgsql calls in your page handlers without blocking the kore worker while the query is going off. There is place for improvement here, and perhaps KORE_PGSQL won't stay as I feel this might overcomplicate things instead of making them simpler as I thought it would.
2014-03-30 23:54:35 +02:00
struct kore_pgsql {
u_int8_t state;
char *error;
PGresult *result;
Major pgsql rework. Gone is the ugly KORE_PGSQL macro that hid an overly complex state machine for the pgsql api. Gone is the pgsql array that was attached to http_requests. Gone are the callback hacks inside the pgsql api. Instead, I strongly encourage people to use the new state machine api Kore offers to properly deal with asynchronous queries. The pgsql example in examples/pgsql has been updated to reflect these changes.
2014-08-14 14:34:23 +02:00
struct pgsql_conn *conn;
Attach tasks/pgsqls to http_requests once more. This way if an http request is removed while tasks or pgsqls are still active they are free'd out and cancelled properly.
2014-08-14 22:05:34 +02:00
LIST_ENTRY(kore_pgsql) rlist;
Initial stab at entering postgresql contrib code. Has support for full async pgsql queries. Most of the logic is hidden behind a KORE_PGSQL() macro allowing you to insert these pgsql calls in your page handlers without blocking the kore worker while the query is going off. There is place for improvement here, and perhaps KORE_PGSQL won't stay as I feel this might overcomplicate things instead of making them simpler as I thought it would.
2014-03-30 23:54:35 +02:00
};
Add pgsql_conn_max configuration parameter. Allows you to tune how many pgsql connections kore will make at one time.
2014-07-04 09:14:05 +02:00
extern u_int16_t pgsql_conn_max;
extern char *pgsql_conn_string;
Make the pgsql connstring programmatically configurable
2014-04-14 08:41:41 +02:00
Add a new "simple query" layer to our pgsql api. This simple query allows you to ditch rolling your own state machine for handling async pgsql states and instead asks you to provide 3 functions: - init - results - done You can see the different in complexity in the pgsql example, which now contains a pgsql_simple.c holding the same asynchronous query as in pgsql.c but using the simple pgsql api. You can of course still roll your own in case you want more control.
2014-09-19 12:32:49 +02:00
void kore_pgsql_init(void);
void kore_pgsql_handle(void *, int);
void kore_pgsql_cleanup(struct kore_pgsql *);
void kore_pgsql_continue(struct http_request *, struct kore_pgsql *);
Add kore_pgsql_query_params(). This function uses PQsendQueryParams() instead of the normal PQsendQuery() allowing you to pass binary data in a cleaner fashion. A basic call would look something like: char *mydata = "Hello"; size_t mydata_len = strlen(mydata); kore_pgsql_query_params(&pgsql, req, "INSERT INTO foo VALUES($1::text)", KORE_PGSQL_FORMAT_TEXT, 1 mydata, mydata_len, KORE_PGSQL_FORMAT_TEXT); kore_pgsql_query_params() is variadic, allowing you to pass any count of parameters where each parameter has the following: data pointer, data length, type of parameter.
2014-09-28 21:39:16 +02:00
int kore_pgsql_query(struct kore_pgsql *, struct http_request *,
const char *);
int kore_pgsql_query_params(struct kore_pgsql *, struct http_request *,
const char *, int, u_int8_t, ...);
Add a new "simple query" layer to our pgsql api. This simple query allows you to ditch rolling your own state machine for handling async pgsql states and instead asks you to provide 3 functions: - init - results - done You can see the different in complexity in the pgsql example, which now contains a pgsql_simple.c holding the same asynchronous query as in pgsql.c but using the simple pgsql api. You can of course still roll your own in case you want more control.
2014-09-19 12:32:49 +02:00
int kore_pgsql_ntuples(struct kore_pgsql *);
void kore_pgsql_logerror(struct kore_pgsql *);
void kore_pgsql_queue_remove(struct http_request *);
char *kore_pgsql_getvalue(struct kore_pgsql *, int, int);
Add kore_pgsql_getlength() which will return length of a column.
2014-09-28 23:03:49 +02:00
int kore_pgsql_getlength(struct kore_pgsql *, int, int);
Add new wrappers
2014-04-01 21:44:22 +02:00
Add __cplusplus macros to headers.
2015-04-01 07:25:10 -04:00
#if defined(__cplusplus)
}
#endif
Initial stab at entering postgresql contrib code. Has support for full async pgsql queries. Most of the logic is hidden behind a KORE_PGSQL() macro allowing you to insert these pgsql calls in your page handlers without blocking the kore worker while the query is going off. There is place for improvement here, and perhaps KORE_PGSQL won't stay as I feel this might overcomplicate things instead of making them simpler as I thought it would.
2014-03-30 23:54:35 +02:00
#define KORE_PGSQL_STATE_INIT 1
#define KORE_PGSQL_STATE_WAIT 2
#define KORE_PGSQL_STATE_RESULT 3
#define KORE_PGSQL_STATE_ERROR 4
#define KORE_PGSQL_STATE_DONE 5
#define KORE_PGSQL_STATE_COMPLETE 6
#endif
Reference in New Issue Copy Permalink