BOOL CunloadApp::ConnectToDatabases()
{
	TRY 
	{

	m_oraDb=new CDatabase();
	m_sqlDb=new CDatabase();

	m_oraDb->OpenEx(_T( "DSN=" )+m_store.db_ora_dsn+_T( ";UID=" )+m_store.db_ora_user+_T( ";PWD=" )+m_store.db_ora_psw,CDatabase::openReadOnly|CDatabase::noOdbcDialog);
	m_sqlDb->OpenEx(_T( "DSN=" )+m_store.db_sql_dsn+_T( ";UID=" )+m_store.db_sql_user+_T( ";PWD=" )+m_store.db_sql_psw,CDatabase::noOdbcDialog);
	}
	CATCH(CDBException,e)
	{
		e->ReportError();
		e->Delete();
		return FALSE;
	}
	END_CATCH;
	return (m_bConnectOk=TRUE);
}

void CunloadApp::DisconnectDatabases()
{
	TRY {
	if(m_oraDb && m_oraDb->IsOpen()) { m_oraDb->Cancel();m_oraDb->Close(); delete m_oraDb;}
	if(m_sqlDb && m_sqlDb->IsOpen()) { m_sqlDb->Cancel(); m_sqlDb->Close(); delete m_sqlDb;}
	m_bConnectOk=FALSE;
	}
	CATCH(CDBException,e)
	{
		e->ReportError();
		e->Delete();
	}
	END_CATCH;
}


void CunloadApp::UnLoad() 
{

	MSG message;
	TRY {
	COraRecordset m_oraRecordSet(m_oraDb);
	CSqlRecordset  m_sqlRecordSet(m_sqlDb);

	if(!m_sqlRecordSet.IsOpen()) m_sqlRecordSet.Open();
	if(!m_sqlRecordSet.IsOpen())
	{
		AfxMessageBox(IDS_SQL0001);
	             return;
	}

	if(!m_oraRecordSet.IsOpen()) 
               m_oraRecordSet.Open(CRecordset::forwardOnly,NULL,CRecordset::readOnly);

             if(!m_oraRecordSet.IsOpen())
	{
		AfxMessageBox(IDS_ORA0001);
	             return;
	}

	if(!m_oraRecordSet.IsEOF() && !m_oraRecordSet.IsBOF())
	{

		while(!m_oraRecordSet.IsEOF())
		{
		SaveSubject(m_oraRecordSet,m_sqlRecordSet);
	            	if(::PeekMessage(&message,NULL, 0 , 0 ,PM_REMOVE))
					{
					::TranslateMessage(&message);
					::DispatchMessage(&message);
					}
                          m_oraRecordSet.MoveNext();
		}

	}
	if(m_oraRecordSet.IsOpen()) m_oraRecordSet.Close();
	if(m_sqlRecordSet.IsOpen()) m_sqlRecordSet.Close();
	} // TRY

	
	CATCH(CDBException,e)
	{
		e->ReportError();
		e->Delete();
	}
	END_CATCH;
}

void CunloadApp::SaveSubject(COraSubject &ora, CSqlSubject &sql)
{
	TRY
	{
		if(ora.IsOpen() && sql.IsOpen())
		{

		sql.AddNew();
		sql.m_CNAME=ora.m_CNAME;
		sql.m_ID=ora.m_ID;
		sql.Update();
		}	  
		
	}
	CATCH(CDBException,e)
	{
		e->ReportError();
		e->Delete();
	}
	END_CATCH;


}

// afx_message map

void CunloadApp::OnButtonUnload()
{
 if(ConnectToDatabases()) 
 { UnLoad();
   DisconnectDatabases();
 }
}