add related script and add debug/create_and_drop

debug/create_and_drop.cc

+#include "main/big_proxy.hh"
+#include <vector>
+using std::string;
+
+std::vector<string> create{
+"create database tpcc1000",
+"use tpcc1000",
+//"drop table if exists history;",
+//"drop table if exists new_orders;",
+//"drop table if exists orders;",
+//"drop table if exists order_line;",
+//"drop table if exists item;",
+//"drop table if exists stock;",
+"create table warehouse (w_id smallint unsigned, w_name varchar(10), w_street_1 varchar(20), w_street_2 varchar(20), w_city varchar(20), w_state char(2), w_zip char(9), w_tax integer unsigned, w_ytd integer unsigned) Engine=InnoDB;",
+"create table district (d_id tinyint unsigned, d_w_id smallint unsigned, d_name varchar(10), d_street_1 varchar(20), d_street_2 varchar(20), d_city varchar(20), d_state char(2), d_zip char(9), d_tax integer unsigned, d_ytd integer unsigned, d_next_o_id int unsigned) Engine=InnoDB;",
+"create table customer (c_id int unsigned, c_d_id tinyint unsigned,c_w_id smallint unsigned, c_first varchar(16), c_middle char(2), c_last varchar(16), c_street_1 varchar(20), c_street_2 varchar(20), c_city varchar(20), c_state char(2), c_zip char(9), c_phone char(16), c_since varchar(20), c_credit char(2), c_credit_lim bigint unsigned, c_discount bigint unsigned, c_balance bigint unsigned, c_ytd_payment bigint unsigned, c_payment_cnt smallint,c_delivery_cnt smallint, c_data VARCHAR(1000)) Engine=InnoDB;",
+"create table history (h_c_id int, h_c_d_id tinyint, h_c_w_id smallint,h_d_id tinyint,h_w_id smallint,h_date varchar(20),h_amount integer unsigned, h_data varchar(24) ) Engine=InnoDB;",
+"create table new_orders (no_o_id int not null,no_d_id tinyint not null,no_w_id smallint not null) Engine=InnoDB;",
+"create table orders (o_id int not null, o_d_id tinyint not null, o_w_id smallint not null,o_c_id int,o_entry_d varchar(20),o_carrier_id tinyint,o_ol_cnt tinyint, o_all_local tinyint) Engine=InnoDB ;",
+"create table order_line ( ol_o_id int not null, ol_d_id tinyint not null,ol_w_id smallint not null,ol_number tinyint not null,ol_i_id int, ol_supply_w_id smallint,ol_delivery_d varchar(20), ol_quantity tinyint, ol_amount integer unsigned, ol_dist_info char(24)) Engine=InnoDB ;",
+"create table item (i_id int not null, i_im_id int, i_name varchar(24), i_price integer unsigned, i_data varchar(50)) Engine=InnoDB;",
+"create table stock (s_i_id int not null, s_w_id smallint not null, s_quantity smallint, s_dist_01 char(24), s_dist_02 char(24),s_dist_03 char(24),s_dist_04 char(24), s_dist_05 char(24), s_dist_06 char(24), s_dist_07 char(24), s_dist_08 char(24), s_dist_09 char(24), s_dist_10 char(24), s_ytd integer unsigned,s_order_cnt smallint, s_remote_cnt smallint,s_data varchar(50)) Engine=InnoDB;",
+"SHOW TABLES;"
+};
+
+
+std::vector<string> drop{
+"drop database tpcc1000;"
+};
+
+
+int
+main(int argc,char ** argv) {
+    if(argc!=2){
+        std::cout<<"expect 1 argument"<<std::endl;
+        return 0;
+    }
+    string option(argv[1]);
+    big_proxy b;
+    if(option == string("create")){
+        for(auto item:create){
+            b.go(item);
+        }
+    }else if(option == string("drop")){
+        for(auto item:drop){
+            b.go(item);
+        }
+    }else{
+        std::cout<<"unknow option"<<std::endl;
+    }
+    return 0;
+}
+

debug/test_proxy.cc

-#include "main/big_proxy.hh"
-#include <vector>
-using std::string;
-using std::vector;
-int
-main(int argc,char ** argv) {
-    big_proxy b;
-    vector<string>queries={
-        "show databases;",
-        "create database tdb;",
-        "use tdb;",
-        "create table student(id integer,name varchar(20));",
-        "insert into student values(1,'zhang');",
-        "select * from student;"
-    };
-    std::string query;
-    for(auto query:queries)
-        b.go(query);
-    return 0;
-}
-

in.sql

-INSERT INTO `student` VALUES (1,"shao"),(2,"shao"),(3,"shao"),(4,"shao");
-INSERT INTO `student` VALUES (1,"shao"),(2,"shao"),(3,"shao"),(4,"shao");
-INSERT INTO `student` VALUES (1,"shao"),(2,"shao"),(3,"shao"),(4,"shao");
-INSERT INTO `student` VALUES (1,"shao"),(2,"shao"),(3,"shao"),(4,"shao");
-INSERT INTO `student` VALUES (1,"shao"),(2,"shao"),(3,"shao"),(4,"shao");
-INSERT INTO `student` VALUES (1,"shao"),(2,"shao"),(3,"shao"),(4,"shao");
-INSERT INTO `student` VALUES (1,"shao"),(2,"shao"),(3,"shao"),(4,"shao");
-INSERT INTO `student` VALUES (1,"shao"),(2,"shao"),(3,"shao"),(4,"shao");
-INSERT INTO `student` VALUES (1,"shao"),(2,"shao"),(3,"shao"),(4,"shao");
-INSERT INTO `student` VALUES (1,"shao"),(2,"shao"),(3,"shao"),(4,"shao");

main/cdb_test.cc

@@ -507,7 +507,7 @@ main(int argc,char ** argv) {
         }
         countWrapper++;
         batchTogether(client,curQuery,_thread_id);
-        //std::cout<<GREEN_BEGIN<<"\nplease input a new query:#######"<<COLOR_END<<std::endl;
+
         std::getline(std::cin,curQuery);
         if(countWrapper==3){
             cout<<"bingo"<<endl;

packages/operation/initcdb.sh

+cd ../..
+./mtl/create_and_drop drop
+./mtl/create_and_drop create

packages/operation/insert.sh

 dir="~/Insert/"
 cur_dir=`pwd`
 cdb_test_dir="../../"
-target_db="tdb2"
+target_db="tpcc1000"
 
 cd ${cdb_test_dir}
 
@@ -11,11 +11,10 @@ fi
 
 files=`find  ${dir} -type f`
 arrayfiles=($files)
-
 for data in ${arrayfiles[@]}
 do
     ss="./obj/main/cdb_test ${target_db} < $data"
-##    eval $ss
-    echo $ss
+    eval $ss
+#    echo $ss
 done
 

packages/operation/limit_pipe.sh

 #backup data with limited pipecount
 current_dir=`pwd`
 
-db=tdb2
+db=tpcc1000
 pipe=100
+
 tables=`mysql -h127.0.0.1 -P3306 $db -e "show tables" | awk '{print $1}'`
 table_array=($tables)
 len=${#table_array[@]}
@@ -12,7 +13,7 @@ mkdir $back_dir
 cd ../tls/mysql_wrapper/
 for((i=1;i<$len;i++))
 do
-    cmd="./main 100 $db ${table_array[$i]}"
+    cmd="./main $pipe $db ${table_array[$i]}"
     eval $cmd > $current_dir/$back_dir/${table_array[$i]}.sql
 done
 

packages/operation/load_data.sh

-mysql -uroot -pletmein -h127.0.0.1 -P3306 -e "set @@GLOBAL.sql_mode = ''"
+mysql -P3306 -e "set @@GLOBAL.sql_mode = ''"
 cd ../tls/tpcc-mysql/;./my_load.sh 1

packages/operation/shell/insert.sh

-files=`ls| grep '\.sql$'`
-arrayfiles=($files)
-#IFS=' ' read -r -a arrayfiles <<< "$files"
-
-
-for data in ${arrayfiles[@]}
-do
-    ss="mysql -uroot -pletmein -h127.0.0.1 tpcc1000 < $data"
-    eval $ss
-done
-

packages/tls/tpcc-mysql/my_load.sh

 # load data and dump all.sql
-mysql -uroot -pletmein -h127.0.0.1 -e "drop database if exists tpcc1000"
-mysql -uroot -pletmein -h127.0.0.1 -e "create database tpcc1000"
-mysql -uroot -pletmein -h127.0.0.1 tpcc1000 < create_table.sql
+mysql -h127.0.0.1 -e "drop database if exists tpcc1000"
+mysql -h127.0.0.1 -e "create database tpcc1000"
+mysql -h127.0.0.1 tpcc1000 < create_table.sql
 
 ./tpcc_load -h127.0.0.1 -uroot -pletmein -d tpcc1000 -w $1
 # mysqldump --skip-extended-insert -uroot -pletmein -h127.0.0.1 --no-create-info --hex-blob --compact tpcc1000 > all$1.sql

warehouse.sql

+INSERT INTO `warehouse` VALUES (1,'iA8sBdW2','DXL49qSQhhKeM','YIkzvaMdIWm','hPfhzqCKuJ9','kq','456278383',0,300000);