Class: ActiveRecord::ConnectionAdapters::SQLite3Adapter

Inherits:
AbstractAdapter show all
Includes:
ActiveRecord::ConnectionAdapters::SQLite3::DatabaseStatements, ActiveRecord::ConnectionAdapters::SQLite3::Quoting, ActiveRecord::ConnectionAdapters::SQLite3::SchemaStatements
Defined in:
activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb

Overview

The SQLite3 adapter works with the sqlite3-ruby drivers (available as gem from rubygems.org/gems/sqlite3).

Options:

  • :database - Path to the database file.

Defined Under Namespace

Classes: SQLite3Integer, StatementPool

Constant Summary collapse

ADAPTER_NAME = 
"SQLite"
NATIVE_DATABASE_TYPES = 
{
  primary_key:  "integer PRIMARY KEY AUTOINCREMENT NOT NULL",
  string:       { name: "varchar" },
  text:         { name: "text" },
  integer:      { name: "integer" },
  float:        { name: "float" },
  decimal:      { name: "decimal" },
  datetime:     { name: "datetime" },
  time:         { name: "time" },
  date:         { name: "date" },
  binary:       { name: "blob" },
  boolean:      { name: "boolean" },
  json:         { name: "json" },
}

Constants inherited from AbstractAdapter

AbstractAdapter::COMMENT_REGEX, AbstractAdapter::SIMPLE_INT

Constants included from ActiveSupport::Callbacks

ActiveSupport::Callbacks::CALLBACK_FILTER_TYPES

Instance Attribute Summary

Attributes inherited from AbstractAdapter

#lock, #logger, #owner, #pool, #visitor

Attributes included from QueryCache

#query_cache, #query_cache_enabled

Attributes included from DatabaseStatements

#transaction_manager

Class Method Summary collapse

Instance Method Summary collapse

Methods included from ActiveRecord::ConnectionAdapters::SQLite3::DatabaseStatements

#begin_db_transaction, #begin_isolated_db_transaction, #commit_db_transaction, #exec_delete, #exec_query, #exec_rollback_db_transaction, #execute, #explain, #write_query?

Methods included from ActiveRecord::ConnectionAdapters::SQLite3::SchemaStatements

#add_foreign_key, #create_schema_dumper, #indexes, #remove_foreign_key

Methods included from ActiveRecord::ConnectionAdapters::SQLite3::Quoting

#column_name_matcher, #column_name_with_order_matcher, #quote_column_name, #quote_string, #quote_table_name, #quote_table_name_for_assignment, #quoted_binary, #quoted_false, #quoted_time, #quoted_true, #unquoted_false, #unquoted_true

Methods inherited from AbstractAdapter

#adapter_name, #advisory_locks_enabled?, build_read_query_regexp, #case_insensitive_comparison, #case_sensitive_comparison, #clear_cache!, #close, #column_name_for_operation, #database_version, #default_index_type?, #default_uniqueness_comparison, #disable_extension, #discard!, #enable_extension, #expire, #extensions, #get_advisory_lock, #index_algorithms, #lease, #migration_context, #migrations_paths, #prefetch_primary_key?, #prepared_statements, #prepared_statements_disabled_cache, #preventing_writes?, quoted_column_names, quoted_table_names, #raw_connection, #release_advisory_lock, #replica?, #reset!, #schema_cache, #schema_cache=, #schema_migration, #seconds_idle, #steal!, #supports_advisory_locks?, #supports_bulk_alter?, #supports_comments?, #supports_comments_in_create?, #supports_extensions?, #supports_foreign_keys_in_create?, #supports_foreign_tables?, #supports_indexes_in_create?, #supports_insert_returning?, #supports_materialized_views?, #supports_multi_insert?, #supports_optimizer_hints?, #supports_validate_constraints?, #supports_virtual_columns?, type_cast_config_to_boolean, type_cast_config_to_integer, #unprepared_statement, #valid_type?, #verify!

Methods included from Savepoints

#create_savepoint, #current_savepoint_name, #exec_rollback_to_savepoint, #release_savepoint

Methods included from QueryCache

#cache, #clear_query_cache, dirties_query_cache, #disable_query_cache!, #enable_query_cache!, included, #select_all, #uncached

Methods included from DatabaseLimits

#column_name_length, #columns_per_multicolumn_index, #columns_per_table, #in_clause_length, #index_name_length, #indexes_per_table, #joins_per_query, #max_identifier_length, #sql_query_length, #table_alias_length, #table_name_length

Methods included from Quoting

#column_name_matcher, #column_name_with_order_matcher, #lookup_cast_type_from_column, #quote, #quote_column_name, #quote_default_expression, #quote_string, #quote_table_name, #quote_table_name_for_assignment, #quoted_binary, #quoted_date, #quoted_false, #quoted_time, #quoted_true, #sanitize_as_sql_comment, #type_cast, #type_cast_from_column, #unquoted_false, #unquoted_true

Methods included from DatabaseStatements

#add_transaction_record, #begin_db_transaction, #begin_isolated_db_transaction, #cacheable_query, #commit_db_transaction, #default_sequence_name, #delete, #empty_insert_statement_value, #exec_delete, #exec_insert, #exec_insert_all, #exec_query, #exec_rollback_db_transaction, #exec_update, #execute, #insert, #insert_fixture, #insert_fixtures_set, #query, #query_value, #query_values, #reset_sequence!, #reset_transaction, #rollback_db_transaction, #rollback_to_savepoint, #sanitize_limit, #select_all, #select_one, #select_rows, #select_value, #select_values, #to_sql, #transaction, #transaction_isolation_levels, #transaction_open?, #transaction_state, #truncate, #truncate_tables, #update, #with_yaml_fallback, #write_query?

Methods included from SchemaStatements

#add_foreign_key, #add_index, #add_index_options, #add_timestamps, #assume_migrated_upto_version, #change_column_comment, #change_table, #change_table_comment, #column_exists?, #columns, #columns_for_distinct, #create_join_table, #create_schema_dumper, #create_table, #data_source_exists?, #data_sources, #drop_join_table, #drop_table, #dump_schema_information, #foreign_key_column_for, #foreign_key_exists?, #foreign_key_options, #index_exists?, #index_name, #index_name_exists?, #indexes, #internal_string_options_for_primary_key, #options_include_default?, #primary_key, #remove_columns, #remove_foreign_key, #remove_reference, #remove_timestamps, #rename_index, #table_alias_for, #table_comment, #table_exists?, #table_options, #tables, #type_to_sql, #update_table_definition, #view_exists?, #views

Methods included from ActiveSupport::Callbacks

#run_callbacks

Methods included from ActiveSupport::Concern

#append_features, #class_methods, extended, #included

Constructor Details

#initialize(connection, logger, connection_options, config) ⇒ SQLite3Adapter

Returns a new instance of SQLite3Adapter.



96
97
98
99
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 96

def initialize(connection, logger, connection_options, config)
  super(connection, logger, config)
  configure_connection
end

Class Method Details

.database_exists?(config) ⇒ Boolean

Returns:

  • (Boolean) 


101
102
103
104
105
106
107
108
109
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 101

def self.database_exists?(config)
  config = config.symbolize_keys
  if config[:database] == ":memory:"
    true
  else
    database_file = defined?(Rails.root) ? File.expand_path(config[:database], Rails.root) : config[:database]
    File.exist?(database_file)
  end
end

.represent_boolean_as_integer=(value) ⇒ Object

:nodoc:



79
80
81
82
83
84
85
86
87
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 79

def self.represent_boolean_as_integer=(value) # :nodoc:
  if value == false
    raise "`.represent_boolean_as_integer=` is now always true, so make sure your application can work with it and remove this settings."
  end

  ActiveSupport::Deprecation.warn(
    "`.represent_boolean_as_integer=` is now always true, so setting this is deprecated and will be removed in Rails 6.1."
  )
end

Instance Method Details

#active? ⇒ Boolean

Returns:

  • (Boolean) 


162
163
164
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 162

def active?
  !@connection.closed?
end

#add_column(table_name, column_name, type, **options) ⇒ Object

:nodoc:



245
246
247
248
249
250
251
252
253
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 245

def add_column(table_name, column_name, type, **options) #:nodoc:
  if invalid_alter_table_type?(type, options)
    alter_table(table_name) do |definition|
      definition.column(column_name, type, **options)
    end
  else
    super
  end
end

#add_reference(table_name, ref_name, **options) ⇒ Object Also known as: add_belongs_to

:nodoc:



301
302
303
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 301

def add_reference(table_name, ref_name, **options) # :nodoc:
  super(table_name, ref_name, type: :integer, **options)
end

#allowed_index_name_length ⇒ Object

Returns 62. SQLite supports index names up to 64 characters. The rest is used by Rails internally to perform temporary rename operations



185
186
187
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 185

def allowed_index_name_length
  index_name_length - 2
end

#build_insert_sql(insert) ⇒ Object

:nodoc:



319
320
321
322
323
324
325
326
327
328
329
330
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 319

def build_insert_sql(insert) # :nodoc:
  sql = +"INSERT #{insert.into} #{insert.values_list}"

  if insert.skip_duplicates?
    sql << " ON CONFLICT #{insert.conflict_target} DO NOTHING"
  elsif insert.update_duplicates?
    sql << " ON CONFLICT #{insert.conflict_target} DO UPDATE SET "
    sql << insert.updatable_columns.map { |column| "#{column}=excluded.#{column}" }.join(",")
  end

  sql
end

#change_column(table_name, column_name, type, options = {}) ⇒ Object

:nodoc:



281
282
283
284
285
286
287
288
289
290
291
292
293
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 281

def change_column(table_name, column_name, type, options = {}) #:nodoc:
  alter_table(table_name) do |definition|
    definition[column_name].instance_eval do
      self.type    = type
      self.limit   = options[:limit] if options.include?(:limit)
      self.default = options[:default] if options.include?(:default)
      self.null    = options[:null] if options.include?(:null)
      self.precision = options[:precision] if options.include?(:precision)
      self.scale = options[:scale] if options.include?(:scale)
      self.collation = options[:collation] if options.include?(:collation)
    end
  end
end

#change_column_default(table_name, column_name, default_or_changes) ⇒ Object

:nodoc:



264
265
266
267
268
269
270
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 264

def change_column_default(table_name, column_name, default_or_changes) #:nodoc:
  default = extract_new_default_value(default_or_changes)

  alter_table(table_name) do |definition|
    definition[column_name].default = default
  end
end

#change_column_null(table_name, column_name, null, default = nil) ⇒ Object

:nodoc:



272
273
274
275
276
277
278
279
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 272

def change_column_null(table_name, column_name, null, default = nil) #:nodoc:
  unless null || default.nil?
    exec_query("UPDATE #{quote_table_name(table_name)} SET #{quote_column_name(column_name)}=#{quote(default)} WHERE #{quote_column_name(column_name)} IS NULL")
  end
  alter_table(table_name) do |definition|
    definition[column_name].null = null
  end
end

#check_version ⇒ Object

:nodoc:



340
341
342
343
344
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 340

def check_version # :nodoc:
  if database_version < "3.8.0"
    raise "Your version of SQLite (#{database_version}) is too old. Active Record supports SQLite >= 3.8."
  end
end

#disable_referential_integrity ⇒ Object

REFERENTIAL INTEGRITY ====================================



208
209
210
211
212
213
214
215
216
217
218
219
220
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 208

def disable_referential_integrity # :nodoc:
  old_foreign_keys = query_value("PRAGMA foreign_keys")
  old_defer_foreign_keys = query_value("PRAGMA defer_foreign_keys")

  begin
    execute("PRAGMA defer_foreign_keys = ON")
    execute("PRAGMA foreign_keys = OFF")
    yield
  ensure
    execute("PRAGMA defer_foreign_keys = #{old_defer_foreign_keys}")
    execute("PRAGMA foreign_keys = #{old_foreign_keys}")
  end
end

#disconnect! ⇒ Object

Disconnects from the database if already connected. Otherwise, this method does nothing.



173
174
175
176
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 173

def disconnect!
  super
  @connection.close rescue nil
end

#encoding ⇒ Object

Returns the current database encoding format as a string, eg: ‘UTF-8’



194
195
196
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 194

def encoding
  @connection.encoding.to_s
end

#foreign_keys(table_name) ⇒ Object 



306
307
308
309
310
311
312
313
314
315
316
317
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 306

def foreign_keys(table_name)
  fk_info = exec_query("PRAGMA foreign_key_list(#{quote(table_name)})", "SCHEMA")
  fk_info.map do |row|
    options = {
      column: row["from"],
      primary_key: row["to"],
      on_delete: extract_foreign_key_action(row["on_delete"]),
      on_update: extract_foreign_key_action(row["on_update"])
    }
    ForeignKeyDefinition.new(table_name, row["table"], options)
  end
end

#get_database_version ⇒ Object

:nodoc:



336
337
338
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 336

def get_database_version # :nodoc:
  SQLite3Adapter::Version.new(query_value("SELECT sqlite_version(*)"))
end

#native_database_types ⇒ Object

:nodoc:



189
190
191
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 189

def native_database_types #:nodoc:
  NATIVE_DATABASE_TYPES
end

#primary_keys(table_name) ⇒ Object

SCHEMA STATEMENTS ========================================



224
225
226
227
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 224

def primary_keys(table_name) # :nodoc:
  pks = table_structure(table_name).select { |f| f["pk"] > 0 }
  pks.sort_by { |f| f["pk"] }.map { |f| f["name"] }
end

#reconnect! ⇒ Object 



166
167
168
169
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 166

def reconnect!
  super
  connect if @connection.closed?
end

#remove_column(table_name, column_name, type = nil, options = {}) ⇒ Object

:nodoc:



255
256
257
258
259
260
261
262
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 255

def remove_column(table_name, column_name, type = nil, options = {}) #:nodoc:
  alter_table(table_name) do |definition|
    definition.remove_column column_name
    definition.foreign_keys.delete_if do |_, fk_options|
      fk_options[:column] == column_name.to_s
    end
  end
end

#remove_index(table_name, column_name, options = {}) ⇒ Object

:nodoc:



229
230
231
232
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 229

def remove_index(table_name, column_name, options = {}) #:nodoc:
  index_name = index_name_for_remove(table_name, column_name, options)
  exec_query "DROP INDEX #{quote_column_name(index_name)}"
end

#rename_column(table_name, column_name, new_column_name) ⇒ Object

:nodoc:



295
296
297
298
299
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 295

def rename_column(table_name, column_name, new_column_name) #:nodoc:
  column = column_for(table_name, column_name)
  alter_table(table_name, rename: { column.name => new_column_name.to_s })
  rename_column_indexes(table_name, column.name, new_column_name)
end

#rename_table(table_name, new_name) ⇒ Object

Renames a table.

Example:

rename_table('octopuses', 'octopi')



238
239
240
241
242
243
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 238

def rename_table(table_name, new_name)
  schema_cache.clear_data_source_cache!(table_name.to_s)
  schema_cache.clear_data_source_cache!(new_name.to_s)
  exec_query "ALTER TABLE #{quote_table_name(table_name)} RENAME TO #{quote_table_name(new_name)}"
  rename_table_indexes(table_name, new_name)
end

#requires_reloading? ⇒ Boolean

Returns:

  • (Boolean) 


131
132
133
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 131

def requires_reloading?
  true
end

#shared_cache? ⇒ Boolean

:nodoc:

Returns:

  • (Boolean) 


332
333
334
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 332

def shared_cache? # :nodoc:
  @config.fetch(:flags, 0).anybits?(::SQLite3::Constants::Open::SHAREDCACHE)
end

#supports_common_table_expressions? ⇒ Boolean

Returns:

  • (Boolean) 


151
152
153
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 151

def supports_common_table_expressions?
  database_version >= "3.8.3"
end

#supports_datetime_with_precision? ⇒ Boolean

Returns:

  • (Boolean) 


143
144
145
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 143

def supports_datetime_with_precision?
  true
end

#supports_ddl_transactions? ⇒ Boolean

Returns:

  • (Boolean) 


111
112
113
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 111

def supports_ddl_transactions?
  true
end

#supports_explain? ⇒ Boolean

Returns:

  • (Boolean) 


198
199
200
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 198

def supports_explain?
  true
end

#supports_expression_index? ⇒ Boolean

Returns:

  • (Boolean) 


127
128
129
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 127

def supports_expression_index?
  database_version >= "3.9.0"
end

#supports_foreign_keys? ⇒ Boolean

Returns:

  • (Boolean) 


135
136
137
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 135

def supports_foreign_keys?
  true
end

#supports_index_sort_order? ⇒ Boolean

Returns:

  • (Boolean) 


178
179
180
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 178

def supports_index_sort_order?
  true
end

#supports_insert_on_conflict? ⇒ Boolean Also known as: supports_insert_on_duplicate_skip?, supports_insert_on_duplicate_update?, supports_insert_conflict_target?

Returns:

  • (Boolean) 


155
156
157
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 155

def supports_insert_on_conflict?
  database_version >= "3.24.0"
end

#supports_json? ⇒ Boolean

Returns:

  • (Boolean) 


147
148
149
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 147

def supports_json?
  true
end

#supports_lazy_transactions? ⇒ Boolean

Returns:

  • (Boolean) 


202
203
204
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 202

def supports_lazy_transactions?
  true
end

#supports_partial_index? ⇒ Boolean

Returns:

  • (Boolean) 


123
124
125
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 123

def supports_partial_index?
  true
end

#supports_savepoints? ⇒ Boolean

Returns:

  • (Boolean) 


115
116
117
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 115

def supports_savepoints?
  true
end

#supports_transaction_isolation? ⇒ Boolean

Returns:

  • (Boolean) 


119
120
121
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 119

def supports_transaction_isolation?
  true
end

#supports_views? ⇒ Boolean

Returns:

  • (Boolean) 


139
140
141
 
# File 'activerecord/lib/active_record/connection_adapters/sqlite3_adapter.rb', line 139

def supports_views?
  true
end