mack-data_mapper/spec/fixtures/test_test_mysql_schema_structure.sql.fixture mack-data_mapper/spec/fixtures/test_test_postgres_schema_structure.sql.fixture mack-data_mapper/spec/fixtures/test_test_sqlite3_schema_structure.sql.fixture mack-data_mapper/spec/lib/database_spec.rb @@ -27,33 +27,6 @@ module Mack Mack::Database.establish_connection(env) drop_database(repis) end - - # abcs = ActiveRecord::Base.configurations - # case abcs[RAILS_ENV]["adapter"] - # when "mysql", "oci", "oracle" - # ActiveRecord::Base.establish_connection(abcs[RAILS_ENV]) - # File.open("db/#{RAILS_ENV}_structure.sql", "w+") { |f| f << ActiveRecord::Base.connection.structure_dump } - # when "postgresql" - # ENV['PGHOST'] = abcs[RAILS_ENV]["host"] if abcs[RAILS_ENV]["host"] - # ENV['PGPORT'] = abcs[RAILS_ENV]["port"].to_s if abcs[RAILS_ENV]["port"] - # ENV['PGPASSWORD'] = abcs[RAILS_ENV]["password"].to_s if abcs[RAILS_ENV]["password"] - # search_path = abcs[RAILS_ENV]["schema_search_path"] - # search_path = "--schema=#{search_path}" if search_path - # `pg_dump -i -U "#{abcs[RAILS_ENV]["username"]}" -s -x -O -f db/#{RAILS_ENV}_structure.sql #{search_path} #{abcs[RAILS_ENV]["database"]}` - # raise "Error dumping database" if $?.exitstatus == 1 - # when "sqlite", "sqlite3" - # dbfile = abcs[RAILS_ENV]["database"] || abcs[RAILS_ENV]["dbfile"] - # `#{abcs[RAILS_ENV]["adapter"]} #{dbfile} .schema > db/#{RAILS_ENV}_structure.sql` - # when "sqlserver" - # `scptxfr /s #{abcs[RAILS_ENV]["host"]} /d #{abcs[RAILS_ENV]["database"]} /I /f db\\#{RAILS_ENV}_structure.sql /q /A /r` - # `scptxfr /s #{abcs[RAILS_ENV]["host"]} /d #{abcs[RAILS_ENV]["database"]} /I /F db\ /q /A /r` - # when "firebird" - # set_firebird_env(abcs[RAILS_ENV]) - # db_string = firebird_db_string(abcs[RAILS_ENV]) - # sh "isql -a #{db_string} > db/#{RAILS_ENV}_structure.sql" - # else - # raise "Task not supported by '#{abcs["test"]["adapter"]}'" - # end def self.structure_dump(env = Mack.env, repis = :default) adapter = repository(repis).adapter @@ -61,28 +34,22 @@ module Mack structure = "" output_file = File.join(Mack.root, "db", "#{env}_#{repis}_schema_structure.sql") case adapter.class.name - when /Mysql/ - sql = "SHOW FULL TABLES WHERE Table_type = 'BASE TABLE'" - sql = "SHOW TABLES" - adapter.query(sql).each do |res| - show = adapter.query("SHOW CREATE TABLE #{res}").first - structure += show.attributes["create table".to_sym] - structure += ";\n\n" - end - # puts structure - File.open(output_file, "w") {|f| f.puts structure} - when /Postgres/ - `pg_dump -i -U "#{uri.user}" -s -x -O -f #{output_file} #{uri.basename}` - # setup_temp(uri, "postgres") - # repository(:tmp) do |repo| - # puts "Creating (PostgreSQL): #{uri.basename}" - # repo.adapter.execute "CREATE DATABASE #{uri.basename} ENCODING = 'utf8'" - # end - when /Sqlite3/ - db_dir = File.join(Mack.root, "db") - `sqlite3 #{File.join(db_dir, uri.basename)} .schema > #{output_file}` - else - raise "Task not supported for '#{repository(repis).adapter.class.name}'" + when /Mysql/ + sql = "SHOW FULL TABLES WHERE Table_type = 'BASE TABLE'" + sql = "SHOW TABLES" + adapter.query(sql).each do |res| + show = adapter.query("SHOW CREATE TABLE #{res}").first + structure += show.attributes["create table".to_sym] + structure += ";\n\n" + end + File.open(output_file, "w") {|f| f.puts structure} + when /Postgres/ + `pg_dump -i -U "#{uri.user}" -s -x -O -f #{output_file} #{uri.basename}` + when /Sqlite3/ + db_dir = File.join(Mack.root, "db") + `sqlite3 #{File.join(db_dir, uri.basename)} .schema > #{output_file}` + else + raise "Task not supported for '#{repository(repis).adapter.class.name}'" end end @@ -100,50 +67,49 @@ module Mack def self.create_database(repis = :default) uri = repository(repis).adapter.uri case repository(repis).adapter.class.name - when /Mysql/ - setup_temp(uri, "mysql") - repository(:tmp) do |repo| - puts "Creating (MySQL): #{uri.basename}" - repo.adapter.execute "CREATE DATABASE `#{uri.basename}` DEFAULT CHARACTER SET `utf8`" - end - when /Postgres/ - setup_temp(uri, "postgres") - repository(:tmp) do |repo| - puts "Creating (PostgreSQL): #{uri.basename}" - repo.adapter.execute "CREATE DATABASE #{uri.basename} ENCODING = 'utf8'" - end - when /Sqlite3/ - db_dir = File.join(Mack.root, "db") - puts "Creating (SQLite3): #{uri.basename}" - FileUtils.mkdir_p(db_dir) - FileUtils.touch(File.join(db_dir, uri.basename)) - else - raise "Task not supported for '#{repository(repis).adapter.class.name}'" + when /Mysql/ + setup_temp(uri, "mysql") + repository(:tmp) do |repo| + puts "Creating (MySQL): #{uri.basename}" + repo.adapter.execute "CREATE DATABASE `#{uri.basename}` DEFAULT CHARACTER SET `utf8`" + end + when /Postgres/ + setup_temp(uri, "postgres") + repository(:tmp) do |repo| + puts "Creating (PostgreSQL): #{uri.basename}" + repo.adapter.execute "CREATE DATABASE #{uri.basename} ENCODING = 'utf8'" + end + when /Sqlite3/ + db_dir = File.join(Mack.root, "db") + puts "Creating (SQLite3): #{uri.basename}" + FileUtils.mkdir_p(db_dir) + FileUtils.touch(File.join(db_dir, uri.basename)) + else + raise "Task not supported for '#{repository(repis).adapter.class.name}'" end end - def self.drop_database(repis = :default) uri = repository(repis).adapter.uri case repository(repis).adapter.class.name - when /Mysql/ - setup_temp(uri, "mysql") - repository(:tmp) do |repo| - puts "Dropping (MySQL): #{uri.basename}" - repo.adapter.execute "DROP DATABASE IF EXISTS `#{uri.basename}`" - end - when /Postgres/ - setup_temp(uri, "postgres") - repository(:tmp) do |repo| - puts "Dropping (PostgreSQL): #{uri.basename}" - repo.adapter.execute "DROP DATABASE IF EXISTS #{uri.basename}" - end - when /Sqlite3/ - puts "Dropping (SQLite3): #{uri.basename}" - db_dir = File.join(Mack.root, "db") - FileUtils.rm_rf(File.join(db_dir.to_s, uri.basename)) - else - raise "Task not supported for '#{repository(repis).adapter.class.name}'" + when /Mysql/ + setup_temp(uri, "mysql") + repository(:tmp) do |repo| + puts "Dropping (MySQL): #{uri.basename}" + repo.adapter.execute "DROP DATABASE IF EXISTS `#{uri.basename}`" + end + when /Postgres/ + setup_temp(uri, "postgres") + repository(:tmp) do |repo| + puts "Dropping (PostgreSQL): #{uri.basename}" + repo.adapter.execute "DROP DATABASE IF EXISTS #{uri.basename}" + end + when /Sqlite3/ + puts "Dropping (SQLite3): #{uri.basename}" + db_dir = File.join(Mack.root, "db") + FileUtils.rm_rf(File.join(db_dir.to_s, uri.basename)) + else + raise "Task not supported for '#{repository(repis).adapter.class.name}'" end end mack-data_mapper/lib/mack-data_mapper/database.rb 2263caf43ab79d61970f3e7148dafc39ffbaa0ff Mark Bates mark@mackframework.com http://github.com/markbates/mack-more/commit/41ec8a0fe9fb206f5a6bb490a1e58655a712cef0 41ec8a0fe9fb206f5a6bb490a1e58655a712cef0 2008-08-08T18:09:42-07:00 2008-08-08T18:09:42-07:00 Added specs for mack-data_mapper structure_dump [#67] 627fad1c8d4e2f5290a4231214ff2086496a3bfd Mark Bates mark@mackframework.com