1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
/*
* Copyright (c) 2009, 2014, Oracle and/or its affiliates. All rights reserved.
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License as
* published by the Free Software Foundation; version 2 of the
* License.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA
*/
#ifndef _WB_PLUGIN_BE_H_
#define _WB_PLUGIN_BE_H_
#include "db_mysql_public_interface.h"
#include "grt/grt_manager.h"
#include "base/trackable.h"
class Wb_plugin;
#ifdef _WIN32
#pragma make_public(Wb_plugin)
#endif
class WBPLUGINDBMYSQLBE_PUBLIC_FUNC Wb_plugin : public base::trackable
{
public:
Wb_plugin() : _grtm(NULL) {}
virtual ~Wb_plugin() {}
public:
virtual void grtm(bec::GRTManager *grtm);
protected:
bec::GRTManager *_grtm;
public:
virtual std::string task_desc() = 0;
void exec_task(bool sync= false);
protected:
typedef boost::function<grt::StringRef (grt::GRT *)> Task_proc_cb;
virtual void set_task_proc() = 0;
Task_proc_cb _task_proc_cb;
public:
typedef boost::function<int (int, const std::string&)> Task_msg_cb;
typedef boost::function<int (float, const std::string&)> Task_progress_cb;
typedef boost::function<int ()> Task_finish_cb;
typedef boost::function<int (const std::string&)> Task_fail_cb;
void task_msg_cb(Task_msg_cb cb) { _task_msg_cb= cb; }
void task_progress_cb(Task_progress_cb cb) { _task_progress_cb= cb; }
void task_finish_cb(Task_finish_cb cb) { _task_finish_cb= cb; }
void task_fail_cb(Task_fail_cb cb) { _task_fail_cb= cb; }
void process_task_msg(const grt::Message &msgs);
void process_task_finish(grt::ValueRef res);
void process_task_fail(const std::exception &error);
private:
Task_msg_cb _task_msg_cb;
Task_progress_cb _task_progress_cb;
Task_finish_cb _task_finish_cb;
Task_fail_cb _task_fail_cb;
public:
void set_option(const std::string &name, int val);
void set_option(const std::string &name, const double &val);
void set_option(const std::string &name, const std::string &val);
int get_int_option(const std::string &name);
double get_double_option(const std::string &name);
std::string get_string_option(const std::string &name);
protected:
grt::DictRef _options;
};
#endif /* _WB_PLUGIN_BE_H_ */
|
