StoredProcedure.h

#ifndef STOREDPROC_DETAIL_STOREDPROCEDURE_H
#define STOREDPROC_DETAIL_STOREDPROCEDURE_H
 
#pragma once
 
#include <memory>
#include <string>
 
#include <nanodbc/nanodbc.h>
 
namespace storedProc
{
    namespace detail
    {
        class StoredProcedure
        {
        protected:
            StoredProcedure();
            StoredProcedure(std::shared_ptr<nanodbc::connection> conn);

            void prepare(const std::string& query) noexcept(false);

            // This must be called in the destructor of a stored procedure with any output & return values.
            void flush_on_destruct();

            std::weak_ptr<nanodbc::result> execute() noexcept(false);
 
        public:
            void set_connection(const std::shared_ptr<nanodbc::connection>& conn);

            void flush();
 
        protected:
            void skip_rows_in_result_set();
 
            std::shared_ptr<nanodbc::connection> _conn;
            nanodbc::statement _stmt;
            std::shared_ptr<nanodbc::result> _result;
            bool _flushed;
        };
    }
}
 
#endif // STOREDPROC_DETAIL_STOREDPROCEDURE_H