byjg /
anydataset
| @@ 117-131 (lines=15) @@ | ||
| 114 | sqlrcon_autoCommitOff($this->_conn); |
|
| 115 | } |
|
| 116 | ||
| 117 | public function commitTransaction() |
|
| 118 | { |
|
| 119 | if ($this->_transaction) { |
|
| 120 | $this->_transaction = false; |
|
| 121 | ||
| 122 | $ret = sqlrcon_commit($this->_conn); |
|
| 123 | if ($ret === 0) { |
|
| 124 | throw new DatabaseException('Commit failed'); |
|
| 125 | } else if ($ret === -1) { |
|
| 126 | throw new DatabaseException('An error occurred. Commit failed'); |
|
| 127 | } |
|
| 128 | ||
| 129 | sqlrcon_autoCommitOn($this->_conn); |
|
| 130 | } |
|
| 131 | } |
|
| 132 | ||
| 133 | public function rollbackTransaction() |
|
| 134 | { |
|
| @@ 133-147 (lines=15) @@ | ||
| 130 | } |
|
| 131 | } |
|
| 132 | ||
| 133 | public function rollbackTransaction() |
|
| 134 | { |
|
| 135 | if ($this->_transaction) { |
|
| 136 | $this->_transaction = false; |
|
| 137 | ||
| 138 | $ret = sqlrcon_rollback($this->_conn); |
|
| 139 | if ($ret === 0) { |
|
| 140 | throw new DatabaseException('Commit failed'); |
|
| 141 | } else if ($ret === -1) { |
|
| 142 | throw new DatabaseException('An error occurred. Commit failed'); |
|
| 143 | } |
|
| 144 | ||
| 145 | sqlrcon_autoCommitOn($this->_conn); |
|
| 146 | } |
|
| 147 | } |
|
| 148 | ||
| 149 | public function executeSql($sql, $array = null) |
|
| 150 | { |
|
