class ActiveRecord::FixtureSet

def self.create_fixtures(fixtures_directory, fixture_set_names, class_names = {})
  fixture_set_names = Array(fixture_set_names).map(&:to_s)
  class_names = class_names.stringify_keys
  # FIXME: Apparently JK uses this.
  connection = block_given? ? yield : ActiveRecord::Base.connection
  files_to_read = fixture_set_names.reject { |fs_name|
    fixture_is_cached?(connection, fs_name)
  }
  unless files_to_read.empty?
    connection.disable_referential_integrity do
      fixtures_map = {}
      fixture_sets = files_to_read.map do |fs_name|
        fixtures_map[fs_name] = new( # ActiveRecord::FixtureSet.new
          connection,
          fs_name,
          class_names[fs_name] || default_fixture_model_name(fs_name),
          ::File.join(fixtures_directory, fs_name))
      end
      all_loaded_fixtures.update(fixtures_map)
      connection.transaction(:requires_new => true) do
        fixture_sets.each do |fs|
          conn = fs.model_class.respond_to?(:connection) ? fs.model_class.connection : connection
          table_rows = fs.table_rows
          table_rows.keys.each do |table|
            conn.delete "DELETE FROM #{conn.quote_table_name(table)}", 'Fixture Delete'
          end
          table_rows.each do |fixture_set_name, rows|
            rows.each do |row|
              conn.insert_fixture(row, fixture_set_name)
            end
          end
        end
        # Cap primary key sequences to max(pk).
        if connection.respond_to?(:reset_pk_sequence!)
          fixture_sets.each do |fs|
            connection.reset_pk_sequence!(fs.table_name)
          end
        end
      end
      cache_fixtures(connection, fixtures_map)
    end
  end
  cached_fixtures(connection, fixture_set_names)
end