MySQL 5.0.9 Beta: ndb/tools/restore/restore

00235 {
00236   NDB_INIT(argv[0]);
00237 
00238   if (!readArguments(&argc, &argv))
00239   {
00240     return -1;
00241   }
00242 
00243   g_connect_string = opt_connect_str;
00244 
00248   RestoreMetaData metaData(ga_backupPath, ga_nodeId, ga_backupId);
00249   if (!metaData.readHeader())
00250   {
00251     ndbout << "Failed to read " << metaData.getFilename() << endl << endl;
00252     return -1;
00253   }
00254 
00255   const BackupFormat::FileHeader & tmp = metaData.getFileHeader();
00256   const Uint32 version = tmp.NdbVersion;
00257   
00258   ndbout << "Ndb version in backup files: " 
00259          <<  getVersionString(version, 0) << endl;
00260   
00264   int res  = metaData.loadContent();
00265   
00266   if (res == 0)
00267   {
00268     ndbout_c("Restore: Failed to load content");
00269     return -1;
00270   }
00271   
00272   if (metaData.getNoOfTables() == 0) 
00273   {
00274     ndbout_c("Restore: The backup contains no tables ");
00275     return -1;
00276   }
00277 
00278 
00279   if (!metaData.validateFooter()) 
00280   {
00281     ndbout_c("Restore: Failed to validate footer.");
00282     return -1;
00283   }
00284 
00285   Uint32 i;
00286   for(i= 0; i < g_consumers.size(); i++)
00287   {
00288     if (!g_consumers[i]->init())
00289     {
00290       clearConsumers();
00291       return -11;
00292     }
00293 
00294   }
00295 
00296   for(i = 0; i<metaData.getNoOfTables(); i++)
00297   {
00298     if (checkSysTable(metaData[i]->getTableName()))
00299     {
00300       for(Uint32 j= 0; j < g_consumers.size(); j++)
00301         if (!g_consumers[j]->table(* metaData[i]))
00302         {
00303           ndbout_c("Restore: Failed to restore table: %s. "
00304                    "Exiting...", 
00305                    metaData[i]->getTableName());
00306           return -11;
00307         } 
00308     }
00309   }
00310   
00311   for(i= 0; i < g_consumers.size(); i++)
00312     if (!g_consumers[i]->endOfTables())
00313     {
00314       ndbout_c("Restore: Failed while closing tables");
00315       return -11;
00316     } 
00317   
00318   if (ga_restore || ga_print) 
00319   {
00320     if (ga_restore) 
00321     {
00322       RestoreDataIterator dataIter(metaData, &free_data_callback);
00323       
00324       // Read data file header
00325       if (!dataIter.readHeader())
00326       {
00327         ndbout << "Failed to read header of data file. Exiting..." ;
00328         return -11;
00329       }
00330       
00331       
00332       while (dataIter.readFragmentHeader(res= 0))
00333       {
00334         const TupleS* tuple;
00335         while ((tuple = dataIter.getNextTuple(res= 1)) != 0)
00336         {
00337           if (checkSysTable(tuple->getTable()->getTableName()))
00338             for(Uint32 i= 0; i < g_consumers.size(); i++) 
00339               g_consumers[i]->tuple(* tuple);
00340         } // while (tuple != NULL);
00341         
00342         if (res < 0)
00343         {
00344           ndbout_c("Restore: An error occured while restoring data. "
00345                    "Exiting...");
00346           return -1;
00347         }
00348         if (!dataIter.validateFragmentFooter()) {
00349           ndbout_c("Restore: Error validating fragment footer. "
00350                    "Exiting...");
00351           return -1;
00352         }
00353       } // while (dataIter.readFragmentHeader(res))
00354       
00355       if (res < 0)
00356       {
00357         err << "Restore: An error occured while restoring data. Exiting... "
00358             << "res=" << res << endl;
00359         return -1;
00360       }
00361       
00362       
00363       dataIter.validateFooter(); //not implemented
00364       
00365       for (i= 0; i < g_consumers.size(); i++)
00366         g_consumers[i]->endOfTuples();
00367 
00368       RestoreLogIterator logIter(metaData);
00369       if (!logIter.readHeader())
00370       {
00371         err << "Failed to read header of data file. Exiting..." << endl;
00372         return -1;
00373       }
00374       
00375       const LogEntry * logEntry = 0;
00376       while ((logEntry = logIter.getNextLogEntry(res= 0)) != 0)
00377       {
00378         if (checkSysTable(logEntry->m_table->getTableName()))
00379           for(Uint32 i= 0; i < g_consumers.size(); i++)
00380             g_consumers[i]->logEntry(* logEntry);
00381       }
00382       if (res < 0)
00383       {
00384         err << "Restore: An restoring the data log. Exiting... res=" 
00385             << res << endl;
00386         return -1;
00387       }
00388       logIter.validateFooter(); //not implemented
00389       for (i= 0; i < g_consumers.size(); i++)
00390         g_consumers[i]->endOfLogEntrys();
00391       for(i = 0; i<metaData.getNoOfTables(); i++)
00392       {
00393         if (checkSysTable(metaData[i]->getTableName()))
00394         {
00395           for(Uint32 j= 0; j < g_consumers.size(); j++)
00396             if (!g_consumers[j]->finalize_table(* metaData[i]))
00397             {
00398               ndbout_c("Restore: Failed to finalize restore table: %s. "
00399                        "Exiting...", 
00400                        metaData[i]->getTableName());
00401               return -11;
00402             } 
00403         }
00404       }
00405     }
00406   }
00407   clearConsumers();
00408   return 0;
00409 } // main


Functions
static bool	checkSysTable (const char *tableName)
void	clearConsumers ()
static void	free_data_callback ()
static my_bool	get_one_option (int optid, const struct my_option opt __attribute__((unused)), char argument)
int	main (int argc, char **argv)
bool	readArguments (int pargc, char **pargv)
static void	short_usage_sub (void)
static void	usage ()
Variables
static int	_print = 0
static int	_print_data = 0
static int	_print_log = 0
static int	_print_meta = 0
static int	_restore_data = 0
static int	_restore_meta = 0
FilteredNdbOut	debug
FilteredNdbOut	err
const char *	g_connect_string = 0
static Vector< class BackupConsumer * >	g_consumers
static int	ga_backupId = 0
static const char *	ga_backupPath = "." DIR_SEPARATOR
static bool	ga_dont_ignore_systab_0 = false
static int	ga_nodeId = 0
static int	ga_nParallelism = 128
static bool	ga_print = false
static bool	ga_restore = false
FilteredNdbOut	info
static struct my_option	my_long_options []
	NDB_STD_OPTS_VARS

restore_main.cpp File Reference

Functions

Variables

Function Documentation

Variable Documentation