// Data Streamer Object

#ifndef _DATASTREAMER_HPP_
#define _DATASTREAMER_HPP_

#define OTL_ODBC
#define OTL_STL
#define OTL_ANSI_CPP
#define OTL_STREAM_READ_ITERATOR_ON
#include <otlv4.h>

class DataStreamer {

    protected:
        otl_connect db;
        otl_stream qry;
        unsigned char* table;
        unsigned char* pk_field;
        unsigned char* data_field;

    public:

        DataStreamer();
        virtual ~DataStreamer();

        virtual void Open(unsigned char* dsn, unsigned char* uid, unsigned char* pwd);

        // Set up the field to receive the data
        // t - table name
        // p - primary key field
        // d - data field to be updated
        virtual void SetField(unsigned char* t, unsigned char* p, unsigned char* d);

        // Set the actual value to be updated
        // id - the integer id of the record in question
        // val - the string value to be updated.
        virtual void SetValue(int id, const char* val);

};

#endif