module Adapters

    module MockTransactions
      def begin_transaction
        DataMapper.logger.debug("BEGIN TRANSACTION (mock transaction!)")
      end

      def commit_transaction
        DataMapper.logger.debug("COMMIT TRANSACTION (mock transaction!)")
      end

      def rollback_transaction
        DataMapper.logger.debug("ROLLBACK TRANSACTION (mock transaction!)")
      end
    end

    module StandardSqlTransactions
      def begin_transaction
        connection = create_connection
        Thread::current["doa_#{@uri.scheme}_transaction"] = connection
        DataMapper.logger.debug("BEGIN TRANSACTION")
        command = connection.create_command("BEGIN")
        command.execute_non_query
      end

      def commit_transaction
        connection = create_connection
        Thread::current["doa_#{@uri.scheme}_transaction"] = nil
        DataMapper.logger.debug("COMMIT TRANSACTION")
        command = connection.create_command("COMMIT")
        command.execute_non_query
      end

      def rollback_transaction
        connection = create_connection
        Thread::current["doa_#{@uri.scheme}_transaction"] = nil
        DataMapper.logger.debug("ROLLBACK TRANSACTION")
        command = connection.create_command("ROLLBACK")
        command.execute_non_query
      end
    end