adjust query counts to be consistent across databases, make sure data…

…base log the same things

activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb

@@ -85,6 +85,12 @@ def initialize(spec)
         @checked_out = []
         @automatic_reconnect = true
 
+        @tables = Hash.new do |h, table_name|
+          with_connection do |conn|
+            h[table_name] = conn.table_exists?(table_name)
+          end
+        end
+
         @columns     = Hash.new do |h, table_name|
           h[table_name] = with_connection do |conn|
 
@@ -107,11 +113,7 @@ def initialize(spec)
 
         @primary_keys = Hash.new do |h, table_name|
           h[table_name] = with_connection do |conn|
-            if conn.table_exists?(table_name)
-              conn.primary_key(table_name)
-            else
-              'id'
-            end
+            @tables[table_name] ? conn.primary_key(table_name) : 'id'
           end
         end
       end
@@ -121,10 +123,12 @@ def initialize(spec)
       #   * columns
       #   * columns_hash
       #   * primary_keys
+      #   * tables
       def clear_cache!
         @columns.clear
         @columns_hash.clear
         @primary_keys.clear
+        @tables.clear
       end
 
       # Clear out internal caches for table with +table_name+

activerecord/lib/active_record/connection_adapters/mysql_adapter.rb

@@ -537,7 +537,7 @@ def indexes(table_name, name = nil)#:nodoc:
       def columns(table_name, name = nil)#:nodoc:
         sql = "SHOW FIELDS FROM #{quote_table_name(table_name)}"
         columns = []
-        result = execute(sql, :skip_logging)
+        result = execute(sql)
         result.each { |field| columns << MysqlColumn.new(field[0], field[4], field[1], field[2] == "YES") }
         result.free
         columns

activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb

@@ -786,7 +786,7 @@ def reset_pk_sequence!(table, pk = nil, sequence = nil) #:nodoc:
       def pk_and_sequence_for(table) #:nodoc:
         # First try looking for a sequence with a dependency on the
         # given table's primary key.
-        result = query(<<-end_sql, 'PK and serial sequence')[0]
+        result = exec_query(<<-end_sql, 'PK and serial sequence').rows.first
           SELECT attr.attname, seq.relname
           FROM pg_class      seq,
                pg_attribute  attr,
@@ -1071,7 +1071,7 @@ def select_raw(sql, name = nil)
         #  - format_type includes the column size constraint, e.g. varchar(50)
         #  - ::regclass is a function that gives the id for a table name
         def column_definitions(table_name) #:nodoc:
-          query <<-end_sql
+          exec_query(<<-end_sql).rows
             SELECT a.attname, format_type(a.atttypid, a.atttypmod), d.adsrc, a.attnotnull
               FROM pg_attribute a LEFT JOIN pg_attrdef d
                 ON a.attrelid = d.adrelid AND a.attnum = d.adnum

activerecord/lib/active_record/connection_adapters/sqlite_adapter.rb

@@ -152,8 +152,11 @@ def exec_query(sql, name = nil, binds = [])
 
           # Don't cache statements without bind values
           if binds.empty?
-            stmt = @connection.prepare(sql)
-            cols = stmt.columns
+            stmt    = @connection.prepare(sql)
+            cols    = stmt.columns
+            records = stmt.to_a
+            stmt.close
+            stmt = records
           else
             cache = @statements[sql] ||= {
               :stmt => @connection.prepare(sql)
@@ -233,6 +236,15 @@ def tables(name = nil) #:nodoc:
 
       def columns(table_name, name = nil) #:nodoc:
         table_structure(table_name).map do |field|
+          case field["dflt_value"]
+          when /^null$/i
+            field["dflt_value"] = nil
+          when /^'(.*)'$/
+            field["dflt_value"] = $1.gsub(/''/, "'")
+          when /^"(.*)"$/
+            field["dflt_value"] = $1.gsub(/""/, '"')
+          end
+
           SQLiteColumn.new(field['name'], field['dflt_value'], field['type'], field['notnull'].to_i == 0)
         end
       end
@@ -334,7 +346,7 @@ def select(sql, name = nil, binds = []) #:nodoc:
         end
 
         def table_structure(table_name)
-          structure = @connection.table_info(quote_table_name(table_name))
+          structure = exec_query("PRAGMA table_info(#{quote_table_name(table_name)})").to_hash
           raise(ActiveRecord::StatementInvalid, "Could not find table '#{table_name}'") if structure.empty?
           structure
         end

activerecord/lib/active_record/result.rb

@@ -20,6 +20,10 @@ def each
       hash_rows.each { |row| yield row }
     end
 
+    def to_hash
+      hash_rows
+    end
+
     private
     def hash_rows
       @hash_rows ||= @rows.map { |row|

activerecord/test/cases/associations/has_and_belongs_to_many_associations_test.rb

@@ -757,10 +757,13 @@ def test_caching_of_columns
     david = Developer.find(1)
     # clear cache possibly created by other tests
     david.projects.reset_column_information
-    assert_queries(0) { david.projects.columns; david.projects.columns }
-    # and again to verify that reset_column_information clears the cache correctly
+
+    # One query for columns, one for primary key
+    assert_queries(2) { david.projects.columns; david.projects.columns }
+
+    ## and again to verify that reset_column_information clears the cache correctly
     david.projects.reset_column_information
-    assert_queries(0) { david.projects.columns; david.projects.columns }
+    assert_queries(2) { david.projects.columns; david.projects.columns }
   end
 
   def test_attributes_are_being_set_when_initialized_from_habm_association_with_where_clause

activerecord/test/cases/helper.rb

@@ -50,7 +50,7 @@ def with_active_record_default_timezone(zone)
 end
 
 ActiveRecord::Base.connection.class.class_eval do
-  IGNORED_SQL = [/^PRAGMA/, /^SELECT currval/, /^SELECT CAST/, /^SELECT @@IDENTITY/, /^SELECT @@ROWCOUNT/, /^SAVEPOINT/, /^ROLLBACK TO SAVEPOINT/, /^RELEASE SAVEPOINT/, /SHOW FIELDS/]
+  IGNORED_SQL = [/^PRAGMA (?!(table_info))/, /^SELECT currval/, /^SELECT CAST/, /^SELECT @@IDENTITY/, /^SELECT @@ROWCOUNT/, /^SAVEPOINT/, /^ROLLBACK TO SAVEPOINT/, /^RELEASE SAVEPOINT/]
 
   # FIXME: this needs to be refactored so specific database can add their own
   # ignored SQL.  This ignored SQL is for Oracle.

activerecord/test/cases/migration_test.rb

@@ -2022,7 +2022,10 @@ def test_changing_columns
         assert ! column(:name).default
         assert_equal :date, column(:birthdate).type
 
-        assert_queries(1) do
+        # One query for columns (delete_me table)
+        # One query for primary key (delete_me table)
+        # One query to do the bulk change
+        assert_queries(3) do
           with_bulk_change_table do |t|
             t.change :name, :string, :default => 'NONAME'
             t.change :birthdate, :datetime