summaryrefslogtreecommitdiff
path: root/ext/pdo_firebird/firebird_driver.c
diff options
context:
space:
mode:
Diffstat (limited to 'ext/pdo_firebird/firebird_driver.c')
-rw-r--r--ext/pdo_firebird/firebird_driver.c728
1 files changed, 728 insertions, 0 deletions
diff --git a/ext/pdo_firebird/firebird_driver.c b/ext/pdo_firebird/firebird_driver.c
new file mode 100644
index 0000000..bda6d23
--- /dev/null
+++ b/ext/pdo_firebird/firebird_driver.c
@@ -0,0 +1,728 @@
+/*
+ +----------------------------------------------------------------------+
+ | PHP Version 5 |
+ +----------------------------------------------------------------------+
+ | Copyright (c) 1997-2013 The PHP Group |
+ +----------------------------------------------------------------------+
+ | This source file is subject to version 3.01 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_01.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: Ard Biesheuvel <abies@php.net> |
+ +----------------------------------------------------------------------+
+*/
+
+/* $Id$ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#define _GNU_SOURCE
+
+#include "php.h"
+#ifdef ZEND_ENGINE_2
+# include "zend_exceptions.h"
+#endif
+#include "php_ini.h"
+#include "ext/standard/info.h"
+#include "pdo/php_pdo.h"
+#include "pdo/php_pdo_driver.h"
+#include "php_pdo_firebird.h"
+#include "php_pdo_firebird_int.h"
+
+static int firebird_alloc_prepare_stmt(pdo_dbh_t*, const char*, long, XSQLDA*, isc_stmt_handle*,
+ HashTable* TSRMLS_DC);
+
+/* map driver specific error message to PDO error */
+void _firebird_error(pdo_dbh_t *dbh, pdo_stmt_t *stmt, char const *file, long line TSRMLS_DC) /* {{{ */
+{
+#if 0
+ pdo_firebird_db_handle *H = stmt ? ((pdo_firebird_stmt *)stmt->driver_data)->H
+ : (pdo_firebird_db_handle *)dbh->driver_data;
+#endif
+ pdo_error_type *const error_code = stmt ? &stmt->error_code : &dbh->error_code;
+
+#if 0
+ switch (isc_sqlcode(H->isc_status)) {
+
+ case 0:
+ *error_code = PDO_ERR_NONE;
+ break;
+ default:
+ *error_code = PDO_ERR_CANT_MAP;
+ break;
+ case -104:
+ *error_code = PDO_ERR_SYNTAX;
+ break;
+ case -530:
+ case -803:
+ *error_code = PDO_ERR_CONSTRAINT;
+ break;
+ case -204:
+ case -205:
+ case -206:
+ case -829:
+ *error_code = PDO_ERR_NOT_FOUND;
+ break;
+
+ *error_code = PDO_ERR_ALREADY_EXISTS;
+ break;
+
+ *error_code = PDO_ERR_NOT_IMPLEMENTED;
+ break;
+ case -313:
+ case -804:
+ *error_code = PDO_ERR_MISMATCH;
+ break;
+ case -303:
+ case -314:
+ case -413:
+ *error_code = PDO_ERR_TRUNCATED;
+ break;
+
+ *error_code = PDO_ERR_DISCONNECTED;
+ break;
+ }
+#else
+ strcpy(*error_code, "HY000");
+#endif
+}
+/* }}} */
+
+#define RECORD_ERROR(dbh) _firebird_error(dbh, NULL, __FILE__, __LINE__ TSRMLS_CC)
+
+/* called by PDO to close a db handle */
+static int firebird_handle_closer(pdo_dbh_t *dbh TSRMLS_DC) /* {{{ */
+{
+ pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
+
+ if (dbh->in_txn) {
+ if (dbh->auto_commit) {
+ if (isc_commit_transaction(H->isc_status, &H->tr)) {
+ RECORD_ERROR(dbh);
+ }
+ } else {
+ if (isc_rollback_transaction(H->isc_status, &H->tr)) {
+ RECORD_ERROR(dbh);
+ }
+ }
+ }
+
+ if (isc_detach_database(H->isc_status, &H->db)) {
+ RECORD_ERROR(dbh);
+ }
+
+ if (H->date_format) {
+ efree(H->date_format);
+ }
+ if (H->time_format) {
+ efree(H->time_format);
+ }
+ if (H->timestamp_format) {
+ efree(H->timestamp_format);
+ }
+
+ pefree(H, dbh->is_persistent);
+
+ return 0;
+}
+/* }}} */
+
+/* called by PDO to prepare an SQL query */
+static int firebird_handle_preparer(pdo_dbh_t *dbh, const char *sql, long sql_len, /* {{{ */
+ pdo_stmt_t *stmt, zval *driver_options TSRMLS_DC)
+{
+ pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
+ pdo_firebird_stmt *S = NULL;
+ HashTable *np;
+
+ do {
+ isc_stmt_handle s = NULL;
+ XSQLDA num_sqlda;
+ static char const info[] = { isc_info_sql_stmt_type };
+ char result[8];
+
+ num_sqlda.version = PDO_FB_SQLDA_VERSION;
+ num_sqlda.sqln = 1;
+
+ ALLOC_HASHTABLE(np);
+ zend_hash_init(np, 8, NULL, NULL, 0);
+
+ /* allocate and prepare statement */
+ if (!firebird_alloc_prepare_stmt(dbh, sql, sql_len, &num_sqlda, &s, np TSRMLS_CC)) {
+ break;
+ }
+
+ /* allocate a statement handle struct of the right size (struct out_sqlda is inlined) */
+ S = ecalloc(1, sizeof(*S)-sizeof(XSQLDA) + XSQLDA_LENGTH(num_sqlda.sqld));
+ S->H = H;
+ S->stmt = s;
+ S->fetch_buf = ecalloc(1,sizeof(char*) * num_sqlda.sqld);
+ S->out_sqlda.version = PDO_FB_SQLDA_VERSION;
+ S->out_sqlda.sqln = stmt->column_count = num_sqlda.sqld;
+ S->named_params = np;
+
+ /* determine the statement type */
+ if (isc_dsql_sql_info(H->isc_status, &s, sizeof(info), const_cast(info), sizeof(result),
+ result)) {
+ break;
+ }
+ S->statement_type = result[3];
+
+ /* fill the output sqlda with information about the prepared query */
+ if (isc_dsql_describe(H->isc_status, &s, PDO_FB_SQLDA_VERSION, &S->out_sqlda)) {
+ RECORD_ERROR(dbh);
+ break;
+ }
+
+ /* allocate the input descriptors */
+ if (isc_dsql_describe_bind(H->isc_status, &s, PDO_FB_SQLDA_VERSION, &num_sqlda)) {
+ break;
+ }
+
+ if (num_sqlda.sqld) {
+ S->in_sqlda = ecalloc(1,XSQLDA_LENGTH(num_sqlda.sqld));
+ S->in_sqlda->version = PDO_FB_SQLDA_VERSION;
+ S->in_sqlda->sqln = num_sqlda.sqld;
+
+ if (isc_dsql_describe_bind(H->isc_status, &s, PDO_FB_SQLDA_VERSION, S->in_sqlda)) {
+ break;
+ }
+ }
+
+ stmt->driver_data = S;
+ stmt->methods = &firebird_stmt_methods;
+ stmt->supports_placeholders = PDO_PLACEHOLDER_POSITIONAL;
+
+ return 1;
+
+ } while (0);
+
+ RECORD_ERROR(dbh);
+
+ zend_hash_destroy(np);
+ FREE_HASHTABLE(np);
+
+ if (S) {
+ if (S->in_sqlda) {
+ efree(S->in_sqlda);
+ }
+ efree(S);
+ }
+
+ return 0;
+}
+/* }}} */
+
+/* called by PDO to execute a statement that doesn't produce a result set */
+static long firebird_handle_doer(pdo_dbh_t *dbh, const char *sql, long sql_len TSRMLS_DC) /* {{{ */
+{
+ pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
+ isc_stmt_handle stmt = NULL;
+ static char const info_count[] = { isc_info_sql_records };
+ char result[64];
+ int ret = 0;
+ XSQLDA in_sqlda, out_sqlda;
+
+ /* TODO no placeholders in exec() for now */
+ in_sqlda.version = out_sqlda.version = PDO_FB_SQLDA_VERSION;
+ in_sqlda.sqld = out_sqlda.sqld = 0;
+ out_sqlda.sqln = 1;
+
+ /* allocate and prepare statement */
+ if (!firebird_alloc_prepare_stmt(dbh, sql, sql_len, &out_sqlda, &stmt, 0 TSRMLS_CC)) {
+ return -1;
+ }
+
+ /* execute the statement */
+ if (isc_dsql_execute2(H->isc_status, &H->tr, &stmt, PDO_FB_SQLDA_VERSION, &in_sqlda, &out_sqlda)) {
+ RECORD_ERROR(dbh);
+ return -1;
+ }
+
+ /* find out how many rows were affected */
+ if (isc_dsql_sql_info(H->isc_status, &stmt, sizeof(info_count), const_cast(info_count),
+ sizeof(result), result)) {
+ RECORD_ERROR(dbh);
+ return -1;
+ }
+
+ if (result[0] == isc_info_sql_records) {
+ unsigned i = 3, result_size = isc_vax_integer(&result[1],2);
+
+ while (result[i] != isc_info_end && i < result_size) {
+ short len = (short)isc_vax_integer(&result[i+1],2);
+ if (result[i] != isc_info_req_select_count) {
+ ret += isc_vax_integer(&result[i+3],len);
+ }
+ i += len+3;
+ }
+ }
+
+ /* commit if we're in auto_commit mode */
+ if (dbh->auto_commit && isc_commit_retaining(H->isc_status, &H->tr)) {
+ RECORD_ERROR(dbh);
+ }
+
+ return ret;
+}
+/* }}} */
+
+/* called by the PDO SQL parser to add quotes to values that are copied into SQL */
+static int firebird_handle_quoter(pdo_dbh_t *dbh, const char *unquoted, int unquotedlen, /* {{{ */
+ char **quoted, int *quotedlen, enum pdo_param_type paramtype TSRMLS_DC)
+{
+ int qcount = 0;
+ char const *co, *l, *r;
+ char *c;
+
+ if (!unquotedlen) {
+ *quotedlen = 2;
+ *quoted = emalloc(*quotedlen+1);
+ strcpy(*quoted, "''");
+ return 1;
+ }
+
+ /* Firebird only requires single quotes to be doubled if string lengths are used */
+ /* count the number of ' characters */
+ for (co = unquoted; (co = strchr(co,'\'')); qcount++, co++);
+
+ *quotedlen = unquotedlen + qcount + 2;
+ *quoted = c = emalloc(*quotedlen+1);
+ *c++ = '\'';
+
+ /* foreach (chunk that ends in a quote) */
+ for (l = unquoted; (r = strchr(l,'\'')); l = r+1) {
+ strncpy(c, l, r-l+1);
+ c += (r-l+1);
+ /* add the second quote */
+ *c++ = '\'';
+ }
+
+ /* copy the remainder */
+ strncpy(c, l, *quotedlen-(c-*quoted)-1);
+ (*quoted)[*quotedlen-1] = '\'';
+ (*quoted)[*quotedlen] = '\0';
+
+ return 1;
+}
+/* }}} */
+
+/* called by PDO to start a transaction */
+static int firebird_handle_begin(pdo_dbh_t *dbh TSRMLS_DC) /* {{{ */
+{
+ pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
+ char tpb[8] = { isc_tpb_version3 }, *ptpb = tpb+1;
+#if abies_0
+ if (dbh->transaction_flags & PDO_TRANS_ISOLATION_LEVEL) {
+ if (dbh->transaction_flags & PDO_TRANS_READ_UNCOMMITTED) {
+ /* this is a poor fit, but it's all we have */
+ *ptpb++ = isc_tpb_read_committed;
+ *ptpb++ = isc_tpb_rec_version;
+ dbh->transaction_flags &= ~(PDO_TRANS_ISOLATION_LEVEL^PDO_TRANS_READ_UNCOMMITTED);
+ } else if (dbh->transaction_flags & PDO_TRANS_READ_COMMITTED) {
+ *ptpb++ = isc_tpb_read_committed;
+ *ptpb++ = isc_tpb_no_rec_version;
+ dbh->transaction_flags &= ~(PDO_TRANS_ISOLATION_LEVEL^PDO_TRANS_READ_COMMITTED);
+ } else if (dbh->transaction_flags & PDO_TRANS_REPEATABLE_READ) {
+ *ptpb++ = isc_tpb_concurrency;
+ dbh->transaction_flags &= ~(PDO_TRANS_ISOLATION_LEVEL^PDO_TRANS_REPEATABLE_READ);
+ } else {
+ *ptpb++ = isc_tpb_consistency;
+ dbh->transaction_flags &= ~(PDO_TRANS_ISOLATION_LEVEL^PDO_TRANS_SERIALIZABLE);
+ }
+ }
+
+ if (dbh->transaction_flags & PDO_TRANS_ACCESS_MODE) {
+ if (dbh->transaction_flags & PDO_TRANS_READONLY) {
+ *ptpb++ = isc_tpb_read;
+ dbh->transaction_flags &= ~(PDO_TRANS_ACCESS_MODE^PDO_TRANS_READONLY);
+ } else {
+ *ptpb++ = isc_tpb_write;
+ dbh->transaction_flags &= ~(PDO_TRANS_ACCESS_MODE^PDO_TRANS_READWRITE);
+ }
+ }
+
+ if (dbh->transaction_flags & PDO_TRANS_CONFLICT_RESOLUTION) {
+ if (dbh->transaction_flags & PDO_TRANS_RETRY) {
+ *ptpb++ = isc_tpb_wait;
+ dbh->transaction_flags &= ~(PDO_TRANS_CONFLICT_RESOLUTION^PDO_TRANS_RETRY);
+ } else {
+ *ptpb++ = isc_tpb_nowait;
+ dbh->transaction_flags &= ~(PDO_TRANS_CONFLICT_RESOLUTION^PDO_TRANS_ABORT);
+ }
+ }
+#endif
+ if (isc_start_transaction(H->isc_status, &H->tr, 1, &H->db, (unsigned short)(ptpb-tpb), tpb)) {
+ RECORD_ERROR(dbh);
+ return 0;
+ }
+ return 1;
+}
+/* }}} */
+
+/* called by PDO to commit a transaction */
+static int firebird_handle_commit(pdo_dbh_t *dbh TSRMLS_DC) /* {{{ */
+{
+ pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
+
+ if (isc_commit_transaction(H->isc_status, &H->tr)) {
+ RECORD_ERROR(dbh);
+ return 0;
+ }
+ return 1;
+}
+/* }}} */
+
+/* called by PDO to rollback a transaction */
+static int firebird_handle_rollback(pdo_dbh_t *dbh TSRMLS_DC) /* {{{ */
+{
+ pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
+
+ if (isc_rollback_transaction(H->isc_status, &H->tr)) {
+ RECORD_ERROR(dbh);
+ return 0;
+ }
+ return 1;
+}
+/* }}} */
+
+/* used by prepare and exec to allocate a statement handle and prepare the SQL */
+static int firebird_alloc_prepare_stmt(pdo_dbh_t *dbh, const char *sql, long sql_len, /* {{{ */
+ XSQLDA *out_sqlda, isc_stmt_handle *s, HashTable *named_params TSRMLS_DC)
+{
+ pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
+ char *c, *new_sql, in_quote, in_param, pname[64], *ppname;
+ long l, pindex = -1;
+
+ /* Firebird allows SQL statements up to 64k, so bail if it doesn't fit */
+ if (sql_len > 65536) {
+ strcpy(dbh->error_code, "01004");
+ return 0;
+ }
+
+ /* start a new transaction implicitly if auto_commit is enabled and no transaction is open */
+ if (dbh->auto_commit && !dbh->in_txn) {
+ /* dbh->transaction_flags = PDO_TRANS_READ_UNCOMMITTED; */
+
+ if (!firebird_handle_begin(dbh TSRMLS_CC)) {
+ return 0;
+ }
+ dbh->in_txn = 1;
+ }
+
+ /* allocate the statement */
+ if (isc_dsql_allocate_statement(H->isc_status, &H->db, s)) {
+ RECORD_ERROR(dbh);
+ return 0;
+ }
+
+ /* in order to support named params, which Firebird itself doesn't,
+ we need to replace :foo by ?, and store the name we just replaced */
+ new_sql = c = emalloc(sql_len+1);
+
+ for (l = in_quote = in_param = 0; l <= sql_len; ++l) {
+ if ( !(in_quote ^= (sql[l] == '\''))) {
+ if (!in_param) {
+ switch (sql[l]) {
+ case ':':
+ in_param = 1;
+ ppname = pname;
+ *ppname++ = sql[l];
+ case '?':
+ *c++ = '?';
+ ++pindex;
+ continue;
+ }
+ } else {
+ if ((in_param &= ((sql[l] >= 'A' && sql[l] <= 'Z') || (sql[l] >= 'a' && sql[l] <= 'z')
+ || (sql[l] >= '0' && sql[l] <= '9') || sql[l] == '_' || sql[l] == '-'))) {
+
+
+ *ppname++ = sql[l];
+ continue;
+ } else {
+ *ppname++ = 0;
+ if (named_params) {
+ zend_hash_update(named_params, pname, (unsigned int)(ppname-pname),
+ (void*)&pindex, sizeof(long)+1,NULL);
+ }
+ }
+ }
+ }
+ *c++ = sql[l];
+ }
+
+ /* prepare the statement */
+ if (isc_dsql_prepare(H->isc_status, &H->tr, s, 0, new_sql, PDO_FB_DIALECT, out_sqlda)) {
+ RECORD_ERROR(dbh);
+ efree(new_sql);
+ return 0;
+ }
+
+ efree(new_sql);
+ return 1;
+}
+/* }}} */
+
+/* called by PDO to set a driver-specific dbh attribute */
+static int firebird_handle_set_attribute(pdo_dbh_t *dbh, long attr, zval *val TSRMLS_DC) /* {{{ */
+{
+ pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
+
+ switch (attr) {
+ case PDO_ATTR_AUTOCOMMIT:
+
+ convert_to_boolean(val);
+
+ /* ignore if the new value equals the old one */
+ if (dbh->auto_commit ^ Z_BVAL_P(val)) {
+ if (dbh->in_txn) {
+ if (Z_BVAL_P(val)) {
+ /* turning on auto_commit with an open transaction is illegal, because
+ we won't know what to do with it */
+ H->last_app_error = "Cannot enable auto-commit while a transaction is already open";
+ return 0;
+ } else {
+ /* close the transaction */
+ if (!firebird_handle_commit(dbh TSRMLS_CC)) {
+ break;
+ }
+ dbh->in_txn = 0;
+ }
+ }
+ dbh->auto_commit = Z_BVAL_P(val);
+ }
+ return 1;
+
+ case PDO_ATTR_FETCH_TABLE_NAMES:
+ convert_to_boolean(val);
+ H->fetch_table_names = Z_BVAL_P(val);
+ return 1;
+
+ case PDO_FB_ATTR_DATE_FORMAT:
+ convert_to_string(val);
+ if (H->date_format) {
+ efree(H->date_format);
+ }
+ spprintf(&H->date_format, 0, "%s", Z_STRVAL_P(val));
+ return 1;
+
+ case PDO_FB_ATTR_TIME_FORMAT:
+ convert_to_string(val);
+ if (H->time_format) {
+ efree(H->time_format);
+ }
+ spprintf(&H->time_format, 0, "%s", Z_STRVAL_P(val));
+ return 1;
+
+ case PDO_FB_ATTR_TIMESTAMP_FORMAT:
+ convert_to_string(val);
+ if (H->timestamp_format) {
+ efree(H->timestamp_format);
+ }
+ spprintf(&H->timestamp_format, 0, "%s", Z_STRVAL_P(val));
+ return 1;
+ }
+ return 0;
+}
+/* }}} */
+
+/* callback to used to report database server info */
+static void firebird_info_cb(void *arg, char const *s) /* {{{ */
+{
+ if (arg) {
+ if (*(char*)arg) { /* second call */
+ strcat(arg, " ");
+ }
+ strcat(arg, s);
+ }
+}
+/* }}} */
+
+/* called by PDO to get a driver-specific dbh attribute */
+static int firebird_handle_get_attribute(pdo_dbh_t *dbh, long attr, zval *val TSRMLS_DC) /* {{{ */
+{
+ pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
+
+ switch (attr) {
+ char tmp[512];
+
+ case PDO_ATTR_AUTOCOMMIT:
+ ZVAL_LONG(val,dbh->auto_commit);
+ return 1;
+
+ case PDO_ATTR_CONNECTION_STATUS:
+ ZVAL_BOOL(val, !isc_version(&H->db, firebird_info_cb, NULL));
+ return 1;
+
+ case PDO_ATTR_CLIENT_VERSION: {
+#if defined(__GNUC__) || defined(PHP_WIN32)
+ info_func_t info_func = NULL;
+#ifdef __GNUC__
+ info_func = (info_func_t)dlsym(RTLD_DEFAULT, "isc_get_client_version");
+#else
+ HMODULE l = GetModuleHandle("fbclient");
+
+ if (!l && !(l = GetModuleHandle("gds32"))) {
+ break;
+ }
+ info_func = (info_func_t)GetProcAddress(l, "isc_get_client_version");
+#endif
+ if (info_func) {
+ info_func(tmp);
+ ZVAL_STRING(val,tmp,1);
+ } else {
+ ZVAL_STRING(val,"Firebird 1.0/Interbase 6",1);
+ }
+#else
+ ZVAL_NULL(val);
+#endif
+ }
+ return 1;
+
+ case PDO_ATTR_SERVER_VERSION:
+ case PDO_ATTR_SERVER_INFO:
+ *tmp = 0;
+
+ if (!isc_version(&H->db, firebird_info_cb, (void*)tmp)) {
+ ZVAL_STRING(val,tmp,1);
+ return 1;
+ }
+
+ case PDO_ATTR_FETCH_TABLE_NAMES:
+ ZVAL_BOOL(val, H->fetch_table_names);
+ return 1;
+ }
+ return 0;
+}
+/* }}} */
+
+/* called by PDO to retrieve driver-specific information about an error that has occurred */
+static int pdo_firebird_fetch_error_func(pdo_dbh_t *dbh, pdo_stmt_t *stmt, zval *info TSRMLS_DC) /* {{{ */
+{
+ pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
+ ISC_STATUS *s = H->isc_status;
+ char buf[400];
+ long i = 0, l, sqlcode = isc_sqlcode(s);
+
+ if (sqlcode) {
+ add_next_index_long(info, sqlcode);
+
+ while ((l = isc_interprete(&buf[i],&s))) {
+ i += l;
+ strcpy(&buf[i++], " ");
+ }
+ add_next_index_string(info, buf, 1);
+ } else if (H->last_app_error) {
+ add_next_index_long(info, -999);
+ add_next_index_string(info, const_cast(H->last_app_error),1);
+ }
+ return 1;
+}
+/* }}} */
+
+static struct pdo_dbh_methods firebird_methods = { /* {{{ */
+ firebird_handle_closer,
+ firebird_handle_preparer,
+ firebird_handle_doer,
+ firebird_handle_quoter,
+ firebird_handle_begin,
+ firebird_handle_commit,
+ firebird_handle_rollback,
+ firebird_handle_set_attribute,
+ NULL, /* last_id not supported */
+ pdo_firebird_fetch_error_func,
+ firebird_handle_get_attribute,
+ NULL /* check_liveness */
+};
+/* }}} */
+
+/* the driver-specific PDO handle constructor */
+static int pdo_firebird_handle_factory(pdo_dbh_t *dbh, zval *driver_options TSRMLS_DC) /* {{{ */
+{
+ struct pdo_data_src_parser vars[] = {
+ { "dbname", NULL, 0 },
+ { "charset", NULL, 0 },
+ { "role", NULL, 0 }
+ };
+ int i, ret = 0;
+ short buf_len = 256, dpb_len;
+
+ pdo_firebird_db_handle *H = dbh->driver_data = pecalloc(1,sizeof(*H),dbh->is_persistent);
+
+ php_pdo_parse_data_source(dbh->data_source, dbh->data_source_len, vars, 3);
+
+ do {
+ static char const dpb_flags[] = {
+ isc_dpb_user_name, isc_dpb_password, isc_dpb_lc_ctype, isc_dpb_sql_role_name };
+ char const *dpb_values[] = { dbh->username, dbh->password, vars[1].optval, vars[2].optval };
+ char dpb_buffer[256] = { isc_dpb_version1 }, *dpb;
+
+ dpb = dpb_buffer + 1;
+
+ /* loop through all the provided arguments and set dpb fields accordingly */
+ for (i = 0; i < sizeof(dpb_flags); ++i) {
+ if (dpb_values[i] && buf_len > 0) {
+ dpb_len = slprintf(dpb, buf_len, "%c%c%s", dpb_flags[i], (unsigned char)strlen(dpb_values[i]),
+ dpb_values[i]);
+ dpb += dpb_len;
+ buf_len -= dpb_len;
+ }
+ }
+
+ /* fire it up baby! */
+ if (isc_attach_database(H->isc_status, 0, vars[0].optval, &H->db,(short)(dpb-dpb_buffer), dpb_buffer)) {
+ break;
+ }
+
+ dbh->methods = &firebird_methods;
+ dbh->native_case = PDO_CASE_UPPER;
+ dbh->alloc_own_columns = 1;
+
+ ret = 1;
+
+ } while (0);
+
+ for (i = 0; i < sizeof(vars)/sizeof(vars[0]); ++i) {
+ if (vars[i].freeme) {
+ efree(vars[i].optval);
+ }
+ }
+
+ if (!dbh->methods) {
+ char errmsg[512];
+ ISC_STATUS *s = H->isc_status;
+ isc_interprete(errmsg, &s);
+ zend_throw_exception_ex(php_pdo_get_exception(), H->isc_status[1] TSRMLS_CC, "SQLSTATE[%s] [%d] %s",
+ "HY000", H->isc_status[1], errmsg);
+ }
+
+ if (!ret) {
+ firebird_handle_closer(dbh TSRMLS_CC);
+ }
+
+ return ret;
+}
+/* }}} */
+
+
+pdo_driver_t pdo_firebird_driver = { /* {{{ */
+ PDO_DRIVER_HEADER(firebird),
+ pdo_firebird_handle_factory
+};
+/* }}} */
+
+/*
+ * 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
+ */