Module: ArJdbc::Derby

Includes:
Util::TableCopier
Defined in:
lib/arjdbc/derby/adapter.rb,
lib/arjdbc/derby/schema_creation.rb

Defined Under Namespace

Modules: Column Classes: SchemaCreation

Constant Summary collapse

ADAPTER_NAME = 
'Derby'.freeze
NATIVE_DATABASE_TYPES = 
{
  :primary_key => "int GENERATED BY DEFAULT AS identity NOT NULL PRIMARY KEY",
  :string => { :name => "varchar", :limit => 255 }, # 32672
  :text => { :name => "clob" }, # 2,147,483,647
  :char => { :name => "char", :limit => 254 }, # JDBC limit: 254
  :binary => { :name => "blob" }, # 2,147,483,647
  :float => { :name => "float", :limit => 8 }, # DOUBLE PRECISION
  :real => { :name => "real", :limit => 4 }, # JDBC limit: 23
  :double => { :name => "double", :limit => 8 }, # JDBC limit: 52
  :decimal => { :name => "decimal", :precision => 5, :scale => 0 }, # JDBC limit: 31
  :numeric => { :name => "decimal", :precision => 5, :scale => 0 }, # JDBC limit: 31
  :integer => { :name => "integer", :limit => 4 }, # JDBC limit: 10
  :smallint => { :name => "smallint", :limit => 2 }, # JDBC limit: 5
  :bigint => { :name => "bigint", :limit => 8 }, # JDBC limit: 19
  :date => { :name => "date" },
  :time => { :name => "time" },
  :datetime => { :name => "timestamp" },
  :timestamp => { :name => "timestamp" },
  :xml => { :name => "xml" },
  :boolean => { :name => "smallint", :limit => 1 }, # TODO boolean (since 10.7)
  :object => { :name => "object" },
}

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Util::TableCopier

#alter_table, #copy_table, #copy_table_contents, #copy_table_indexes, #move_table

Class Method Details

.arel_visitor_type(config = nil) ⇒ Object

See Also:



84
85
86
 
# File 'lib/arjdbc/derby/adapter.rb', line 84

def self.arel_visitor_type(config = nil)
  require 'arel/visitors/derby'; ::Arel::Visitors::Derby
end

.column_selector ⇒ Object

See Also:

  • ActiveRecord::ConnectionAdapters::JdbcColumn#column_types


24
25
26
 
# File 'lib/arjdbc/derby/adapter.rb', line 24

def self.column_selector
  [ /derby/i, lambda { |config, column| column.extend(Column) } ]
end

.jdbc_connection_class ⇒ Object

See Also:



19
20
21
 
# File 'lib/arjdbc/derby/adapter.rb', line 19

def self.jdbc_connection_class
  ::ActiveRecord::ConnectionAdapters::DerbyJdbcConnection
end

Instance Method Details

#adapter_name ⇒ Object 



90
91
92
 
# File 'lib/arjdbc/derby/adapter.rb', line 90

def adapter_name
  ADAPTER_NAME
end

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



263
264
265
266
267
 
# File 'lib/arjdbc/derby/adapter.rb', line 263

def add_column(table_name, column_name, type, options = {})
  add_column_sql = "ALTER TABLE #{quote_table_name(table_name)} ADD #{quote_column_name(column_name)} #{type_to_sql(type, options[:limit], options[:precision], options[:scale])}"
  add_column_options!(add_column_sql, options)
  execute(add_column_sql)
end

#add_column_options!(sql, options) ⇒ Object 



270
271
272
273
274
 
# File 'lib/arjdbc/derby/adapter.rb', line 270

def add_column_options!(sql, options)
  options.delete(:default) if options.has_key?(:default) && options[:default].nil?
  sql << " DEFAULT #{quote(options.delete(:default))}" if options.has_key?(:default)
  super
end

#add_limit_offset!(sql, options) ⇒ Object

Note:

Only used with (non-AREL) ActiveRecord 2.3.

See Also:



429
430
431
432
433
 
# File 'lib/arjdbc/derby/adapter.rb', line 429

def add_limit_offset!(sql, options)
  sql << " OFFSET #{options[:offset]} ROWS" if options[:offset]
  # ROWS/ROW and FIRST/NEXT mean the same
  sql << " FETCH FIRST #{options[:limit]} ROWS ONLY" if options[:limit]
end

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



284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
 
# File 'lib/arjdbc/derby/adapter.rb', line 284

def change_column(table_name, column_name, type, options = {})
  # TODO this needs a review since now we're likely to be on >= 10.8

  # Notes about changing in Derby:
  #    http://db.apache.org/derby/docs/10.2/ref/rrefsqlj81859.html#rrefsqlj81859__rrefsqlj37860)
  #
  # We support changing columns using the strategy outlined in:
  #    https://issues.apache.org/jira/browse/DERBY-1515
  #
  # This feature has not made it into a formal release and is not in Java 6.
  # We will need to conditionally support this (supposed to arrive for 10.3.0.0).

  # null/not nulling is easy, handle that separately
  if options.include?(:null)
    # This seems to only work with 10.2 of Derby
    if options.delete(:null) == false
      execute "ALTER TABLE #{quote_table_name(table_name)} ALTER COLUMN #{quote_column_name(column_name)} NOT NULL"
    else
      execute "ALTER TABLE #{quote_table_name(table_name)} ALTER COLUMN #{quote_column_name(column_name)} NULL"
    end
  end

  # anything left to do?
  unless options.empty?
    begin
      execute "ALTER TABLE #{quote_table_name(table_name)} ALTER COLUMN " <<
              " #{quote_column_name(column_name)} SET DATA TYPE #{type_to_sql(type, options[:limit])}"
    rescue
      transaction do
        temp_new_column_name = "#{column_name}_newtype"
        # 1) ALTER TABLE t ADD COLUMN c1_newtype NEWTYPE;
        add_column table_name, temp_new_column_name, type, options
        # 2) UPDATE t SET c1_newtype = c1;
        execute "UPDATE #{quote_table_name(table_name)} SET " <<
                " #{quote_column_name(temp_new_column_name)} = " <<
                " CAST(#{quote_column_name(column_name)} AS #{type_to_sql(type, options[:limit])})"
        # 3) ALTER TABLE t DROP COLUMN c1;
        remove_column table_name, column_name
        # 4) ALTER TABLE t RENAME COLUMN c1_newtype to c1;
        rename_column table_name, temp_new_column_name, column_name
      end
    end
  end
end

#columns_for_distinct(columns, orders) ⇒ Object 



349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
 
# File 'lib/arjdbc/derby/adapter.rb', line 349

def columns_for_distinct(columns, orders)
  return columns if orders.blank?

  # construct a clean list of column names from the ORDER BY clause,
  # removing any ASC/DESC modifiers
  order_columns = [ orders ]; order_columns.flatten! # AR 3.x vs 4.x
  order_columns.map! do |column|
    column = column.to_sql unless column.is_a?(String) # handle AREL node
    column.split(',').collect! { |s| s.split.first }
  end.flatten!
  order_columns.reject!(&:blank?)
  order_columns = order_columns.zip (0...order_columns.size).to_a
  order_columns = order_columns.map { |s, i| "#{s} AS alias_#{i}" }

  columns = [ columns ]; columns.flatten!
  columns.push( *order_columns ).join(', ')
  # return a DISTINCT clause that's distinct on the columns we want but
  # includes all the required columns for the ORDER BY to work properly
end

#configure_connection ⇒ Object 



110
111
112
113
114
115
116
 
# File 'lib/arjdbc/derby/adapter.rb', line 110

def configure_connection
  # must be done or SELECT...FOR UPDATE won't work how we expect :
  execute("SET ISOLATION = SERIALIZABLE")
  # if a user name was specified upon connection, the user's name is the
  # default schema for the connection, if a schema with that name exists
  set_schema(config[:schema]) if config.key?(:schema)
end

#create_schema(schema) ⇒ Object

Creates a new Derby schema.

See Also:



394
395
396
 
# File 'lib/arjdbc/derby/adapter.rb', line 394

def create_schema(schema)
  execute "CREATE SCHEMA #{schema}", 'Create Schema'
end

#current_schema ⇒ String

Returns the current schema name.

Returns:

  • (String) —

    the current schema name



380
381
382
383
 
# File 'lib/arjdbc/derby/adapter.rb', line 380

def current_schema
  @current_schema ||=
    select_value "SELECT CURRENT SCHEMA FROM SYS.SYSSCHEMAS FETCH FIRST 1 ROWS ONLY", 'SCHEMA'
end

#distinct(columns, order_by) ⇒ Object

Note:

This is based on distinct method for the PostgreSQL Adapter.

SELECT DISTINCT clause for a given set of columns and a given ORDER BY clause.

Derby requires the ORDER BY columns in the select list for distinct queries, and requires that the ORDER BY include the distinct column.

  distinct("posts.id", "posts.created_at desc")



344
345
346
 
# File 'lib/arjdbc/derby/adapter.rb', line 344

def distinct(columns, order_by)
  "DISTINCT #{columns_for_distinct(columns, order_by)}"
end

#drop_schema(schema) ⇒ Object

Drops an existing schema, needs to be empty (no DB objects).



399
400
401
 
# File 'lib/arjdbc/derby/adapter.rb', line 399

def drop_schema(schema)
  execute "DROP SCHEMA #{schema} RESTRICT", 'Drop Schema'
end

#empty_insert_statement_value ⇒ Object 



228
229
230
 
# File 'lib/arjdbc/derby/adapter.rb', line 228

def empty_insert_statement_value
  'VALUES ( DEFAULT )' # won't work as Derby does need to know the columns count
end

#execute(sql, name = nil, binds = []) ⇒ Object 



436
437
438
439
440
441
442
 
# File 'lib/arjdbc/derby/adapter.rb', line 436

def execute(sql, name = nil, binds = [])
  sql = to_sql(sql, binds)
  insert = self.class.insert?(sql)
  update = ! insert && ! self.class.select?(sql)
  sql = correct_is_null(sql, insert || update)
  super(sql, name, binds)
end

#index_name_length ⇒ Object 



118
119
120
 
# File 'lib/arjdbc/derby/adapter.rb', line 118

def index_name_length
  128
end

#last_insert_id ⇒ Fixnum

Note:

Check the IDENTITY_VAL_LOCAL function for documentation.

Returns the value of an identity column of the last INSERT statement made over this connection.

Returns:

  • (Fixnum) 


448
449
450
 
# File 'lib/arjdbc/derby/adapter.rb', line 448

def last_insert_id
  @connection.identity_val_local
end

#native_database_types ⇒ Object 



146
147
148
 
# File 'lib/arjdbc/derby/adapter.rb', line 146

def native_database_types
  NATIVE_DATABASE_TYPES
end

#primary_keys(table_name) ⇒ Object 



370
371
372
 
# File 'lib/arjdbc/derby/adapter.rb', line 370

def primary_keys(table_name)
  @connection.primary_keys table_name.to_s.upcase
end

#quote(value, column = nil) ⇒ Object 



151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
 
# File 'lib/arjdbc/derby/adapter.rb', line 151

def quote(value, column = nil)
  return value.quoted_id if value.respond_to?(:quoted_id)
  return value if sql_literal?(value)
  return 'NULL' if value.nil?

  column_type = column && column.type
  if column_type == :string || column_type == :text
    # Derby is not permissive
    # e.g. sending an Integer to a VARCHAR column will fail
    case value
    when BigDecimal then value = value.to_s('F')
    when Numeric then value = value.to_s
    when true, false then value = value.to_s
    when Date, Time then value = quoted_date(value)
    else # on 2.3 attribute serialization needs to_yaml here
      value = value.to_s if ActiveRecord::VERSION::MAJOR >= 3
    end
  end

  case value
  when String, ActiveSupport::Multibyte::Chars
    if column_type == :text
      "CAST('#{quote_string(value)}' AS CLOB)"
    elsif column_type == :binary
      "CAST(X'#{quote_binary(value)}' AS BLOB)"
    elsif column_type == :xml
      "XMLPARSE(DOCUMENT '#{quote_string(value)}' PRESERVE WHITESPACE)"
    elsif column_type == :integer
      value.to_i
    elsif column_type == :float
      value.to_f
    else
      "'#{quote_string(value)}'"
    end
  else
    super
  end
end

#quote_column_name(name) ⇒ Object 



418
419
420
 
# File 'lib/arjdbc/derby/adapter.rb', line 418

def quote_column_name(name)
  %Q{"#{name.to_s.upcase.gsub('"', '""')}"}
end

#quote_table_name_for_assignment(table, attr) ⇒ Object 



423
424
425
 
# File 'lib/arjdbc/derby/adapter.rb', line 423

def quote_table_name_for_assignment(table, attr)
  quote_column_name(attr)
end

#quoted_date(value) ⇒ Object 



191
192
193
194
195
196
197
198
199
 
# File 'lib/arjdbc/derby/adapter.rb', line 191

def quoted_date(value)
  if value.acts_like?(:time) && value.respond_to?(:usec)
    usec = sprintf("%06d", value.usec)
    value = ::ActiveRecord::Base.default_timezone == :utc ? value.getutc : value.getlocal
    "#{value.strftime("%Y-%m-%d %H:%M:%S")}.#{usec}"
  else
    super
  end
end

#remove_column(table_name, *column_names) ⇒ Object 



277
278
279
280
281
 
# File 'lib/arjdbc/derby/adapter.rb', line 277

def remove_column(table_name, *column_names)
  for column_name in column_names.flatten
    execute "ALTER TABLE #{quote_table_name(table_name)} DROP COLUMN #{quote_column_name(column_name)} RESTRICT"
  end
end

#remove_index(table_name, options) ⇒ Object 



254
255
256
 
# File 'lib/arjdbc/derby/adapter.rb', line 254

def remove_index(table_name, options)
  execute "DROP INDEX #{index_name(table_name, options)}"
end

#rename_column(table_name, column_name, new_column_name) ⇒ Object 



330
331
332
333
 
# File 'lib/arjdbc/derby/adapter.rb', line 330

def rename_column(table_name, column_name, new_column_name)
  execute "RENAME COLUMN #{quote_table_name(table_name)}.#{quote_column_name(column_name)} " <<
          " TO #{quote_column_name(new_column_name)}"
end

#rename_table(name, new_name) ⇒ Object 



259
260
261
 
# File 'lib/arjdbc/derby/adapter.rb', line 259

def rename_table(name, new_name)
  execute "RENAME TABLE #{quote_table_name(name)} TO #{quote_table_name(new_name)}"
end

#reset_pk_sequence!(table, pk = nil, sequence = nil) ⇒ Object 



239
240
241
242
243
244
245
246
 
# File 'lib/arjdbc/derby/adapter.rb', line 239

def reset_pk_sequence!(table, pk = nil, sequence = nil)
  klasses = classes_for_table_name(table)
  klass   = klasses.nil? ? nil : klasses.first
  pk      = klass.primary_key unless klass.nil?
  if pk && klass.columns_hash[pk].type == :integer
    reset_sequence!(klass.table_name, pk)
  end
end

#reset_sequence!(table, column, sequence = nil) ⇒ Object

Set the sequence to the max value of the table's column.



234
235
236
237
 
# File 'lib/arjdbc/derby/adapter.rb', line 234

def reset_sequence!(table, column, sequence = nil)
  mpk = select_value("SELECT MAX(#{quote_column_name(column)}) FROM #{quote_table_name(table)}")
  execute("ALTER TABLE #{quote_table_name(table)} ALTER COLUMN #{quote_column_name(column)} RESTART WITH #{mpk.to_i + 1}")
end

#set_schema(schema) ⇒ Object Also known as: current_schema=

Change the current (implicit) Derby schema to be used for this connection.



386
387
388
389
 
# File 'lib/arjdbc/derby/adapter.rb', line 386

def set_schema(schema)
  @current_schema = nil
  execute "SET SCHEMA #{schema}", 'SCHEMA'
end

#table_definition(*args) ⇒ Object 



223
224
225
 
# File 'lib/arjdbc/derby/adapter.rb', line 223

def table_definition(*args)
  new_table_definition(TableDefinition, *args)
end

#tables(name = nil) ⇒ Object 



375
376
377
 
# File 'lib/arjdbc/derby/adapter.rb', line 375

def tables(name = nil)
  @connection.tables(nil, current_schema)
end

#type_to_sql(type, limit = nil, precision = nil, scale = nil) ⇒ Object

Convert the specified column type to a SQL string.



206
207
208
209
210
211
 
# File 'lib/arjdbc/derby/adapter.rb', line 206

def type_to_sql(type, limit = nil, precision = nil, scale = nil)
  return super unless NO_LIMIT_TYPES.include?(t = type.to_s.downcase.to_sym)

  native_type = NATIVE_DATABASE_TYPES[t]
  native_type.is_a?(Hash) ? native_type[:name] : native_type
end