/*
 * RecordsetModifyBatchApplet.cpp 
 * Copyright (c) 2009 Antillia.com TOSHIYUKI ARAI. ALL RIGHTS RESERVED. 
 */


// SOL9
// 2009/05/28
// Assumes that environment of SQL Server 2008 and SQLClient1.0 
// Please create a database 'Sample' for this example
// and following table 'SolUser'.
/*
Create Table SolUser(
    ID int not NULL primary key,
    Name  varchar(255) not NULL,
    Sex   varchar(10),
    Age   int,
    Birthday  Date,
    Nationality varchar(255),
    Email varchar(255),
    Telephone varchar(128),
    Address varchar(255),
    Company varchar(255));
*/

#include <sol/sql/ADOApplet.h>
#include <sol/PerformanceCounter.h>

namespace SOL {

class RecordsetModifyBatchApplet: public ADOApplet {

public:
    /**
     * Constructor
     */
    RecordsetModifyBatchApplet(int argc, const TCHAR** argv)
        :ADOApplet(argc, argv)
    {
    }

public:
    ~RecordsetModifyBatchApplet()
    {
    }

public:
    /**
     * RecordsetModifyBatchApplet main procedure.
     * Demonstration for ADORecordset::updateBatch() and ADORecordset::requery().
     */
    virtual void run()
    {
        printf("1 Start\n");
        ADOConnection connection = getConnection();

        //SQL statement: select 
        _bstr_t query("SELECT ID, Name, Age, Company FROM SolUser WHERE Age>25 AND Age<28 ORDER by Age");

        ADORecordset recordset;
        recordset.createInstance();

        recordset.open(query, connection.getConnectionPtr(), 
            ADODB::adOpenKeyset,
            ADODB::adLockOptimistic);

        printf("2 OK, recordset.open(\"%S\")\n", (const wchar_t*)query);
        printf("3 pageSize=%ld\n", recordset.getPageSize());
        printf("4 Sort=%S\n", (const wchar_t*)recordset.getSort());

        ADOFields colFields;
        recordset.getFields(colFields);
        printf("5 recordset.getFields()\n");
        colFields.dump();
        long count = colFields.getCount();
        printf("6 colFields.getCount():%ld\n", count);

        _bstr_t company = "company";
        long companyIndex = colFields.getNameIndex(company);
        printf("7 OK colFields.getNameIndex(\"%S\"): %ld\n", (const wchar_t*)company, companyIndex);

        PerformanceCounter counter;

        counter.start();
        printf("8 Start: recordset walk\n");

        while(!recordset.getadoEOF()){
            printf("\n9 Matched record:\n");
            for (long i = 0L; i<count; i++) {
                ADOField field;
                if (colFields.getItem(i, field)) {
                    _bstr_t name = field.getName();

                    //Call recordset.getCollect(name);
                    _variant_t variant = recordset.getCollect(name);
                    
                    _bstr_t value = "";
                    COMTypeConverter converter;
                    converter.toString(variant, value);
                    printf("10 %S=%S\n", (const wchar_t*)name, (const wchar_t*)value);
                }
            }

            //Change "company" field to the following value.
            _bstr_t nvalue = L"Solar System Laboratory";
            recordset.putCollect(_variant_t(companyIndex), nvalue);
            printf("11 OK, recordset.putCollect(%ld, %S)\n", companyIndex, (const wchar_t*)nvalue);
            
            recordset.moveNext();
        }

        //Call UpdateBatch all changed recordset
        recordset.updateBatch(ADODB::adAffectAll);
        printf("12 OK, recordset.updateBatch(adAffectAll)\n");

        counter.stop();
        printf("13 End: rencordset.walk, Seconds %d\n", counter.getMilliseconds());

        recordset.requery(ADODB::adOptionUnspecified);
        printf("14 OK, recordset.requery()\n");

        while(!recordset.getadoEOF()){
            printf("\n15 Matched record:\n");
            for (long i = 0L; i<count; i++) {
                ADOField field;
                if (colFields.getItem(i, field)) {
                    _bstr_t name = field.getName();
                    _variant_t variant = recordset.getCollect(name);
                    
                    _bstr_t value = "";
                    COMTypeConverter converter;
                    converter.toString(variant, value);
                    printf("16 %S=%S\n", (const wchar_t*)name, (const wchar_t*)value);
                }
            }
            recordset.moveNext();
        }        
    }
};

}

// Console application starts here.
void _tmain(int argc, const TCHAR** argv)
{
    try {
        RecordsetModifyBatchApplet applet(argc, argv);
        applet.start();

    } catch(Exception& ex){
        ex.dump();
    } catch(...){
        printf("Exception:Unknown\n");
    }
}