bulkinsert.cpp

Go to the documentation of this file.

Go to the SVN repository for this file.

/* $Id: bulkinsert.cpp 44442 2010-01-13 20:05:34Z ivanovp $
* ===========================================================================
*
*                            PUBLIC DOMAIN NOTICE                          
*               National Center for Biotechnology Information
*                                                                          
*  This software/database is a "United States Government Work" under the   
*  terms of the United States Copyright Act.  It was written as part of    
*  the author's official duties as a United States Government employee and 
*  thus cannot be copyrighted.  This software/database is freely available 
*  to the public for use. The National Library of Medicine and the U.S.    
*  Government have not placed any restriction on its use or reproduction.  
*                                                                          
*  Although all reasonable efforts have been taken to ensure the accuracy  
*  and reliability of the software and data, the NLM and the U.S.          
*  Government do not and cannot warrant the performance or results that    
*  may be obtained by using this software or data. The NLM and the U.S.    
*  Government disclaim all warranties, express or implied, including       
*  warranties of performance, merchantability or fitness for any particular
*  purpose.                                                                
*                                                                          
*  Please cite the author in any work or product based on this material.   
*
* ===========================================================================
*
* File Name:  $Id: bulkinsert.cpp 44442 2010-01-13 20:05:34Z ivanovp $
*
* Author:  Michael Kholodov
*   
* File Description:  Base class for database access
*/
 
#include <ncbi_pch.hpp>
#include "conn_impl.hpp"
#include "bulkinsert.hpp"
#include <dbapi/driver/exception.hpp>
#include <dbapi/driver/public.hpp>
#include <dbapi/error_codes.hpp>
 
 
#define NCBI_USE_ERRCODE_X   Dbapi_BulkInsert
 
BEGIN_NCBI_SCOPE
 
// implementation
CDBAPIBulkInsert::CDBAPIBulkInsert(const string& name,
                                   CConnection* conn)
    : m_cmd(0), m_conn(conn)
{
    m_cmd = m_conn->GetCDB_Connection()->BCPIn(name);
    SetIdent("CDBAPIBulkInsert");
}
 
CDBAPIBulkInsert::~CDBAPIBulkInsert()
{
    try {
        Notify(CDbapiClosedEvent(this));
        FreeResources();
        Notify(CDbapiDeletedEvent(this));
        _TRACE(GetIdent() << " " << (void*)this << " deleted."); 
    }
    NCBI_CATCH_ALL_X( 1, kEmptyStr )
}
 
void CDBAPIBulkInsert::Close()
{
    Notify(CDbapiClosedEvent(this));
    FreeResources();
}
 
void CDBAPIBulkInsert::FreeResources()
{
    delete m_cmd;
    m_cmd = 0;
    if( m_conn != 0 && m_conn->IsAux() ) {
        delete m_conn;
        m_conn = 0;
        Notify(CDbapiAuxDeletedEvent(this));
    }
}
 
void CDBAPIBulkInsert::Bind(const CDBParamVariant& param, CVariant* v)
{
    // GetBCPInCmd()->GetBindParams().Bind(col - 1, v->GetData());
 
    if (param.IsPositional()) {
        // Decrement position by ONE.
        GetBCPInCmd()->GetBindParams().Bind(param.GetPosition() - 1, v->GetData());
    } else {
        GetBCPInCmd()->GetBindParams().Bind(param, v->GetData());
    }
}
        
        
void CDBAPIBulkInsert::SetHints(CTempString hints)
{
    GetBCPInCmd()->SetHints(hints);
}
 
void CDBAPIBulkInsert::AddHint(EHints hint, unsigned int value /* = 0 */)
{
    GetBCPInCmd()->AddHint((CDB_BCPInCmd::EBCP_Hints)hint, value);
}
 
void CDBAPIBulkInsert::AddOrderHint(CTempString columns)
{
    GetBCPInCmd()->AddOrderHint(columns);
}
 
void CDBAPIBulkInsert::AddRow()
{
    GetBCPInCmd()->SendRow();
}
 
void CDBAPIBulkInsert::StoreBatch() 
{
    GetBCPInCmd()->CompleteBatch();
}
 
void CDBAPIBulkInsert::Cancel()
{
    GetBCPInCmd()->Cancel();
}
 
void CDBAPIBulkInsert::Complete()
{
    GetBCPInCmd()->CompleteBCP();
}
 
void CDBAPIBulkInsert::Action(const CDbapiEvent& e) 
{
    _TRACE(GetIdent() << " " << (void*)this << ": '" << e.GetName() 
           << "' from " << e.GetSource()->GetIdent());
 
    if(dynamic_cast<const CDbapiDeletedEvent*>(&e) != 0 ) {
    RemoveListener(e.GetSource());
        if(dynamic_cast<CConnection*>(e.GetSource()) != 0 ) {
            _TRACE("Deleting " << GetIdent() << " " << (void*)this); 
            delete this;
        }
    }
}
 
END_NCBI_SCOPE