 |
Add :distinct boolean to use DISTINCT counts - reportable - Fork of reportable … |
 |
Log |
|
Files |
|
Refs |
|
README |
|
--- |
|
commit 865d6f6c639a2e5e1b50b559bd0278af35ad5c67 |
|
parent 5f29dfb16b4b34158a89f37283d31d2c42852f04 |
 |
Author: Mark Towfiq <[email protected]> |
|
Date: Wed, 9 Jan 2013 17:56:38 -0800 |
|
|
|
Add :distinct boolean to use DISTINCT counts |
|
|
|
Diffstat: |
|
M lib/saulabs/reportable/report.rb | 4 +++- |
|
M spec/classes/report_spec.rb | 32 ++++++++++++++++++++++++-----… |
|
M spec/db/schema.rb | 1 + |
|
|
|
3 files changed, 29 insertions(+), 8 deletions(-) |
|
--- |
|
diff --git a/lib/saulabs/reportable/report.rb b/lib/saulabs/reportable/report.rb |
|
@@ -68,6 +68,7 @@ module Saulabs |
|
@value_column = (options[:value_column] || (@aggregation == :count ? '… |
|
@options = { |
|
:limit => options[:limit] || 100, |
|
+ :distinct => options[:distinct] || false, |
|
:conditions => options[:conditions] || [], |
|
:grouping => Grouping.new(options[:grouping] || :day), |
|
:live_data => options[:live_data] || false, |
|
@@ -118,6 +119,7 @@ module Saulabs |
|
@klass.send(@aggregation, |
|
@value_column, |
|
:conditions => conditions, |
|
+ :distinct => options[:distinct], |
|
:group => options[:grouping].to_sql(@date_column), |
|
:order => "#{options[:grouping].to_sql(@date_column)} ASC", |
|
:limit => options[:limit] |
|
@@ -145,7 +147,7 @@ module Saulabs |
|
case context |
|
when :initialize |
|
options.each_key do |k| |
|
- raise ArgumentError.new("Invalid option #{k}!") unless [:limit… |
|
+ raise ArgumentError.new("Invalid option #{k}!") unless [:limit… |
|
end |
|
raise ArgumentError.new("Invalid aggregation #{options[:aggregat… |
|
raise ArgumentError.new('The name of the column holding the valu… |
|
diff --git a/spec/classes/report_spec.rb b/spec/classes/report_spec.rb |
|
@@ -21,7 +21,7 @@ describe Saulabs::Reportable::Report do |
|
it 'should process the data with the report cache' do |
|
Saulabs::Reportable::ReportCache.should_receive(:process).once.with( |
|
@report, |
|
- { :limit => 100, :grouping => @report.options[:grouping], :conditions … |
|
+ { :limit => 100, :grouping => @report.options[:grouping], :conditions … |
|
) |
|
|
|
@report.run |
|
@@ -30,7 +30,7 @@ describe Saulabs::Reportable::Report do |
|
it 'should process the data with the report cache when custom conditions a… |
|
Saulabs::Reportable::ReportCache.should_receive(:process).once.with( |
|
@report, |
|
- { :limit => 100, :grouping => @report.options[:grouping], :conditions … |
|
+ { :limit => 100, :grouping => @report.options[:grouping], :conditions … |
|
) |
|
|
|
@report.run(:conditions => { :some => :condition }) |
|
@@ -47,7 +47,7 @@ describe Saulabs::Reportable::Report do |
|
Saulabs::Reportable::Grouping.should_receive(:new).once.with(:month).and… |
|
Saulabs::Reportable::ReportCache.should_receive(:process).once.with( |
|
@report, |
|
- { :limit => 100, :grouping => grouping, :conditions => [], :live_data … |
|
+ { :limit => 100, :grouping => grouping, :conditions => [], :live_data … |
|
) |
|
|
|
@report.run(:grouping => :month) |
|
@@ -71,10 +71,10 @@ describe Saulabs::Reportable::Report do |
|
describe "for grouping :#{grouping.to_s}" do |
|
|
|
before(:all) do |
|
- User.create!(:login => 'test 1', :created_at => Time.now, … |
|
- User.create!(:login => 'test 2', :created_at => Time.now - 1.send(gr… |
|
- User.create!(:login => 'test 3', :created_at => Time.now - 3.send(gr… |
|
- User.create!(:login => 'test 4', :created_at => Time.now - 3.send(gr… |
|
+ User.create!(:login => 'test 1', :created_at => Time.now, … |
|
+ User.create!(:login => 'test 2', :created_at => Time.now - 1.send(gr… |
|
+ User.create!(:login => 'test 3', :created_at => Time.now - 3.send(gr… |
|
+ User.create!(:login => 'test 4', :created_at => Time.now - 3.send(gr… |
|
end |
|
|
|
describe 'optimized querying with contiguously cached data' do |
|
@@ -299,6 +299,24 @@ describe Saulabs::Reportable::Report do |
|
result[6][1].should == 0.0 |
|
end |
|
|
|
+ it 'should return correct data for aggregation :count with distinc… |
|
+ @report = Saulabs::Reportable::Report.new(User, :registrations, |
|
+ :aggregation => :count, |
|
+ :grouping => grouping, |
|
+ :value_column => :sub_type, |
|
+ :distinct => true, |
|
+ :limit => 10, |
|
+ :live_data => live_data |
|
+ ) |
|
+ result = @report.run.to_a |
|
+ |
|
+ result[10][1].should == 1.0 if live_data |
|
+ result[9][1].should == 1.0 |
|
+ result[8][1].should == 0.0 |
|
+ result[7][1].should == 1.0 |
|
+ result[6][1].should == 0.0 |
|
+ end |
|
+ |
|
it 'should return correct data for aggregation :sum' do |
|
@report = Saulabs::Reportable::Report.new(User, :registrations, |
|
:aggregation => :sum, |
|
diff --git a/spec/db/schema.rb b/spec/db/schema.rb |
|
@@ -4,6 +4,7 @@ ActiveRecord::Schema.define(:version => 1) do |
|
t.string :login, :null => false |
|
t.integer :profile_visits, :null => false, :default => 0 |
|
t.string :type, :null => false, :default => 'User' |
|
+ t.string :sub_type |
|
|
|
t.timestamps |
|
end |
