Sync

Signed-off-by: Rohit Nayak <[email protected]>

Author: rohit-nayak-ps

examples/adopt.sh

@@ -9,7 +9,7 @@ echo ">>>>>> Starting vtctld"
 scripts/vtctld-up.sh
 echo ">>>>>> Starting vtgate"
 scripts/vtgate-up.sh
-sleep 2
+sleep 10
 echo ">>>>>> Step 1: Starting unmanaged tablet"
 scripts/unmanaged.sh
 sleep 5
@@ -30,6 +30,7 @@ echo ">>>>>> Step 3. Calling MoveTables"
 vtctlclient MoveTables -tablet_types=MASTER -workflow=commerce2customer commerce customer customer,corder #'{"customer":{}, "corder":{}}'
 echo ">>>>> Step 4. Waiting for Vreplication to copy the data ..."
 sleep 5
+
 echo ">>>>> Step 5. Run VDiff "
 vtctlclient VDiff customer.commerce2customer
 echo ">>>>>> Step 6. Calling SwitchReads"

examples/env.sh

@@ -25,10 +25,10 @@ mkdir -p "${VTDATAROOT}/etcd"
 mkdir -p "${VTDATAROOT}/tmp"
 
 alias mysql="command mysql -h 127.0.0.1 -P 15306"
-alias vtctlclient="command vtctlclient -server localhost:15999 -log_dir ${VTDATAROOT}/tmp -alsologtostderr"
+alias vtctlclient="command vtctlclient -server localhost:15999 -log_dir ${VTDATAROOT}/tmp"
 
 # Make sure aliases are expanded in non-interactive shell
 shopt -s expand_aliases
 
 export MYSQL="command mysql -h 127.0.0.1 -P 15306"
-export LVTCTL="command vtctlclient -server localhost:15999 -log_dir ${VTDATAROOT}/tmp -alsologtostderr"
+export LVTCTL="command vtctlclient -server localhost:15999 -log_dir ${VTDATAROOT}/tmp"

examples/kubecon.sh

@@ -0,0 +1,73 @@
+#start afresh processes and db
+./cleanup.sh
+mysql -h 127.0.0.1 -P 19327 -u msandbox --password=msandbox commerce < sql/create_commerce_schema.sql
+mysql -h 127.0.0.1 -P 19327 -u msandbox --password=msandbox commerce < sql/insert_commerce_data.sql
+
+
+#asciinema demo starts
+source ./env.sh
+mysql -h 127.0.0.1 -P 19327 -u msandbox --password=msandbox commerce  -e "select * from corder;select * from customer;select * from product;"
+
+# start topology, vtctld and vtgate
+scripts/etcd-up.sh
+scripts/vtctld-up.sh
+scripts/vtgate-up.sh
+
+#Start unmanaged tablet in keyspace commerce
+scripts/unmanaged.sh
+
+#Start vitess cluster in keyspace customer
+for i in 200 201 202;  do
+	CELL=zone1 TABLET_UID=$i ./scripts/mysqlctl-up.sh
+	CELL=zone1 KEYSPACE=customer TABLET_UID=$i ./scripts/vttablet-up.sh
+done
+
+vtctlclient InitShardMaster -force customer/0 zone1-200
+
+# start vreplication workflow
+vtctlclient MoveTables -tablet_types=MASTER -workflow=commerce2customer commerce customer customer,corder
+
+# use vdiff to confirm replication has taken plae
+vtctlclient VDiff customer.commerce2customer
+
+# insert row and show that we are syncing
+vtctlclient VExec customer.commerce2customer "select id,workflow,state,pos from _vt.vreplication"
+
+mysql -h 127.0.0.1 -P 19327 -u msandbox --password=msandbox commerce  -e "insert into customer(email) values ('[email protected]');"
+vtctlclient VExec customer.commerce2customer "select id,workflow,state,pos from _vt.vreplication"
+
+
+echo ">>>>>> Step 6. Calling SwitchReads"
+vtctlclient SwitchReads -tablet_type=rdonly customer.commerce2customer
+vtctlclient SwitchReads -tablet_type=replica customer.commerce2customer
+sleep 5
+echo ">>>>>> Step 7. Calling SwitchWrites"
+vtctlclient SwitchWrites customer.commerce2customer
+
+
+
+vtctlclient VExec commerce.commerce2customer_reverse "select id,workflow,state,pos from _vt.vreplication"
+
+echo ">>>>> Step 8. Run VDiff after inserting data into the customer keyspace"
+sleep 15
+mysql -h 127.0.0.1 -P 15306 -u msandbox --password=msandbox customer < sql/insert_commerce_data_after_switch.sql
+
+
+echo "Steps for rolling back"
+vtctlclient VExec commerce.commerce2customer_reverse "select id,workflow,state,pos from _vt.vreplication"
+
+echo ">>>>>> Step 9. Rollback SwitchReads"
+vtctlclient SwitchReads -tablet_type=rdonly commerce.commerce2customer_reverse
+vtctlclient SwitchReads -tablet_type=replica commerce.commerce2customer_reverse
+
+echo ">>>>>> Step 10. Rollback SwitchWrites"
+vtctlclient SwitchWrites commerce.commerce2customer_reverse
+
+echo ">>>>>> Rolled back to original setup. VReplication is still running on Vitess cluster, so you can still move forward ..."
+
+
+mysql -h 127.0.0.1 -P 19327 -u msandbox --password=msandbox commerce < sql/insert_commerce_data_after_rollback.sql
+
+vtctlclient VDiff customer.commerce2customer
+
+echo ">>>>>>>>> ALL DONE"

examples/managed_initial_data.sh

@@ -0,0 +1,2 @@
+mysql -h 127.0.0.1 -P 19327 -u msandbox --password=msandbox commerce < sql/create_commerce_schema.sql
+mysql -h 127.0.0.1 -P 19327 -u msandbox --password=msandbox commerce < sql/insert_commerce_data.sql

examples/scripts/unmanaged.sh

@@ -5,7 +5,6 @@ DB_PASS=msandbox
 DB_PORT=19327
 vttablet \
  $TOPOLOGY_FLAGS \
- -logtostderr \
  -log_queries_to_file $VTDATAROOT/tmp/vttablet_0000000100_querylog.txt \
  -tablet-path "zone1-0000000100" \
  -init_keyspace commerce \
@@ -20,25 +19,26 @@ vttablet \
  -db_port $DB_PORT \
  -db_app_user $DB_USER \
  -db_app_password $DB_PASS \
- -db_allprivs_user $DB_USER \
--db_allprivs_password $DB_PASS \
--db_appdebug_user $DB_USER \
--db_appdebug_password $DB_PASS \
--db_dba_user $DB_USER \
--db_dba_password $DB_PASS \
--db_filtered_user $DB_USER \
--db_filtered_password $DB_PASS \
--db_repl_user $DB_USER \
--db_repl_password $DB_PASS \
- -vtctld_addr http://$hostname:$vtctld_web_port/ \
  -init_db_name_override commerce \
  -init_populate_metadata \
+ -db_allprivs_user $DB_USER \
+ -db_allprivs_password $DB_PASS \
+ -db_appdebug_user $DB_USER \
+ -db_appdebug_password $DB_PASS \
+ -db_dba_user $DB_USER \
+ -db_dba_password $DB_PASS \
+ -db_filtered_user $DB_USER \
+ -db_filtered_password $DB_PASS \
+ -db_repl_user $DB_USER \
+ -db_repl_password $DB_PASS \
+ -vtctld_addr http://$hostname:$vtctld_web_port/ \
  > $VTDATAROOT/vt_0000000100/vttablet.out 2>&1 &
 
 sleep 10
 
 vtctlclient InitShardMaster -force commerce/0 zone1-100
 
+return
 # create the schema
 vtctlclient ApplySchema -sql-file sql/create_commerce_schema.sql commerce