DbStream.h

Go to the documentation of this file.

#ifndef __SRADATA_DBSTREAM_H
#define __SRADATA_DBSTREAM_H

#include "stdafx.h"

#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include <iostream>
#include <map>
#include <memory>

#include <cppconn/driver.h>
#include <cppconn/exception.h>
#include <cppconn/resultset.h>
#include <cppconn/statement.h>
#include <cppconn/prepared_statement.h>

#include "ManagedDictionary.h"
#include "DbConnectionFactory.h"

//http://dev.mysql.com/doc/refman/5.1/en/connector-net-tutorials-stored-routines-statements.html

namespace SraData
{
    class DbStream
    {
    protected:
        //instance fields
        sql::Connection* _connection;
        std::auto_ptr<sql::Statement> _stmt;
        std::auto_ptr<sql::ResultSet> _result;
        int _id;
        bool _firstRowFlag;

        //static fields
        static ManagedDictionary<int, DbStream> _Streams;
        static int _SerialNumber;

        //protected static methods

        static int GetStreamId();

        //protected instance methods

        bool checkHasMoreRows();

        bool execute(const std::string& query);
    
    public:
        static const int InitStreamId = 0;

        static DbStream* StartStream(const std::string& query);

        static DbStream* RetrieveStream(int* id);

        static bool CheckHasMoreRows(DbStream* stream, int* newId);

        DbStream();

        ~DbStream();

        int getInt(int index);

        bool getBool(int index);
    };
}

#endif