InsertQBox.h

Go to the documentation of this file.

#ifndef INSERT_QBOX_H
#define INSERT_QBOX_H

#include "QBox.h"
#include "Table.h"
#include "SQLInsert.h"

BOREALIS_NAMESPACE_BEGIN;

class InsertQBox : public QBox {
        
private:
    ptr<SQLInsert> _sql;
    Table *_table;
    EvalContext _ctxt;
    size_t _row_size;
    char *_row_buf;
        bool _pass_input;
        size_t _input_tuple_size;

protected:
        void setupImpl() throw (AuroraException);
        void initImpl() throw (AuroraException);
        void runImpl(QBoxInvocation&) throw (AuroraException);

public:
    InsertQBox() : _row_buf(0) {}
    ~InsertQBox() { delete[] _row_buf; }
        
    AURORA_DECLARE_QBOX(InsertQBox, "insert");
};

BOREALIS_NAMESPACE_END;

#endif

---