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
 
# File 'lib/tapsoob/cli/schema.rb', line 10

def console(database_url)
  $db = Sequel.connect(database_url)
  require 'ripl'
  Ripl.start binding: binding
end

#dump(database_url) ⇒ Object 



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

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

#dump_table(database_url, table) ⇒ Object 



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

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

#indexes(database_url) ⇒ Object 



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

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

#indexes_individual(database_url) ⇒ Object 



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

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, options)
  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 



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

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