SEQUEL_ADAPTER_TEST = :sqlite require File.join(File.dirname(File.expand_path(__FILE__)), 'spec_helper.rb') describe "An SQLite database" do before do @db = DB @fk = @db.foreign_keys end after do @db.drop_table?(:fk) @db.auto_vacuum = :none @db.run 'VACUUM' @db.foreign_keys = @fk @db.case_sensitive_like = true @db.use_timestamp_timezones = false Sequel.datetime_class = Time end it "should support getting setting pragma values" do @db.pragma_set(:auto_vacuum, '0') @db.run 'VACUUM' @db.pragma_get(:auto_vacuum).to_s.must_equal '0' @db.pragma_set(:auto_vacuum, '1') @db.run 'VACUUM' @db.pragma_get(:auto_vacuum).to_s.must_equal '1' @db.pragma_set(:auto_vacuum, '2') @db.run 'VACUUM' @db.pragma_get(:auto_vacuum).to_s.must_equal '2' end it "should support getting and setting the auto_vacuum pragma" do @db.auto_vacuum = :full @db.run 'VACUUM' @db.auto_vacuum.must_equal :full @db.auto_vacuum = :incremental @db.run 'VACUUM' @db.auto_vacuum.must_equal :incremental proc {@db.auto_vacuum = :invalid}.must_raise(Sequel::Error) end it "should respect case sensitive like false" do @db.case_sensitive_like = false @db.get(Sequel.like('a', 'A')).to_s.must_equal '1' end it "should respect case sensitive like true" do @db.case_sensitive_like = true @db.get(Sequel.like('a', 'A')).to_s.must_equal '0' end it "should support casting to Date by using the date function" do @db.get(Sequel.cast('2012-10-20 11:12:13', Date)).must_equal '2012-10-20' end it "should support casting to Time or DateTime by using the datetime function" do @db.get(Sequel.cast('2012-10-20', Time)).must_equal '2012-10-20 00:00:00' @db.get(Sequel.cast('2012-10-20', DateTime)).must_equal '2012-10-20 00:00:00' end it "should provide the SQLite version as an integer" do @db.sqlite_version.must_be_kind_of(Integer) end it "should support setting and getting the foreign_keys pragma" do (@db.sqlite_version >= 30619 ? [true, false] : [nil]).must_include(@db.foreign_keys) @db.foreign_keys = true @db.foreign_keys = false end it "should enforce foreign key integrity if foreign_keys pragma is set" do @db.foreign_keys = true @db.create_table!(:fk){primary_key :id; foreign_key :parent_id, :fk} @db[:fk].insert(1, nil) @db[:fk].insert(2, 1) @db[:fk].insert(3, 3) proc{@db[:fk].insert(4, 5)}.must_raise(Sequel::ForeignKeyConstraintViolation, Sequel::ConstraintViolation, Sequel::DatabaseError) end if DB.sqlite_version >= 30619 it "should not enforce foreign key integrity if foreign_keys pragma is unset" do @db.foreign_keys = false @db.create_table!(:fk){primary_key :id; foreign_key :parent_id, :fk} @db[:fk].insert(1, 2) @db[:fk].all.must_equal [{:id=>1, :parent_id=>2}] end it "should support a use_timestamp_timezones setting" do @db.use_timestamp_timezones = true @db.create_table!(:fk){Time :time} @db[:fk].insert(Time.now) @db[:fk].get(Sequel.cast(:time, String)).must_match(/[-+]\d\d\d\d\z/) @db.use_timestamp_timezones = false @db[:fk].delete @db[:fk].insert(Time.now) @db[:fk].get(Sequel.cast(:time, String)).wont_match(/[-+]\d\d\d\d\z/) end it "should provide a list of existing tables" do @db.drop_table?(:fk) @db.tables.must_be_kind_of(Array) @db.tables.wont_include(:fk) @db.create_table!(:fk){String :name} @db.tables.must_include(:fk) end it "should support getting and setting the synchronous pragma" do @db.synchronous = :off @db.synchronous.must_equal :off @db.synchronous = :normal @db.synchronous.must_equal :normal @db.synchronous = :full @db.synchronous.must_equal :full proc {@db.synchronous = :invalid}.must_raise(Sequel::Error) end it "should support getting and setting the temp_store pragma" do @db.temp_store = :default @db.temp_store.must_equal :default @db.temp_store = :file @db.temp_store.must_equal :file @db.temp_store = :memory @db.temp_store.must_equal :memory proc {@db.temp_store = :invalid}.must_raise(Sequel::Error) end cspecify "should support timestamps and datetimes and respect datetime_class", [:do], [:jdbc], [:swift] do @db.create_table!(:fk){timestamp :t; datetime :d} @db.use_timestamp_timezones = true t1 = Time.at(1) @db[:fk] << {:t => t1, :d => t1} @db[:fk].map(:t).must_equal [t1] @db[:fk].map(:d).must_equal [t1] Sequel.datetime_class = DateTime t2 = Sequel.string_to_datetime(t1.iso8601) @db[:fk].map(:t).must_equal [t2] @db[:fk].map(:d).must_equal [t2] end it "should support sequential primary keys" do @db.create_table!(:fk) {primary_key :id; text :name} @db[:fk] << {:name => 'abc'} @db[:fk] << {:name => 'def'} @db[:fk] << {:name => 'ghi'} @db[:fk].order(:name).all.must_equal [ {:id => 1, :name => 'abc'}, {:id => 2, :name => 'def'}, {:id => 3, :name => 'ghi'} ] end it "should correctly parse the schema" do @db.create_table!(:fk) {timestamp :t} @db.schema(:fk, :reload=>true).must_equal [[:t, {:type=>:datetime, :allow_null=>true, :default=>nil, :ruby_default=>nil, :db_type=>"timestamp", :primary_key=>false}]] end it "should handle and return BigDecimal values for numeric columns" do DB.create_table!(:fk){numeric :d} d = DB[:fk] d.insert(:d=>BigDecimal.new('80.0')) d.insert(:d=>BigDecimal.new('NaN')) d.insert(:d=>BigDecimal.new('Infinity')) d.insert(:d=>BigDecimal.new('-Infinity')) ds = d.all ds.shift.must_equal(:d=>BigDecimal.new('80.0')) ds.map{|x| x[:d].to_s}.must_equal %w'NaN Infinity -Infinity' DB end end describe "SQLite temporary views" do before do @db = DB @db.drop_view(:items) rescue nil @db.create_table!(:items){Integer :number} @db[:items].insert(10) @db[:items].insert(20) end after do @db.drop_table?(:items) end it "should be supported" do @db.create_view(:items_view, @db[:items].where(:number=>10), :temp=>true) @db[:items_view].map(:number).must_equal [10] @db.disconnect lambda{@db[:items_view].map(:number)}.must_raise(Sequel::DatabaseError) end end describe "SQLite VALUES support" do before do @db = DB end it "should create a dataset using the VALUES clause via #values" do @db.values([[1, 2], [3, 4]]).map([:column1, :column2]).must_equal [[1, 2], [3, 4]] end it "should support VALUES with unions" do @db.values([[1]]).union(@db.values([[3]])).map(&:values).map(&:first).must_equal [1, 3] end it "should support VALUES in CTEs" do @db[:a].cross_join(:b).with(:a, @db.values([[1, 2]]), :args=>[:c1, :c2]).with(:b, @db.values([[3, 4]]), :args=>[:c3, :c4]).map([:c1, :c2, :c3, :c4]).must_equal [[1, 2, 3, 4]] end end if DB.sqlite_version >= 30803 describe "SQLite type conversion" do before do @db = DB @integer_booleans = @db.integer_booleans @db.integer_booleans = true @ds = @db[:items] @db.drop_table?(:items) end after do @db.integer_booleans = @integer_booleans Sequel.datetime_class = Time @db.drop_table?(:items) end it "should handle integers in boolean columns" do @db.create_table(:items){TrueClass :a} @db[:items].insert(false) @db[:items].select_map(:a).must_equal [false] @db[:items].select_map(Sequel.expr(:a)+:a).must_equal [0] @db[:items].update(:a=>true) @db[:items].select_map(:a).must_equal [true] @db[:items].select_map(Sequel.expr(:a)+:a).must_equal [2] end it "should handle integers/floats/strings/decimals in numeric/decimal columns" do @db.create_table(:items){Numeric :a} @db[:items].insert(100) @db[:items].select_map(:a).must_equal [BigDecimal.new('100')] @db[:items].get(:a).must_be_kind_of(BigDecimal) @db[:items].update(:a=>100.1) @db[:items].select_map(:a).must_equal [BigDecimal.new('100.1')] @db[:items].get(:a).must_be_kind_of(BigDecimal) @db[:items].update(:a=>'100.1') @db[:items].select_map(:a).must_equal [BigDecimal.new('100.1')] @db[:items].get(:a).must_be_kind_of(BigDecimal) @db[:items].update(:a=>BigDecimal.new('100.1')) @db[:items].select_map(:a).must_equal [BigDecimal.new('100.1')] @db[:items].get(:a).must_be_kind_of(BigDecimal) end it "should handle integer/float date columns as julian date" do @db.create_table(:items){Date :a} i = 2455979 @db[:items].insert(i) @db[:items].first.must_equal(:a=>Date.jd(i)) @db[:items].update(:a=>2455979.1) @db[:items].first.must_equal(:a=>Date.jd(i)) end it "should handle integer/float time columns as seconds" do @db.create_table(:items){Time :a, :only_time=>true} @db[:items].insert(3661) @db[:items].first.must_equal(:a=>Sequel::SQLTime.create(1, 1, 1)) @db[:items].update(:a=>3661.000001) @db[:items].first.must_equal(:a=>Sequel::SQLTime.create(1, 1, 1, 1)) end it "should handle integer datetime columns as unix timestamp" do @db.create_table(:items){DateTime :a} i = 1329860756 @db[:items].insert(i) @db[:items].first.must_equal(:a=>Time.at(i)) Sequel.datetime_class = DateTime @db[:items].first.must_equal(:a=>DateTime.strptime(i.to_s, '%s')) end it "should handle float datetime columns as julian date" do @db.create_table(:items){DateTime :a} i = 2455979.5 @db[:items].insert(i) @db[:items].first.must_equal(:a=>Time.at(1329825600)) Sequel.datetime_class = DateTime @db[:items].first.must_equal(:a=>DateTime.jd(2455979.5)) end it "should handle integer/float blob columns" do @db.create_table(:items){File :a} @db[:items].insert(1) @db[:items].first.must_equal(:a=>Sequel::SQL::Blob.new('1')) @db[:items].update(:a=>'1.1') @db[:items].first.must_equal(:a=>Sequel::SQL::Blob.new(1.1.to_s)) end end if DB.adapter_scheme == :sqlite describe "An SQLite dataset" do before do @d = DB[:items] end it "should raise errors if given a regexp pattern match" do proc{@d.literal(Sequel.expr(:x).like(/a/))}.must_raise(Sequel::InvalidOperation) proc{@d.literal(~Sequel.expr(:x).like(/a/))}.must_raise(Sequel::InvalidOperation) proc{@d.literal(Sequel.expr(:x).like(/a/i))}.must_raise(Sequel::InvalidOperation) proc{@d.literal(~Sequel.expr(:x).like(/a/i))}.must_raise(Sequel::InvalidOperation) end end describe "An SQLite dataset AS clause" do it "should use a string literal for Sequel[:col].as(:alias)" do DB.literal(Sequel[:c].as(:a)).must_equal "`c` AS 'a'" end it "should use a string literal for Sequel[:table][:col].as(:alias)" do DB.literal(Sequel[:t][:c].as(:a)).must_equal "`t`.`c` AS 'a'" end it "should use a string literal for :column.as(:alias)" do DB.literal(Sequel.as(:c, :a)).must_equal "`c` AS 'a'" end it "should use a string literal in the SELECT clause" do DB[:t].select(Sequel[:c].as(:a)).sql.must_equal "SELECT `c` AS 'a' FROM `t`" end it "should use a string literal in the FROM clause" do DB[Sequel[:t].as(:a)].sql.must_equal "SELECT * FROM `t` AS 'a'" end it "should use a string literal in the JOIN clause" do DB[:t].join_table(:natural, :j, nil, :table_alias=>:a).sql.must_equal "SELECT * FROM `t` NATURAL JOIN `j` AS 'a'" end end describe "SQLite::Dataset#delete" do before do DB.create_table! :items do primary_key :id String :name Float :value end @d = DB[:items] @d.delete # remove all records @d << {:name => 'abc', :value => 1.23} @d << {:name => 'def', :value => 4.56} @d << {:name => 'ghi', :value => 7.89} end it "should return the number of records affected when filtered" do @d.count.must_equal 3 @d.filter{value < 3}.delete.must_equal 1 @d.count.must_equal 2 @d.filter{value < 3}.delete.must_equal 0 @d.count.must_equal 2 end it "should return the number of records affected when unfiltered" do @d.count.must_equal 3 @d.delete.must_equal 3 @d.count.must_equal 0 @d.delete.must_equal 0 end end describe "SQLite::Dataset#update" do before do DB.create_table! :items do primary_key :id String :name Float :value end @d = DB[:items] @d.delete # remove all records @d << {:name => 'abc', :value => 1.23} @d << {:name => 'def', :value => 4.56} @d << {:name => 'ghi', :value => 7.89} end it "should return the number of records affected" do @d.filter(:name => 'abc').update(:value => 2).must_equal 1 @d.update(:value => 10).must_equal 3 @d.filter(:name => 'xxx').update(:value => 23).must_equal 0 end end describe "SQLite::Dataset#insert_conflict" do before(:all) do DB.create_table! :ic_test do primary_key :id String :name end end after(:each) do DB[:ic_test].delete end after(:all) do DB.drop_table?(:ic_test) end it "Dataset#insert_ignore and insert_constraint should ignore uniqueness violations" do DB[:ic_test].insert(:id => 1, :name => "one") proc {DB[:ic_test].insert(:id => 1, :name => "one")}.must_raise Sequel::ConstraintViolation DB[:ic_test].insert_ignore.insert(:id => 1, :name => "one") DB[:ic_test].all.must_equal([{:id => 1, :name => "one"}]) DB[:ic_test].insert_conflict(:ignore).insert(:id => 1, :name => "one") DB[:ic_test].all.must_equal([{:id => 1, :name => "one"}]) end it "Dataset#insert_constraint should handle replacement" do DB[:ic_test].insert(:id => 1, :name => "one") DB[:ic_test].insert_conflict(:replace).insert(:id => 1, :name => "two") DB[:ic_test].all.must_equal([{:id => 1, :name => "two"}]) end end describe "SQLite dataset" do before do DB.create_table! :test do primary_key :id String :name Float :value end DB.create_table! :items do primary_key :id String :name Float :value end @d = DB[:items] @d << {:name => 'abc', :value => 1.23} @d << {:name => 'def', :value => 4.56} @d << {:name => 'ghi', :value => 7.89} end after do DB.drop_table?(:test, :items) end it "should be able to insert from a subquery" do DB[:test] << @d DB[:test].count.must_equal 3 DB[:test].select(:name, :value).order(:value).to_a.must_equal \ @d.select(:name, :value).order(:value).to_a end it "should support #explain" do DB[:test].explain.must_be_kind_of(String) end it "should have #explain work when identifier_output_method is modified" do DB[:test].with_identifier_output_method(:upcase).explain.must_be_kind_of(String) end end describe "A SQLite database" do before do @db = DB @db.create_table! :test2 do text :name integer :value end end after do @db.drop_table?(:test2) end it "should support add_column operations" do @db.add_column :test2, :xyz, :text @db[:test2].columns.must_equal [:name, :value, :xyz] @db[:test2] << {:name => 'mmm', :value => 111, :xyz=>'000'} @db[:test2].first.must_equal(:name => 'mmm', :value => 111, :xyz=>'000') end it "should support drop_column operations" do @db.drop_column :test2, :value @db[:test2].columns.must_equal [:name] @db[:test2] << {:name => 'mmm'} @db[:test2].first.must_equal(:name => 'mmm') end it "should support drop_column operations in a transaction" do @db.transaction{@db.drop_column :test2, :value} @db[:test2].columns.must_equal [:name] @db[:test2] << {:name => 'mmm'} @db[:test2].first.must_equal(:name => 'mmm') end it "should keep a composite primary key when dropping columns" do @db.create_table!(:test2){Integer :a; Integer :b; Integer :c; primary_key [:a, :b]} @db.drop_column :test2, :c @db[:test2].columns.must_equal [:a, :b] @db[:test2] << {:a=>1, :b=>2} @db[:test2] << {:a=>2, :b=>3} proc{@db[:test2] << {:a=>2, :b=>3}}.must_raise(Sequel::UniqueConstraintViolation, Sequel::ConstraintViolation, Sequel::DatabaseError) end it "should keep column attributes when dropping a column" do @db.create_table! :test3 do primary_key :id text :name integer :value end # This lame set of additions and deletions are to test that the primary keys # don't get messed up when we recreate the database. @db[:test3] << { :name => "foo", :value => 1} @db[:test3] << { :name => "foo", :value => 2} @db[:test3] << { :name => "foo", :value => 3} @db[:test3].filter(:id => 2).delete @db.drop_column :test3, :value @db['PRAGMA table_info(?)', :test3][:id][:pk].to_i.must_equal 1 @db[:test3].select(:id).all.must_equal [{:id => 1}, {:id => 3}] end if DB.foreign_keys it "should keep foreign keys when dropping a column" do @db.create_table! :test do primary_key :id String :name Integer :value end @db.create_table! :test3 do String :name Integer :value foreign_key :test_id, :test, :on_delete => :set_null, :on_update => :cascade end @db[:test3].insert(:name => "abc", :test_id => @db[:test].insert(:name => "foo", :value => 3)) @db[:test3].insert(:name => "def", :test_id => @db[:test].insert(:name => "bar", :value => 4)) @db.drop_column :test3, :value @db[:test].filter(:name => 'bar').delete @db[:test3][:name => 'def'][:test_id].must_equal nil @db[:test].filter(:name => 'foo').update(:id=>100) @db[:test3][:name => 'abc'][:test_id].must_equal 100 @db.drop_table? :test, :test3 end end it "should support rename_column operations" do @db[:test2].delete @db.add_column :test2, :xyz, :text @db[:test2] << {:name => 'mmm', :value => 111, :xyz => 'qqqq'} @db[:test2].columns.must_equal [:name, :value, :xyz] @db.rename_column :test2, :xyz, :zyx, :type => :text @db[:test2].columns.must_equal [:name, :value, :zyx] @db[:test2].first[:zyx].must_equal 'qqqq' @db[:test2].count.must_equal 1 end it "should preserve defaults when dropping or renaming columns" do @db.create_table! :test3 do String :s, :default=>'a' Integer :i end @db[:test3].insert @db[:test3].first[:s].must_equal 'a' @db[:test3].delete @db.drop_column :test3, :i @db[:test3].insert @db[:test3].first[:s].must_equal 'a' @db[:test3].delete @db.rename_column :test3, :s, :t @db[:test3].insert @db[:test3].first[:t].must_equal 'a' @db[:test3].delete end it "should handle quoted tables when dropping or renaming columns" do @db.quote_identifiers = true table_name = "T T" @db.drop_table?(table_name) @db.create_table! table_name do Integer :"s s" Integer :"i i" end @db.from(table_name).insert(:"s s"=>1, :"i i"=>2) @db.from(table_name).all.must_equal [{:"s s"=>1, :"i i"=>2}] @db.drop_column table_name, :"i i" @db.from(table_name).all.must_equal [{:"s s"=>1}] @db.rename_column table_name, :"s s", :"t t" @db.from(table_name).all.must_equal [{:"t t"=>1}] @db.drop_table?(table_name) end it "should choose a temporary table name that isn't already used when dropping or renaming columns" do sqls = [] @db.loggers << (l=Class.new{%w'info error'.each{|m| define_method(m){|sql| sqls << sql}}}.new) @db.tables.each{|t| @db.drop_table(t) if t.to_s =~ /test3/} @db.create_table :test3 do Integer :h Integer :i end @db.create_table :test3_backup0 do Integer :j end @db.create_table :test3_backup1 do Integer :k end @db[:test3].columns.must_equal [:h, :i] @db[:test3_backup0].columns.must_equal [:j] @db[:test3_backup1].columns.must_equal [:k] sqls.clear @db.drop_column(:test3, :i) sqls.any?{|x| x =~ /\AALTER TABLE.*test3.*RENAME TO.*test3_backup2/}.must_equal true sqls.any?{|x| x =~ /\AALTER TABLE.*test3.*RENAME TO.*test3_backup[01]/}.must_equal false @db[:test3].columns.must_equal [:h] @db[:test3_backup0].columns.must_equal [:j] @db[:test3_backup1].columns.must_equal [:k] @db.create_table :test3_backup2 do Integer :l end sqls.clear @db.rename_column(:test3, :h, :i) sqls.any?{|x| x =~ /\AALTER TABLE.*test3.*RENAME TO.*test3_backup3/}.must_equal true sqls.any?{|x| x =~ /\AALTER TABLE.*test3.*RENAME TO.*test3_backup[012]/}.must_equal false @db[:test3].columns.must_equal [:i] @db[:test3_backup0].columns.must_equal [:j] @db[:test3_backup1].columns.must_equal [:k] @db[:test3_backup2].columns.must_equal [:l] @db.loggers.delete(l) @db.drop_table?(:test3, :test3_backup0, :test3_backup1, :test3_backup2) end it "should support add_index" do @db.add_index :test2, :value, :unique => true @db.add_index :test2, [:name, :value] end it "should support drop_index" do @db.add_index :test2, :value, :unique => true @db.drop_index :test2, :value end it "should keep applicable indexes when emulating schema methods" do @db.create_table!(:a){Integer :a; Integer :b} @db.add_index :a, :a @db.add_index :a, :b @db.add_index :a, [:b, :a] @db.drop_column :a, :b @db.indexes(:a).must_equal(:a_a_index=>{:unique=>false, :columns=>[:a]}) end it "should have support for various #transaction modes" do sqls = [] @db.loggers << Class.new{%w'info error'.each{|m| define_method(m){|sql| sqls << sql}}}.new @db.transaction(:mode => :immediate) do sqls.last.must_equal "BEGIN IMMEDIATE TRANSACTION" end @db.transaction(:mode => :exclusive) do sqls.last.must_equal "BEGIN EXCLUSIVE TRANSACTION" end @db.transaction(:mode => :deferred) do sqls.last.must_equal "BEGIN DEFERRED TRANSACTION" end @db.transaction do sqls.last.must_equal Sequel::Database::SQL_BEGIN end @db.transaction_mode.must_equal nil @db.transaction_mode = :immediate @db.transaction_mode.must_equal :immediate @db.transaction do sqls.last.must_equal "BEGIN IMMEDIATE TRANSACTION" end @db.transaction(:mode => :exclusive) do sqls.last.must_equal "BEGIN EXCLUSIVE TRANSACTION" end proc {@db.transaction_mode = :invalid}.must_raise(Sequel::Error) @db.transaction_mode.must_equal :immediate proc {@db.transaction(:mode => :invalid) {}}.must_raise(Sequel::Error) end it "should keep unique constraints when copying tables" do @db.alter_table(:test2){add_unique_constraint :name} @db.alter_table(:test2){drop_column :value} @db[:test2].insert(:name=>'a') proc{@db[:test2].insert(:name=>'a')}.must_raise(Sequel::ConstraintViolation, Sequel::UniqueConstraintViolation) end end