dbapi.h

#ifndef DBALLE_FORTRAN_DBAPI_H
#define DBALLE_FORTRAN_DBAPI_H
 
#include "commonapi.h"
#include <dballe/file.h>
 
namespace dballe {
struct DB;
 
namespace db {
struct CursorStation;
struct Transaction;
} // namespace db
 
namespace fortran {
 
struct InputFile;
struct OutputFile;
 
struct DbAPI : public CommonAPIImplementation
{
protected:
    void shutdown(bool commit);
 
public:
    std::shared_ptr<db::Transaction> tr;
    InputFile* input_file   = nullptr;
    OutputFile* output_file = nullptr;
 
    DbAPI(std::shared_ptr<db::Transaction> tr, const char* anaflag,
          const char* dataflag, const char* attrflag);
    DbAPI(std::shared_ptr<db::Transaction> tr, unsigned perms);
    virtual ~DbAPI();
 
    void seti(const char* param, int value) override;
    void reinit_db(const char* repinfofile = nullptr) override;
    void remove_all() override;
    int query_stations() override;
    int query_data() override;
    void insert_data() override;
    void remove_data() override;
    void commit() override;
    void messages_open_input(const char* filename, const char* mode,
                             Encoding format, bool simplified = true) override;
    void messages_open_output(const char* filename, const char* mode,
                              Encoding format) override;
    bool messages_read_next() override;
    void messages_write_next(const char* template_name = 0) override;
 
    static std::unique_ptr<API> fortran_connect(const DBConnectOptions& options,
                                                const char* anaflag,
                                                const char* dataflag,
                                                const char* attrflag);
 
    friend class Operation;
};
 
} // namespace fortran
} // namespace dballe
 
#endif