mirror of
https://github.com/php/php-src.git
synced 2025-08-16 05:58:45 +02:00
ef0de01b62
We allocate a unique cursor name for each statement, so that we don't interfere with other open statement handles on the same dbh. Note, however, that we force a new transaction for each open scrollable cursor (postgres requires cursors to be used inside a transaction). This is okay, except for the case where a scrollable cursor is opened, an update is made and the cursor is closed; closing the cursor commits the transaction that was begun when it was opened. It might well be better to avoid the transaction in PDO and force the user to be aware of the requirements of cursors and explicitly initiate the transaction themselves. This is all untested code; it compiles and looks like it will work, but I encourage someone with a real postgres setup to actually sit down and try to use it.
81 lines
2.5 KiB
C
81 lines
2.5 KiB
C
/*
|
|
+----------------------------------------------------------------------+
|
|
| PHP Version 5 |
|
|
+----------------------------------------------------------------------+
|
|
| Copyright (c) 1997-2004 The PHP Group |
|
|
+----------------------------------------------------------------------+
|
|
| This source file is subject to version 3.0 of the PHP license, |
|
|
| that is bundled with this package in the file LICENSE, and is |
|
|
| available through the world-wide-web at the following url: |
|
|
| http://www.php.net/license/3_0.txt. |
|
|
| If you did not receive a copy of the PHP license and are unable to |
|
|
| obtain it through the world-wide-web, please send a note to |
|
|
| license@php.net so we can mail you a copy immediately. |
|
|
+----------------------------------------------------------------------+
|
|
| Author: Edin Kadribasic <edink@emini.dk> |
|
|
+----------------------------------------------------------------------+
|
|
*/
|
|
|
|
/* $Id$ */
|
|
|
|
#ifndef PHP_PDO_PGSQL_INT_H
|
|
#define PHP_PDO_PGSQL_INT_H
|
|
|
|
#if HAVE_PDO_PGSQL
|
|
|
|
#include <libpq-fe.h>
|
|
|
|
typedef struct {
|
|
const char *file;
|
|
int line;
|
|
unsigned int errcode;
|
|
char *errmsg;
|
|
} pdo_pgsql_error_info;
|
|
|
|
/* stuff we use in a pgsql database handle */
|
|
typedef struct {
|
|
PGconn *server;
|
|
unsigned attached:1;
|
|
unsigned _reserved:31;
|
|
pdo_pgsql_error_info einfo;
|
|
Oid pgoid;
|
|
} pdo_pgsql_db_handle;
|
|
|
|
typedef struct {
|
|
char *def;
|
|
} pdo_pgsql_column;
|
|
|
|
typedef struct {
|
|
pdo_pgsql_db_handle *H;
|
|
PGresult *result;
|
|
int current_row;
|
|
pdo_pgsql_column *cols;
|
|
char *cursor_name;
|
|
} pdo_pgsql_stmt;
|
|
|
|
typedef struct {
|
|
char *repr;
|
|
long repr_len;
|
|
int pgsql_type;
|
|
void *thing; /* for LOBS, REFCURSORS etc. */
|
|
} pdo_pgsql_bound_param;
|
|
|
|
extern pdo_driver_t pdo_pgsql_driver;
|
|
|
|
extern int _pdo_pgsql_error(pdo_dbh_t *dbh, pdo_stmt_t *stmt, int errcode, const char *file, int line TSRMLS_DC);
|
|
#define pdo_pgsql_error(d,e) _pdo_pgsql_error(d, NULL, e, __FILE__, __LINE__ TSRMLS_CC)
|
|
#define pdo_pgsql_error_stmt(s,e) _pdo_pgsql_error(s->dbh, s, e, __FILE__, __LINE__ TSRMLS_CC)
|
|
|
|
extern struct pdo_stmt_methods pgsql_stmt_methods;
|
|
|
|
#endif /* HAVE_PDO_PGSQL */
|
|
#endif /* PHP_PDO_PGSQL_INT_H */
|
|
|
|
/*
|
|
* Local variables:
|
|
* tab-width: 4
|
|
* c-basic-offset: 4
|
|
* End:
|
|
* vim600: noet sw=4 ts=4 fdm=marker
|
|
* vim<600: noet sw=4 ts=4
|
|
*/
|