sync

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

Author: rohit-nayak-ps

examples/load.sh

@@ -33,10 +33,10 @@ movetables(){
   sleep 10
 
   $LVTCTL InitShardMaster -force load2/0 zone1-200
-
+exit
   sleep 2
   echo ">>>>>> Step 3. Calling MoveTables"
-  TABLE=c2
+  TABLE=Email
   WORKFLOW=mt
   SOURCE_KS=load1
   TARGET_KS=load2

examples/scripts/populate.go

@@ -6,32 +6,62 @@ import (
     "database/sql"
     _ "github.com/go-sql-driver/mysql"
     "github.com/paulbellamy/ratecounter"
+    "github.com/brianvoe/gofakeit"
+    "strings"
 )
 
 func main() {
     // Open up our database connection.
     // I've set up a database on my local machine using phpmyadmin.
     // The database is called testDb
 
-
+    gofakeit.Seed(0)
     // perform a db.Query insert
     counter := ratecounter.NewRateCounter(1 * time.Second)
     done := false
     var i int64
-    i = 0
-    		db, err := sql.Open("mysql", "msandbox:msandbox@tcp(127.0.0.1:19327)/test")
+
+    db, err := sql.Open("mysql", "msandbox:msandbox@tcp(127.0.0.1:19327)/prod-charlotte-1")
 		fmt.Println("connection opened")
 		if err != nil {
 			panic(err.Error())
 		}
 		defer db.Close()
-    		now := time.Now().UnixNano()
+    now := time.Now().UnixNano()
+    _ = now
+    rows, err := db.Query("select max(id) from Email")
+    if err != nil {
+      panic(err.Error())
+    }
+    if rows != nil {
+      rows.Close()
+    }
+    var maxId int
+    rows.Scan(&maxId)
+    fmt.Printf("maxid is %d\n", maxId)
+    i = int64(maxId)
 		db.Query("BEGIN")
+
+    limit := func(s string, i int) string {
+      s = strings.ReplaceAll(s, "'", "")
+      if len(s) <= i {
+        return s
+      }
+      return s[:i]
+    }
     for !done {
-	    	
+
 		i++
 	    	// if there is an error opening the connection, handle it
-		rows, err := db.Query(fmt.Sprintf("INSERT INTO c1 VALUES ( %d, 'TEST' )", now+i))
+    //query := fmt.Sprintf("INSERT INTO c1 VALUES ( %d, 'TEST' )", now+i)
+    // query := fmt.Sprintf("insert into rule values('%d', now(), now(), '%s', '%s', '%s');",
+    //         i, gofakeit.Name(), gofakeit.Name(), gofakeit.Name())
+    query := "insert into Email (id, created, ari, email_thread_id, from_address, body) "
+    query += fmt.Sprintf("values (%d, '%s', '%s', %s, '%s', '%s')",
+      i, time.Now().UTC().Format("2006-01-02 15:04:05"), limit(gofakeit.Name(), 15), gofakeit.CreditCardNumber(nil),
+      strings.ReplaceAll(gofakeit.Company(),"'",""), strings.ReplaceAll(gofakeit.HackerPhrase(),"'",""))
+    rows, err := db.Query(query)
+
 		if err != nil {
 			panic(err.Error())
 		}

examples/scripts/unmanaged_load.sh

@@ -32,7 +32,7 @@ vttablet \
 -db_repl_password $DB_PASS \
 -track_schema_versions=true \
  -vtctld_addr http://$hostname:$vtctld_web_port/ \
- -init_db_name_override test \
+ -init_db_name_override prod-charlotte-1 \
  -init_populate_metadata \
  > $VTDATAROOT/vt_0000000100/vttablet.out 2>&1 &