release/src/router/mysql/mysql-test/suite/rpl_ndb/t/rpl_ndb_load.test

   1 #
   2 # Currently this test only runs in the source tree with the
   3 # ndb/test programs compiled.
   4 # invoke with:  ./mysql-test-run --ndb-extra-test --do-test=rpl_ndb_load
   5 #
   6
   7 --source include/have_ndb.inc
   8 --source include/have_ndb_extra.inc
   9 --source include/have_binlog_format_row.inc
  10 --source include/ndb_master-slave.inc
  11
  12 --disable_warnings
  13 # reset master
  14 connection master;
  15 DROP DATABASE IF EXISTS TEST_DB;
  16 CREATE DATABASE TEST_DB;
  17 --enable_warnings
  18
  19 #
  20 # These tables should correspond to the table definitions in
  21 # storage/ndb/test/ndbapi/bench/
  22 #
  23 connection master;
  24 USE TEST_DB;
  25 CREATE TABLE SUBSCRIBER
  26                 ( NUMBER       CHAR(12) BINARY NOT NULL,
  27                   NAME         CHAR(32) BINARY NOT NULL,
  28                   GROUP_ID     INT UNSIGNED NOT NULL,
  29                   LOCATION     INT UNSIGNED NOT NULL,
  30                   SESSIONS     INT UNSIGNED NOT NULL,
  31                   CHANGED_BY   CHAR(32) BINARY NOT NULL,
  32                   CHANGED_TIME CHAR(32) BINARY NOT NULL,
  33                   PRIMARY KEY USING HASH (NUMBER))
  34    ENGINE = NDB;
  35
  36 CREATE TABLE GROUP_T
  37                 ( GROUP_ID     INT UNSIGNED NOT NULL,
  38                   GROUP_NAME   CHAR(32) BINARY NOT NULL,
  39                   ALLOW_READ   CHAR(1)  BINARY NOT NULL,
  40                   ALLOW_INSERT INT UNSIGNED NOT NULL,
  41                   ALLOW_DELETE INT UNSIGNED NOT NULL,
  42                   PRIMARY KEY USING HASH (GROUP_ID))
  43    ENGINE = NDB;
  44
  45 CREATE TABLE SESSION
  46                 ( NUMBER    CHAR(12)   BINARY NOT NULL,
  47                   SERVER_ID INT UNSIGNED NOT NULL,
  48                   DATA      VARBINARY(1998) NOT NULL,
  49                   PRIMARY KEY USING HASH (NUMBER,SERVER_ID))
  50    ENGINE = NDB;
  51
  52 CREATE TABLE SERVER
  53                 ( SUFFIX       CHAR(2)  BINARY NOT NULL,
  54                   SERVER_ID    INT UNSIGNED NOT NULL,
  55                   NAME         CHAR(32) BINARY NOT NULL,
  56                   NO_OF_READ   INT UNSIGNED NOT NULL,
  57                   NO_OF_INSERT INT UNSIGNED NOT NULL,
  58                   NO_OF_DELETE INT UNSIGNED NOT NULL,
  59                   PRIMARY KEY USING HASH (SUFFIX, SERVER_ID))
  60    ENGINE = NDB;
  61
  62 #
  63 # start "load" application
  64 #
  65 --exec NDB_CONNECTSTRING=$NDB_CONNECTSTRING ../storage/ndb/test/ndbapi/DbCreate >> $NDB_TOOLS_OUTPUT
  66 --exec NDB_CONNECTSTRING=$NDB_CONNECTSTRING ../storage/ndb/test/ndbapi/DbAsyncGenerator  >> $NDB_TOOLS_OUTPUT
  67 --source include/rpl_end.inc