@@ -14,29 +14,28 @@ module NeverBlock
end
end
- # A proxy for the connection's exec method
+ # A proxy for the connection's query method
# quries the pool to get a connection first
- def exec(query)
+ def query(query)
@pool.hold do |conn|
conn.query(query)
end
end
- alias :query :exec
# This method must be called for transactions to work correctly.
# One cannot just send "begin" as you never know which connection
# will be available next. This method ensures you get the same connection
# while in a transaction.
def begin_db_transaction
@pool.hold(true) do |conn|
- conn.exec("begin")
+ conn.query("begin")
end
end
# see =begin_db_transaction
def rollback_db_transaction
@pool.hold do |conn|
- conn.exec("rollback")
+ conn.query("rollback")
@pool.release(Fiber.current,conn)
end
end
@@ -44,7 +43,7 @@ module NeverBlock
# see =begin_db_transaction
def commit_db_transaction
@pool.hold do |conn|
- conn.exec("commit")
+ conn.query("commit")
@pool.release(Fiber.current,conn)
end
end
lib/never_block/db/pooled_fibered_mysql_connection.rb
b4558844eb7e5a872db7bb49b8df3604854649bb
espace
mohammad.ali@espace.com.eg
http://github.com/espace/neverblock/commit/2e1876efcf729c3f794f771a833e9db176fe790d
2e1876efcf729c3f794f771a833e9db176fe790d
2008-09-05T04:27:39-07:00
2008-09-05T04:27:39-07:00
better transaction behavior
2c828b6e075d5a602a6eb20618357993ef486e5d
espace
mohammad.ali@espace.com.eg