| 307 | | def update_sql(sql, name = nil) |
|---|
| 308 | | execute(sql, name) do |handle| |
|---|
| 309 | | handle.rows |
|---|
| 310 | | end || select_value("SELECT @@ROWCOUNT AS AffectedRows") |
|---|
| | 307 | def update_sql(sql, name = nil) |
|---|
| | 308 | autoCommiting = @connection["AutoCommit"] |
|---|
| | 309 | begin |
|---|
| | 310 | begin_db_transaction if autoCommiting |
|---|
| | 311 | execute(sql, name) |
|---|
| | 312 | affectedRows = select_value("SELECT @@ROWCOUNT AS AffectedRows") |
|---|
| | 313 | commit_db_transaction if autoCommiting |
|---|
| | 314 | affectedRows |
|---|
| | 315 | rescue |
|---|
| | 316 | rollback_db_transaction if autoCommiting |
|---|
| | 317 | raise |
|---|
| | 318 | end |
|---|
