[wxWidgets.git] / demos / dbbrowse / browsedb.cpp

//----------------------------------------------------------------------------------------
// Name:		BrowserDB.h,cpp
// Purpose: 	a wxDB class
// Author:		Mark Johnson
// Modified by:
// Created: 	19991127.mj10777
// Copyright:	(c) Mark Johnson
// Licence: 	wxWindows license
// RCS-ID:		$Id$
//----------------------------------------------------------------------------------------
//-- 1)
//----------------------------------------------------------------------------------------
//-- all #ifdefs that the whole Project needs. -------------------------------------------
//----------------------------------------------------------------------------------------
#ifdef __GNUG__
#pragma implementation
#pragma interface
#endif
//----------------------------------------------------------------------------------------
// For compilers that support precompilation, includes "wx/wx.h".
#include "wx/wxprec.h"
//----------------------------------------------------------------------------------------
#ifdef __BORLANDC__
#pragma hdrstop
#endif
//----------------------------------------------------------------------------------------
#ifndef WX_PRECOMP
#include "wx/wx.h"
#endif
//----------------------------------------------------------------------------------------
#include "std.h"
//----------------------------------------------------------------------------------------
// Global structure for holding ODBC connection information
wxDbConnectInf DbConnectInf;

#if !wxUSE_ODBC
  #error Demo cannot be compiled unless setup.h has wxUSE_ODBC set to 1
#endif

//----------------------------------------------------------------------------------------
extern WXDLLEXPORT_DATA(wxDbList*) PtrBegDbList;	/* from db.cpp, used in getting back error results from db connections */

//----------------------------------------------------------------------------------------
wxChar *GetExtendedDBErrorMsg(wxChar *ErrFile, int ErrLine)
{
    static wxString msg;
    wxString tStr;
    if (ErrFile || ErrLine)
    {
        msg += _T("File: ");
        msg += ErrFile;
        msg += _T("   Line: ");
        tStr.Printf(_T("%d"),ErrLine);
        msg += tStr.GetData();
        // msg += _T("\n");
    }
    msg.Append (_T("\nODBC errors:\n"));
    // msg += _T("\n");
    /* Scan through each database connection displaying
    * any ODBC errors that have occured. */
    wxDbList *pDbList;
    for (pDbList = PtrBegDbList; pDbList; pDbList = pDbList->PtrNext)
    {
        // Skip over any free connections
        if (pDbList->Free)
            continue;
        // Display errors for this connection
        for (int i = 0; i < DB_MAX_ERROR_HISTORY; i++)
        {
            if (pDbList->PtrDb->errorList[i])
            {
                msg.Append(pDbList->PtrDb->errorList[i]);
                if (wxStrcmp(pDbList->PtrDb->errorList[i],_T("")) != 0)
                    msg.Append(_T("\n"));
            }
        }
    }
    msg += _T("\n");
    return (wxChar*) (const wxChar*) msg;
}  // GetExtendedDBErrorMsg

//----------------------------------------------------------------------------------------
BrowserDB::BrowserDB()
{
    PointerToNULL(0);
    ODBCSource = _T("");  // ODBC data source name (created with ODBC Administrator under Win95/NT)
    UserName   = _T("");  // database username - must already exist in the data source
    Password   = _T("");  // password database username
    OnFillSqlTyp();
    OnFilldbTyp();
}  // BrowserDB Constructor

//----------------------------------------------------------------------------------------
BrowserDB::~BrowserDB()
{
    PointerToNULL(1);  // Clean up Tables and Databases (Commit, Close and delete)
}  // BrowserDB destructor

//----------------------------------------------------------------------------------------
bool BrowserDB::Initialize(int Quiet)
{
    if (!OnStartDB(Quiet))
    {
        wxLogMessage(_("\n\n-E-> BrowserDB::OnStartDB(%s) : Failed ! "),ODBCSource.c_str());
        return FALSE;
    }
    return TRUE;
}  // BrowserDB:Initialize

//----------------------------------------------------------------------------------------
bool BrowserDB::OnStartDB(int Quiet)
{
    wxStopWatch sw;
    if (!Quiet)
        wxLogMessage(_("\n-I-> BrowserDB::OnStartDB(%s) : Begin "),ODBCSource.c_str());
    if (db_BrowserDB != NULL)
    {
        if (!Quiet)
            wxLogMessage(_("\n-I-> BrowserDB::OnStartDB() : DB is already open."));
        return TRUE;
    }

    DbConnectInf.AllocHenv();

    //---------------------------------------------------------------------------------------
    // Connect to datasource
    //---------------------------------------------------------------------------------------
    DlgUser *p_Dlg;
    p_Dlg = new DlgUser(pDoc->p_MainFrame,pDoc,_T(""));
    p_Dlg->s_DSN	  = ODBCSource;
    p_Dlg->s_User	  = UserName;
    p_Dlg->s_Password = Password;
    p_Dlg->OnInit();
    p_Dlg->Fit();
    
    bool OK = FALSE;
    if (p_Dlg->ShowModal() == wxID_OK)
    {
        (pDoc->p_DSN+i_Which)->Usr = p_Dlg->s_User;
        (pDoc->p_DSN+i_Which)->Pas = p_Dlg->s_Password;
        UserName  = p_Dlg->s_User;
        Password  = p_Dlg->s_Password;
        OK = TRUE;
    }
    delete p_Dlg;
    if (OK)
    {
        //--------------------------------------------------------------------------------------
        DbConnectInf.SetDsn(ODBCSource); 		  // ODBC data source name (created with ODBC Administrator under Win95/NT)
        DbConnectInf.SetUserID(UserName);	      // database username - must already exist in the data source
        DbConnectInf.SetPassword(Password);	  // password database username
        db_BrowserDB = wxDbGetConnection(&DbConnectInf);
        // wxLogMessage(">>>%s<<<>>>%s<<<",UserName.c_str(),Password.c_str());
        if (db_BrowserDB == NULL)
        {
            DbConnectInf.SetDsn(wxT(""));
            DbConnectInf.SetUserID(wxT(""));
            DbConnectInf.SetPassword(wxT(""));
            if (!Quiet)
            {
                wxLogMessage(_("\n-E-> BrowserDB::OnConnectDataSource() DB CONNECTION ERROR : Unable to connect to the data source.\n\nCheck the name of your data source to verify it has been correctly entered/spelled.\n\nWith some databases, the user name and password must\nbe created with full rights to the table prior to making a connection\n(using tools provided by the database manufacturer)"));
                wxLogMessage(_("-I-> BrowserDB::OnStartDB(%s) : End - Time needed : %ld ms"),ODBCSource.c_str(),sw.Time());
            }
            DbConnectInf.FreeHenv();
            return FALSE;
        }
        //--------------------------------------------------------------------------------------
        if (!Quiet)
        {
            Temp1 = db_BrowserDB->GetDatabaseName();
            Temp2 = db_BrowserDB->GetDataSource();
            wxLogMessage(_("-I-> BrowserDB::OnGetDataSourceODBC() - DatabaseName(%s) ; DataSource(%s)"),Temp1.c_str(),Temp2.c_str());
            wxLogMessage(_("-I-> BrowserDB::OnStartDB(%s) : End - Time needed : %ld ms"),ODBCSource.c_str(),sw.Time());
        }
        return TRUE;
    }
    else
    {
        DbConnectInf.FreeHenv();
        return FALSE;
    }
}

//----------------------------------------------------------------------------------------
bool BrowserDB::OnCloseDB(int Quiet)
{
    if (!Quiet)
        wxLogMessage(_("-I-> BrowserDB::OnCloseDB() : Begin "));
    if (db_BrowserDB)
    {
//        db_BrowserDB->Close();
        wxDbFreeConnection(db_BrowserDB);

        DbConnectInf.FreeHenv();

        db_BrowserDB = NULL;
    }
    if (!Quiet)
        wxLogMessage(_("\n-I-> BrowserDB::OnCloseDB() : End "));
    return TRUE;
}

//----------------------------------------------------------------------------------------
bool BrowserDB::OnGetNext(int Cols,int Quiet)
{
    SDWORD cb;
    int 	 i_dbDataType;
    int   i=0;
    wxChar s_temp[1024+1];
    long			 l_temp;
    double			 f_temp;
    int 			 AnzError=0;
    TIMESTAMP_STRUCT t_temp;
    wxString Temp0;
    //-----------------------------
    if (!db_BrowserDB->GetNext())
    {
        return FALSE;
        Temp0.Printf(_("\n-E-> BrowserDB::OnGetNext - ODBC-Error with GetNext \n-E-> "));
        Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
        wxLogMessage(Temp0);
        wxMessageBox(Temp0);
    }
    else
    {
        for (i=0;i<Cols;i++)
        {
            wxStrcpy((cl_BrowserDB+i)->tableName,_T("-E->"));
            i_dbDataType = (cl_BrowserDB+i)->pColFor->i_dbDataType;
            if (i_dbDataType == 0)						  // Filter unsupported dbDataTypes
            {
                if (((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_VARCHAR) ||
						  ((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_LONGVARCHAR))
                    i_dbDataType = DB_DATA_TYPE_VARCHAR;
                if ((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_C_DATE)
                    i_dbDataType = DB_DATA_TYPE_DATE;
                if ((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_C_BIT)
                    i_dbDataType = DB_DATA_TYPE_INTEGER;
                if ((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_NUMERIC)
                    i_dbDataType = DB_DATA_TYPE_VARCHAR;
                if ((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_REAL)
                    i_dbDataType = DB_DATA_TYPE_FLOAT;
            }
            if ((i_dbDataType == DB_DATA_TYPE_INTEGER) &&
					 ((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_C_DOUBLE))
            {	// DBASE Numeric
                i_dbDataType = DB_DATA_TYPE_FLOAT;
            }
            switch(i_dbDataType)
            {
            case DB_DATA_TYPE_VARCHAR:
                wxStrcpy(s_temp,_T(""));
                if (!db_BrowserDB->GetData(i+1,(cl_BrowserDB+i)->pColFor->i_dbDataType,&s_temp,sizeof(s_temp), &cb))
                {
                    Temp0.Printf(_("\n-E-> BrowserDB::OnGetNext - ODBC-Error with GetNext of >%s<.\n-E-> "),(cl_BrowserDB+i)->tableName);
                    Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
                    wxLogMessage(Temp0);
                }
                Temp0.Printf((cl_BrowserDB+i)->pColFor->s_Field,s_temp);
                wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
                break;
            case DB_DATA_TYPE_INTEGER:
                l_temp = 0;
                if (!db_BrowserDB->GetData(i+1,(cl_BrowserDB+i)->pColFor->i_sqlDataType,&l_temp,sizeof(l_temp), &cb))
                {
                    Temp0.Printf(_("\n-E-> BrowserDB::OnGetData - ODBC-Error with GetNext \n-E-> "));
                    Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
                }
                else
                {
                    Temp0.Printf((cl_BrowserDB+i)->pColFor->s_Field,l_temp);
                    wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
                }
                break;
            case DB_DATA_TYPE_FLOAT:
                f_temp = 0;
                if (!db_BrowserDB->GetData(i+1,(cl_BrowserDB+i)->pColFor->i_sqlDataType,&f_temp,sizeof(f_temp), &cb))
                {
                    Temp0.Printf(_("\n-E-> BrowserDB::OnGetData - ODBC-Error with GetNext \n-E-> "));
                    Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
                    wxMessageBox(Temp0);
                }
                else
                {
                    Temp0.Printf((cl_BrowserDB+i)->pColFor->s_Field,f_temp);
                    wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
                }
                break;
            case DB_DATA_TYPE_DATE:
                t_temp.day = t_temp.month = t_temp.year = t_temp.hour = t_temp.minute = t_temp.second = t_temp.fraction = 0;
                if (!db_BrowserDB->GetData(i+1,(cl_BrowserDB+i)->pColFor->i_sqlDataType,&t_temp,sizeof(t_temp), &cb))
                {
                    Temp0.Printf(_("\n-E-> BrowserDB::OnGetData - ODBC-Error with GetNext \n-E-> "));
                    Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
                }
                else
                {
                    // i_Nation =  0 = timestamp , 1=EU, 2=UK, 3=International, 4=US
                    if (((cl_BrowserDB+i)->pColFor->i_Nation == 0)	||	// TS  YYYY-MM-DD
                        ((cl_BrowserDB+i)->pColFor->i_Nation == 3)) 	// IT  YYYY-MM-DD
                    {
                        Temp0.Printf((cl_BrowserDB+i)->pColFor->s_Field,t_temp.year,t_temp.month,t_temp.day,
                            t_temp.hour, t_temp.minute, t_temp.second, t_temp.fraction);
                        wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
                    }
                    if (((cl_BrowserDB+i)->pColFor->i_Nation == 1) ||  // EU  DD.MM.YYYY
                        ((cl_BrowserDB+i)->pColFor->i_Nation == 2))   // UK  DD/MM/YYYY
                    {
                        Temp0.Printf((cl_BrowserDB+i)->pColFor->s_Field,t_temp.day,t_temp.month,t_temp.year,
                            t_temp.hour, t_temp.minute, t_temp.second, t_temp.fraction);
                        wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
                    }
                    if ((cl_BrowserDB+i)->pColFor->i_Nation == 3)	   // US  MM/DD/YYYY
                    {
                        Temp0.Printf((cl_BrowserDB+i)->pColFor->s_Field,t_temp.month,t_temp.day,t_temp.year,
                            t_temp.hour, t_temp.minute, t_temp.second, t_temp.fraction);
                        wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
                    }
                }
                break;
            default:
                AnzError++;
                if (AnzError <= 100)
                {
                    Temp0 = (cl_BrowserDB+i)->colName;
                    wxLogMessage(_("-E-> BrowserDB::OnGetNext - DB_DATA_TYPE_?? (%d) in Col(%s)"),(cl_BrowserDB+i)->pColFor->i_dbDataType,Temp0.c_str());
                }
                else
                    return TRUE;
                Temp0.Printf(_("-E-> unknown Format(%d) - sql(%d)"),(cl_BrowserDB+i)->pColFor->i_dbDataType,(cl_BrowserDB+i)->pColFor->i_sqlDataType);
                wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
                break;
            };  // switch
        }  // for
    }  // else

    return TRUE;
}

//----------------------------------------------------------------------------------------
bool BrowserDB::OnSelect(wxString tb_Name, int Quiet)
{
    wxStopWatch sw;
    wxString SQLStmt;
    i_Records = 0;
    //---------------------------------------------------------------------------------------
    SQLStmt.sprintf(_T("SELECT * FROM %s"),db_BrowserDB->SQLTableName(tb_Name.c_str()));
    if (!db_BrowserDB->ExecSql((wxChar *)(SQLStmt.GetData())))
    {
        Temp0.Printf(_("\n-E-> BrowserDB::OnSelect - ODBC-Error with ExecSql of >%s<.\n-E-> "),tb_Name.c_str());
        Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
        wxLogMessage(Temp0);
        wxMessageBox(_T("-E-> BrowserDB::OnSelect - GetData()"));
        return FALSE;
    }
    //---------------------------------------------------------------------------------------
    while (db_BrowserDB->GetNext())
    {
        i_Records++;
    }
    //---------------------------------------------------------------------------------------
    if (!db_BrowserDB->ExecSql((wxChar *)(SQLStmt.GetData())))
    {
        Temp0.Printf(_("\n-E-> BrowserDB::OnSelect - ODBC-Error with ExecSql of >%s<.\n-E-> "),tb_Name.c_str());
        Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
        wxLogMessage(Temp0);
        return FALSE;
    }
    //---------------------------------------------------------------------------------------
    // SetColDefs ( 0,"NAME",	  DB_DATA_TYPE_VARCHAR,  Name,	   SQL_C_CHAR,		sizeof(Name),	 TRUE, TRUE);  // Primary index
    //---------------------------------------------------------------------------------------
    if (!Quiet)
    {
        wxLogMessage(_("\n-I-> BrowserDB::OnSelect(%s) Records(%d): End - Time needed : %ld ms"),tb_Name.c_str(),i_Records,sw.Time());
    }
    return TRUE;
}

//----------------------------------------------------------------------------------------
bool BrowserDB::OnExecSql(wxString SQLStmt, int Quiet)
{
    //---------------------------------------------------------------------------------------
    if (!db_BrowserDB->ExecSql((wxChar *)(SQLStmt.GetData())))
    {
        Temp0.Printf(_("\n-E-> BrowserDB::OnExecSQL - ODBC-Error with ExecSql of >%s<.\n-E-> "),SQLStmt.c_str());
        Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
        if (!Quiet)
            wxLogMessage(Temp0);
        else
            wxMessageBox(_T("-E-> BrowserDB::OnExecSql - ExecSql()"));
        return FALSE;
    }
    if (!Quiet)
    {
        // wxLogMessage(_("\n-I-> BrowserDB::OnExecSql(%s) - End - Time needed : %ld ms"),SQLStmt.c_str(),sw.Time());
    }
    return TRUE;
}

//----------------------------------------------------------------------------------------
wxDbInf* BrowserDB::OnGetCatalog(int Quiet)
{
    wxChar UName[255];
    wxStrcpy(UName,UserName);
    ct_BrowserDB = db_BrowserDB->GetCatalog(UName);
    return ct_BrowserDB;
}

//----------------------------------------------------------------------------------------
wxDbColInf* BrowserDB::OnGetColumns(wxChar *tableName, UWORD numCols, int Quiet)
{
    wxChar UName[255];
    int i;
    wxStrcpy(UName,UserName);
    cl_BrowserDB = db_BrowserDB->GetColumns(tableName,&numCols,UName);
//    cl_BrowserDB->pColFor = new wxDbColFor[numCols];
    for (i=0;i<numCols;i++)
    {
//        (cl_BrowserDB->pColFor+i)->Format(1,(cl_BrowserDB+i)->dbDataType,(cl_BrowserDB+i)->sqlDataType,
//            (cl_BrowserDB+i)->columnSize, (cl_BrowserDB+i)->decimalDigits);
        (cl_BrowserDB+i)->pColFor = new wxDbColFor;
        (cl_BrowserDB+i)->pColFor->Format(1,
                                        (cl_BrowserDB+i)->dbDataType,
                                        (cl_BrowserDB+i)->sqlDataType,
                                        (cl_BrowserDB+i)->columnSize, 
                                        (cl_BrowserDB+i)->decimalDigits);
    }
    return cl_BrowserDB;
}

//----------------------------------------------------------------------------------------
void BrowserDB::PointerToNULL(int Art)
{
Commit	Line	Data
c92b0f9a	1	//----------------------------------------------------------------------------------------
645889ad GT	2	// Name: BrowserDB.h,cpp
645889ad GT	3	// Purpose: a wxDB class
829c421b	4	// Author: Mark Johnson
b5ffecfc	5	// Modified by:
645889ad GT	6	// Created: 19991127.mj10777
	7	// Copyright: (c) Mark Johnson
	8	// Licence: wxWindows license
	9	// RCS-ID: $Id$
c92b0f9a	10	//----------------------------------------------------------------------------------------
b5ffecfc	11	//-- 1)
c92b0f9a MJ	12	//----------------------------------------------------------------------------------------
	13	//-- all #ifdefs that the whole Project needs. -------------------------------------------
	14	//----------------------------------------------------------------------------------------
b5ffecfc	15	#ifdef __GNUG__
b5ce269b BJ	16	#pragma implementation
b5ce269b BJ	17	#pragma interface
b5ffecfc	18	#endif
c92b0f9a	19	//----------------------------------------------------------------------------------------
b5ffecfc GT	20	// For compilers that support precompilation, includes "wx/wx.h".
b5ffecfc GT	21	#include "wx/wxprec.h"
c92b0f9a	22	//----------------------------------------------------------------------------------------
b5ffecfc	23	#ifdef __BORLANDC__
b5ce269b	24	#pragma hdrstop
b5ffecfc	25	#endif
c92b0f9a	26	//----------------------------------------------------------------------------------------
b5ffecfc	27	#ifndef WX_PRECOMP
b5ce269b	28	#include "wx/wx.h"
b5ffecfc	29	#endif
c92b0f9a	30	//----------------------------------------------------------------------------------------
b5ffecfc	31	#include "std.h"
c92b0f9a	32	//----------------------------------------------------------------------------------------
b5ffecfc	33	// Global structure for holding ODBC connection information
daf06bb8	34	wxDbConnectInf DbConnectInf;
645889ad	35
c20a12bd	36	#if !wxUSE_ODBC
5d59e67a GT	37	#error Demo cannot be compiled unless setup.h has wxUSE_ODBC set to 1
	38	#endif
	39
c92b0f9a	40	//----------------------------------------------------------------------------------------
645889ad GT	41	extern WXDLLEXPORT_DATA(wxDbList) PtrBegDbList; / from db.cpp, used in getting back error results from db connections */
645889ad GT	42
c92b0f9a	43	//----------------------------------------------------------------------------------------
daf06bb8	44	wxChar GetExtendedDBErrorMsg(wxChar ErrFile, int ErrLine)
b5ffecfc	45	{
645889ad GT	46	static wxString msg;
	47	wxString tStr;
	48	if (ErrFile \|\| ErrLine)
	49	{
daf06bb8	50	msg += _T("File: ");
645889ad	51	msg += ErrFile;
daf06bb8 JS	52	msg += _T(" Line: ");
daf06bb8 JS	53	tStr.Printf(_T("%d"),ErrLine);
645889ad	54	msg += tStr.GetData();
daf06bb8	55	// msg += _T("\n");
645889ad	56	}
daf06bb8 JS	57	msg.Append (_T("\nODBC errors:\n"));
daf06bb8 JS	58	// msg += _T("\n");
645889ad GT	59	/* Scan through each database connection displaying
	60	* any ODBC errors that have occured. */
	61	wxDbList *pDbList;
	62	for (pDbList = PtrBegDbList; pDbList; pDbList = pDbList->PtrNext)
	63	{
	64	// Skip over any free connections
	65	if (pDbList->Free)
	66	continue;
	67	// Display errors for this connection
	68	for (int i = 0; i < DB_MAX_ERROR_HISTORY; i++)
	69	{
	70	if (pDbList->PtrDb->errorList[i])
	71	{
	72	msg.Append(pDbList->PtrDb->errorList[i]);
daf06bb8 JS	73	if (wxStrcmp(pDbList->PtrDb->errorList[i],_T("")) != 0)
daf06bb8 JS	74	msg.Append(_T("\n"));
645889ad GT	75	}
	76	}
	77	}
daf06bb8 JS	78	msg += _T("\n");
daf06bb8 JS	79	return (wxChar) (const wxChar) msg;
b5ffecfc	80	} // GetExtendedDBErrorMsg
13b59a33	81
c92b0f9a	82	//----------------------------------------------------------------------------------------
b5ffecfc GT	83	BrowserDB::BrowserDB()
b5ffecfc GT	84	{
eacf9d88	85	PointerToNULL(0);
daf06bb8 JS	86	ODBCSource = _T(""); // ODBC data source name (created with ODBC Administrator under Win95/NT)
	87	UserName = _T(""); // database username - must already exist in the data source
	88	Password = _T(""); // password database username
645889ad GT	89	OnFillSqlTyp();
645889ad GT	90	OnFilldbTyp();
b5ffecfc	91	} // BrowserDB Constructor
645889ad	92
c92b0f9a	93	//----------------------------------------------------------------------------------------
b5ffecfc GT	94	BrowserDB::~BrowserDB()
b5ffecfc GT	95	{
eacf9d88	96	PointerToNULL(1); // Clean up Tables and Databases (Commit, Close and delete)
b5ffecfc	97	} // BrowserDB destructor
645889ad	98
c92b0f9a	99	//----------------------------------------------------------------------------------------
f6bcfd97	100	bool BrowserDB::Initialize(int Quiet)
b5ffecfc	101	{
645889ad GT	102	if (!OnStartDB(Quiet))
	103	{
	104	wxLogMessage(_("\n\n-E-> BrowserDB::OnStartDB(%s) : Failed ! "),ODBCSource.c_str());
	105	return FALSE;
	106	}
	107	return TRUE;
b5ffecfc	108	} // BrowserDB:Initialize
645889ad	109
c92b0f9a	110	//----------------------------------------------------------------------------------------
f6bcfd97	111	bool BrowserDB::OnStartDB(int Quiet)
b5ffecfc	112	{
645889ad GT	113	wxStopWatch sw;
	114	if (!Quiet)
	115	wxLogMessage(_("\n-I-> BrowserDB::OnStartDB(%s) : Begin "),ODBCSource.c_str());
	116	if (db_BrowserDB != NULL)
	117	{
	118	if (!Quiet)
eacf9d88	119	wxLogMessage(_("\n-I-> BrowserDB::OnStartDB() : DB is already open."));
645889ad GT	120	return TRUE;
645889ad GT	121	}
eacf9d88 GT	122
	123	DbConnectInf.AllocHenv();
	124
645889ad GT	125	//---------------------------------------------------------------------------------------
	126	// Connect to datasource
	127	//---------------------------------------------------------------------------------------
	128	DlgUser *p_Dlg;
daf06bb8	129	p_Dlg = new DlgUser(pDoc->p_MainFrame,pDoc,_T(""));
645889ad GT	130	p_Dlg->s_DSN = ODBCSource;
	131	p_Dlg->s_User = UserName;
	132	p_Dlg->s_Password = Password;
	133	p_Dlg->OnInit();
	134	p_Dlg->Fit();
	135
	136	bool OK = FALSE;
	137	if (p_Dlg->ShowModal() == wxID_OK)
	138	{
	139	(pDoc->p_DSN+i_Which)->Usr = p_Dlg->s_User;
	140	(pDoc->p_DSN+i_Which)->Pas = p_Dlg->s_Password;
	141	UserName = p_Dlg->s_User;
	142	Password = p_Dlg->s_Password;
	143	OK = TRUE;
	144	}
	145	delete p_Dlg;
	146	if (OK)
	147	{
	148	//--------------------------------------------------------------------------------------
eacf9d88 GT	149	DbConnectInf.SetDsn(ODBCSource); // ODBC data source name (created with ODBC Administrator under Win95/NT)
	150	DbConnectInf.SetUserID(UserName); // database username - must already exist in the data source
	151	DbConnectInf.SetPassword(Password); // password database username
	152	db_BrowserDB = wxDbGetConnection(&DbConnectInf);
645889ad GT	153	// wxLogMessage(">>>%s<<<>>>%s<<<",UserName.c_str(),Password.c_str());
	154	if (db_BrowserDB == NULL)
	155	{
eacf9d88 GT	156	DbConnectInf.SetDsn(wxT(""));
	157	DbConnectInf.SetUserID(wxT(""));
	158	DbConnectInf.SetPassword(wxT(""));
645889ad GT	159	if (!Quiet)
	160	{
	161	wxLogMessage(_("\n-E-> BrowserDB::OnConnectDataSource() DB CONNECTION ERROR : Unable to connect to the data source.\n\nCheck the name of your data source to verify it has been correctly entered/spelled.\n\nWith some databases, the user name and password must\nbe created with full rights to the table prior to making a connection\n(using tools provided by the database manufacturer)"));
	162	wxLogMessage(_("-I-> BrowserDB::OnStartDB(%s) : End - Time needed : %ld ms"),ODBCSource.c_str(),sw.Time());
	163	}
eacf9d88	164	DbConnectInf.FreeHenv();
645889ad GT	165	return FALSE;
	166	}
	167	//--------------------------------------------------------------------------------------
	168	if (!Quiet)
	169	{
	170	Temp1 = db_BrowserDB->GetDatabaseName();
	171	Temp2 = db_BrowserDB->GetDataSource();
	172	wxLogMessage(_("-I-> BrowserDB::OnGetDataSourceODBC() - DatabaseName(%s) ; DataSource(%s)"),Temp1.c_str(),Temp2.c_str());
	173	wxLogMessage(_("-I-> BrowserDB::OnStartDB(%s) : End - Time needed : %ld ms"),ODBCSource.c_str(),sw.Time());
	174	}
	175	return TRUE;
	176	}
	177	else
eacf9d88 GT	178	{
eacf9d88 GT	179	DbConnectInf.FreeHenv();
645889ad	180	return FALSE;
eacf9d88	181	}
b5ffecfc	182	}
645889ad	183
c92b0f9a	184	//----------------------------------------------------------------------------------------
f6bcfd97	185	bool BrowserDB::OnCloseDB(int Quiet)
b5ffecfc	186	{
645889ad GT	187	if (!Quiet)
	188	wxLogMessage(_("-I-> BrowserDB::OnCloseDB() : Begin "));
	189	if (db_BrowserDB)
	190	{
	191	// db_BrowserDB->Close();
	192	wxDbFreeConnection(db_BrowserDB);
eacf9d88 GT	193
	194	DbConnectInf.FreeHenv();
	195
645889ad GT	196	db_BrowserDB = NULL;
	197	}
	198	if (!Quiet)
	199	wxLogMessage(_("\n-I-> BrowserDB::OnCloseDB() : End "));
	200	return TRUE;
b5ffecfc	201	}
645889ad	202
b5ffecfc	203	//----------------------------------------------------------------------------------------
f6bcfd97	204	bool BrowserDB::OnGetNext(int Cols,int Quiet)
b5ffecfc	205	{
645889ad GT	206	SDWORD cb;
	207	int i_dbDataType;
	208	int i=0;
daf06bb8	209	wxChar s_temp[1024+1];
645889ad GT	210	long l_temp;
	211	double f_temp;
	212	int AnzError=0;
	213	TIMESTAMP_STRUCT t_temp;
	214	wxString Temp0;
	215	//-----------------------------
	216	if (!db_BrowserDB->GetNext())
	217	{
	218	return FALSE;
	219	Temp0.Printf(_("\n-E-> BrowserDB::OnGetNext - ODBC-Error with GetNext \n-E-> "));
daf06bb8	220	Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
645889ad GT	221	wxLogMessage(Temp0);
	222	wxMessageBox(Temp0);
	223	}
	224	else
	225	{
	226	for (i=0;i<Cols;i++)
	227	{
daf06bb8	228	wxStrcpy((cl_BrowserDB+i)->tableName,_T("-E->"));
412394b8	229	i_dbDataType = (cl_BrowserDB+i)->pColFor->i_dbDataType;
645889ad GT	230	if (i_dbDataType == 0) // Filter unsupported dbDataTypes
645889ad GT	231	{
412394b8 GT	232	if (((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_VARCHAR) \|\|
412394b8 GT	233	((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_LONGVARCHAR))
645889ad	234	i_dbDataType = DB_DATA_TYPE_VARCHAR;
412394b8	235	if ((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_C_DATE)
645889ad	236	i_dbDataType = DB_DATA_TYPE_DATE;
412394b8	237	if ((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_C_BIT)
645889ad	238	i_dbDataType = DB_DATA_TYPE_INTEGER;
412394b8	239	if ((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_NUMERIC)
645889ad	240	i_dbDataType = DB_DATA_TYPE_VARCHAR;
412394b8	241	if ((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_REAL)
645889ad GT	242	i_dbDataType = DB_DATA_TYPE_FLOAT;
645889ad GT	243	}
412394b8 GT	244	if ((i_dbDataType == DB_DATA_TYPE_INTEGER) &&
412394b8 GT	245	((cl_BrowserDB+i)->pColFor->i_sqlDataType == SQL_C_DOUBLE))
645889ad GT	246	{ // DBASE Numeric
	247	i_dbDataType = DB_DATA_TYPE_FLOAT;
	248	}
	249	switch(i_dbDataType)
	250	{
	251	case DB_DATA_TYPE_VARCHAR:
daf06bb8	252	wxStrcpy(s_temp,_T(""));
412394b8	253	if (!db_BrowserDB->GetData(i+1,(cl_BrowserDB+i)->pColFor->i_dbDataType,&s_temp,sizeof(s_temp), &cb))
645889ad GT	254	{
645889ad GT	255	Temp0.Printf(_("\n-E-> BrowserDB::OnGetNext - ODBC-Error with GetNext of >%s<.\n-E-> "),(cl_BrowserDB+i)->tableName);
daf06bb8	256	Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
645889ad GT	257	wxLogMessage(Temp0);
645889ad GT	258	}
412394b8	259	Temp0.Printf((cl_BrowserDB+i)->pColFor->s_Field,s_temp);
daf06bb8	260	wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
645889ad GT	261	break;
	262	case DB_DATA_TYPE_INTEGER:
	263	l_temp = 0;
412394b8	264	if (!db_BrowserDB->GetData(i+1,(cl_BrowserDB+i)->pColFor->i_sqlDataType,&l_temp,sizeof(l_temp), &cb))
645889ad GT	265	{
645889ad GT	266	Temp0.Printf(_("\n-E-> BrowserDB::OnGetData - ODBC-Error with GetNext \n-E-> "));
daf06bb8	267	Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
645889ad GT	268	}
	269	else
	270	{
412394b8	271	Temp0.Printf((cl_BrowserDB+i)->pColFor->s_Field,l_temp);
daf06bb8	272	wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
645889ad GT	273	}
	274	break;
	275	case DB_DATA_TYPE_FLOAT:
	276	f_temp = 0;
412394b8	277	if (!db_BrowserDB->GetData(i+1,(cl_BrowserDB+i)->pColFor->i_sqlDataType,&f_temp,sizeof(f_temp), &cb))
645889ad GT	278	{
645889ad GT	279	Temp0.Printf(_("\n-E-> BrowserDB::OnGetData - ODBC-Error with GetNext \n-E-> "));
daf06bb8	280	Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
645889ad GT	281	wxMessageBox(Temp0);
	282	}
	283	else
	284	{
412394b8	285	Temp0.Printf((cl_BrowserDB+i)->pColFor->s_Field,f_temp);
daf06bb8	286	wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
645889ad GT	287	}
	288	break;
	289	case DB_DATA_TYPE_DATE:
	290	t_temp.day = t_temp.month = t_temp.year = t_temp.hour = t_temp.minute = t_temp.second = t_temp.fraction = 0;
412394b8	291	if (!db_BrowserDB->GetData(i+1,(cl_BrowserDB+i)->pColFor->i_sqlDataType,&t_temp,sizeof(t_temp), &cb))
645889ad GT	292	{
645889ad GT	293	Temp0.Printf(_("\n-E-> BrowserDB::OnGetData - ODBC-Error with GetNext \n-E-> "));
daf06bb8	294	Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
645889ad GT	295	}
	296	else
	297	{
	298	// i_Nation = 0 = timestamp , 1=EU, 2=UK, 3=International, 4=US
412394b8 GT	299	if (((cl_BrowserDB+i)->pColFor->i_Nation == 0) \|\| // TS YYYY-MM-DD
412394b8 GT	300	((cl_BrowserDB+i)->pColFor->i_Nation == 3)) // IT YYYY-MM-DD
645889ad	301	{
412394b8	302	Temp0.Printf((cl_BrowserDB+i)->pColFor->s_Field,t_temp.year,t_temp.month,t_temp.day,
645889ad	303	t_temp.hour, t_temp.minute, t_temp.second, t_temp.fraction);
daf06bb8	304	wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
645889ad	305	}
412394b8 GT	306	if (((cl_BrowserDB+i)->pColFor->i_Nation == 1) \|\| // EU DD.MM.YYYY
412394b8 GT	307	((cl_BrowserDB+i)->pColFor->i_Nation == 2)) // UK DD/MM/YYYY
645889ad	308	{
412394b8	309	Temp0.Printf((cl_BrowserDB+i)->pColFor->s_Field,t_temp.day,t_temp.month,t_temp.year,
645889ad	310	t_temp.hour, t_temp.minute, t_temp.second, t_temp.fraction);
daf06bb8	311	wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
645889ad	312	}
412394b8	313	if ((cl_BrowserDB+i)->pColFor->i_Nation == 3) // US MM/DD/YYYY
645889ad	314	{
412394b8	315	Temp0.Printf((cl_BrowserDB+i)->pColFor->s_Field,t_temp.month,t_temp.day,t_temp.year,
645889ad	316	t_temp.hour, t_temp.minute, t_temp.second, t_temp.fraction);
daf06bb8	317	wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
645889ad GT	318	}
	319	}
	320	break;
	321	default:
	322	AnzError++;
	323	if (AnzError <= 100)
	324	{
	325	Temp0 = (cl_BrowserDB+i)->colName;
412394b8	326	wxLogMessage(_("-E-> BrowserDB::OnGetNext - DB_DATA_TYPE_?? (%d) in Col(%s)"),(cl_BrowserDB+i)->pColFor->i_dbDataType,Temp0.c_str());
645889ad GT	327	}
	328	else
	329	return TRUE;
412394b8	330	Temp0.Printf(_("-E-> unknown Format(%d) - sql(%d)"),(cl_BrowserDB+i)->pColFor->i_dbDataType,(cl_BrowserDB+i)->pColFor->i_sqlDataType);
daf06bb8	331	wxStrcpy((cl_BrowserDB+i)->tableName,Temp0.c_str());
645889ad GT	332	break;
	333	}; // switch
	334	} // for
	335	} // else
	336
	337	return TRUE;
b5ffecfc	338	}
645889ad	339
b5ffecfc	340	//----------------------------------------------------------------------------------------
f6bcfd97	341	bool BrowserDB::OnSelect(wxString tb_Name, int Quiet)
b5ffecfc	342	{
645889ad GT	343	wxStopWatch sw;
	344	wxString SQLStmt;
	345	i_Records = 0;
	346	//---------------------------------------------------------------------------------------
daf06bb8 JS	347	SQLStmt.sprintf(_T("SELECT * FROM %s"),db_BrowserDB->SQLTableName(tb_Name.c_str()));
daf06bb8 JS	348	if (!db_BrowserDB->ExecSql((wxChar *)(SQLStmt.GetData())))
645889ad GT	349	{
645889ad GT	350	Temp0.Printf(_("\n-E-> BrowserDB::OnSelect - ODBC-Error with ExecSql of >%s<.\n-E-> "),tb_Name.c_str());
daf06bb8	351	Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
645889ad	352	wxLogMessage(Temp0);
daf06bb8	353	wxMessageBox(_T("-E-> BrowserDB::OnSelect - GetData()"));
645889ad GT	354	return FALSE;
	355	}
	356	//---------------------------------------------------------------------------------------
	357	while (db_BrowserDB->GetNext())
	358	{
	359	i_Records++;
	360	}
	361	//---------------------------------------------------------------------------------------
daf06bb8	362	if (!db_BrowserDB->ExecSql((wxChar *)(SQLStmt.GetData())))
645889ad GT	363	{
645889ad GT	364	Temp0.Printf(_("\n-E-> BrowserDB::OnSelect - ODBC-Error with ExecSql of >%s<.\n-E-> "),tb_Name.c_str());
daf06bb8	365	Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
645889ad GT	366	wxLogMessage(Temp0);
	367	return FALSE;
	368	}
	369	//---------------------------------------------------------------------------------------
	370	// SetColDefs ( 0,"NAME", DB_DATA_TYPE_VARCHAR, Name, SQL_C_CHAR, sizeof(Name), TRUE, TRUE); // Primary index
	371	//---------------------------------------------------------------------------------------
	372	if (!Quiet)
	373	{
	374	wxLogMessage(_("\n-I-> BrowserDB::OnSelect(%s) Records(%d): End - Time needed : %ld ms"),tb_Name.c_str(),i_Records,sw.Time());
	375	}
	376	return TRUE;
b5ffecfc	377	}
645889ad	378
b5ffecfc	379	//----------------------------------------------------------------------------------------
f6bcfd97	380	bool BrowserDB::OnExecSql(wxString SQLStmt, int Quiet)
b5ffecfc	381	{
645889ad	382	//---------------------------------------------------------------------------------------
daf06bb8	383	if (!db_BrowserDB->ExecSql((wxChar *)(SQLStmt.GetData())))
645889ad GT	384	{
645889ad GT	385	Temp0.Printf(_("\n-E-> BrowserDB::OnExecSQL - ODBC-Error with ExecSql of >%s<.\n-E-> "),SQLStmt.c_str());
daf06bb8	386	Temp0 += GetExtendedDBErrorMsg(__TFILE__,__LINE__);
645889ad GT	387	if (!Quiet)
	388	wxLogMessage(Temp0);
	389	else
daf06bb8	390	wxMessageBox(_T("-E-> BrowserDB::OnExecSql - ExecSql()"));
645889ad GT	391	return FALSE;
	392	}
	393	if (!Quiet)
	394	{
	395	// wxLogMessage(_("\n-I-> BrowserDB::OnExecSql(%s) - End - Time needed : %ld ms"),SQLStmt.c_str(),sw.Time());
	396	}
	397	return TRUE;
b5ffecfc	398	}
645889ad	399
b5ffecfc	400	//----------------------------------------------------------------------------------------
f6bcfd97	401	wxDbInf* BrowserDB::OnGetCatalog(int Quiet)
b5ffecfc	402	{
daf06bb8 JS	403	wxChar UName[255];
daf06bb8 JS	404	wxStrcpy(UName,UserName);
645889ad GT	405	ct_BrowserDB = db_BrowserDB->GetCatalog(UName);
645889ad GT	406	return ct_BrowserDB;
b5ffecfc	407	}
645889ad	408
b5ffecfc	409	//----------------------------------------------------------------------------------------
daf06bb8	410	wxDbColInf* BrowserDB::OnGetColumns(wxChar *tableName, UWORD numCols, int Quiet)
b5ffecfc	411	{
daf06bb8	412	wxChar UName[255];
645889ad	413	int i;
daf06bb8	414	wxStrcpy(UName,UserName);
645889ad	415	cl_BrowserDB = db_BrowserDB->GetColumns(tableName,&numCols,UName);
412394b8	416	// cl_BrowserDB->pColFor = new wxDbColFor[numCols];
645889ad GT	417	for (i=0;i<numCols;i++)
645889ad GT	418	{
412394b8 GT	419	// (cl_BrowserDB->pColFor+i)->Format(1,(cl_BrowserDB+i)->dbDataType,(cl_BrowserDB+i)->sqlDataType,
	420	// (cl_BrowserDB+i)->columnSize, (cl_BrowserDB+i)->decimalDigits);
	421	(cl_BrowserDB+i)->pColFor = new wxDbColFor;
	422	(cl_BrowserDB+i)->pColFor->Format(1,
	423	(cl_BrowserDB+i)->dbDataType,
	424	(cl_BrowserDB+i)->sqlDataType,
	425	(cl_BrowserDB+i)->columnSize,
	426	(cl_BrowserDB+i)->decimalDigits);
645889ad GT	427	}
645889ad GT	428	return cl_BrowserDB;
b5ffecfc	429	}
645889ad	430
b5ffecfc	431	//----------------------------------------------------------------------------------------
eacf9d88	432	void BrowserDB::PointerToNULL(int Art)
b5ffecfc	433	{
645889ad GT	434