runtime/nepomuk/services/storage/modelcopyjob.cpp

   1 /*
   2  *
   3  * $Id: sourceheader 511311 2006-02-19 14:51:05Z trueg $
   4  *
   5  * This file is part of the Nepomuk KDE project.
   6  * Copyright (C) 2006-2007 Sebastian Trueg <trueg@kde.org>
   7  *
   8  * This program is free software; you can redistribute it and/or modify
   9  * it under the terms of the GNU General Public License as published by
  10  * the Free Software Foundation; either version 2 of the License, or
  11  * (at your option) any later version.
  12  * See the file "COPYING" for the exact licensing terms.
  13  */
  14
  15 #include "modelcopyjob.h"
  16
  17 #include <Soprano/Model>
  18 #include <Soprano/Error/Error>
  19
  20 #include <KLocale>
  21 #include <KDebug>
  22
  23
  24 Nepomuk::ModelCopyJob::ModelCopyJob( Soprano::Model* source, Soprano::Model* dest, QObject* parent )
  25     : KJob( parent ),
  26       m_source( source ),
  27       m_dest( dest )
  28 {
  29     kDebug();
  30     connect( &m_timer, SIGNAL( timeout() ),
  31              this, SLOT( slotCopy() ) );
  32 }
  33
  34
  35 Nepomuk::ModelCopyJob::~ModelCopyJob()
  36 {
  37 }
  38
  39
  40 void Nepomuk::ModelCopyJob::start()
  41 {
  42     kDebug();
  43     emit description( this, i18n( "Converting Nepomuk database" ) );
  44
  45     m_size = m_source->statementCount();
  46     m_done = 0;
  47     m_allCopied = true;
  48
  49     if ( m_size > 0 ) {
  50         setTotalAmount( KJob::Files, m_size );
  51     }
  52
  53     m_iterator = m_source->listStatements();
  54
  55     m_timer.start( 0 );
  56 }
  57
  58
  59 void Nepomuk::ModelCopyJob::slotCopy()
  60 {
  61     if ( m_iterator.next() ) {
  62         ++m_done;
  63
  64         if ( m_dest->addStatement( *m_iterator ) != Soprano::Error::ErrorNone ) {
  65             kDebug() << m_dest->lastError();
  66             emit warning( this, m_dest->lastError().message() );
  67             m_allCopied = false;
  68         }
  69
  70         setProcessedAmount( KJob::Files, m_done );
  71     }
  72     else {
  73         kDebug() << "done";
  74         m_timer.stop();
  75
  76         if ( !m_allCopied ) {
  77             setError( 1 );
  78             setErrorText( i18n( "Some data was lost in the conversion." ) );
  79         }
  80
  81         emitResult();
  82     }
  83 }
  84
  85 #include "modelcopyjob.moc"