mysql test trans #mysql

mysql_test_trans.sql

--create database for testing rollback


create database if not exists dmstest;

use dmstest; 

create table people(
    id int auto_increment
    , first_name varchar(50)
    , last_name varchar(50)
    , email varchar(50)
    , gender varchar(50)
    , ip_address varchar(50)
);





--change file
set autocommit=0;
BEGIN;
    CREATE TABLE if not exists tmp.people_CHANGE_2345 (start_id int, end_id int);
    truncate table tmp.people_CHANGE_2345;

    INSERT INTO people (first_name, last_name, email, gender, ip_address)
    VALUES ('Albert', 'Fields1', '[email protected]', 'Male', '55.100.238.49')
          ,('Albert', 'Fields1', '[email protected]', 'Male', '55.100.238.49');

    INSERT INTO tmp.people_CHANGE_2345
    SELECT LAST_INSERT_ID(), LAST_INSERT_ID() + ROW_COUNT() - 1;

    INSERT INTO people (first_name, last_name, email, gender, ip_address)
    VALUES ('Albert', 'Fields2', '[email protected]', 'Male', '55.100.238.49')
          ,('Albert', 'Fields2', '[email protected]', 'Male', '55.100.238.49')
    ;

    INSERT INTO tmp.people_CHANGE_2345
    SELECT LAST_INSERT_ID(), LAST_INSERT_ID() + ROW_COUNT() - 1;
commit;




--rollback file
set autocommit = 0;
begin;
    DELETE FROM people
    WHERE ID >= (SELECT start_id FROM tmp.people_CHANGE_2345)
    and id <= (SELECT end_id FROM tmp.people_CHANGE_2345) ;

    DROP TABLE tmp.people_CHANGE_2345;
commit;