Module: ActiveRecord::ConnectionAdapters::Spanner::SchemaStatements
- Included in:
- ActiveRecord::ConnectionAdapters::SpannerAdapter
- Defined in:
- lib/active_record/connection_adapters/spanner/schema_statements.rb
Overview
Constant Summary collapse
- VERSION_6_1_0 =
Gem::Version.create "6.1.0"
- VERSION_6_0_3 =
Gem::Version.create "6.0.3"
Instance Method Summary collapse
- #_add_foreign_key(from_table, to_table, **options) ⇒ Object
- #_remove_columns(table_name, *column_names) ⇒ Object
- #add_column(table_name, column_name, type, **options) ⇒ Object
- #add_foreign_key(from_table, to_table, **options) ⇒ Object
- #add_index(table_name, column_name, options = {}) ⇒ Object
-
#add_reference(table_name, ref_name, **options) ⇒ Object
(also: #add_belongs_to)
Reference Column.
- #change_column(table_name, column_name, type, **options) ⇒ Object
- #change_column_default(_table_name, _column_name, _default_or_changes) ⇒ Object
- #change_column_null(table_name, column_name, null, _default = nil) ⇒ Object
-
#column_definitions(table_name) ⇒ Object
Column.
-
#create_join_table(table_1, table_2, column_options: {}, **options) ⇒ Object
Creates a join table that uses all the columns in the table as the primary key by default, unless an explicit primary key has been defined for the table.
- #create_schema_dumper(options) ⇒ Object
- #create_table(table_name, **options) {|td| ... } ⇒ Object
- #current_database ⇒ Object
-
#data_sources ⇒ Object
(also: #tables)
Table.
- #drop_table(table_name, options = {}) ⇒ Object
- #fetch_type_metadata(sql_type, ordinal_position = nil) ⇒ Object
-
#foreign_keys(table_name, column: nil) ⇒ Object
Foreign Keys.
- #index_name_exists?(table_name, index_name) ⇒ Boolean
-
#indexes(table_name) ⇒ Object
Index.
- #new_column_from_field(_table_name, field) ⇒ Object
- #primary_and_parent_keys(table_name) ⇒ Object
-
#primary_keys(table_name) ⇒ Object
Primary Keys.
- #quoted_scope(name = nil, type: nil) ⇒ Object
- #remove_column(table_name, column_name, _type = nil, _options = {}) ⇒ Object
- #remove_columns(table_name, *column_names, _type: nil, **_options) ⇒ Object
- #remove_foreign_key(from_table, to_table = nil, **options) ⇒ Object
- #remove_index(table_name, column_name = nil, **options) ⇒ Object
- #rename_column(table_name, column_name, new_column_name) ⇒ Object
- #rename_index(table_name, old_name, new_name) ⇒ Object
- #rename_table(_table_name, _new_name) ⇒ Object
- #table_exists?(table_name) ⇒ Boolean (also: #data_source_exists?)
-
#type_to_sql(type, limit: nil, precision: nil, scale: nil, **opts) ⇒ Object
rubocop:disable Lint/UnusedMethodArgument.
Instance Method Details
#_add_foreign_key(from_table, to_table, **options) ⇒ Object
351 352 353 354 355 356 357 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 351 def _add_foreign_key from_table, to_table, ** = from_table, to_table, at = create_alter_table from_table at.add_foreign_key to_table, execute_schema_statements schema_creation.accept(at) end |
#_remove_columns(table_name, *column_names) ⇒ Object
161 162 163 164 165 166 167 168 169 170 171 172 173 174 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 161 def _remove_columns table_name, *column_names if column_names.empty? raise ArgumentError, "You must specify at least one column name. "\ "Example: remove_columns(:people, :first_name)" end statements = [] column_names.each do |column_name| statements.concat drop_column_sql(table_name, column_name) end execute_schema_statements statements end |
#add_column(table_name, column_name, type, **options) ⇒ Object
123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 123 def add_column table_name, column_name, type, ** # Add column with NOT NULL not supported by spanner. # It is currently un-implemented state in spanner service. nullable = .delete(:null) == false at = create_alter_table table_name at.add_column column_name, type, ** statements = [schema_creation.accept(at)] # Alter NOT NULL if nullable cd = at.adds.first.column cd.null = false ccd = Spanner::ChangeColumnDefinition.new( table_name, cd, column_name ) statements << schema_creation.accept(ccd) end execute_schema_statements statements end |
#add_foreign_key(from_table, to_table, **options) ⇒ Object
342 343 344 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 342 def add_foreign_key from_table, to_table, = {} _add_foreign_key from_table, to_table, ** end |
#add_index(table_name, column_name, options = {}) ⇒ Object
251 252 253 254 255 256 257 258 259 260 261 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 251 def add_index table_name, column_name, = {} id = create_index_definition table_name, column_name, ** if data_source_exists?(table_name) && index_name_exists?(table_name, id.name) raise ArgumentError, "Index name '#{id.name}' on table" \ "'#{table_name}' already exists" end execute_schema_statements schema_creation.accept(id) end |
#add_reference(table_name, ref_name, **options) ⇒ Object Also known as: add_belongs_to
Reference Column
372 373 374 375 376 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 372 def add_reference table_name, ref_name, ** ReferenceDefinition.new(ref_name, **).add_to( update_table_definition(table_name, self) ) end |
#change_column(table_name, column_name, type, **options) ⇒ Object
177 178 179 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 177 def change_column table_name, column_name, type, = {} _change_column table_name, column_name, type, ** end |
#change_column_default(_table_name, _column_name, _default_or_changes) ⇒ Object
190 191 192 193 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 190 def change_column_default _table_name, _column_name, _default_or_changes raise ActiveRecordSpannerAdapter::NotSupportedError, \ "change column with default value not supported." end |
#change_column_null(table_name, column_name, null, _default = nil) ⇒ Object
186 187 188 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 186 def change_column_null table_name, column_name, null, _default = nil change_column table_name, column_name, nil, null: null end |
#column_definitions(table_name) ⇒ Object
Column
106 107 108 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 106 def column_definitions table_name information_schema { |i| i.table_columns table_name } end |
#create_join_table(table_1, table_2, column_options: {}, **options) ⇒ Object
Creates a join table that uses all the columns in the table as the primary key by default, unless an explicit primary key has been defined for the table. ActiveRecord will by default generate join tables without a primary key. Cloud Spanner however requires all tables to have a primary key. Instead of adding an additional column to the table only for the purpose of being the primary key, the Spanner ActiveRecord adapter defines a primary key that contains all the columns in the join table, as all values in the table should be unique anyways.
86 87 88 89 90 91 92 93 94 95 96 97 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 86 def create_join_table table_1, table_2, column_options: {}, ** super do |td| unless td.columns.any?(&:primary_key?) td.columns.each do |col| def col.primary_key? true end end end yield td if block_given? end end |
#create_schema_dumper(options) ⇒ Object
386 387 388 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 386 def create_schema_dumper SchemaDumper.create self, end |
#create_table(table_name, **options) {|td| ... } ⇒ Object
42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 42 def create_table table_name, ** td = create_table_definition table_name, if [:id] != false pk = .fetch :primary_key do Base.get_primary_key table_name.to_s.singularize end if pk.is_a? Array td.primary_keys pk else td.primary_key pk, .fetch(:id, :primary_key), **{} end end yield td if block_given? statements = [] if [:force] statements.concat drop_table_with_indexes_sql(table_name, ) end statements << schema_creation.accept(td) td.indexes.each do |column_name, | id = create_index_definition table_name, column_name, ** statements << schema_creation.accept(id) end execute_schema_statements statements end |
#current_database ⇒ Object
26 27 28 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 26 def current_database @connection.database_id end |
#data_sources ⇒ Object Also known as: tables
Table
32 33 34 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 32 def data_sources information_schema { |i| i.tables.map(&:name) } end |
#drop_table(table_name, options = {}) ⇒ Object
75 76 77 78 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 75 def drop_table table_name, = {} statements = drop_table_with_indexes_sql table_name, execute_schema_statements statements end |
#fetch_type_metadata(sql_type, ordinal_position = nil) ⇒ Object
118 119 120 121 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 118 def sql_type, ordinal_position = nil Spanner::TypeMetadata.new \ super(sql_type), ordinal_position: ordinal_position end |
#foreign_keys(table_name, column: nil) ⇒ Object
Foreign Keys
319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 319 def foreign_keys table_name, column: nil raise ArgumentError if table_name.blank? result = information_schema { |i| i.foreign_keys table_name } if column result = result.select { |fk| fk.columns.include? column.to_s } end result.map do |fk| = { column: fk.columns.first, name: fk.name, primary_key: fk.ref_columns.first, on_delete: fk.on_update, on_update: fk.on_update } ForeignKeyDefinition.new table_name, fk.ref_table, end end |
#index_name_exists?(table_name, index_name) ⇒ Boolean
247 248 249 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 247 def index_name_exists? table_name, index_name information_schema { |i| i.index table_name, index_name }.present? end |
#indexes(table_name) ⇒ Object
Index
228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 228 def indexes table_name result = information_schema do |i| i.indexes table_name, index_type: "INDEX" end result.map do |index| IndexDefinition.new( index.table, index.name, index.columns.map(&:name), unique: index.unique, null_filtered: index.null_filtered, interleave_in: index.interleave_in, storing: index.storing, orders: index.orders ) end end |
#new_column_from_field(_table_name, field) ⇒ Object
110 111 112 113 114 115 116 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 110 def new_column_from_field _table_name, field ConnectionAdapters::Column.new \ field.name, field.default, (field.spanner_type, field.ordinal_position), field.nullable end |
#primary_and_parent_keys(table_name) ⇒ Object
309 310 311 312 313 314 315 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 309 def primary_and_parent_keys table_name columns = information_schema do |i| i.table_primary_keys table_name, true end columns.map(&:name) end |
#primary_keys(table_name) ⇒ Object
Primary Keys
301 302 303 304 305 306 307 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 301 def primary_keys table_name columns = information_schema do |i| i.table_primary_keys table_name end columns.map(&:name) end |
#quoted_scope(name = nil, type: nil) ⇒ Object
379 380 381 382 383 384 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 379 def quoted_scope name = nil, type: nil scope = { schema: quote("") } scope[:name] = quote name if name scope[:type] = quote type if type scope end |
#remove_column(table_name, column_name, _type = nil, _options = {}) ⇒ Object
146 147 148 149 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 146 def remove_column table_name, column_name, _type = nil, = {} statements = drop_column_sql table_name, column_name execute_schema_statements statements end |
#remove_columns(table_name, *column_names, _type: nil, **_options) ⇒ Object
152 153 154 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 152 def remove_columns table_name, *column_names _remove_columns table_name, *column_names end |
#remove_foreign_key(from_table, to_table = nil, **options) ⇒ Object
359 360 361 362 363 364 365 366 367 368 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 359 def remove_foreign_key from_table, to_table = nil, ** fk_name_to_delete = foreign_key_for!( from_table, to_table: to_table, ** ).name at = create_alter_table from_table at.drop_foreign_key fk_name_to_delete execute_schema_statements schema_creation.accept(at) end |
#remove_index(table_name, column_name = nil, **options) ⇒ Object
264 265 266 267 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 264 def remove_index table_name, = {} index_name = index_name_for_remove table_name, execute "DROP INDEX #{quote_table_name index_name}" end |
#rename_column(table_name, column_name, new_column_name) ⇒ Object
195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 195 def rename_column table_name, column_name, new_column_name if ActiveRecord::Base.connection.ddl_batch? raise ActiveRecordSpannerAdapter::NotSupportedError, \ "rename_column in a DDL Batch is not supported." end column = information_schema do |i| i.table_column table_name, column_name end unless column raise ArgumentError, "Column '#{column_name}' not exist for table '#{table_name}'" end # Add Column cast_type = lookup_cast_type column.spanner_type add_column table_name, new_column_name, cast_type.type, **column. # Copy data copy_data table_name, column_name, new_column_name # Recreate Indexes recreate_indexes table_name, column_name, new_column_name # Recreate Foreign keys recreate_foreign_keys table_name, column_name, new_column_name # Drop Indexes, Drop Foreign keys and columns remove_column table_name, column_name end |
#rename_index(table_name, old_name, new_name) ⇒ Object
275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 275 def rename_index table_name, old_name, new_name validate_index_length! table_name, new_name old_index = information_schema { |i| i.index table_name, old_name } return unless old_index statements = [ schema_creation.accept(DropIndexDefinition.new(old_name)) ] id = IndexDefinition.new \ old_index.table, new_name, old_index.columns.map(&:name), unique: old_index.unique, null_filtered: old_index.null_filtered, interleave_in: old_index.interleave_in, storing: old_index.storing, orders: old_index.orders statements << schema_creation.accept(id) execute_schema_statements statements end |
#rename_table(_table_name, _new_name) ⇒ Object
99 100 101 102 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 99 def rename_table _table_name, _new_name raise ActiveRecordSpannerAdapter::NotSupportedError, \ "rename_table is not implemented" end |
#table_exists?(table_name) ⇒ Boolean Also known as: data_source_exists?
37 38 39 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 37 def table_exists? table_name information_schema { |i| i.table table_name }.present? end |
#type_to_sql(type, limit: nil, precision: nil, scale: nil, **opts) ⇒ Object
rubocop:disable Lint/UnusedMethodArgument
391 392 393 394 395 396 397 398 399 400 401 402 403 |
# File 'lib/active_record/connection_adapters/spanner/schema_statements.rb', line 391 def type_to_sql type, limit: nil, precision: nil, scale: nil, **opts type = type.to_sym if type native = native_database_types[type] return type.to_s unless native sql_type = (native.is_a?(Hash) ? native[:name] : native).dup sql_type = "#{sql_type}(#{limit || native[:limit]})" if [:string, :text, :binary].include? type sql_type = "ARRAY<#{sql_type}>" if opts[:array] sql_type end |