Class: RequestLogAnalyzer::Database::Base

Inherits:
ActiveRecord::Base
  • Object
show all
Defined in:
lib/request_log_analyzer/database/base.rb

Direct Known Subclasses

Request, Source, Warning

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.column_type(type_indicator) ⇒ Object

Function to determine the column type for a field TODO: make more robust / include in file-format definition



95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
 
# File 'lib/request_log_analyzer/database/base.rb', line 95

def self.column_type(type_indicator)
  case type_indicator
  when :eval;      :text
  when :hash;      :text
  when :text;      :text
  when :string;    :string
  when :sec;       :double
  when :msec;      :double
  when :duration;  :double
  when :float;     :double
  when :double;    :double
  when :integer;   :integer
  when :int;       :int
  when :timestamp; :datetime
  when :datetime;  :datetime
  when :date;      :date
  else             :string
  end
end

.create_table! ⇒ Object 



66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
 
# File 'lib/request_log_analyzer/database/base.rb', line 66

def self.create_table!
  raise "No line_definition available to base table schema on!" unless self.line_definition
  
  unless table_exists?
    database.connection.create_table(table_name.to_sym) do |t|
    
      # Default fields
      t.column :request_id, :integer
      t.column :source_id,  :integer
      t.column :lineno,     :integer
    
      line_definition.captures.each do |capture|
        # Add a field for every capture
        t.column(capture[:name], column_type(capture[:type]))

        # If the capture provides other field as well, create columns for them, too
        capture[:provides].each { |field, field_type| t.column(field, column_type(field_type)) } if capture[:provides].kind_of?(Hash)
      end
    end
  end
  
  # Add indices to table for more speedy querying
  database.connection.add_index(self.table_name.to_sym, [:request_id]) # rescue
  database.connection.add_index(self.table_name.to_sym, [:source_id])  # rescue
end

.drop_table! ⇒ Object 



60
61
62
63
64
 
# File 'lib/request_log_analyzer/database/base.rb', line 60

def self.drop_table!
  database.connection.remove_index(self.table_name, [:source_id])  rescue nil
  database.connection.remove_index(self.table_name, [:request_id]) rescue nil
  database.connection.drop_table(self.table_name) if database.connection.table_exists?(self.table_name)
end

.subclass_from_line_definition(definition) ⇒ Object 



20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/request_log_analyzer/database/base.rb', line 20

def self.subclass_from_line_definition(definition)
  klass = Class.new(RequestLogAnalyzer::Database::Base)
  klass.set_table_name("#{definition.name}_lines")
  
  klass.line_definition = definition
  
  # Set relations with requests and sources table
  klass.belongs_to :request
  klass.belongs_to :source
  
  # Serialize complex fields into the database
  definition.captures.select { |c| c.has_key?(:provides) }.each do |capture|
    klass.send(:serialize, capture[:name], Hash)
  end

  RequestLogAnalyzer::Database::Request.has_many  "#{definition.name}_lines".to_sym
  RequestLogAnalyzer::Database::Source.has_many   "#{definition.name}_lines".to_sym

  return klass
end

.subclass_from_table(table) ⇒ Object 



41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
 
# File 'lib/request_log_analyzer/database/base.rb', line 41

def self.subclass_from_table(table)
  raise "Table #{table} not found!" unless database.connection.table_exists?(table)

  klass = Class.new(RequestLogAnalyzer::Database::Base)
  klass.set_table_name(table)

  if klass.column_names.include?('request_id')
    klass.belongs_to :request
    RequestLogAnalyzer::Database::Request.has_many table.to_sym
  end
  
  if klass.column_names.include?('source_id')
    klass.belongs_to :source
    RequestLogAnalyzer::Database::Source.has_many table.to_sym
  end
  
  return klass
end

Instance Method Details

#<=>(other) ⇒ Object 



5
6
7
8
9
10
11
 
# File 'lib/request_log_analyzer/database/base.rb', line 5

def <=>(other)
  if (source_id.nil? && other.source_id.nil?) || (source_comparison = source_id <=> other.source_id) == 0
    lineno <=> other.lineno
  else
    source_comparison
  end
end

#line_type ⇒ Object 



13
14
15
 
# File 'lib/request_log_analyzer/database/base.rb', line 13

def line_type
  self.class.name.underscore.gsub(/_line$/, '').to_sym
end