DIR : /home/kozerus/public_html/dgs/scripts/admin-export-games_info.php

/home/kozerus/public_html/dgs/scripts

<?php
/*
Dragon Go Server
Copyright (C) 2001-  Erik Ouchterlony, Jens-Uwe Gaspar

This program is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as
published by the Free Software Foundation, either version 3 of the
License, or (at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU Affero General Public License for more details.

You should have received a copy of the GNU Affero General Public License
along with this program.  If not, see <http://www.gnu.org/licenses/>.
*/

function error( $err, $debugmsg=NULL )
{
   $title = str_replace('_',' ',$err);
   list( $xerr, $uri ) = DgsErrors::err_log( $uhandle, $err, $debugmsg );
   exit;
}

require_once 'include/std_functions.php';
require_once 'include/rating.php';
require_once 'include/game_functions.php';


{
   // USAGE: Adjust query below to fit your needs!!

   // This script should not run via webserver, but from command-line
   if ( isset($_SERVER["SERVER_NAME"]) )
      exit;

   // check args
   $errors = array();
   if ( $argc == 2 )
   {
      $offset = $argv[1];
      $max_offset = 10000;
      if ( !is_numeric($offset) || $offset < 10 || $offset > $max_offset )
         $errors[] = "Bad offset '$offset', allowed are integers between [10..$max_offset]";
   }
   else
      $errors[] = 'Bad arguments';
   if ( count($errors) )
   {
      $err_text = implode('], [', $errors);
      echo "ERROR: [$err_text]\n";
      echo "Usage: $argv[0] <offset>\n";
      echo "Options:\n";
      echo "   <offset> = row-count to retrieve in one SELECT-query\n";
      echo "\n";
      exit;
   }


   connect2mysql();

   $out_dir = "GAMESINFO"; // output-directory
   if ( !file_exists($out_dir) )
      create_dir( $out_dir );

   $qsql = new QuerySQL(
      SQLP_FIELDS,
         'G.*',
         'YEAR(G.Lastchanged) AS Year',
         'UNIX_TIMESTAMP(G.Starttime) AS X_Starttime',
         'UNIX_TIMESTAMP(G.Lastchanged) AS X_Lastchanged',
      SQLP_FROM,
         'Games AS G',
      SQLP_WHERE,
         "G.Status='".GAME_STATUS_FINISHED."'",
         "G.GameType='".GAMETYPE_GO."'",
      SQLP_ORDER,
         'G.Lastchanged ASC' // needs sort by date (year)
   );
   $query = $qsql->get_select();

   $cnt = 0;
   $begin_secs = time();
   $filehandle = null;
   global $filehandle;

   $curr_year = -1;
   $curr_offset = 0;
   while ( true )
   {
      $result = db_query( 'export_gamesinfo.find_games', "$query LIMIT $curr_offset, $offset" );

      $rows = @mysql_num_rows($result);
      if ( $rows <= 0 )
         break;
      echo "There are $rows games to export from offset $offset ...\n";

      while ( $row = mysql_fetch_array( $result ) )
      {
         $cnt++;
         if ( !($cnt % 20) )
         {
            $timediff = time() - $begin_secs;
            echo "Retrieving game $gid ($cnt / $rows) ... needed $timediff secs so far ...\n";
         }

         write_game_info( $curr_year, $row );
      }
      mysql_free_result($result);
      $curr_offset += $offset;
   }

   close_file();

   echo "Export finished.\n";
}


function write_game_info( &$curr_year, array $row )
{
   global $filehandle, $out_dir;

   $year = $row['Year'];
   if ( $year != $curr_year )
   {
      close_file();
      $filename = sprintf( "%s/DGS-games_info-%04d.csv", $out_dir, $year );
      $filehandle = @fopen( $filename, 'wb' );
      @fwrite( $filehandle, build_game_info() );
   }
   $curr_year = $year;

   fwrite( $filehandle, build_game_info($row) );
}

function close_file()
{
   global $filehandle;
   if ( !is_null($filehandle) )
      fclose($filehandle);
   $filehandle = null;
}

function build_game_info( array $row = null )
{
   if ( is_null($row) ) // headers
   {
      return "GameID;Starttime;EndTime;Size;Moves;Rated;Ruleset;Handicap;Komi;Score;BlackID;WhiteID;BlackStartRating;WhiteStartRating;BlackEndRating;WhiteEndRating;TimeLimit\r\n";
   }
   else
   {
      return implode(';', array(
         $row['ID'],
         date('Y-m-d H:i:s', $row['X_Starttime'] ),
         date('Y-m-d H:i:s', $row['X_Lastchanged'] ),
         $row['Size'],
         $row['Moves'],
         ($row['Rated'] == 'N') ? 0 : 1,
         ($row['Ruleset'] == 'CHINESE') ? 'CH' : 'JP',
         $row['Handicap'],
         $row['Komi'],
         ( ($row['Flags'] & GAMEFLAGS_NO_RESULT) ? 'VOID' : $row['Score'] ),
         $row['Black_ID'],
         $row['White_ID'],
         $row['Black_Start_Rating'],
         $row['White_Start_Rating'],
         $row['Black_End_Rating'],
         $row['White_End_Rating'],
         TimeFormat::echo_time_limit( $row['Maintime'], $row['Byotype'], $row['Byotime'], $row['Byoperiods'],
               TIMEFMT_ENGL|TIMEFMT_SHORT|TIMEFMT_ADDTYPE),
      )) . "\r\n";
   }
}

function create_dir( $path )
{
   // NOTE: PHP4 don't have recursive-parameter yet
   if ( !@mkdir($path) )
      error('assert', "export_gamesinfo.create_dir($path)");
}
?>