code: def runSql(self, migrationName, version):
          
          sys.stdout.write("Running migration %s to version %s: ..."%(migrationName, version))
          sqlPath = os.path.join(self.migrationDirectory, migrationName)
          sql = open(sqlPath, "r").read()
          try:
              if self.session.is_active:
                  print "session is active"
                  self.session.commit()
              self.session.begin()
              executeBatch(self.session, sql)
              self.session.add(models.Migration(version, migrationName))
          except:
              print "\n"
              self.session.rollback()
              raise
          else:
              self.session.commit()
          sys.stdout.write("\r")
          sys.stdout.flush()
          sys.stdout.write("Running migration %s to version %s: SUCCESS!\n"%(migrationName, version))
docs: Given a migration name and version lookup the sql file and run it.