Skip to content

Commit 0bc6851

Browse files
SakiTakamachiSakiTakamachi
committed
[pdo_firebird] Transaction management optimization
1 parent d7d3a1c commit 0bc6851

12 files changed

+149
-70
lines changed

‎ext/pdo/tests/pdo_017.phpt

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@ $dir = getenv('REDIR_TEST_DIR');
88
if (false == $dir) die('skip no driver');
99
require_once $dir . 'pdo_test.inc';
1010
PDOTest::skip();
11-
if (str_starts_with(getenv('PDOTEST_DSN'), "firebird")) die('xfail firebird driver does not behave as expected');
1211

1312
$db = PDOTest::factory();
1413
try {

‎ext/pdo_firebird/firebird_driver.c

Lines changed: 99 additions & 41 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@
3333

3434
static int php_firebird_alloc_prepare_stmt(pdo_dbh_t*, const zend_string*, XSQLDA*, isc_stmt_handle*,
3535
HashTable*);
36+
static bool php_firebird_rollback_transaction(pdo_dbh_t *dbh, bool retain);
3637

3738
const char CHR_LETTER = 1;
3839
const char CHR_DIGIT = 2;
@@ -526,17 +527,14 @@ static void firebird_handle_closer(pdo_dbh_t *dbh) /* {{{ */
526527
{
527528
pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
528529

529-
if (dbh->in_txn) {
530+
if (H->tr) {
530531
if (dbh->auto_commit) {
531-
if (isc_commit_transaction(H->isc_status, &H->tr)) {
532-
php_firebird_error(dbh);
533-
}
532+
php_firebird_commit_transaction(dbh, FB_TXN_RELEASE);
534533
} else {
535-
if (isc_rollback_transaction(H->isc_status, &H->tr)) {
536-
php_firebird_error(dbh);
537-
}
534+
php_firebird_rollback_transaction(dbh, FB_TXN_RELEASE);
538535
}
539536
}
537+
H->in_manually_txn = 0;
540538

541539
if (isc_detach_database(H->isc_status, &H->db)) {
542540
php_firebird_error(dbh);
@@ -702,9 +700,8 @@ static zend_long firebird_handle_doer(pdo_dbh_t *dbh, const zend_string *sql) /*
702700
}
703701
}
704702

705-
/* commit if we're in auto_commit mode */
706-
if (dbh->auto_commit && isc_commit_retaining(H->isc_status, &H->tr)) {
707-
php_firebird_error(dbh);
703+
if (dbh->auto_commit && !H->in_manually_txn) {
704+
php_firebird_commit_transaction(dbh, FB_TXN_RETAIN);
708705
}
709706

710707
free_statement:
@@ -756,8 +753,8 @@ static zend_string* firebird_handle_quoter(pdo_dbh_t *dbh, const zend_string *un
756753
}
757754
/* }}} */
758755

759-
/* called by PDO to start a transaction */
760-
static bool firebird_handle_begin(pdo_dbh_t *dbh) /* {{{ */
756+
/* php_firebird_begin_transaction */
757+
static bool php_firebird_begin_transaction(pdo_dbh_t *dbh) /* {{{ */
761758
{
762759
pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
763760
char tpb[8] = { isc_tpb_version3 }, *ptpb = tpb+1;
@@ -809,28 +806,84 @@ static bool firebird_handle_begin(pdo_dbh_t *dbh) /* {{{ */
809806
}
810807
/* }}} */
811808

812-
/* called by PDO to commit a transaction */
813-
static bool firebird_handle_commit(pdo_dbh_t *dbh) /* {{{ */
809+
/* called by PDO to start a transaction */
810+
static bool firebird_handle_manually_begin(pdo_dbh_t *dbh) /* {{{ */
814811
{
815812
pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
816813

817-
if (isc_commit_transaction(H->isc_status, &H->tr)) {
818-
php_firebird_error(dbh);
814+
if (dbh->auto_commit && H->tr && !php_firebird_commit_transaction(dbh, FB_TXN_RELEASE)) {
815+
return false;
816+
}
817+
818+
if (!php_firebird_begin_transaction(dbh)) {
819+
return false;
820+
}
821+
H->in_manually_txn = 1;
822+
return true;
823+
}
824+
/* }}} */
825+
826+
/* php_firebird_commit_transaction */
827+
bool php_firebird_commit_transaction(pdo_dbh_t *dbh, bool retain) /* {{{ */
828+
{
829+
pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
830+
831+
if (retain) {
832+
if (isc_commit_retaining(H->isc_status, &H->tr)) {
833+
php_firebird_error(dbh);
834+
return false;
835+
}
836+
} else {
837+
if (isc_commit_transaction(H->isc_status, &H->tr)) {
838+
php_firebird_error(dbh);
839+
return false;
840+
}
841+
}
842+
return true;
843+
}
844+
/* }}} */
845+
846+
/* called by PDO to commit a transaction */
847+
static bool firebird_handle_manually_commit(pdo_dbh_t *dbh) /* {{{ */
848+
{
849+
pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
850+
if (!php_firebird_commit_transaction(dbh, dbh->auto_commit)) {
819851
return false;
820852
}
853+
H->in_manually_txn = 0;
854+
return true;
855+
}
856+
/* }}} */
857+
858+
/* php_firebird_rollback_transaction */
859+
static bool php_firebird_rollback_transaction(pdo_dbh_t *dbh, bool retain) /* {{{ */
860+
{
861+
pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
862+
863+
if (retain) {
864+
if (isc_rollback_retaining(H->isc_status, &H->tr)) {
865+
php_firebird_error(dbh);
866+
return false;
867+
}
868+
} else {
869+
if (isc_rollback_transaction(H->isc_status, &H->tr)) {
870+
php_firebird_error(dbh);
871+
return false;
872+
}
873+
}
821874
return true;
822875
}
823876
/* }}} */
824877

825878
/* called by PDO to rollback a transaction */
826-
static bool firebird_handle_rollback(pdo_dbh_t *dbh) /* {{{ */
879+
static bool firebird_handle_manually_rollback(pdo_dbh_t *dbh) /* {{{ */
827880
{
828881
pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
829882

830-
if (isc_rollback_transaction(H->isc_status, &H->tr)) {
831-
php_firebird_error(dbh);
883+
if (!php_firebird_rollback_transaction(dbh, dbh->auto_commit)) {
832884
return false;
833885
}
886+
H->in_manually_txn = 0;
834887
return true;
835888
}
836889
/* }}} */
@@ -848,16 +901,6 @@ static int php_firebird_alloc_prepare_stmt(pdo_dbh_t *dbh, const zend_string *sq
848901
return 0;
849902
}
850903

851-
/* start a new transaction implicitly if auto_commit is enabled and no transaction is open */
852-
if (dbh->auto_commit && !dbh->in_txn) {
853-
/* dbh->transaction_flags = PDO_TRANS_READ_UNCOMMITTED; */
854-
855-
if (!firebird_handle_begin(dbh)) {
856-
return 0;
857-
}
858-
dbh->in_txn = true;
859-
}
860-
861904
/* allocate the statement */
862905
if (isc_dsql_allocate_statement(H->isc_status, &H->db, s)) {
863906
php_firebird_error(dbh);
@@ -900,19 +943,21 @@ static bool pdo_firebird_set_attribute(pdo_dbh_t *dbh, zend_long attr, zval *val
900943

901944
/* ignore if the new value equals the old one */
902945
if (dbh->auto_commit ^ bval) {
903-
if (dbh->in_txn) {
904-
if (bval) {
946+
if (bval) {
947+
if (H->in_manually_txn) {
905948
/* turning on auto_commit with an open transaction is illegal, because
906949
we won't know what to do with it */
907950
const char *msg = "Cannot enable auto-commit while a transaction is already open";
908951
php_firebird_error_with_info(dbh, "HY000", strlen("HY000"), msg, strlen(msg));
909952
return false;
910-
} else {
911-
/* close the transaction */
912-
if (!firebird_handle_commit(dbh)) {
913-
break;
914-
}
915-
dbh->in_txn = false;
953+
}
954+
if (!H->tr && !php_firebird_begin_transaction(dbh)) {
955+
return false;
956+
}
957+
} else {
958+
/* close the transaction */
959+
if (!H->in_manually_txn && H->tr && !php_firebird_commit_transaction(dbh, FB_TXN_RELEASE)) {
960+
return false;
916961
}
917962
}
918963
dbh->auto_commit = bval;
@@ -1058,22 +1103,30 @@ static void pdo_firebird_fetch_error_func(pdo_dbh_t *dbh, pdo_stmt_t *stmt, zval
10581103
}
10591104
/* }}} */
10601105

1106+
/* {{{ firebird_in_manually_transaction */
1107+
static bool pdo_firebird_in_manually_transaction(pdo_dbh_t *dbh)
1108+
{
1109+
pdo_firebird_db_handle *H = (pdo_firebird_db_handle *)dbh->driver_data;
1110+
return H->in_manually_txn;
1111+
}
1112+
/* }}} */
1113+
10611114
static const struct pdo_dbh_methods firebird_methods = { /* {{{ */
10621115
firebird_handle_closer,
10631116
firebird_handle_preparer,
10641117
firebird_handle_doer,
10651118
firebird_handle_quoter,
1066-
firebird_handle_begin,
1067-
firebird_handle_commit,
1068-
firebird_handle_rollback,
1119+
firebird_handle_manually_begin,
1120+
firebird_handle_manually_commit,
1121+
firebird_handle_manually_rollback,
10691122
pdo_firebird_set_attribute,
10701123
NULL, /* last_id not supported */
10711124
pdo_firebird_fetch_error_func,
10721125
pdo_firebird_get_attribute,
10731126
NULL, /* check_liveness */
10741127
NULL, /* get driver methods */
10751128
NULL, /* request shutdown */
1076-
NULL, /* in transaction, use PDO's internal tracking mechanism */
1129+
pdo_firebird_in_manually_transaction,
10771130
NULL /* get gc */
10781131
};
10791132
/* }}} */
@@ -1154,6 +1207,11 @@ static int pdo_firebird_handle_factory(pdo_dbh_t *dbh, zval *driver_options) /*
11541207
"HY000", H->isc_status[1], errmsg);
11551208
}
11561209

1210+
H->in_manually_txn = 0;
1211+
if (dbh->auto_commit && !H->tr) {
1212+
ret = php_firebird_begin_transaction(dbh);
1213+
}
1214+
11571215
if (!ret) {
11581216
firebird_handle_closer(dbh);
11591217
}

‎ext/pdo_firebird/firebird_statement.c

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -180,8 +180,7 @@ static int pdo_firebird_stmt_execute(pdo_stmt_t *stmt) /* {{{ */
180180
;
181181
}
182182

183-
/* commit? */
184-
if (stmt->dbh->auto_commit && isc_commit_retaining(H->isc_status, &H->tr)) {
183+
if (stmt->dbh->auto_commit && !S->H->in_manually_txn && !php_firebird_commit_transaction(stmt->dbh, FB_TXN_RETAIN)) {
185184
break;
186185
}
187186

‎ext/pdo_firebird/php_pdo_firebird_int.h

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,6 @@ typedef struct {
6666
} pdo_firebird_error_info;
6767

6868
typedef struct {
69-
7069
/* the result of the last API call */
7170
ISC_STATUS isc_status[20];
7271

@@ -75,6 +74,7 @@ typedef struct {
7574

7675
/* the transaction handle */
7776
isc_tr_handle tr;
77+
bool in_manually_txn;
7878

7979
/* date and time format strings, can be set by the set_attribute method */
8080
char *date_format;
@@ -93,7 +93,6 @@ typedef struct {
9393

9494

9595
typedef struct {
96-
9796
/* the link that owns this statement */
9897
pdo_firebird_db_handle *H;
9998

@@ -122,7 +121,6 @@ typedef struct {
122121

123122
/* the output SQLDA */
124123
XSQLDA out_sqlda; /* last member */
125-
126124
} pdo_firebird_stmt;
127125

128126
extern const pdo_driver_t pdo_firebird_driver;
@@ -136,10 +134,17 @@ extern void php_firebird_set_error(pdo_dbh_t *dbh, pdo_stmt_t *stmt, const char
136134
#define php_firebird_error_with_info(d,e,el,m,ml) php_firebird_set_error(d, NULL, e, el, m, ml)
137135
#define php_firebird_error_stmt_with_info(s,e,el,m,ml) php_firebird_set_error(s->dbh, s, e, el, m, ml)
138136

137+
extern bool php_firebird_commit_transaction(pdo_dbh_t *dbh, bool retain);
138+
139139
enum {
140140
PDO_FB_ATTR_DATE_FORMAT = PDO_ATTR_DRIVER_SPECIFIC,
141141
PDO_FB_ATTR_TIME_FORMAT,
142142
PDO_FB_ATTR_TIMESTAMP_FORMAT,
143143
};
144144

145+
enum {
146+
FB_TXN_RELEASE,
147+
FB_TXN_RETAIN
148+
};
149+
145150
#endif /* PHP_PDO_FIREBIRD_INT_H */

‎ext/pdo_firebird/tests/bug_47415.phpt

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,6 @@ $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
1616
$dbh->exec('CREATE TABLE test47415 (idx int NOT NULL PRIMARY KEY, txt VARCHAR(20))');
1717
$dbh->exec('INSERT INTO test47415 VALUES(0, \'String0\')');
1818

19-
$dbh->commit();
20-
2119
$query = "SELECT idx, txt FROM test47415 ORDER by idx";
2220
$idx = $txt = 0;
2321
$stmt = $dbh->prepare($query);
@@ -32,8 +30,6 @@ var_dump($stmt->rowCount());
3230
$stmt = $dbh->prepare('DELETE FROM test47415');
3331
$stmt->execute();
3432

35-
$dbh->commit();
36-
3733
unset($stmt);
3834
unset($dbh);
3935
?>

‎ext/pdo_firebird/tests/bug_48877.phpt

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@ $dbh->exec('CREATE TABLE test48877 (A integer)');
1818
$dbh->exec("INSERT INTO test48877 VALUES ('1')");
1919
$dbh->exec("INSERT INTO test48877 VALUES ('2')");
2020
$dbh->exec("INSERT INTO test48877 VALUES ('3')");
21-
$dbh->commit();
2221

2322
$query = "SELECT * FROM test48877 WHERE A = :paramno";
2423

@@ -33,7 +32,6 @@ var_dump($stmt->rowCount());
3332
$stmt = $dbh->prepare('DELETE FROM test48877');
3433
$stmt->execute();
3534

36-
$dbh->commit();
3735
unset($stmt);
3836
unset($dbh);
3937

‎ext/pdo_firebird/tests/bug_53280.phpt

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@ require("testdb.inc");
1414

1515
$dbh->exec('CREATE TABLE test53280(A VARCHAR(30), B VARCHAR(30), C VARCHAR(30))');
1616
$dbh->exec("INSERT INTO test53280 VALUES ('A', 'B', 'C')");
17-
$dbh->commit();
1817

1918
$stmt1 = "SELECT B FROM test53280 WHERE A = ? AND B = ?";
2019
$stmt2 = "SELECT B, C FROM test53280 WHERE A = ? AND B = ?";
@@ -29,7 +28,6 @@ $stmth1->execute(array('A', 'B'));
2928
$rows = $stmth1->fetchAll(); // <------- segfault
3029
var_dump($rows);
3130

32-
$dbh->commit();
3331
unset($stmth1);
3432
unset($stmth2);
3533
unset($stmt);

‎ext/pdo_firebird/tests/bug_62024.phpt

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -15,8 +15,6 @@ require("testdb.inc");
1515
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
1616
$dbh->exec("CREATE TABLE test62024 (ID INTEGER NOT NULL, TEXT VARCHAR(10))");
1717

18-
$dbh->commit();
19-
2018
//start actual test
2119

2220
$sql = "insert into test62024 (id, text) values (?, ?)";
@@ -31,15 +29,11 @@ var_dump($res);
3129
$res = $sttmt->execute($args_err);
3230
var_dump($res);
3331

34-
$dbh->commit();
35-
3632

3733
//teardown test data
3834
$sttmt = $dbh->prepare('DELETE FROM test62024');
3935
$sttmt->execute();
4036

41-
$dbh->commit();
42-
4337
unset($sttmt);
4438
unset($dbh);
4539

‎ext/pdo_firebird/tests/bug_64037.phpt

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,8 +18,6 @@ $dbh->exec("INSERT INTO test64037 (ID, TEXT, COST) VALUES (1, 'test', -1.0)");
1818
$dbh->exec("INSERT INTO test64037 (ID, TEXT, COST) VALUES (2, 'test', -0.99)");
1919
$dbh->exec("INSERT INTO test64037 (ID, TEXT, COST) VALUES (3, 'test', -1.01)");
2020

21-
$dbh->commit();
22-
2321
$query = "SELECT * from test64037 order by ID";
2422
$stmt = $dbh->prepare($query);
2523
$stmt->execute();
@@ -32,8 +30,6 @@ var_dump($rows[2]['COST']);
3230
$stmt = $dbh->prepare('DELETE FROM test64037');
3331
$stmt->execute();
3432

35-
$dbh->commit();
36-
3733
unset($stmt);
3834
unset($dbh);
3935

0 commit comments

Comments
 (0)