Class: Tapsoob::CLI::Schema

Inherits:
Thor
  • Object
show all
Defined in:
lib/tapsoob/cli/schema.rb

Instance Method Summary collapse

Instance Method Details

#console(database_url) ⇒ Object



10
11
12
13
14
15
# File 'lib/tapsoob/cli/schema.rb', line 10

def console(database_url)
  $db = Sequel.connect(database_url)
  require 'irb'
  require 'irb/completion'
  IRB.start
end

#dump(database_url) ⇒ Object



18
19
20
# File 'lib/tapsoob/cli/schema.rb', line 18

def dump(database_url)
  puts Tapsoob::Schema.dump(database_url)
end

#dump_table(database_url, table) ⇒ Object



23
24
25
# File 'lib/tapsoob/cli/schema.rb', line 23

def dump_table(database_url, table)
  puts Tapsoob::Schema.dump_table(database_url, table)
end

#indexes(database_url) ⇒ Object



28
29
30
# File 'lib/tapsoob/cli/schema.rb', line 28

def indexes(database_url)
  puts Tapsoob::Schema.indexes(database_url)
end

#indexes_individual(database_url) ⇒ Object



33
34
35
# File 'lib/tapsoob/cli/schema.rb', line 33

def indexes_individual(database_url)
  puts Tapsoob::Schema.indexes_individual(database_url)
end

#load(database_url, filename = nil) ⇒ Object



43
44
45
46
47
48
49
50
51
52
53
54
55
# File 'lib/tapsoob/cli/schema.rb', line 43

def load(database_url, filename = nil)
  schema = if filename && File.exists?(filename)
    File.read(filename)
  else
    STDIN.read
  end

  begin
    Tapsoob::Schema.load(database_url, schema)
  rescue Exception => e
    throw e
  end
end

#load_indexes(database_url, filename = nil) ⇒ Object



58
59
60
61
62
63
64
65
66
67
68
69
70
# File 'lib/tapsoob/cli/schema.rb', line 58

def load_indexes(database_url, filename = nil)
  indexes = if filename && File.exists?(filename)
    File.read(filename)
  else
    STDIN.read
  end

  begin
    Tapsoob::Schema.load_indexes(database_url, indexes)
  rescue Exception => e
    throw e
  end
end

#reset_db_sequences(database_url) ⇒ Object



38
39
40
# File 'lib/tapsoob/cli/schema.rb', line 38

def reset_db_sequences(database_url)
  Tapsoob::Schema.reset_db_sequences(database_url)
end