Module | Sequel::DB2::DatabaseMethods |
In: |
lib/sequel/adapters/shared/db2.rb
|
DATABASE_ERROR_REGEXPS | = | { /DB2 SQL Error: SQLCODE=-803, SQLSTATE=23505|One or more values in the INSERT statement, UPDATE statement, or foreign key update caused by a DELETE statement are not valid because the primary key, unique constraint or unique index/ => UniqueConstraintViolation, /DB2 SQL Error: (SQLCODE=-530, SQLSTATE=23503|SQLCODE=-532, SQLSTATE=23504)|The insert or update value of the FOREIGN KEY .+ is not equal to any value of the parent key of the parent table|A parent row cannot be deleted because the relationship .+ restricts the deletion/ => ForeignKeyConstraintViolation, /DB2 SQL Error: SQLCODE=-545, SQLSTATE=23513|The requested operation is not allowed because a row does not satisfy the check constraint/ => CheckConstraintViolation, /DB2 SQL Error: SQLCODE=-407, SQLSTATE=23502|Assignment of a NULL value to a NOT NULL column/ => NotNullConstraintViolation, /DB2 SQL Error: SQLCODE=-911, SQLSTATE=40001|The current transaction has been rolled back because of a deadlock or timeout/ => SerializationFailure, }.freeze |
use_clob_as_blob | [RW] | Whether to use clob as the generic File type, false by default. |
Return the database version as a string. Don‘t rely on this, it may return an integer in the future.
# File lib/sequel/adapters/shared/db2.rb, line 19 19: def db2_version 20: return @db2_version if defined?(@db2_version) 21: @db2_version = metadata_dataset.with_sql("select service_level from sysibmadm.env_inst_info").first[:service_level] 22: end
# File lib/sequel/adapters/shared/db2.rb, line 25 25: def freeze 26: db2_version 27: offset_strategy 28: super 29: end
Use SYSCAT.INDEXES to get the indexes for the table
# File lib/sequel/adapters/shared/db2.rb, line 70 70: def indexes(table, opts = OPTS) 71: m = output_identifier_meth 72: table = table.value if table.is_a?(Sequel::SQL::Identifier) 73: indexes = {} 74: metadata_dataset. 75: from(Sequel[:syscat][:indexes]). 76: select(:indname, :uniquerule, :colnames). 77: where(:tabname=>input_identifier_meth.call(table), :system_required=>0). 78: each do |r| 79: indexes[m.call(r[:indname])] = {:unique=>(r[:uniquerule]=='U'), :columns=>r[:colnames][1..-1].split('+').map{|v| m.call(v)}} 80: end 81: indexes 82: end
# File lib/sequel/adapters/shared/db2.rb, line 84 84: def offset_strategy 85: return @offset_strategy if defined?(@offset_strategy) 86: 87: @offset_strategy = case strategy = opts[:offset_strategy].to_s 88: when "limit_offset", "offset_fetch" 89: opts[:offset_strategy] = strategy.to_sym 90: else 91: opts[:offset_strategy] = :emulate 92: end 93: end
Use SYSIBM.SYSCOLUMNS to get the information on the tables.
# File lib/sequel/adapters/shared/db2.rb, line 32 32: def schema_parse_table(table, opts = OPTS) 33: m = output_identifier_meth(opts[:dataset]) 34: im = input_identifier_meth(opts[:dataset]) 35: metadata_dataset.with_sql("SELECT * FROM SYSIBM.SYSCOLUMNS WHERE TBNAME = #{literal(im.call(table))} ORDER BY COLNO"). 36: collect do |column| 37: column[:db_type] = column.delete(:typename) 38: if column[:db_type] =~ /\A(VAR)?CHAR\z/ 39: column[:db_type] << "(#{column[:length]})" 40: end 41: if column[:db_type] == "DECIMAL" 42: column[:db_type] << "(#{column[:longlength]},#{column[:scale]})" 43: end 44: column[:allow_null] = column.delete(:nulls) == 'Y' 45: identity = column.delete(:identity) == 'Y' 46: if column[:primary_key] = identity || !column[:keyseq].nil? 47: column[:auto_increment] = identity 48: end 49: column[:type] = schema_column_type(column[:db_type]) 50: column[:max_length] = column[:longlength] if column[:type] == :string 51: [ m.call(column.delete(:name)), column] 52: end 53: end
On DB2, a table might need to be REORGed if you are testing existence of it. This REORGs automatically if the database raises a specific error that indicates it should be REORGed.
# File lib/sequel/adapters/shared/db2.rb, line 103 103: def table_exists?(name) 104: v ||= false # only retry once 105: sch, table_name = schema_and_table(name) 106: name = SQL::QualifiedIdentifier.new(sch, table_name) if sch 107: from(name).first 108: true 109: rescue DatabaseError => e 110: if e.to_s =~ /Operation not allowed for reason code "7" on table/ && v == false 111: # table probably needs reorg 112: reorg(name) 113: v = true 114: retry 115: end 116: false 117: end
Use SYSCAT.TABLES to get the tables for the database
# File lib/sequel/adapters/shared/db2.rb, line 56 56: def tables 57: metadata_dataset. 58: with_sql("SELECT TABNAME FROM SYSCAT.TABLES WHERE TYPE='T' AND OWNER = #{literal(input_identifier_meth.call(opts[:user]))}"). 59: all.map{|h| output_identifier_meth.call(h[:tabname]) } 60: end
Use SYSCAT.TABLES to get the views for the database
# File lib/sequel/adapters/shared/db2.rb, line 63 63: def views 64: metadata_dataset. 65: with_sql("SELECT TABNAME FROM SYSCAT.TABLES WHERE TYPE='V' AND OWNER = #{literal(input_identifier_meth.call(opts[:user]))}"). 66: all.map{|h| output_identifier_meth.call(h[:tabname]) } 67: end