Class: DbSession

Inherits:
Sequel::Model
  • Object
show all
Defined in:
lib/taps/db_session.rb

Constant Summary collapse

@@connections = 
{}
@@mutex = 
Mutex.new

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.cleanup ⇒ Object

Removes connections that have not been accessed within the past thirty seconds.



42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/taps/db_session.rb', line 42

def self.cleanup
	@@mutex.synchronize {
		now = Time.now
		@@connections.each do |key, (conn, time)|
			if now - time > 30
				@@connections.delete(key)
				conn.disconnect
			end
		end
	}
end

Instance Method Details

#connection ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/taps/db_session.rb', line 18

def connection
	@@mutex.synchronize {
		conn =
			if @@connections.key?(key)
				@@connections[key].first
			else
				Sequel.connect(database_url)
			end
		@@connections[key] = [conn, Time.now]
		return conn
	}
end

#disconnect ⇒ Object 



31
32
33
34
35
36
37
38
 
# File 'lib/taps/db_session.rb', line 31

def disconnect
	@@mutex.synchronize {
		if @@connections.key?(key)
			conn, time = @@connections.delete(key)
			conn.disconnect
		end
	}
end