2
2
* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
4
4
* Copyright (C) 2008-2009 Sun Microsystems
5
* Copyright (c) 2009-2010 Jay Pipes <jaypipes@gmail.com>
8
* Jay Pipes <joinfu@sun.com>
9
* Jay Pipes <jaypipes@gmail.com>
10
11
* This program is free software; you can redistribute it and/or modify
11
12
* it under the terms of the GNU General Public License as published by
324
324
void deleteRecord(Session *in_session, Table *in_table);
326
* Creates a TruncateTable Statement GPB message and add it
326
* Creates a CreateSchema Statement GPB message and adds it
327
* to the Session's active Transaction GPB message for pushing
328
* out to the replicator streams.
330
* @param[in] Pointer to the Session which issued the statement
331
* @param[in] message::Schema message describing new schema
333
void createSchema(Session *in_session, const message::Schema &schema);
335
* Creates a DropSchema Statement GPB message and adds it
336
* to the Session's active Transaction GPB message for pushing
337
* out to the replicator streams.
339
* @param[in] Pointer to the Session which issued the statement
340
* @param[in] message::Schema message describing new schema
342
void dropSchema(Session *in_session, const std::string &schema_name);
344
* Creates a CreateTable Statement GPB message and adds it
345
* to the Session's active Transaction GPB message for pushing
346
* out to the replicator streams.
348
* @param[in] Pointer to the Session which issued the statement
349
* @param[in] message::Table message describing new schema
351
void createTable(Session *in_session, const message::Table &table);
353
* Creates a DropTable Statement GPB message and adds it
354
* to the Session's active Transaction GPB message for pushing
355
* out to the replicator streams.
357
* @param[in] Pointer to the Session which issued the statement
358
* @param[in] The schema of the table being dropped
359
* @param[in] The table name of the table being dropped
360
* @param[in] Did the user specify an IF EXISTS clause?
362
void dropTable(Session *in_session,
363
const std::string &schema_name,
364
const std::string &table_name,
367
* Creates a TruncateTable Statement GPB message and adds it
327
368
* to the Session's active Transaction GPB message for pushing
328
369
* out to the replicator streams.
343
384
* @param Pointer to the Session which issued the statement
344
385
* @param Query string
345
* @param Length of the query string
347
void rawStatement(Session *in_session, const char *in_query, size_t in_query_len);
387
void rawStatement(Session *in_session, const std::string &query);
349
389
* Returns the timestamp of the last Transaction which was sent to