src/bundles/Database/Migrator.php
private function run_queries( $group )
	{
		if ( !$handle = fopen( $this->path , "r") )
		{
			throw new Exception( "Could not read migration: ".$this->path );
		}
		
		$mode = null;
		$query  = '';
		
		while ( !feof( $handle ) ) 
		{
			$buffer = trim( fgets( $handle, 4096 ) );
			
			$this->parse_mode( $mode, $buffer );
			
			if ( $this->is_comment( $buffer ) )
			{
				continue;
			}
			
			// only continue if we are in up mode
			if ( $mode === $group )
			{
				$query .= $buffer;
				
				if ( substr( rtrim( $query ), -1 ) == ';' ) 
				{
					// run the query
					DB::run( $query );
					
					// reset the query for the next one.
					$query = '';
				}
			}
			
		}
		
		fclose($handle);
	}
private function run_queries( $group )
	{
		if ( !$handle = fopen( $this->path , "r") )
		{
			throw new Exception( "Could not read migration: ".$this->path );
		}
		
		$mode = null;
		$query  = '';
		
		while ( !feof( $handle ) ) 
		{
			$buffer = trim( fgets( $handle, 4096 ) );
			
			$this->parse_mode( $mode, $buffer );
			
			if ( $this->is_comment( $buffer ) )
			{
				continue;
			}
			
			// only continue if we are in up mode
			if ( $mode === $group )
			{
				$query .= $buffer;
				
				if ( substr( rtrim( $query ), -1 ) == ';' ) 
				{
					// run the query
					DB::run( $query );
					
					// reset the query for the next one.
					$query = '';
				}
			}
			
		}
		
		fclose($handle);
	}
private function run_queries ( $ group ) { if ( ! $ handle = fopen ( $ this -> path , "r" ) ) { throw new Exception ( "Could not read migration: " . $ this -> path ) ; } $ mode = null ; $ query = '' ; while ( ! feof ( $ handle ) ) { $ buffer = trim ( fgets ( $ handle , 4096 ) ) ; $ this -> parse_mode ( $ mode , $ buffer ) ; if ( $ this -> is_comment ( $ buffer ) ) { continue ; } // only continue if we are in up mode if ( $ mode === $ group ) { $ query .= $ buffer ; if ( substr ( rtrim ( $ query ) , - 1 ) == ';' ) { // run the query DB :: run ( $ query ) ; // reset the query for the next one. $ query = '' ; } } } fclose ( $ handle ) ; }
Run all queries of specified group

@param string 		$group
@return void
Run all queries of specified group