fix(mysql): fix parsing datetime types

data/dataset.go

@@ -143,7 +143,7 @@ func (d *Set) GetStringValues() []string {
 		case KindBool:
 			values[i] = fmt.Sprintf("%t", data.GetValue().GetValue())
 		case KindDateTime:
-			values[i] = fmt.Sprintf("%s", data.GetValue().GetValue().(time.Time).Format("2006-01-02 15:04:05"))
+			values[i] = fmt.Sprintf("%s", data.GetValue().GetValue().(time.Time).Format("2006-01-02 15:04:05.999999999"))
 		default:
 			values[i] = fmt.Sprintf("%s", data.GetValue().GetValue())
 		}

driver/mysql/types.go

@@ -595,11 +595,11 @@ func (t *DateTimeType) Parse(v any) error {
 		t.value = v.(time.Time)
 		return nil
 	case []byte:
-		v, err := time.Parse("2006-01-02 15:04:05", string(v.([]byte)))
+		tm, err := time.Parse("2006-01-02 15:04:05.999999999", string(v.([]byte)))
 		if err != nil {
 			return err
 		}
-		t.value = v
+		t.value = tm
 		return nil
 	default:
 		return fmt.Errorf("%v: expected time.Time, got %T", data.ErrInvalidValue, v)

gloader.go

@@ -12,7 +12,7 @@ import (
 
 const (
 	DefaultRowsPerBatch = 100
-	DefaultWorkers      = 5
+	DefaultWorkers      = 3
 )
 
 var (
@@ -110,7 +110,6 @@ func (g *GLoader) Start() error {
 	}
 
 	wg := sync.WaitGroup{}
-
 	for _, dc := range sDetails.DataCollections {
 		wg.Add(2)
 		fmt.Println("Starting to load", dc.Name, "from", 0, "to", dc.DataSetCount)

reader.go

@@ -102,7 +102,7 @@ func (r *Reader) Start() error {
 					}
 				}
 			retryRead:
-				batch, err := sConn.Read(r.dataCollection, startOffset, endOffset)
+				batch, err := sConn.Read(r.dataCollection, i, i+rowPerBatch)
 				if err != nil {
 					log.Println(err)
 					goto retryRead