← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/plugin_replicator.h

  • Committer: Monty Taylor
  • Date: 2008-12-06 22:41:03 UTC
  • mto: (656.1.7 devel)
  • mto: This revision was merged to the branch mainline in revision 665.
  • Revision ID: monty@inaugust.com-20081206224103-jdouqwt9hb0f01y1
Moved non-working tests into broken suite for easier running of working tests.

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/plugin_replicator.h
2
2
  -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
3
3
  *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
4
4
 
5
 
  *  Definitions required for Configuration Variables plugin
 
5
  *  Definitions required for Configuration Variables plugin 
6
6
 
7
7
  *  Copyright (C) 2008 Mark Atwood
8
8
  *
23
23
#ifndef DRIZZLED_PLUGIN_REPLICATOR_H
24
24
#define DRIZZLED_PLUGIN_REPLICATOR_H
25
25
 
26
 
/**
27
 
 * @file
28
 
 *
29
 
 * Defines the API for Replication
30
 
 */
31
 
 
32
 
/**
33
 
 * Base class for replication implementations.
34
 
 *
35
 
 *    if a method returns bool true, that means it failed.
36
 
 */
37
 
class Replicator
 
26
typedef struct replicator_st
38
27
{
39
 
private:
40
 
  bool enabled;
41
 
protected:
42
 
  virtual bool session_init_hook(Session *) { return false; }
43
 
  virtual bool row_insert_hook(Session *, Table *) { return false; }
44
 
  virtual bool row_update_hook(Session *, Table *,
45
 
                               const unsigned char *,
46
 
                               const unsigned char *) { return false; }
47
 
  virtual bool row_delete_hook(Session *, Table *) { return false; }
48
 
  virtual bool end_transaction_hook(Session *, bool, bool) { return false; }
49
 
  virtual bool statement_hook(Session *, const char *, size_t) { return false; }
50
 
public:
51
 
 
52
 
  Replicator() : enabled(true) {}
53
 
 
54
 
  virtual ~Replicator() {}
55
 
  /**
56
 
   * Initialize session for replication
57
 
   */
58
 
  bool session_init(Session *session)
59
 
  {
60
 
    return session_init_hook(session);
61
 
  }
62
 
 
63
 
  /**
64
 
   * Row insert
65
 
   *
66
 
   * @param current Session
67
 
   * @param Table inserted
68
 
   */
69
 
  bool row_insert(Session *session, Table *table)
70
 
  {
71
 
    return row_insert_hook(session, table);
72
 
  }
73
 
 
74
 
  /**
75
 
   * Row update
76
 
   *
77
 
   * @param current Session
78
 
   * @param Table updated
79
 
   * @param before values
80
 
   * @param after values
81
 
   */
82
 
  bool row_update(Session *session, Table *table,
83
 
                          const unsigned char *before,
84
 
                          const unsigned char *after)
85
 
  {
86
 
    return row_update_hook(session, table, before, after);
87
 
  }
88
 
 
89
 
  /**
90
 
   * Row Delete
91
 
   *
92
 
   * @param current session
93
 
   * @param Table deleted from
94
 
   */
95
 
  bool row_delete(Session *session, Table *table)
96
 
  {
97
 
    return row_delete_hook(session, table);
98
 
  }
99
 
 
100
 
  /**
101
 
   * End Transaction
102
 
   *
103
 
   * @param current Session
104
 
   * @param is autocommit on?
105
 
   * @param did the transaction commit?
106
 
   */
107
 
  bool end_transaction(Session *session, bool autocommit, bool commit)
108
 
  {
109
 
    return end_transaction_hook(session, autocommit, commit);
110
 
  }
111
 
 
112
 
  /**
113
 
   * Raw statement
114
 
   *
115
 
   * @param current Session
116
 
   * @param query string
117
 
   * @param length of query string in bytes
118
 
   */
119
 
  bool statement(Session *session, const char *query, size_t query_length)
120
 
  {
121
 
    return statement_hook(session, query, query_length);
122
 
  }
123
 
};
 
28
  /* todo, define this api */
 
29
  /* this is the API that a replicator plugin must implement.
 
30
     it should implement each of these function pointers.
 
31
     if a function returns bool true, that means it failed.
 
32
     if a function pointer is NULL, that's ok.
 
33
  */
 
34
 
 
35
  bool (*replicator_func1)(Session *session, void *parm1, void *parm2);
 
36
  bool (*replicator_func2)(Session *session, void *parm3, void *parm4);
 
37
} replicator_t;
124
38
 
125
39
#endif /* DRIZZLED_PLUGIN_REPLICATOR_H */