DB::MigrateSourceDBMigrateMigration

class Migration

Definitions

def migration_exists?

Check if this migration has already been executed

Implementation

def migration_exists?
	statement = @session.clause("SELECT COUNT(*) FROM")
	statement.identifier(:migration)
	statement.clause("WHERE")
	statement.identifier(:name)
	statement.clause("=")
	statement.literal(@name)
	
	result = statement.call
	count = result.to_a.first.first
	count > 0
end

def record_migration

Record that this migration has been executed

Implementation

def record_migration
	statement = @session.clause("INSERT INTO")
	statement.identifier(:migration)
	statement.clause("(")
	statement.identifier(:name)
	statement.clause(",")
	statement.identifier(:created_at)
	statement.clause(",")
	statement.identifier(:updated_at)
	statement.clause(") VALUES (")
	statement.literal(@name)
	statement.clause(", NOW(), NOW())")
	
	statement.call
end